serialization

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Nov 9, 2021 License: Apache-2.0 Imports: 15 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
	TypeJavaArrayList     = -29
	TypeJavaLinkedList    = -30
	TypeJSONSerialization = -130
	TypeGobSerialization  = -140
)
View Source 
const (
	DataOffset = 8
)

Variables

This section is empty.

Functions

func NewFieldDefinition 

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

func ReadBool 

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

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 ReadUInt16 

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

func TypeByID 

func TypeByID(fieldType serialization.FieldDefinitionType) string

func WriteBool 

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

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 WriteUInt16 

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

Types

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

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

func (*ClassDefinitionWriter) WriteUInt16Array 

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

type Data 

type Data struct {
	Payload []byte
}

func NewData 

func NewData(payload []byte) *Data

NewData returns serialization Data with the given payload. Ownership of Payload is transferred, so it mustn't be used after passed to NewData

func (*Data) Buffer 

func (d *Data) Buffer() []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) TotalSize 

func (d *Data) TotalSize() int

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

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

func (*DefaultPortableWriter) WriteUInt16Array 

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

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 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(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 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 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.