mirror of
https://github.com/opencloud-eu/opencloud.git
synced 2025-12-30 17:48:52 -05:00
96 lines
2.8 KiB
Go
96 lines
2.8 KiB
Go
package msgpack
|
|
|
|
import (
|
|
"fmt"
|
|
"io"
|
|
|
|
"github.com/shamaton/msgpack/v2/def"
|
|
"github.com/shamaton/msgpack/v2/ext"
|
|
"github.com/shamaton/msgpack/v2/internal/decoding"
|
|
"github.com/shamaton/msgpack/v2/internal/encoding"
|
|
streamdecoding "github.com/shamaton/msgpack/v2/internal/stream/decoding"
|
|
streamencoding "github.com/shamaton/msgpack/v2/internal/stream/encoding"
|
|
"github.com/shamaton/msgpack/v2/time"
|
|
)
|
|
|
|
// StructAsArray is encoding option.
|
|
// If this option sets true, default encoding sets to array-format.
|
|
var StructAsArray = false
|
|
|
|
// Marshal returns the MessagePack-encoded byte array of v.
|
|
func Marshal(v interface{}) ([]byte, error) {
|
|
return encoding.Encode(v, StructAsArray)
|
|
}
|
|
|
|
// MarshalWrite writes MessagePack-encoded byte array of v to writer.
|
|
func MarshalWrite(w io.Writer, v interface{}) error {
|
|
return streamencoding.Encode(w, v, StructAsArray)
|
|
}
|
|
|
|
// Unmarshal analyzes the MessagePack-encoded data and stores
|
|
// the result into the pointer of v.
|
|
func Unmarshal(data []byte, v interface{}) error {
|
|
return decoding.Decode(data, v, StructAsArray)
|
|
}
|
|
|
|
// UnmarshalRead reads the MessagePack-encoded data from reader and stores
|
|
// the result into the pointer of v.
|
|
func UnmarshalRead(r io.Reader, v interface{}) error {
|
|
return streamdecoding.Decode(r, v, StructAsArray)
|
|
}
|
|
|
|
// AddExtCoder adds encoders for extension types.
|
|
func AddExtCoder(e ext.Encoder, d ext.Decoder) error {
|
|
if e.Code() != d.Code() {
|
|
return fmt.Errorf("code different %d:%d", e.Code(), d.Code())
|
|
}
|
|
encoding.AddExtEncoder(e)
|
|
decoding.AddExtDecoder(d)
|
|
return nil
|
|
}
|
|
|
|
// AddExtStreamCoder adds stream encoders for extension types.
|
|
func AddExtStreamCoder(e ext.StreamEncoder, d ext.StreamDecoder) error {
|
|
if e.Code() != d.Code() {
|
|
return fmt.Errorf("code different %d:%d", e.Code(), d.Code())
|
|
}
|
|
streamencoding.AddExtEncoder(e)
|
|
streamdecoding.AddExtDecoder(d)
|
|
return nil
|
|
}
|
|
|
|
// RemoveExtCoder removes encoders for extension types.
|
|
func RemoveExtCoder(e ext.Encoder, d ext.Decoder) error {
|
|
if e.Code() != d.Code() {
|
|
return fmt.Errorf("code different %d:%d", e.Code(), d.Code())
|
|
}
|
|
encoding.RemoveExtEncoder(e)
|
|
decoding.RemoveExtDecoder(d)
|
|
return nil
|
|
}
|
|
|
|
// RemoveExtStreamCoder removes stream encoders for extension types.
|
|
func RemoveExtStreamCoder(e ext.StreamEncoder, d ext.StreamDecoder) error {
|
|
if e.Code() != d.Code() {
|
|
return fmt.Errorf("code different %d:%d", e.Code(), d.Code())
|
|
}
|
|
streamencoding.RemoveExtEncoder(e)
|
|
streamdecoding.RemoveExtDecoder(d)
|
|
return nil
|
|
}
|
|
|
|
// SetComplexTypeCode sets def.complexTypeCode
|
|
func SetComplexTypeCode(code int8) {
|
|
def.SetComplexTypeCode(code)
|
|
}
|
|
|
|
// SetDecodedTimeAsUTC sets decoded time.Time values to UTC timezone.
|
|
func SetDecodedTimeAsUTC() {
|
|
time.SetDecodedAsLocal(false)
|
|
}
|
|
|
|
// SetDecodedTimeAsLocal sets decoded time.Time values to local timezone.
|
|
func SetDecodedTimeAsLocal() {
|
|
time.SetDecodedAsLocal(true)
|
|
}
|