serialization

package
v1.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 22, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BitsInAByte        = 8
	ByteSizeInBytes    = 1
	BoolSizeInBytes    = 1
	Uint8SizeInBytes   = 1
	Int16SizeInBytes   = 2
	Uint16SizeInBytes  = 2
	Int32SizeInBytes   = 4
	Float32SizeInBytes = 4
	Float64SizeInBytes = 8
	Int64SizeInBytes   = 8
)
View Source 
const (
	TypeNil                = 0
	TypePortable           = -1
	TypeDataSerializable   = -2
	TypeByte               = -3
	TypeBool               = -4
	TypeUInt16             = -5
	TypeInt16              = -6
	TypeInt32              = -7
	TypeInt64              = -8
	TypeFloat32            = -9
	TypeFloat64            = -10
	TypeString             = -11
	TypeByteArray          = -12
	TypeBoolArray          = -13
	TypeUInt16Array        = -14
	TypeInt16Array         = -15
	TypeInt32Array         = -16
	TypeInt64Array         = -17
	TypeFloat32Array       = -18
	TypeFloat64Array       = -19
	TypeStringArray        = -20
	TypeUUID               = -21
	TypeJavaClass          = -24
	TypeJavaDate           = -25
	TypeJavaBigInteger     = -26
	TypeJavaDecimal        = -27
	TypeJavaArray          = -28
	TypeJavaArrayList      = -29
	TypeJavaLinkedList     = -30
	TypeJavaLocalDate      = -51
	TypeJavaLocalTime      = -52
	TypeJavaLocalDateTime  = -53
	TypeJavaOffsetDateTime = -54
	TypeCompact            = -55
	TypeJSONSerialization  = -130
	TypeGobSerialization   = -140
)
View Source 
const (
	DataOffset = 8
)

Variables

View Source 
var BuiltinDeserializers map[int32]pubserialization.Serializer

BuiltinDeserializers must be set before the client is created and should not be changed afterwards.

View Source 
var FieldKindSize = [pserialization.FieldKindArrayOfNullableFloat64 + 1]int32{}
View Source 
var RabinFingerPrint = newRabinFingerPrint()

Functions

func BigIntToJavaBytes added in v1.2.0 

func BigIntToJavaBytes(b *big.Int) []byte

BigIntToJavaBytes returns a Java BigInteger compatible byte array.

func JavaBytesToBigInt added in v1.2.0 

func JavaBytesToBigInt(bs []byte) (*big.Int, error)

JavaBytesToBigInt creates a Go big.Int value from the given byte array.

func MakeSchemasFromConfig added in v1.4.0 

func MakeSchemasFromConfig(cfg pubserialization.CompactConfig) (map[int64]*Schema, error)

func NewFieldDefinition 

func NewFieldDefinition(index int32, fieldName string, fieldType pubserialization.FieldDefinitionType, factoryID int32,
	classID int32, version int32) pubserialization.FieldDefinition

func ReadBigInt added in v1.2.0 

func ReadBigInt(i serialization.DataInput) *big.Int

func ReadBool 

func ReadBool(buf []byte, pos int32) bool

func ReadDate added in v1.2.0 

func ReadDate(i serialization.DataInput) time.Time

func ReadDecimal added in v1.2.0 

func ReadDecimal(i serialization.DataInput) types.Decimal

func ReadFloat32 

func ReadFloat32(buf []byte, pos int32, bo binary.ByteOrder) float32

func ReadFloat64 

func ReadFloat64(buf []byte, pos int32, bo binary.ByteOrder) float64

func ReadInt16 

func ReadInt16(buf []byte, pos int32, bo binary.ByteOrder) int16

func ReadInt32 

func ReadInt32(buf []byte, pos int32, bo binary.ByteOrder) int32

func ReadInt64 

func ReadInt64(buf []byte, pos int32, bo binary.ByteOrder) int64

func ReadPortableDate added in v1.2.0 

func ReadPortableDate(i serialization.DataInput) time.Time

func ReadPortableTime added in v1.2.0 

func ReadPortableTime(i serialization.DataInput) time.Time

func ReadPortableTimestamp added in v1.2.0 

func ReadPortableTimestamp(i serialization.DataInput) time.Time

func ReadPortableTimestampWithTimezone added in v1.2.0 

func ReadPortableTimestampWithTimezone(i serialization.DataInput) time.Time

func ReadTime added in v1.2.0 

func ReadTime(i serialization.DataInput) time.Time

func ReadTimestamp added in v1.2.0 

func ReadTimestamp(i serialization.DataInput) time.Time

func ReadTimestampWithTimezone added in v1.2.0 

func ReadTimestampWithTimezone(i serialization.DataInput) time.Time

func ReadUInt16 

func ReadUInt16(buf []byte, pos int32, bo binary.ByteOrder) uint16

func TypeByID 

func TypeByID(fieldType serialization.FieldDefinitionType) string

func WriteBigInt added in v1.2.0 

func WriteBigInt(o serialization.DataOutput, b *big.Int)

func WriteBigIntArray added in v1.2.0 

func WriteBigIntArray(o serialization.DataOutput, bs []*big.Int)

func WriteBool 

func WriteBool(buf []byte, pos int32, v bool)

func WriteDate added in v1.2.0 

func WriteDate(o serialization.DataOutput, t time.Time)

func WriteDecimal added in v1.2.0 

func WriteDecimal(o serialization.DataOutput, d types.Decimal)

func WriteFloat32 

func WriteFloat32(buf []byte, pos int32, v float32, bo binary.ByteOrder)

func WriteFloat64 

func WriteFloat64(buf []byte, pos int32, v float64, bo binary.ByteOrder)

func WriteInt16 

func WriteInt16(buf []byte, pos int32, v int16, bo binary.ByteOrder)

func WriteInt32 

func WriteInt32(buf []byte, pos int32, v int32, bo binary.ByteOrder)

func WriteInt64 

func WriteInt64(buf []byte, pos int32, v int64, bo binary.ByteOrder)

func WritePortableDate added in v1.2.0 

func WritePortableDate(o serialization.DataOutput, t time.Time)

func WritePortableTime added in v1.2.0 

func WritePortableTime(o serialization.DataOutput, t time.Time)

func WritePortableTimestamp added in v1.2.0 

func WritePortableTimestamp(o serialization.DataOutput, t time.Time)

func WritePortableTimestampWithTimezone added in v1.2.0 

func WritePortableTimestampWithTimezone(o serialization.DataOutput, t time.Time)

func WriteTime added in v1.2.0 

func WriteTime(o serialization.DataOutput, t time.Time)

func WriteTimestamp added in v1.2.0 

func WriteTimestamp(o serialization.DataOutput, t time.Time)

func WriteTimestampWithTimezone added in v1.2.0 

func WriteTimestampWithTimezone(o serialization.DataOutput, t time.Time)

func WriteUInt16 

func WriteUInt16(buf []byte, pos int32, v uint16, bo binary.ByteOrder)

Types

type BigInt added in v1.2.0 

type BigInt struct {
	// contains filtered or unexported fields
}

BigInt is a port of java.math.BigInteger with only the necessary bits.

func NewBigInt added in v1.2.0 

func NewBigInt(b *big.Int) BigInt

NewBigInt creates a BigInt from the given big.Int

func NewBigIntFromByteArray added in v1.2.0 

func NewBigIntFromByteArray(val []byte) (BigInt, error)

NewBigIntFromByteArray creates a BigInt from the given byte array.

func (BigInt) Bytes added in v1.2.0 

func (b BigInt) Bytes() []byte

Bytes returns a java.math.BigInteger compatible byte array

func (BigInt) GoBigInt added in v1.2.0 

func (b BigInt) GoBigInt() *big.Int

GoBigInt returns a big.Int from this BigInt

type BoolArraySerializer 

type BoolArraySerializer struct{}

func (BoolArraySerializer) ID 

func (BoolArraySerializer) ID() int32

func (BoolArraySerializer) Read 

func (BoolArraySerializer) Read(input serialization.DataInput) interface{}

func (BoolArraySerializer) Write 

func (BoolArraySerializer) Write(output serialization.DataOutput, i interface{})

type BoolSerializer 

type BoolSerializer struct{}

func (BoolSerializer) ID 

func (BoolSerializer) ID() int32

func (BoolSerializer) Read 

func (BoolSerializer) Read(input serialization.DataInput) interface{}

func (BoolSerializer) Write 

func (BoolSerializer) Write(output serialization.DataOutput, i interface{})

type ByteArraySerializer 

type ByteArraySerializer struct{}

func (ByteArraySerializer) ID 

func (ByteArraySerializer) ID() int32

func (ByteArraySerializer) Read 

func (ByteArraySerializer) Read(input serialization.DataInput) interface{}

func (ByteArraySerializer) Write 

func (ByteArraySerializer) Write(output serialization.DataOutput, i interface{})

type ByteOffsetReader added in v1.4.0 

type ByteOffsetReader struct{}

type ByteSerializer 

type ByteSerializer struct{}

func (ByteSerializer) ID 

func (ByteSerializer) ID() int32

func (ByteSerializer) Read 

func (ByteSerializer) Read(input serialization.DataInput) interface{}

func (ByteSerializer) Write 

func (ByteSerializer) Write(output serialization.DataOutput, i interface{})

type ClassDefinitionContext 

type ClassDefinitionContext struct {
	// contains filtered or unexported fields
}

func NewClassDefinitionContext 

func NewClassDefinitionContext(factoryID int32) *ClassDefinitionContext

func (*ClassDefinitionContext) LookUp 

func (c *ClassDefinitionContext) LookUp(classID int32, version int32) *serialization.ClassDefinition

type ClassDefinitionWriter 

type ClassDefinitionWriter struct {
	// contains filtered or unexported fields
}

func NewClassDefinitionWriter 

func NewClassDefinitionWriter(portableContext *PortableContext, factoryID int32, classID int32,
	version int32) *ClassDefinitionWriter

func (*ClassDefinitionWriter) GetRawDataOutput added in v1.2.0 

func (cdw *ClassDefinitionWriter) GetRawDataOutput() serialization.DataOutput

func (*ClassDefinitionWriter) WriteBool 

func (cdw *ClassDefinitionWriter) WriteBool(fieldName string, value bool)

func (*ClassDefinitionWriter) WriteBoolArray 

func (cdw *ClassDefinitionWriter) WriteBoolArray(fieldName string, value []bool)

func (*ClassDefinitionWriter) WriteByte 

func (cdw *ClassDefinitionWriter) WriteByte(fieldName string, value byte)

func (*ClassDefinitionWriter) WriteByteArray 

func (cdw *ClassDefinitionWriter) WriteByteArray(fieldName string, value []byte)

func (*ClassDefinitionWriter) WriteDate added in v1.2.0 

func (cdw *ClassDefinitionWriter) WriteDate(fieldName string, value *types.LocalDate)

func (*ClassDefinitionWriter) WriteDateArray added in v1.2.0 

func (cdw *ClassDefinitionWriter) WriteDateArray(fieldName string, value []types.LocalDate)

func (*ClassDefinitionWriter) WriteDecimal added in v1.2.0 

func (cdw *ClassDefinitionWriter) WriteDecimal(fieldName string, d *types.Decimal)

func (*ClassDefinitionWriter) WriteDecimalArray added in v1.2.0 

func (cdw *ClassDefinitionWriter) WriteDecimalArray(fieldName string, ds []types.Decimal)

func (*ClassDefinitionWriter) WriteFloat32 

func (cdw *ClassDefinitionWriter) WriteFloat32(fieldName string, value float32)

func (*ClassDefinitionWriter) WriteFloat32Array 

func (cdw *ClassDefinitionWriter) WriteFloat32Array(fieldName string, value []float32)

func (*ClassDefinitionWriter) WriteFloat64 

func (cdw *ClassDefinitionWriter) WriteFloat64(fieldName string, value float64)

func (*ClassDefinitionWriter) WriteFloat64Array 

func (cdw *ClassDefinitionWriter) WriteFloat64Array(fieldName string, value []float64)

func (*ClassDefinitionWriter) WriteInt16 

func (cdw *ClassDefinitionWriter) WriteInt16(fieldName string, value int16)

func (*ClassDefinitionWriter) WriteInt16Array 

func (cdw *ClassDefinitionWriter) WriteInt16Array(fieldName string, value []int16)

func (*ClassDefinitionWriter) WriteInt32 

func (cdw *ClassDefinitionWriter) WriteInt32(fieldName string, value int32)

func (*ClassDefinitionWriter) WriteInt32Array 

func (cdw *ClassDefinitionWriter) WriteInt32Array(fieldName string, value []int32)

func (*ClassDefinitionWriter) WriteInt64 

func (cdw *ClassDefinitionWriter) WriteInt64(fieldName string, value int64)

func (*ClassDefinitionWriter) WriteInt64Array 

func (cdw *ClassDefinitionWriter) WriteInt64Array(fieldName string, value []int64)

func (*ClassDefinitionWriter) WriteNilPortable 

func (cdw *ClassDefinitionWriter) WriteNilPortable(fieldName string, factoryID int32, classID int32)

func (*ClassDefinitionWriter) WritePortable 

func (cdw *ClassDefinitionWriter) WritePortable(fieldName string, portable serialization.Portable)

func (*ClassDefinitionWriter) WritePortableArray 

func (cdw *ClassDefinitionWriter) WritePortableArray(fieldName string, portables []serialization.Portable)

func (*ClassDefinitionWriter) WriteString 

func (cdw *ClassDefinitionWriter) WriteString(fieldName string, value string)

func (*ClassDefinitionWriter) WriteStringArray 

func (cdw *ClassDefinitionWriter) WriteStringArray(fieldName string, value []string)

func (*ClassDefinitionWriter) WriteTime added in v1.2.0 

func (cdw *ClassDefinitionWriter) WriteTime(fieldName string, value *types.LocalTime)

func (*ClassDefinitionWriter) WriteTimeArray added in v1.2.0 

func (cdw *ClassDefinitionWriter) WriteTimeArray(fieldName string, value []types.LocalTime)

func (*ClassDefinitionWriter) WriteTimestamp added in v1.2.0 

func (cdw *ClassDefinitionWriter) WriteTimestamp(fieldName string, value *types.LocalDateTime)

func (*ClassDefinitionWriter) WriteTimestampArray added in v1.2.0 

func (cdw *ClassDefinitionWriter) WriteTimestampArray(fieldName string, value []types.LocalDateTime)

func (*ClassDefinitionWriter) WriteTimestampWithTimezone added in v1.2.0 

func (cdw *ClassDefinitionWriter) WriteTimestampWithTimezone(fieldName string, value *types.OffsetDateTime)

func (*ClassDefinitionWriter) WriteTimestampWithTimezoneArray added in v1.2.0 

func (cdw *ClassDefinitionWriter) WriteTimestampWithTimezoneArray(fieldName string, value []types.OffsetDateTime)

func (*ClassDefinitionWriter) WriteUInt16 

func (cdw *ClassDefinitionWriter) WriteUInt16(fieldName string, value uint16)

func (*ClassDefinitionWriter) WriteUInt16Array 

func (cdw *ClassDefinitionWriter) WriteUInt16Array(fieldName string, value []uint16)

type CompactStreamSerializer added in v1.4.0 

type CompactStreamSerializer struct {
	// contains filtered or unexported fields
}

func NewCompactStreamSerializer added in v1.4.0 

func NewCompactStreamSerializer(cfg pubserialization.CompactConfig, schemaCh chan SchemaMsg, dds GenericCompactDeserializer) (*CompactStreamSerializer, error)

func (CompactStreamSerializer) ID added in v1.4.0 

func (CompactStreamSerializer) ID() int32

func (CompactStreamSerializer) IsRegisteredAsCompact added in v1.4.0 

func (c CompactStreamSerializer) IsRegisteredAsCompact(t reflect.Type) bool

func (CompactStreamSerializer) Read added in v1.4.0 

func (c CompactStreamSerializer) Read(input pubserialization.DataInput) interface{}

func (CompactStreamSerializer) Write added in v1.4.0 

func (c CompactStreamSerializer) Write(output pubserialization.DataOutput, object interface{})

type Data 

type Data []byte

func (Data) DataSize 

func (d Data) DataSize() int

func (Data) PartitionHash 

func (d Data) PartitionHash() int32

func (Data) ToByteArray 

func (d Data) ToByteArray() []byte

func (Data) Type 

func (d Data) Type() int32

type DefaultCompactReader added in v1.4.0 

type DefaultCompactReader struct {
	// contains filtered or unexported fields
}

func NewDefaultCompactReader added in v1.4.0 

func NewDefaultCompactReader(serializer CompactStreamSerializer, input *ObjectDataInput, schema *Schema) *DefaultCompactReader

func (*DefaultCompactReader) GetFieldKind added in v1.4.0 

func (d *DefaultCompactReader) GetFieldKind(fieldName string) pubserialization.FieldKind

func (*DefaultCompactReader) ReadArrayOfBoolean added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfBoolean(fieldName string) []bool

func (*DefaultCompactReader) ReadArrayOfCompact added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfCompact(fieldName string) []interface{}

func (*DefaultCompactReader) ReadArrayOfDate added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfDate(fieldName string) []*types.LocalDate

func (*DefaultCompactReader) ReadArrayOfDecimal added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfDecimal(fieldName string) []*types.Decimal

func (*DefaultCompactReader) ReadArrayOfFloat32 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfFloat32(fieldName string) []float32

func (*DefaultCompactReader) ReadArrayOfFloat64 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfFloat64(fieldName string) []float64

func (*DefaultCompactReader) ReadArrayOfInt16 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfInt16(fieldName string) []int16

func (*DefaultCompactReader) ReadArrayOfInt32 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfInt32(fieldName string) []int32

func (*DefaultCompactReader) ReadArrayOfInt64 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfInt64(fieldName string) []int64

func (*DefaultCompactReader) ReadArrayOfInt8 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfInt8(fieldName string) []int8

func (*DefaultCompactReader) ReadArrayOfNullableBoolean added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfNullableBoolean(fieldName string) []*bool

func (*DefaultCompactReader) ReadArrayOfNullableFloat32 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfNullableFloat32(fieldName string) []*float32

func (*DefaultCompactReader) ReadArrayOfNullableFloat64 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfNullableFloat64(fieldName string) []*float64

func (*DefaultCompactReader) ReadArrayOfNullableInt16 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfNullableInt16(fieldName string) []*int16

func (*DefaultCompactReader) ReadArrayOfNullableInt32 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfNullableInt32(fieldName string) []*int32

func (*DefaultCompactReader) ReadArrayOfNullableInt64 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfNullableInt64(fieldName string) []*int64

func (*DefaultCompactReader) ReadArrayOfNullableInt8 added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfNullableInt8(fieldName string) []*int8

func (*DefaultCompactReader) ReadArrayOfString added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfString(fieldName string) []*string

func (*DefaultCompactReader) ReadArrayOfTime added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfTime(fieldName string) []*types.LocalTime

func (*DefaultCompactReader) ReadArrayOfTimestamp added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfTimestamp(fieldName string) []*types.LocalDateTime

func (*DefaultCompactReader) ReadArrayOfTimestampWithTimezone added in v1.4.0 

func (d *DefaultCompactReader) ReadArrayOfTimestampWithTimezone(fieldName string) []*types.OffsetDateTime

func (*DefaultCompactReader) ReadBoolean added in v1.4.0 

func (d *DefaultCompactReader) ReadBoolean(fieldName string) bool

func (*DefaultCompactReader) ReadCompact added in v1.4.0 

func (d *DefaultCompactReader) ReadCompact(fieldName string) interface{}

func (*DefaultCompactReader) ReadDate added in v1.4.0 

func (d *DefaultCompactReader) ReadDate(fieldName string) *types.LocalDate

func (*DefaultCompactReader) ReadDecimal added in v1.4.0 

func (d *DefaultCompactReader) ReadDecimal(fieldName string) *types.Decimal

func (*DefaultCompactReader) ReadFloat32 added in v1.4.0 

func (d *DefaultCompactReader) ReadFloat32(fieldName string) float32

func (*DefaultCompactReader) ReadFloat64 added in v1.4.0 

func (d *DefaultCompactReader) ReadFloat64(fieldName string) float64

func (*DefaultCompactReader) ReadInt16 added in v1.4.0 

func (d *DefaultCompactReader) ReadInt16(fieldName string) int16

func (*DefaultCompactReader) ReadInt32 added in v1.4.0 

func (d *DefaultCompactReader) ReadInt32(fieldName string) int32

func (*DefaultCompactReader) ReadInt64 added in v1.4.0 

func (d *DefaultCompactReader) ReadInt64(fieldName string) int64

func (*DefaultCompactReader) ReadInt8 added in v1.4.0 

func (d *DefaultCompactReader) ReadInt8(fieldName string) int8

func (*DefaultCompactReader) ReadNullableBoolean added in v1.4.0 

func (d *DefaultCompactReader) ReadNullableBoolean(fieldName string) *bool

func (*DefaultCompactReader) ReadNullableFloat32 added in v1.4.0 

func (d *DefaultCompactReader) ReadNullableFloat32(fieldName string) *float32

func (*DefaultCompactReader) ReadNullableFloat64 added in v1.4.0 

func (d *DefaultCompactReader) ReadNullableFloat64(fieldName string) *float64

func (*DefaultCompactReader) ReadNullableInt16 added in v1.4.0 

func (d *DefaultCompactReader) ReadNullableInt16(fieldName string) *int16

func (*DefaultCompactReader) ReadNullableInt32 added in v1.4.0 

func (d *DefaultCompactReader) ReadNullableInt32(fieldName string) *int32

func (*DefaultCompactReader) ReadNullableInt64 added in v1.4.0 

func (d *DefaultCompactReader) ReadNullableInt64(fieldName string) *int64

func (*DefaultCompactReader) ReadNullableInt8 added in v1.4.0 

func (d *DefaultCompactReader) ReadNullableInt8(fieldName string) *int8

func (*DefaultCompactReader) ReadString added in v1.4.0 

func (d *DefaultCompactReader) ReadString(fieldName string) *string

func (*DefaultCompactReader) ReadTime added in v1.4.0 

func (d *DefaultCompactReader) ReadTime(fieldName string) *types.LocalTime

func (*DefaultCompactReader) ReadTimestamp added in v1.4.0 

func (d *DefaultCompactReader) ReadTimestamp(fieldName string) *types.LocalDateTime

func (*DefaultCompactReader) ReadTimestampWithTimezone added in v1.4.0 

func (d *DefaultCompactReader) ReadTimestampWithTimezone(fieldName string) *types.OffsetDateTime

type DefaultCompactWriter added in v1.4.0 

type DefaultCompactWriter struct {
	// contains filtered or unexported fields
}

func NewDefaultCompactWriter added in v1.4.0 

func NewDefaultCompactWriter(serializer CompactStreamSerializer, out *PositionalObjectDataOutput, schema *Schema) *DefaultCompactWriter

func (*DefaultCompactWriter) End added in v1.4.0 

func (r *DefaultCompactWriter) End()

End ends the serialization of the compact objects by writing the offsets of the variable-size fields as well as the data length, if there are some variable-size fields.

func (*DefaultCompactWriter) WriteArrayOfBoolean added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfBoolean(fieldName string, value []bool)

func (*DefaultCompactWriter) WriteArrayOfCompact added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfCompact(fieldName string, value []interface{})

func (*DefaultCompactWriter) WriteArrayOfDate added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfDate(fieldName string, value []*types.LocalDate)

func (*DefaultCompactWriter) WriteArrayOfDecimal added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfDecimal(fieldName string, value []*types.Decimal)

func (*DefaultCompactWriter) WriteArrayOfFloat32 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfFloat32(fieldName string, value []float32)

func (*DefaultCompactWriter) WriteArrayOfFloat64 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfFloat64(fieldName string, value []float64)

func (*DefaultCompactWriter) WriteArrayOfInt16 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfInt16(fieldName string, value []int16)

func (*DefaultCompactWriter) WriteArrayOfInt32 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfInt32(fieldName string, value []int32)

func (*DefaultCompactWriter) WriteArrayOfInt64 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfInt64(fieldName string, value []int64)

func (*DefaultCompactWriter) WriteArrayOfInt8 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfInt8(fieldName string, value []int8)

func (*DefaultCompactWriter) WriteArrayOfNullableBoolean added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfNullableBoolean(fieldName string, value []*bool)

func (*DefaultCompactWriter) WriteArrayOfNullableFloat32 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfNullableFloat32(fieldName string, value []*float32)

func (*DefaultCompactWriter) WriteArrayOfNullableFloat64 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfNullableFloat64(fieldName string, value []*float64)

func (*DefaultCompactWriter) WriteArrayOfNullableInt16 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfNullableInt16(fieldName string, value []*int16)

func (*DefaultCompactWriter) WriteArrayOfNullableInt32 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfNullableInt32(fieldName string, value []*int32)

func (*DefaultCompactWriter) WriteArrayOfNullableInt64 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfNullableInt64(fieldName string, value []*int64)

func (*DefaultCompactWriter) WriteArrayOfNullableInt8 added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfNullableInt8(fieldName string, value []*int8)

func (*DefaultCompactWriter) WriteArrayOfString added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfString(fieldName string, value []*string)

func (*DefaultCompactWriter) WriteArrayOfTime added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfTime(fieldName string, value []*types.LocalTime)

func (*DefaultCompactWriter) WriteArrayOfTimestamp added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfTimestamp(fieldName string, value []*types.LocalDateTime)

func (*DefaultCompactWriter) WriteArrayOfTimestampWithTimezone added in v1.4.0 

func (r *DefaultCompactWriter) WriteArrayOfTimestampWithTimezone(fieldName string, value []*types.OffsetDateTime)

func (*DefaultCompactWriter) WriteBoolean added in v1.4.0 

func (r *DefaultCompactWriter) WriteBoolean(fieldName string, value bool)

func (*DefaultCompactWriter) WriteCompact added in v1.4.0 

func (r *DefaultCompactWriter) WriteCompact(fieldName string, value interface{})

func (*DefaultCompactWriter) WriteDate added in v1.4.0 

func (r *DefaultCompactWriter) WriteDate(fieldName string, value *types.LocalDate)

func (*DefaultCompactWriter) WriteDecimal added in v1.4.0 

func (r *DefaultCompactWriter) WriteDecimal(fieldName string, value *types.Decimal)

func (*DefaultCompactWriter) WriteFloat32 added in v1.4.0 

func (r *DefaultCompactWriter) WriteFloat32(fieldName string, value float32)

func (*DefaultCompactWriter) WriteFloat64 added in v1.4.0 

func (r *DefaultCompactWriter) WriteFloat64(fieldName string, value float64)

func (*DefaultCompactWriter) WriteInt16 added in v1.4.0 

func (r *DefaultCompactWriter) WriteInt16(fieldName string, value int16)

func (*DefaultCompactWriter) WriteInt32 added in v1.4.0 

func (r *DefaultCompactWriter) WriteInt32(fieldName string, value int32)

func (*DefaultCompactWriter) WriteInt64 added in v1.4.0 

func (r *DefaultCompactWriter) WriteInt64(fieldName string, value int64)

func (*DefaultCompactWriter) WriteInt8 added in v1.4.0 

func (r *DefaultCompactWriter) WriteInt8(fieldName string, value int8)

func (*DefaultCompactWriter) WriteNullableBoolean added in v1.4.0 

func (r *DefaultCompactWriter) WriteNullableBoolean(fieldName string, value *bool)

func (*DefaultCompactWriter) WriteNullableFloat32 added in v1.4.0 

func (r *DefaultCompactWriter) WriteNullableFloat32(fieldName string, value *float32)

func (*DefaultCompactWriter) WriteNullableFloat64 added in v1.4.0 

func (r *DefaultCompactWriter) WriteNullableFloat64(fieldName string, value *float64)

func (*DefaultCompactWriter) WriteNullableInt16 added in v1.4.0 

func (r *DefaultCompactWriter) WriteNullableInt16(fieldName string, value *int16)

func (*DefaultCompactWriter) WriteNullableInt32 added in v1.4.0 

func (r *DefaultCompactWriter) WriteNullableInt32(fieldName string, value *int32)

func (*DefaultCompactWriter) WriteNullableInt64 added in v1.4.0 

func (r *DefaultCompactWriter) WriteNullableInt64(fieldName string, value *int64)

func (*DefaultCompactWriter) WriteNullableInt8 added in v1.4.0 

func (r *DefaultCompactWriter) WriteNullableInt8(fieldName string, value *int8)

func (*DefaultCompactWriter) WriteString added in v1.4.0 

func (r *DefaultCompactWriter) WriteString(fieldName string, value *string)

func (*DefaultCompactWriter) WriteTime added in v1.4.0 

func (r *DefaultCompactWriter) WriteTime(fieldName string, value *types.LocalTime)

func (*DefaultCompactWriter) WriteTimestamp added in v1.4.0 

func (r *DefaultCompactWriter) WriteTimestamp(fieldName string, value *types.LocalDateTime)

func (*DefaultCompactWriter) WriteTimestampWithTimezone added in v1.4.0 

func (r *DefaultCompactWriter) WriteTimestampWithTimezone(fieldName string, value *types.OffsetDateTime)

type DefaultPortableReader 

type DefaultPortableReader struct {
	// contains filtered or unexported fields
}

func NewDefaultPortableReader 

func NewDefaultPortableReader(serializer *PortableSerializer, input serialization.DataInput,
	classdefinition *serialization.ClassDefinition) *DefaultPortableReader

func (*DefaultPortableReader) End 

func (pr *DefaultPortableReader) End()

func (*DefaultPortableReader) GetRawDataInput added in v1.2.0 

func (pr *DefaultPortableReader) GetRawDataInput() serialization.DataInput

func (*DefaultPortableReader) ReadBool 

func (pr *DefaultPortableReader) ReadBool(fieldName string) bool

func (*DefaultPortableReader) ReadBoolArray 

func (pr *DefaultPortableReader) ReadBoolArray(fieldName string) []bool

func (*DefaultPortableReader) ReadByte 

func (pr *DefaultPortableReader) ReadByte(fieldName string) byte

func (*DefaultPortableReader) ReadByteArray 

func (pr *DefaultPortableReader) ReadByteArray(fieldName string) []byte

func (*DefaultPortableReader) ReadDate added in v1.2.0 

func (pr *DefaultPortableReader) ReadDate(fieldName string) (t *types.LocalDate)

func (*DefaultPortableReader) ReadDateArray added in v1.2.0 

func (pr *DefaultPortableReader) ReadDateArray(fieldName string) (t []types.LocalDate)

func (*DefaultPortableReader) ReadDecimal added in v1.2.0 

func (pr *DefaultPortableReader) ReadDecimal(fieldName string) (d *types.Decimal)

func (*DefaultPortableReader) ReadDecimalArray added in v1.2.0 

func (pr *DefaultPortableReader) ReadDecimalArray(fieldName string) (ds []types.Decimal)

func (*DefaultPortableReader) ReadFloat32 

func (pr *DefaultPortableReader) ReadFloat32(fieldName string) float32

func (*DefaultPortableReader) ReadFloat32Array 

func (pr *DefaultPortableReader) ReadFloat32Array(fieldName string) []float32

func (*DefaultPortableReader) ReadFloat64 

func (pr *DefaultPortableReader) ReadFloat64(fieldName string) float64

func (*DefaultPortableReader) ReadFloat64Array 

func (pr *DefaultPortableReader) ReadFloat64Array(fieldName string) []float64

func (*DefaultPortableReader) ReadInt16 

func (pr *DefaultPortableReader) ReadInt16(fieldName string) int16

func (*DefaultPortableReader) ReadInt16Array 

func (pr *DefaultPortableReader) ReadInt16Array(fieldName string) []int16

func (*DefaultPortableReader) ReadInt32 

func (pr *DefaultPortableReader) ReadInt32(fieldName string) int32

func (*DefaultPortableReader) ReadInt32Array 

func (pr *DefaultPortableReader) ReadInt32Array(fieldName string) []int32

func (*DefaultPortableReader) ReadInt64 

func (pr *DefaultPortableReader) ReadInt64(fieldName string) int64

func (*DefaultPortableReader) ReadInt64Array 

func (pr *DefaultPortableReader) ReadInt64Array(fieldName string) []int64

func (*DefaultPortableReader) ReadPortable 

func (pr *DefaultPortableReader) ReadPortable(fieldName string) serialization.Portable

func (*DefaultPortableReader) ReadPortableArray 

func (pr *DefaultPortableReader) ReadPortableArray(fieldName string) []serialization.Portable

func (*DefaultPortableReader) ReadString 

func (pr *DefaultPortableReader) ReadString(fieldName string) string

func (*DefaultPortableReader) ReadStringArray 

func (pr *DefaultPortableReader) ReadStringArray(fieldName string) []string

func (*DefaultPortableReader) ReadTime added in v1.2.0 

func (pr *DefaultPortableReader) ReadTime(fieldName string) (t *types.LocalTime)

func (*DefaultPortableReader) ReadTimeArray added in v1.2.0 

func (pr *DefaultPortableReader) ReadTimeArray(fieldName string) (t []types.LocalTime)

func (*DefaultPortableReader) ReadTimestamp added in v1.2.0 

func (pr *DefaultPortableReader) ReadTimestamp(fieldName string) (t *types.LocalDateTime)

func (*DefaultPortableReader) ReadTimestampArray added in v1.2.0 

func (pr *DefaultPortableReader) ReadTimestampArray(fieldName string) (t []types.LocalDateTime)

func (*DefaultPortableReader) ReadTimestampWithTimezone added in v1.2.0 

func (pr *DefaultPortableReader) ReadTimestampWithTimezone(fieldName string) (t *types.OffsetDateTime)

func (*DefaultPortableReader) ReadTimestampWithTimezoneArray added in v1.2.0 

func (pr *DefaultPortableReader) ReadTimestampWithTimezoneArray(fieldName string) (t []types.OffsetDateTime)

func (*DefaultPortableReader) ReadUInt16 

func (pr *DefaultPortableReader) ReadUInt16(fieldName string) uint16

func (*DefaultPortableReader) ReadUInt16Array 

func (pr *DefaultPortableReader) ReadUInt16Array(fieldName string) []uint16

type DefaultPortableWriter 

type DefaultPortableWriter struct {
	// contains filtered or unexported fields
}

func NewDefaultPortableWriter 

func NewDefaultPortableWriter(serializer *PortableSerializer, output *PositionalObjectDataOutput,
	classDefinition *serialization.ClassDefinition) *DefaultPortableWriter

func (*DefaultPortableWriter) End 

func (pw *DefaultPortableWriter) End()

func (*DefaultPortableWriter) GetRawDataOutput added in v1.2.0 

func (pw *DefaultPortableWriter) GetRawDataOutput() serialization.DataOutput

func (*DefaultPortableWriter) WriteBool 

func (pw *DefaultPortableWriter) WriteBool(fieldName string, value bool)

func (*DefaultPortableWriter) WriteBoolArray 

func (pw *DefaultPortableWriter) WriteBoolArray(fieldName string, array []bool)

func (*DefaultPortableWriter) WriteByte 

func (pw *DefaultPortableWriter) WriteByte(fieldName string, value byte)

func (*DefaultPortableWriter) WriteByteArray 

func (pw *DefaultPortableWriter) WriteByteArray(fieldName string, array []byte)

func (*DefaultPortableWriter) WriteDate added in v1.2.0 

func (pw *DefaultPortableWriter) WriteDate(fieldName string, t *types.LocalDate)

func (*DefaultPortableWriter) WriteDateArray added in v1.2.0 

func (pw *DefaultPortableWriter) WriteDateArray(fieldName string, a []types.LocalDate)

func (*DefaultPortableWriter) WriteDecimal added in v1.2.0 

func (pw *DefaultPortableWriter) WriteDecimal(fieldName string, d *types.Decimal)

func (*DefaultPortableWriter) WriteDecimalArray added in v1.2.0 

func (pw *DefaultPortableWriter) WriteDecimalArray(fieldName string, ds []types.Decimal)

func (*DefaultPortableWriter) WriteFloat32 

func (pw *DefaultPortableWriter) WriteFloat32(fieldName string, value float32)

func (*DefaultPortableWriter) WriteFloat32Array 

func (pw *DefaultPortableWriter) WriteFloat32Array(fieldName string, array []float32)

func (*DefaultPortableWriter) WriteFloat64 

func (pw *DefaultPortableWriter) WriteFloat64(fieldName string, value float64)

func (*DefaultPortableWriter) WriteFloat64Array 

func (pw *DefaultPortableWriter) WriteFloat64Array(fieldName string, array []float64)

func (*DefaultPortableWriter) WriteInt16 

func (pw *DefaultPortableWriter) WriteInt16(fieldName string, value int16)

func (*DefaultPortableWriter) WriteInt16Array 

func (pw *DefaultPortableWriter) WriteInt16Array(fieldName string, array []int16)

func (*DefaultPortableWriter) WriteInt32 

func (pw *DefaultPortableWriter) WriteInt32(fieldName string, value int32)

func (*DefaultPortableWriter) WriteInt32Array 

func (pw *DefaultPortableWriter) WriteInt32Array(fieldName string, array []int32)

func (*DefaultPortableWriter) WriteInt64 

func (pw *DefaultPortableWriter) WriteInt64(fieldName string, value int64)

func (*DefaultPortableWriter) WriteInt64Array 

func (pw *DefaultPortableWriter) WriteInt64Array(fieldName string, array []int64)

func (*DefaultPortableWriter) WriteNilPortable 

func (pw *DefaultPortableWriter) WriteNilPortable(fieldName string, factoryID int32, classID int32)

func (*DefaultPortableWriter) WritePortable 

func (pw *DefaultPortableWriter) WritePortable(fieldName string, portable serialization.Portable)

func (*DefaultPortableWriter) WritePortableArray 

func (pw *DefaultPortableWriter) WritePortableArray(fieldName string, portableArray []serialization.Portable)

func (*DefaultPortableWriter) WriteString 

func (pw *DefaultPortableWriter) WriteString(fieldName string, value string)

func (*DefaultPortableWriter) WriteStringArray 

func (pw *DefaultPortableWriter) WriteStringArray(fieldName string, array []string)

func (*DefaultPortableWriter) WriteTime added in v1.2.0 

func (pw *DefaultPortableWriter) WriteTime(fieldName string, t *types.LocalTime)

func (*DefaultPortableWriter) WriteTimeArray added in v1.2.0 

func (pw *DefaultPortableWriter) WriteTimeArray(fieldName string, a []types.LocalTime)

func (*DefaultPortableWriter) WriteTimestamp added in v1.2.0 

func (pw *DefaultPortableWriter) WriteTimestamp(fieldName string, t *types.LocalDateTime)

func (*DefaultPortableWriter) WriteTimestampArray added in v1.2.0 

func (pw *DefaultPortableWriter) WriteTimestampArray(fieldName string, a []types.LocalDateTime)

func (*DefaultPortableWriter) WriteTimestampWithTimezone added in v1.2.0 

func (pw *DefaultPortableWriter) WriteTimestampWithTimezone(fieldName string, t *types.OffsetDateTime)

func (*DefaultPortableWriter) WriteTimestampWithTimezoneArray added in v1.2.0 

func (pw *DefaultPortableWriter) WriteTimestampWithTimezoneArray(fieldName string, a []types.OffsetDateTime)

func (*DefaultPortableWriter) WriteUInt16 

func (pw *DefaultPortableWriter) WriteUInt16(fieldName string, value uint16)

func (*DefaultPortableWriter) WriteUInt16Array 

func (pw *DefaultPortableWriter) WriteUInt16Array(fieldName string, array []uint16)

type EmptyObjectDataOutput added in v1.2.0 

type EmptyObjectDataOutput struct {
}

EmptyObjectDataOutput implements no-op serialization.DataOutput.

func (*EmptyObjectDataOutput) Position added in v1.2.0 

func (e *EmptyObjectDataOutput) Position() int32

func (*EmptyObjectDataOutput) SetPosition added in v1.2.0 

func (e *EmptyObjectDataOutput) SetPosition(int32)

func (*EmptyObjectDataOutput) WriteBool added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteBool(bool)

func (*EmptyObjectDataOutput) WriteBoolArray added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteBoolArray([]bool)

func (*EmptyObjectDataOutput) WriteByte added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteByte(byte)

func (*EmptyObjectDataOutput) WriteByteArray added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteByteArray([]byte)

func (*EmptyObjectDataOutput) WriteFloat32 added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteFloat32(float32)

func (*EmptyObjectDataOutput) WriteFloat32Array added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteFloat32Array([]float32)

func (*EmptyObjectDataOutput) WriteFloat64 added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteFloat64(float64)

func (*EmptyObjectDataOutput) WriteFloat64Array added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteFloat64Array([]float64)

func (*EmptyObjectDataOutput) WriteInt16 added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteInt16(int16)

func (*EmptyObjectDataOutput) WriteInt16Array added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteInt16Array([]int16)

func (*EmptyObjectDataOutput) WriteInt32 added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteInt32(int32)

func (*EmptyObjectDataOutput) WriteInt32Array added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteInt32Array([]int32)

func (*EmptyObjectDataOutput) WriteInt64 added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteInt64(int64)

func (*EmptyObjectDataOutput) WriteInt64Array added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteInt64Array([]int64)

func (*EmptyObjectDataOutput) WriteObject added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteObject(interface{})

func (*EmptyObjectDataOutput) WriteString added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteString(string)

func (*EmptyObjectDataOutput) WriteStringArray added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteStringArray([]string)

func (*EmptyObjectDataOutput) WriteStringBytes added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteStringBytes(string)

func (*EmptyObjectDataOutput) WriteUInt16 added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteUInt16(uint16)

func (*EmptyObjectDataOutput) WriteUInt16Array added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteUInt16Array([]uint16)

func (*EmptyObjectDataOutput) WriteZeroBytes added in v1.2.0 

func (e *EmptyObjectDataOutput) WriteZeroBytes(int)

type FieldDescriptor added in v1.4.0 

type FieldDescriptor struct {
	Name string
	Kind pubserialization.FieldKind
	// contains filtered or unexported fields
}

func NewFieldDescriptor added in v1.4.0 

func NewFieldDescriptor(fieldName string, fieldKind pubserialization.FieldKind) FieldDescriptor

type Float32ArraySerializer 

type Float32ArraySerializer struct{}

func (Float32ArraySerializer) ID 

func (Float32ArraySerializer) ID() int32

func (Float32ArraySerializer) Read 

func (Float32ArraySerializer) Read(input serialization.DataInput) interface{}

func (Float32ArraySerializer) Write 

func (Float32ArraySerializer) Write(output serialization.DataOutput, i interface{})

type Float32Serializer 

type Float32Serializer struct{}

func (Float32Serializer) ID 

func (Float32Serializer) ID() int32

func (Float32Serializer) Read 

func (Float32Serializer) Read(input serialization.DataInput) interface{}

func (Float32Serializer) Write 

func (Float32Serializer) Write(output serialization.DataOutput, i interface{})

type Float64ArraySerializer 

type Float64ArraySerializer struct{}

func (Float64ArraySerializer) ID 

func (Float64ArraySerializer) ID() int32

func (Float64ArraySerializer) Read 

func (Float64ArraySerializer) Read(input serialization.DataInput) interface{}

func (Float64ArraySerializer) Write 

func (Float64ArraySerializer) Write(output serialization.DataOutput, i interface{})

type Float64Serializer 

type Float64Serializer struct{}

func (Float64Serializer) ID 

func (Float64Serializer) ID() int32

func (Float64Serializer) Read 

func (Float64Serializer) Read(input serialization.DataInput) interface{}

func (Float64Serializer) Write 

func (Float64Serializer) Write(output serialization.DataOutput, i interface{})

type GenericCompactDeserializer added in v1.4.1 

type GenericCompactDeserializer interface {
	Read(schema *Schema, reader pubserialization.CompactReader) interface{}
}
var DefaultCompactDeserializer GenericCompactDeserializer

DefaultCompactDeserializer must be set before the client is created and should not be changed afterwards. DefaultCompactDeserializer is used if a compact deserializer for a type is not found.

type GenericPortableDeserializer added in v1.4.1 

type GenericPortableDeserializer interface {
	CreatePortableValue(factoryID, classID int32) serialization.Portable
	ReadPortableWithClassDefinition(portable serialization.Portable, cd *serialization.ClassDefinition, reader serialization.PortableReader)
}
var DefaultPortableDeserializer GenericPortableDeserializer

DefaultPortableDeserializer must be set before the client is created and should not be changed afterwards. DefaultPortableDeserializer is used if the portable factory of a value is not found.

type GobSerializer 

type GobSerializer struct{}

func (GobSerializer) ID 

func (GobSerializer) ID() int32

func (GobSerializer) Read 

func (GobSerializer) Read(input serialization.DataInput) interface{}

func (GobSerializer) Write 

func (GobSerializer) Write(output serialization.DataOutput, i interface{})

type IdentifiedDataSerializableSerializer 

type IdentifiedDataSerializableSerializer struct {
	// contains filtered or unexported fields
}

func NewIdentifiedDataSerializableSerializer 

func NewIdentifiedDataSerializableSerializer(
	factories map[int32]serialization.IdentifiedDataSerializableFactory) *IdentifiedDataSerializableSerializer

func (IdentifiedDataSerializableSerializer) ID 

func (IdentifiedDataSerializableSerializer) ID() int32

func (IdentifiedDataSerializableSerializer) Read 

func (idss IdentifiedDataSerializableSerializer) Read(input serialization.DataInput) interface{}

func (IdentifiedDataSerializableSerializer) Write 

func (IdentifiedDataSerializableSerializer) Write(output serialization.DataOutput, i interface{})

type Int16ArraySerializer 

type Int16ArraySerializer struct{}

func (Int16ArraySerializer) ID 

func (Int16ArraySerializer) ID() int32

func (Int16ArraySerializer) Read 

func (Int16ArraySerializer) Read(input serialization.DataInput) interface{}

func (Int16ArraySerializer) Write 

func (Int16ArraySerializer) Write(output serialization.DataOutput, i interface{})

type Int16Serializer 

type Int16Serializer struct{}

func (Int16Serializer) ID 

func (Int16Serializer) ID() int32

func (Int16Serializer) Read 

func (Int16Serializer) Read(input serialization.DataInput) interface{}

func (Int16Serializer) Write 

func (Int16Serializer) Write(output serialization.DataOutput, i interface{})

type Int32ArraySerializer 

type Int32ArraySerializer struct{}

func (Int32ArraySerializer) ID 

func (Int32ArraySerializer) ID() int32

func (Int32ArraySerializer) Read 

func (Int32ArraySerializer) Read(input serialization.DataInput) interface{}

func (Int32ArraySerializer) Write 

func (Int32ArraySerializer) Write(output serialization.DataOutput, i interface{})

type Int32Serializer 

type Int32Serializer struct{}

func (Int32Serializer) ID 

func (Int32Serializer) ID() int32

func (Int32Serializer) Read 

func (Int32Serializer) Read(input serialization.DataInput) interface{}

func (Int32Serializer) Write 

func (Int32Serializer) Write(output serialization.DataOutput, i interface{})

type Int64ArraySerializer 

type Int64ArraySerializer struct{}

func (Int64ArraySerializer) ID 

func (Int64ArraySerializer) ID() int32

func (Int64ArraySerializer) Read 

func (Int64ArraySerializer) Read(input serialization.DataInput) interface{}

func (Int64ArraySerializer) Write 

func (Int64ArraySerializer) Write(output serialization.DataOutput, i interface{})

type Int64Serializer 

type Int64Serializer struct{}

func (Int64Serializer) ID 

func (Int64Serializer) ID() int32

func (Int64Serializer) Read 

func (Int64Serializer) Read(input serialization.DataInput) interface{}

func (Int64Serializer) Write 

func (Int64Serializer) Write(output serialization.DataOutput, i interface{})

type Int8Serializer added in v1.2.0 

type Int8Serializer struct{}

func (Int8Serializer) ID added in v1.2.0 

func (Int8Serializer) ID() int32

func (Int8Serializer) Read added in v1.2.0 

func (Int8Serializer) Read(input serialization.DataInput) interface{}

func (Int8Serializer) Write added in v1.2.0 

func (Int8Serializer) Write(output serialization.DataOutput, i interface{})

type IntOffsetReader added in v1.4.0 

type IntOffsetReader struct{}

type IntSerializer 

type IntSerializer struct{}

func (IntSerializer) ID 

func (IntSerializer) ID() int32

func (IntSerializer) Read 

func (IntSerializer) Read(input serialization.DataInput) interface{}

func (IntSerializer) Write 

func (IntSerializer) Write(output serialization.DataOutput, i interface{})

type JSONValueSerializer 

type JSONValueSerializer struct {
}

func (JSONValueSerializer) ID 

func (js JSONValueSerializer) ID() int32

func (JSONValueSerializer) Read 

func (js JSONValueSerializer) Read(input serialization.DataInput) interface{}

func (JSONValueSerializer) Write 

func (js JSONValueSerializer) Write(output serialization.DataOutput, object interface{})

type JavaArrayListSerializer 

type JavaArrayListSerializer struct{}

func (JavaArrayListSerializer) ID 

func (JavaArrayListSerializer) ID() int32

func (JavaArrayListSerializer) Read 

func (JavaArrayListSerializer) Read(input serialization.DataInput) interface{}

func (JavaArrayListSerializer) Write 

func (JavaArrayListSerializer) Write(o serialization.DataOutput, i interface{})

type JavaArraySerializer added in v1.2.0 

type JavaArraySerializer struct{}

func (JavaArraySerializer) ID added in v1.2.0 

func (JavaArraySerializer) ID() int32

func (JavaArraySerializer) Read added in v1.2.0 

func (JavaArraySerializer) Read(input serialization.DataInput) interface{}

func (JavaArraySerializer) Write added in v1.2.0 

func (JavaArraySerializer) Write(output serialization.DataOutput, i interface{})

type JavaBigIntegerSerializer added in v1.2.0 

type JavaBigIntegerSerializer struct{}

func (JavaBigIntegerSerializer) ID added in v1.2.0 

func (JavaBigIntegerSerializer) ID() int32

func (JavaBigIntegerSerializer) Read added in v1.2.0 

func (JavaBigIntegerSerializer) Read(input serialization.DataInput) interface{}

func (JavaBigIntegerSerializer) Write added in v1.2.0 

func (JavaBigIntegerSerializer) Write(output serialization.DataOutput, i interface{})

type JavaClassSerializer 

type JavaClassSerializer struct{}

func (JavaClassSerializer) ID 

func (JavaClassSerializer) ID() int32

func (JavaClassSerializer) Read 

func (JavaClassSerializer) Read(input serialization.DataInput) interface{}

func (JavaClassSerializer) Write 

func (JavaClassSerializer) Write(output serialization.DataOutput, i interface{})

type JavaDateSerializer 

type JavaDateSerializer struct{}

func (JavaDateSerializer) ID 

func (JavaDateSerializer) ID() int32

func (JavaDateSerializer) Read 

func (JavaDateSerializer) Read(input serialization.DataInput) interface{}

func (JavaDateSerializer) Write 

func (JavaDateSerializer) Write(output serialization.DataOutput, i interface{})

type JavaDecimalSerializer added in v1.2.0 

type JavaDecimalSerializer struct{}

func (JavaDecimalSerializer) ID added in v1.2.0 

func (JavaDecimalSerializer) ID() int32

func (JavaDecimalSerializer) Read added in v1.2.0 

func (JavaDecimalSerializer) Read(input serialization.DataInput) interface{}

func (JavaDecimalSerializer) Write added in v1.2.0 

func (JavaDecimalSerializer) Write(output serialization.DataOutput, i interface{})

type JavaLinkedListSerializer 

type JavaLinkedListSerializer struct{}

func (JavaLinkedListSerializer) ID 

func (JavaLinkedListSerializer) ID() int32

func (JavaLinkedListSerializer) Read 

func (JavaLinkedListSerializer) Read(input serialization.DataInput) interface{}

func (JavaLinkedListSerializer) Write 

func (JavaLinkedListSerializer) Write(output serialization.DataOutput, i interface{})

type JavaLocalDateSerializer added in v1.2.0 

type JavaLocalDateSerializer struct{}

func (JavaLocalDateSerializer) ID added in v1.2.0 

func (JavaLocalDateSerializer) ID() int32

func (JavaLocalDateSerializer) Read added in v1.2.0 

func (JavaLocalDateSerializer) Read(input serialization.DataInput) interface{}

func (JavaLocalDateSerializer) Write added in v1.2.0 

func (JavaLocalDateSerializer) Write(output serialization.DataOutput, i interface{})

type JavaLocalDateTimeSerializer added in v1.2.0 

type JavaLocalDateTimeSerializer struct{}

func (JavaLocalDateTimeSerializer) ID added in v1.2.0 

func (JavaLocalDateTimeSerializer) ID() int32

func (JavaLocalDateTimeSerializer) Read added in v1.2.0 

func (JavaLocalDateTimeSerializer) Read(input serialization.DataInput) interface{}

func (JavaLocalDateTimeSerializer) Write added in v1.2.0 

func (JavaLocalDateTimeSerializer) Write(output serialization.DataOutput, i interface{})

type JavaLocalTimeSerializer added in v1.2.0 

type JavaLocalTimeSerializer struct{}

func (JavaLocalTimeSerializer) ID added in v1.2.0 

func (JavaLocalTimeSerializer) ID() int32

func (JavaLocalTimeSerializer) Read added in v1.2.0 

func (JavaLocalTimeSerializer) Read(input serialization.DataInput) interface{}

func (JavaLocalTimeSerializer) Write added in v1.2.0 

func (JavaLocalTimeSerializer) Write(output serialization.DataOutput, i interface{})

type JavaOffsetDateTimeSerializer added in v1.2.0 

type JavaOffsetDateTimeSerializer struct{}

func (JavaOffsetDateTimeSerializer) ID added in v1.2.0 

func (JavaOffsetDateTimeSerializer) ID() int32

func (JavaOffsetDateTimeSerializer) Read added in v1.2.0 

func (JavaOffsetDateTimeSerializer) Read(input serialization.DataInput) interface{}

func (JavaOffsetDateTimeSerializer) Write added in v1.2.0 

func (JavaOffsetDateTimeSerializer) Write(output serialization.DataOutput, i interface{})

type MorphingPortableReader 

type MorphingPortableReader struct {
	*DefaultPortableReader
}

func NewMorphingPortableReader 

func NewMorphingPortableReader(portableSerializer *PortableSerializer, input serialization.DataInput,
	classDefinition *serialization.ClassDefinition) *MorphingPortableReader

func (*MorphingPortableReader) ReadBool 

func (mpr *MorphingPortableReader) ReadBool(fieldName string) bool

func (*MorphingPortableReader) ReadBoolArray 

func (mpr *MorphingPortableReader) ReadBoolArray(fieldName string) []bool

func (*MorphingPortableReader) ReadByte 

func (mpr *MorphingPortableReader) ReadByte(fieldName string) byte

func (*MorphingPortableReader) ReadByteArray 

func (mpr *MorphingPortableReader) ReadByteArray(fieldName string) []byte

func (*MorphingPortableReader) ReadFloat32 

func (mpr *MorphingPortableReader) ReadFloat32(fieldName string) float32

func (*MorphingPortableReader) ReadFloat32Array 

func (mpr *MorphingPortableReader) ReadFloat32Array(fieldName string) []float32

func (*MorphingPortableReader) ReadFloat64 

func (mpr *MorphingPortableReader) ReadFloat64(fieldName string) float64

func (*MorphingPortableReader) ReadFloat64Array 

func (mpr *MorphingPortableReader) ReadFloat64Array(fieldName string) []float64

func (*MorphingPortableReader) ReadInt16 

func (mpr *MorphingPortableReader) ReadInt16(fieldName string) int16

func (*MorphingPortableReader) ReadInt16Array 

func (mpr *MorphingPortableReader) ReadInt16Array(fieldName string) []int16

func (*MorphingPortableReader) ReadInt32 

func (mpr *MorphingPortableReader) ReadInt32(fieldName string) int32

func (*MorphingPortableReader) ReadInt32Array 

func (mpr *MorphingPortableReader) ReadInt32Array(fieldName string) []int32

func (*MorphingPortableReader) ReadInt64 

func (mpr *MorphingPortableReader) ReadInt64(fieldName string) int64

func (*MorphingPortableReader) ReadInt64Array 

func (mpr *MorphingPortableReader) ReadInt64Array(fieldName string) []int64

func (*MorphingPortableReader) ReadPortable 

func (mpr *MorphingPortableReader) ReadPortable(fieldName string) serialization.Portable

func (*MorphingPortableReader) ReadPortableArray 

func (mpr *MorphingPortableReader) ReadPortableArray(fieldName string) []serialization.Portable

func (*MorphingPortableReader) ReadString 

func (mpr *MorphingPortableReader) ReadString(fieldName string) string

func (*MorphingPortableReader) ReadStringArray 

func (mpr *MorphingPortableReader) ReadStringArray(fieldName string) []string

func (*MorphingPortableReader) ReadUInt16 

func (mpr *MorphingPortableReader) ReadUInt16(fieldName string) uint16

func (*MorphingPortableReader) ReadUInt16Array 

func (mpr *MorphingPortableReader) ReadUInt16Array(fieldName string) []uint16

type NilSerializer 

type NilSerializer struct{}

func (NilSerializer) ID 

func (NilSerializer) ID() int32

func (NilSerializer) Read 

func (NilSerializer) Read(input serialization.DataInput) interface{}

func (NilSerializer) Write 

func (NilSerializer) Write(output serialization.DataOutput, i interface{})

type ObjectDataInput 

type ObjectDataInput struct {
	// contains filtered or unexported fields
}

func NewObjectDataInput 

func NewObjectDataInput(buffer []byte, offset int32, service *Service, bigEndian bool) *ObjectDataInput

func (*ObjectDataInput) AssertAvailable 

func (i *ObjectDataInput) AssertAvailable(k int)

func (*ObjectDataInput) Available 

func (i *ObjectDataInput) Available() int32

func (*ObjectDataInput) Position 

func (i *ObjectDataInput) Position() int32

func (*ObjectDataInput) ReadBool 

func (i *ObjectDataInput) ReadBool() bool

func (*ObjectDataInput) ReadBoolArray 

func (i *ObjectDataInput) ReadBoolArray() []bool

func (*ObjectDataInput) ReadBoolArrayAtPosition 

func (i *ObjectDataInput) ReadBoolArrayAtPosition(pos int32) []bool

func (*ObjectDataInput) ReadBoolAtPosition 

func (i *ObjectDataInput) ReadBoolAtPosition(pos int32) bool

func (*ObjectDataInput) ReadByte 

func (i *ObjectDataInput) ReadByte() byte

func (*ObjectDataInput) ReadByteArray 

func (i *ObjectDataInput) ReadByteArray() []byte

func (*ObjectDataInput) ReadByteArrayAtPosition 

func (i *ObjectDataInput) ReadByteArrayAtPosition(pos int32) []byte

func (*ObjectDataInput) ReadByteAtPosition 

func (i *ObjectDataInput) ReadByteAtPosition(pos int32) byte

func (*ObjectDataInput) ReadFloat32 

func (i *ObjectDataInput) ReadFloat32() float32

func (*ObjectDataInput) ReadFloat32Array 

func (i *ObjectDataInput) ReadFloat32Array() []float32

func (*ObjectDataInput) ReadFloat32ArrayAtPosition 

func (i *ObjectDataInput) ReadFloat32ArrayAtPosition(pos int32) []float32

func (*ObjectDataInput) ReadFloat32AtPosition 

func (i *ObjectDataInput) ReadFloat32AtPosition(pos int32) float32

func (*ObjectDataInput) ReadFloat64 

func (i *ObjectDataInput) ReadFloat64() float64

func (*ObjectDataInput) ReadFloat64Array 

func (i *ObjectDataInput) ReadFloat64Array() []float64

func (*ObjectDataInput) ReadFloat64ArrayAtPosition 

func (i *ObjectDataInput) ReadFloat64ArrayAtPosition(pos int32) []float64

func (*ObjectDataInput) ReadFloat64AtPosition 

func (i *ObjectDataInput) ReadFloat64AtPosition(pos int32) float64

func (*ObjectDataInput) ReadInt16 

func (i *ObjectDataInput) ReadInt16() int16

func (*ObjectDataInput) ReadInt16Array 

func (i *ObjectDataInput) ReadInt16Array() []int16

func (*ObjectDataInput) ReadInt16ArrayAtPosition 

func (i *ObjectDataInput) ReadInt16ArrayAtPosition(pos int32) []int16

func (*ObjectDataInput) ReadInt16AtPosition 

func (i *ObjectDataInput) ReadInt16AtPosition(pos int32) int16

func (*ObjectDataInput) ReadInt32 

func (i *ObjectDataInput) ReadInt32() int32

func (*ObjectDataInput) ReadInt32Array 

func (i *ObjectDataInput) ReadInt32Array() []int32

func (*ObjectDataInput) ReadInt32ArrayAtPosition 

func (i *ObjectDataInput) ReadInt32ArrayAtPosition(pos int32) []int32

func (*ObjectDataInput) ReadInt32AtPosition 

func (i *ObjectDataInput) ReadInt32AtPosition(pos int32) int32

func (*ObjectDataInput) ReadInt64 

func (i *ObjectDataInput) ReadInt64() int64

func (*ObjectDataInput) ReadInt64Array 

func (i *ObjectDataInput) ReadInt64Array() []int64

func (*ObjectDataInput) ReadInt64ArrayAtPosition 

func (i *ObjectDataInput) ReadInt64ArrayAtPosition(pos int32) []int64

func (*ObjectDataInput) ReadInt64AtPosition 

func (i *ObjectDataInput) ReadInt64AtPosition(pos int32) int64

func (*ObjectDataInput) ReadInt8Array added in v1.4.0 

func (i *ObjectDataInput) ReadInt8Array() []int8

func (*ObjectDataInput) ReadObject 

func (i *ObjectDataInput) ReadObject() interface{}

func (*ObjectDataInput) ReadSignedByte added in v1.4.0 

func (i *ObjectDataInput) ReadSignedByte() int8

func (*ObjectDataInput) ReadSignedByteAtPosition added in v1.4.0 

func (i *ObjectDataInput) ReadSignedByteAtPosition(pos int32) int8

func (*ObjectDataInput) ReadString 

func (i *ObjectDataInput) ReadString() string

func (*ObjectDataInput) ReadStringArray 

func (i *ObjectDataInput) ReadStringArray() []string

func (*ObjectDataInput) ReadStringArrayAtPosition 

func (i *ObjectDataInput) ReadStringArrayAtPosition(pos int32) []string

func (*ObjectDataInput) ReadStringAtPosition 

func (i *ObjectDataInput) ReadStringAtPosition(pos int32) string

func (*ObjectDataInput) ReadUInt16 

func (i *ObjectDataInput) ReadUInt16() uint16

func (*ObjectDataInput) ReadUInt16Array 

func (i *ObjectDataInput) ReadUInt16Array() []uint16

func (*ObjectDataInput) ReadUInt16ArrayAtPosition 

func (i *ObjectDataInput) ReadUInt16ArrayAtPosition(pos int32) []uint16

func (*ObjectDataInput) ReadUInt16AtPosition 

func (i *ObjectDataInput) ReadUInt16AtPosition(pos int32) uint16

func (*ObjectDataInput) SetPosition 

func (i *ObjectDataInput) SetPosition(pos int32)

type ObjectDataOutput 

type ObjectDataOutput struct {
	// contains filtered or unexported fields
}

func NewObjectDataOutput 

func NewObjectDataOutput(length int, service *Service, bigEndian bool) *ObjectDataOutput

func (*ObjectDataOutput) Available 

func (o *ObjectDataOutput) Available() int

func (*ObjectDataOutput) EnsureAvailable 

func (o *ObjectDataOutput) EnsureAvailable(size int)

func (*ObjectDataOutput) Position 

func (o *ObjectDataOutput) Position() int32

func (*ObjectDataOutput) SetPosition 

func (o *ObjectDataOutput) SetPosition(pos int32)

func (*ObjectDataOutput) ToBuffer 

func (o *ObjectDataOutput) ToBuffer() []byte

func (*ObjectDataOutput) WriteBool 

func (o *ObjectDataOutput) WriteBool(v bool)

func (*ObjectDataOutput) WriteBoolArray 

func (o *ObjectDataOutput) WriteBoolArray(v []bool)

func (*ObjectDataOutput) WriteByte 

func (o *ObjectDataOutput) WriteByte(v byte)

func (*ObjectDataOutput) WriteByteArray 

func (o *ObjectDataOutput) WriteByteArray(v []byte)

func (*ObjectDataOutput) WriteFloat32 

func (o *ObjectDataOutput) WriteFloat32(v float32)

func (*ObjectDataOutput) WriteFloat32Array 

func (o *ObjectDataOutput) WriteFloat32Array(v []float32)

func (*ObjectDataOutput) WriteFloat64 

func (o *ObjectDataOutput) WriteFloat64(v float64)

func (*ObjectDataOutput) WriteFloat64Array 

func (o *ObjectDataOutput) WriteFloat64Array(v []float64)

func (*ObjectDataOutput) WriteInt16 

func (o *ObjectDataOutput) WriteInt16(v int16)

func (*ObjectDataOutput) WriteInt16Array 

func (o *ObjectDataOutput) WriteInt16Array(v []int16)

func (*ObjectDataOutput) WriteInt32 

func (o *ObjectDataOutput) WriteInt32(v int32)

func (*ObjectDataOutput) WriteInt32Array 

func (o *ObjectDataOutput) WriteInt32Array(v []int32)

func (*ObjectDataOutput) WriteInt32BigEndian added in v1.3.2 

func (o *ObjectDataOutput) WriteInt32BigEndian(v int32)

func (*ObjectDataOutput) WriteInt64 

func (o *ObjectDataOutput) WriteInt64(v int64)

func (*ObjectDataOutput) WriteInt64Array 

func (o *ObjectDataOutput) WriteInt64Array(v []int64)

func (*ObjectDataOutput) WriteInt8Array added in v1.4.0 

func (o *ObjectDataOutput) WriteInt8Array(signedByteArray []int8)

func (*ObjectDataOutput) WriteObject 

func (o *ObjectDataOutput) WriteObject(object interface{})

func (*ObjectDataOutput) WriteRawBytes 

func (o *ObjectDataOutput) WriteRawBytes(b []byte)

func (*ObjectDataOutput) WriteSignedByte added in v1.4.0 

func (o *ObjectDataOutput) WriteSignedByte(v int8)

func (*ObjectDataOutput) WriteString 

func (o *ObjectDataOutput) WriteString(v string)

func (*ObjectDataOutput) WriteStringArray 

func (o *ObjectDataOutput) WriteStringArray(v []string)

func (*ObjectDataOutput) WriteStringBytes 

func (o *ObjectDataOutput) WriteStringBytes(v string)

func (*ObjectDataOutput) WriteUInt16 

func (o *ObjectDataOutput) WriteUInt16(v uint16)

func (*ObjectDataOutput) WriteUInt16Array 

func (o *ObjectDataOutput) WriteUInt16Array(v []uint16)

func (*ObjectDataOutput) WriteZeroBytes 

func (o *ObjectDataOutput) WriteZeroBytes(count int)

type OffsetReader added in v1.4.0 

type OffsetReader interface {
	// contains filtered or unexported methods
}

type PortableContext 

type PortableContext struct {
	// contains filtered or unexported fields
}

func NewPortableContext 

func NewPortableContext(service *Service, portableVersion int32) *PortableContext

func (*PortableContext) ClassVersion 

func (c *PortableContext) ClassVersion(portable serialization.Portable) int32

func (*PortableContext) LookUpClassDefinition 

func (c *PortableContext) LookUpClassDefinition(factoryID int32, classID int32, version int32) *serialization.ClassDefinition

func (*PortableContext) LookUpOrRegisterClassDefiniton 

func (c *PortableContext) LookUpOrRegisterClassDefiniton(portable serialization.Portable) (*serialization.ClassDefinition, error)

func (*PortableContext) ReadClassDefinitionFromInput 

func (c *PortableContext) ReadClassDefinitionFromInput(input serialization.DataInput, factoryID int32, classID int32,
	version int32) *serialization.ClassDefinition

func (*PortableContext) RegisterClassDefinition 

func (c *PortableContext) RegisterClassDefinition(cd *serialization.ClassDefinition) error

func (*PortableContext) Version 

func (c *PortableContext) Version() int32

type PortableReaderEnder added in v1.4.1 

type PortableReaderEnder interface {
	End()
}

type PortableSerializer 

type PortableSerializer struct {
	// contains filtered or unexported fields
}

func NewPortableSerializer 

func NewPortableSerializer(service *Service, factories []serialization.PortableFactory, version int32, ds GenericPortableDeserializer) (*PortableSerializer, error)

func (*PortableSerializer) ID 

func (ps *PortableSerializer) ID() int32

func (*PortableSerializer) Read 

func (ps *PortableSerializer) Read(input serialization.DataInput) interface{}

func (*PortableSerializer) ReadObject 

func (ps *PortableSerializer) ReadObject(input serialization.DataInput, factoryID int32, classID int32) serialization.Portable

func (*PortableSerializer) Write 

func (ps *PortableSerializer) Write(output serialization.DataOutput, i interface{})

func (*PortableSerializer) WriteObject 

func (ps *PortableSerializer) WriteObject(output serialization.DataOutput, i interface{})

type PositionalObjectDataOutput 

type PositionalObjectDataOutput struct {
	*ObjectDataOutput
}

func NewPositionalObjectDataOutput 

func NewPositionalObjectDataOutput(length int, service *Service, bigEndian bool) *PositionalObjectDataOutput

func (*PositionalObjectDataOutput) PWriteBool 

func (p *PositionalObjectDataOutput) PWriteBool(pos int32, v bool)

func (*PositionalObjectDataOutput) PWriteBoolBit added in v1.4.0 

func (p *PositionalObjectDataOutput) PWriteBoolBit(pos int32, bitIndex int32, v bool)

func (*PositionalObjectDataOutput) PWriteByte 

func (p *PositionalObjectDataOutput) PWriteByte(pos int32, v byte)

func (*PositionalObjectDataOutput) PWriteFloat32 

func (p *PositionalObjectDataOutput) PWriteFloat32(pos int32, v float32)

func (*PositionalObjectDataOutput) PWriteFloat64 

func (p *PositionalObjectDataOutput) PWriteFloat64(pos int32, v float64)

func (*PositionalObjectDataOutput) PWriteInt16 

func (p *PositionalObjectDataOutput) PWriteInt16(pos int32, v int16)

func (*PositionalObjectDataOutput) PWriteInt32 

func (p *PositionalObjectDataOutput) PWriteInt32(pos int32, v int32)

func (*PositionalObjectDataOutput) PWriteInt64 

func (p *PositionalObjectDataOutput) PWriteInt64(pos int32, v int64)

func (*PositionalObjectDataOutput) PWriteUInt16 

func (p *PositionalObjectDataOutput) PWriteUInt16(pos int32, v uint16)

func (*PositionalObjectDataOutput) WriteObject added in v1.3.2 

func (p *PositionalObjectDataOutput) WriteObject(object interface{})

type Reader added in v1.4.0 

type Reader func(*ObjectDataInput) interface{}

type Schema added in v1.4.0 

type Schema struct {
	Fields   map[string]FieldDescriptor
	TypeName string
	// contains filtered or unexported fields
}

func NewSchema added in v1.4.0 

func NewSchema(typeName string, fieldDefinitionMap map[string]FieldDescriptor) *Schema

func (*Schema) FieldCount added in v1.4.0 

func (s *Schema) FieldCount() int

func (*Schema) FieldDefinitions added in v1.4.0 

func (s *Schema) FieldDefinitions() []FieldDescriptor

func (*Schema) GetField added in v1.4.0 

func (s *Schema) GetField(fieldName string) (FieldDescriptor, bool)

func (*Schema) ID added in v1.4.0 

func (s *Schema) ID() int64

func (Schema) String added in v1.4.0 

func (s Schema) String() string

type SchemaMsg added in v1.4.0 

type SchemaMsg struct {
	ID         int64
	ResponseCh chan *Schema
}

type SchemaService added in v1.4.0 

type SchemaService struct {
	// contains filtered or unexported fields
}

func NewSchemaService added in v1.4.0 

func NewSchemaService(cfg pubserialization.CompactConfig, ch chan<- SchemaMsg) (*SchemaService, error)

func (*SchemaService) Get added in v1.4.0 

func (s *SchemaService) Get(ctx context.Context, schemaId int64) (schema *Schema, ok bool)

func (*SchemaService) Schemas added in v1.4.0 

func (s *SchemaService) Schemas() []*Schema

type SchemaWriter added in v1.4.0 

type SchemaWriter struct {
	// contains filtered or unexported fields
}

func NewSchemaWriter added in v1.4.0 

func NewSchemaWriter(typeName string) SchemaWriter

func (SchemaWriter) Build added in v1.4.0 

func (s SchemaWriter) Build() *Schema

func (SchemaWriter) WriteArrayOfBoolean added in v1.4.0 

func (s SchemaWriter) WriteArrayOfBoolean(fieldName string, value []bool)

func (SchemaWriter) WriteArrayOfCompact added in v1.4.0 

func (s SchemaWriter) WriteArrayOfCompact(fieldName string, value []interface{})

func (SchemaWriter) WriteArrayOfDate added in v1.4.0 

func (s SchemaWriter) WriteArrayOfDate(fieldName string, value []*types.LocalDate)

func (SchemaWriter) WriteArrayOfDecimal added in v1.4.0 

func (s SchemaWriter) WriteArrayOfDecimal(fieldName string, value []*types.Decimal)

func (SchemaWriter) WriteArrayOfFloat32 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfFloat32(fieldName string, value []float32)

func (SchemaWriter) WriteArrayOfFloat64 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfFloat64(fieldName string, value []float64)

func (SchemaWriter) WriteArrayOfInt16 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfInt16(fieldName string, value []int16)

func (SchemaWriter) WriteArrayOfInt32 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfInt32(fieldName string, value []int32)

func (SchemaWriter) WriteArrayOfInt64 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfInt64(fieldName string, value []int64)

func (SchemaWriter) WriteArrayOfInt8 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfInt8(fieldName string, value []int8)

func (SchemaWriter) WriteArrayOfNullableBoolean added in v1.4.0 

func (s SchemaWriter) WriteArrayOfNullableBoolean(fieldName string, value []*bool)

func (SchemaWriter) WriteArrayOfNullableFloat32 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfNullableFloat32(fieldName string, value []*float32)

func (SchemaWriter) WriteArrayOfNullableFloat64 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfNullableFloat64(fieldName string, value []*float64)

func (SchemaWriter) WriteArrayOfNullableInt16 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfNullableInt16(fieldName string, value []*int16)

func (SchemaWriter) WriteArrayOfNullableInt32 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfNullableInt32(fieldName string, value []*int32)

func (SchemaWriter) WriteArrayOfNullableInt64 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfNullableInt64(fieldName string, value []*int64)

func (SchemaWriter) WriteArrayOfNullableInt8 added in v1.4.0 

func (s SchemaWriter) WriteArrayOfNullableInt8(fieldName string, value []*int8)

func (SchemaWriter) WriteArrayOfString added in v1.4.0 

func (s SchemaWriter) WriteArrayOfString(fieldName string, value []*string)

func (SchemaWriter) WriteArrayOfTime added in v1.4.0 

func (s SchemaWriter) WriteArrayOfTime(fieldName string, value []*types.LocalTime)

func (SchemaWriter) WriteArrayOfTimestamp added in v1.4.0 

func (s SchemaWriter) WriteArrayOfTimestamp(fieldName string, value []*types.LocalDateTime)

func (SchemaWriter) WriteArrayOfTimestampWithTimezone added in v1.4.0 

func (s SchemaWriter) WriteArrayOfTimestampWithTimezone(fieldName string, value []*types.OffsetDateTime)

func (SchemaWriter) WriteBoolean added in v1.4.0 

func (s SchemaWriter) WriteBoolean(fieldName string, value bool)

func (SchemaWriter) WriteCompact added in v1.4.0 

func (s SchemaWriter) WriteCompact(fieldName string, value interface{})

func (SchemaWriter) WriteDate added in v1.4.0 

func (s SchemaWriter) WriteDate(fieldName string, value *types.LocalDate)

func (SchemaWriter) WriteDecimal added in v1.4.0 

func (s SchemaWriter) WriteDecimal(fieldName string, value *types.Decimal)

func (SchemaWriter) WriteFloat32 added in v1.4.0 

func (s SchemaWriter) WriteFloat32(fieldName string, value float32)

func (SchemaWriter) WriteFloat64 added in v1.4.0 

func (s SchemaWriter) WriteFloat64(fieldName string, value float64)

func (SchemaWriter) WriteInt16 added in v1.4.0 

func (s SchemaWriter) WriteInt16(fieldName string, value int16)

func (SchemaWriter) WriteInt32 added in v1.4.0 

func (s SchemaWriter) WriteInt32(fieldName string, value int32)

func (SchemaWriter) WriteInt64 added in v1.4.0 

func (s SchemaWriter) WriteInt64(fieldName string, value int64)

func (SchemaWriter) WriteInt8 added in v1.4.0 

func (s SchemaWriter) WriteInt8(fieldName string, value int8)

func (SchemaWriter) WriteNullableBoolean added in v1.4.0 

func (s SchemaWriter) WriteNullableBoolean(fieldName string, value *bool)

func (SchemaWriter) WriteNullableFloat32 added in v1.4.0 

func (s SchemaWriter) WriteNullableFloat32(fieldName string, value *float32)

func (SchemaWriter) WriteNullableFloat64 added in v1.4.0 

func (s SchemaWriter) WriteNullableFloat64(fieldName string, value *float64)

func (SchemaWriter) WriteNullableInt16 added in v1.4.0 

func (s SchemaWriter) WriteNullableInt16(fieldName string, value *int16)

func (SchemaWriter) WriteNullableInt32 added in v1.4.0 

func (s SchemaWriter) WriteNullableInt32(fieldName string, value *int32)

func (SchemaWriter) WriteNullableInt64 added in v1.4.0 

func (s SchemaWriter) WriteNullableInt64(fieldName string, value *int64)

func (SchemaWriter) WriteNullableInt8 added in v1.4.0 

func (s SchemaWriter) WriteNullableInt8(fieldName string, value *int8)

func (SchemaWriter) WriteString added in v1.4.0 

func (s SchemaWriter) WriteString(fieldName string, value *string)

func (SchemaWriter) WriteTime added in v1.4.0 

func (s SchemaWriter) WriteTime(fieldName string, value *types.LocalTime)

func (SchemaWriter) WriteTimestamp added in v1.4.0 

func (s SchemaWriter) WriteTimestamp(fieldName string, value *types.LocalDateTime)

func (SchemaWriter) WriteTimestampWithTimezone added in v1.4.0 

func (s SchemaWriter) WriteTimestampWithTimezone(fieldName string, value *types.OffsetDateTime)

type Service 

type Service struct {
	SerializationConfig *pubserialization.Config
	// contains filtered or unexported fields
}

Service serializes user objects to Data and back to Object. Data is the internal representation of binary Data in Hazelcast.

func NewService 

func NewService(config *pubserialization.Config, schemaCh chan SchemaMsg) (*Service, error)

func (*Service) FindSerializerFor 

func (s *Service) FindSerializerFor(obj interface{}) (pubserialization.Serializer, error)

func (*Service) LookUpDefaultSerializer 

func (s *Service) LookUpDefaultSerializer(obj interface{}) pubserialization.Serializer

func (*Service) ReadObject 

func (s *Service) ReadObject(input pubserialization.DataInput) interface{}

func (*Service) SchemaService added in v1.4.0 

func (s *Service) SchemaService() *SchemaService

func (*Service) SetSchemaService added in v1.4.0 

func (s *Service) SetSchemaService(ss *SchemaService)

SetSchemaService is used in tests

func (*Service) ToData 

func (s *Service) ToData(object interface{}) (r Data, err error)

ToData serializes an object to a Data. It can safely be called with a Data. In that case, that instance is returned. If it is called with nil, nil is returned.

func (*Service) ToObject 

func (s *Service) ToObject(data Data) (r interface{}, err error)

ToObject deserializes the given Data to an object. nil is returned if called with nil.

func (*Service) WriteObject 

func (s *Service) WriteObject(output pubserialization.DataOutput, object interface{})

type ShortOffsetReader added in v1.4.0 

type ShortOffsetReader struct{}

type SliceConstructor added in v1.4.0 

type SliceConstructor func(int)

type SliceReader added in v1.4.0 

type SliceReader func(*ObjectDataInput, int32, bool)

type StringArraySerializer 

type StringArraySerializer struct{}

func (StringArraySerializer) ID 

func (StringArraySerializer) ID() int32

func (StringArraySerializer) Read 

func (StringArraySerializer) Read(input serialization.DataInput) interface{}

func (StringArraySerializer) Write 

func (StringArraySerializer) Write(output serialization.DataOutput, i interface{})

type StringSerializer 

type StringSerializer struct{}

func (StringSerializer) ID 

func (StringSerializer) ID() int32

func (StringSerializer) Read 

func (StringSerializer) Read(input serialization.DataInput) interface{}

func (StringSerializer) Write 

func (StringSerializer) Write(output serialization.DataOutput, i interface{})

type UInt16ArraySerializer 

type UInt16ArraySerializer struct{}

func (UInt16ArraySerializer) ID 

func (UInt16ArraySerializer) ID() int32

func (UInt16ArraySerializer) Read 

func (UInt16ArraySerializer) Read(input serialization.DataInput) interface{}

func (UInt16ArraySerializer) Write 

func (UInt16ArraySerializer) Write(output serialization.DataOutput, i interface{})

type UInt16Serializer 

type UInt16Serializer struct{}

func (UInt16Serializer) ID 

func (UInt16Serializer) ID() int32

func (UInt16Serializer) Read 

func (UInt16Serializer) Read(input serialization.DataInput) interface{}

func (UInt16Serializer) Write 

func (UInt16Serializer) Write(output serialization.DataOutput, i interface{})

type UUIDSerializer 

type UUIDSerializer struct{}

func (UUIDSerializer) ID 

func (UUIDSerializer) ID() int32

func (UUIDSerializer) Read 

func (UUIDSerializer) Read(input serialization.DataInput) interface{}

func (UUIDSerializer) Write 

func (UUIDSerializer) Write(output serialization.DataOutput, i interface{})

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.