serialization

package
v1.2.1 Latest Latest
Warning

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

 Go to latest Published: Jul 7, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	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
	TypeJSONSerialization  = -130
	TypeGobSerialization   = -140
)
View Source 
const (
	DataOffset = 8
)

Variables

This section is empty.

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 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 ReadDecimalArray added in v1.2.0 

func ReadDecimalArray(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 WriteDecimalArray added in v1.2.0 

func WriteDecimalArray(o serialization.DataOutput, ds []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 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

func (*ClassDefinitionContext) Register 

func (c *ClassDefinitionContext) Register(classDefinition *serialization.ClassDefinition) error

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 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 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 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 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 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) ReadObject 

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

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) WriteInt64 

func (o *ObjectDataOutput) WriteInt64(v int64)

func (*ObjectDataOutput) WriteInt64Array 

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

func (*ObjectDataOutput) WriteObject 

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

func (*ObjectDataOutput) WriteRawBytes 

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

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 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(classDefinition *serialization.ClassDefinition) error

func (*PortableContext) Version 

func (c *PortableContext) Version() int32

type PortableSerializer 

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

func NewPortableSerializer 

func NewPortableSerializer(service *Service, factories []serialization.PortableFactory, version int32) (*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) 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)

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) (*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) 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 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

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.