serialization

package
v1.0.0-preview.2 Latest Latest
Warning

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

 Go to latest Published: May 21, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TypePortable = iota
	TypeByte
	TypeBool
	TypeUint16
	TypeInt16
	TypeInt32
	TypeInt64
	TypeFloat32
	TypeFloat64
	TypeUTF
	TypePortableArray
	TypeByteArray
	TypeBoolArray
	TypeUint16Array
	TypeInt16Array
	TypeInt32Array
	TypeInt64Array
	TypeFloat32Array
	TypeFloat64Array
	TypeStringArray
)
View Source 
const (
	ByteSizeInBytes    = 1
	BoolSizeInBytes    = 1
	Uint8SizeInBytes   = 1
	Int16SizeInBytes   = 2
	Uint16SizeInBytes  = 2
	Int32SizeInBytes   = 4
	Float32SizeInBytes = 4
	Float64SizeInBytes = 8
	Int64SizeInBytes   = 8
)
View Source 
const (
	ConstantTypeNil              = 0
	ConstantTypePortable         = -1
	ConstantTypeDataSerializable = -2
	ConstantTypeByte             = -3
	ConstantTypeBool             = -4
	ConstantTypeUInteger16       = -5
	ConstantTypeInteger16        = -6
	ConstantTypeInteger32        = -7
	ConstantTypeInteger64        = -8
	ConstantTypeFloat32          = -9
	ConstantTypeFloat64          = -10
	ConstantTypeString           = -11
	ConstantTypeByteArray        = -12
	ConstantTypeBoolArray        = -13
	ConstantTypeUInteger16Array  = -14
	ConstantTypeInteger16Array   = -15
	ConstantTypeInteger32Array   = -16
	ConstantTypeInteger64Array   = -17
	ConstantTypeFloat32Array     = -18
	ConstantTypeFloat64Array     = -19
	ConstantTypeStringArray      = -20
	JSONSerializationType        = -130
	GoGobSerializationType       = -140
)
View Source 
const (
	DataOffset = 8
)

Variables

This section is empty.

Functions

func NewFieldDefinitionImpl 

func NewFieldDefinitionImpl(index int32, fieldName string, fieldType int32, factoryID int32,
	classID int32, version int32) serialization.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 int32) 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 ClassDefinitionBuilder 

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

ClassDefinitionBuilder is used to build and register class definitions manually.

func NewClassDefinitionBuilder 

func NewClassDefinitionBuilder(factoryID int32, classID int32, version int32) *ClassDefinitionBuilder

NewClassDefinitionBuilder returns a ClassDefinitionBuilder. You can use a default portableVersion (0) for non-versioned classes. Make sure to specify the portableVersion compatible with portableVersion in the serialization.Service.

func (*ClassDefinitionBuilder) AddBoolArrayField 

func (cdb *ClassDefinitionBuilder) AddBoolArrayField(fieldName string) error

AddBoolArrayField adds []bool field to class definition.

func (*ClassDefinitionBuilder) AddBoolField 

func (cdb *ClassDefinitionBuilder) AddBoolField(fieldName string) error

AddBoolField adds bool field to class definition.

func (*ClassDefinitionBuilder) AddByteArrayField 

func (cdb *ClassDefinitionBuilder) AddByteArrayField(fieldName string) error

AddByteArrayField adds []byte field to class definition.

func (*ClassDefinitionBuilder) AddByteField 

func (cdb *ClassDefinitionBuilder) AddByteField(fieldName string) error

AddByteField adds byte field to class definition.

func (*ClassDefinitionBuilder) AddField 

func (cdb *ClassDefinitionBuilder) AddField(fieldDefinition serialization.FieldDefinition) error

AddField adds a field to class definition.

func (*ClassDefinitionBuilder) AddFloat32ArrayField 

func (cdb *ClassDefinitionBuilder) AddFloat32ArrayField(fieldName string) error

AddFloat32ArrayField adds []float32 field to class definition.

func (*ClassDefinitionBuilder) AddFloat32Field 

func (cdb *ClassDefinitionBuilder) AddFloat32Field(fieldName string) error

AddFloat32Field adds float32 field to class definition.

func (*ClassDefinitionBuilder) AddFloat64ArrayField 

func (cdb *ClassDefinitionBuilder) AddFloat64ArrayField(fieldName string) error

AddFloat64ArrayField adds []float64 field to class definition.

func (*ClassDefinitionBuilder) AddFloat64Field 

func (cdb *ClassDefinitionBuilder) AddFloat64Field(fieldName string) error

AddFloat64Field adds float64 field to class definition.

func (*ClassDefinitionBuilder) AddInt16ArrayField 

func (cdb *ClassDefinitionBuilder) AddInt16ArrayField(fieldName string) error

AddInt16ArrayField adds []int16 field to class definition.

func (*ClassDefinitionBuilder) AddInt16Field 

func (cdb *ClassDefinitionBuilder) AddInt16Field(fieldName string) error

AddInt16Field adds int16 field to class definition.

func (*ClassDefinitionBuilder) AddInt32ArrayField 

func (cdb *ClassDefinitionBuilder) AddInt32ArrayField(fieldName string) error

AddInt32ArrayField adds []int32 field to class definition.

func (*ClassDefinitionBuilder) AddInt32Field 

func (cdb *ClassDefinitionBuilder) AddInt32Field(fieldName string) error

AddInt32Field adds int32 field to class definition.

func (*ClassDefinitionBuilder) AddInt64ArrayField 

func (cdb *ClassDefinitionBuilder) AddInt64ArrayField(fieldName string) error

AddInt64ArrayField adds []int64 field to class definition.

func (*ClassDefinitionBuilder) AddInt64Field 

func (cdb *ClassDefinitionBuilder) AddInt64Field(fieldName string) error

AddInt64Field adds int64 field to class definition.

func (*ClassDefinitionBuilder) AddPortableArrayField 

func (cdb *ClassDefinitionBuilder) AddPortableArrayField(fieldName string, def serialization.ClassDefinition) error

AddPortableArrayField adds []Portable field to class definition.

func (*ClassDefinitionBuilder) AddPortableField 

func (cdb *ClassDefinitionBuilder) AddPortableField(fieldName string, def serialization.ClassDefinition) error

AddPortableField adds Portable field to class definition.

func (*ClassDefinitionBuilder) AddUInt16ArrayField 

func (cdb *ClassDefinitionBuilder) AddUInt16ArrayField(fieldName string) error

AddUInt16ArrayField adds []uint16 field to class definition.

func (*ClassDefinitionBuilder) AddUInt16Field 

func (cdb *ClassDefinitionBuilder) AddUInt16Field(fieldName string) error

AddUInt16Field adds uint16 field to class definition.

func (*ClassDefinitionBuilder) AddUTFArrayField 

func (cdb *ClassDefinitionBuilder) AddUTFArrayField(fieldName string) error

AddUTFArrayField adds []string field to class definition.

func (*ClassDefinitionBuilder) AddUTFField 

func (cdb *ClassDefinitionBuilder) AddUTFField(fieldName string) error

AddUTFField adds UTF field to class definition.

func (*ClassDefinitionBuilder) Build 

func (cdb *ClassDefinitionBuilder) Build() serialization.ClassDefinition

Build returns the built class definition.

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

type ClassDefinitionImpl 

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

func NewClassDefinitionImpl 

func NewClassDefinitionImpl(factoryID int32, classID int32, version int32) *ClassDefinitionImpl

func (*ClassDefinitionImpl) AddFieldDefinition 

func (cd *ClassDefinitionImpl) AddFieldDefinition(definition serialization.FieldDefinition)

func (*ClassDefinitionImpl) ClassID 

func (cd *ClassDefinitionImpl) ClassID() int32

func (*ClassDefinitionImpl) FactoryID 

func (cd *ClassDefinitionImpl) FactoryID() int32

func (*ClassDefinitionImpl) Field 

func (cd *ClassDefinitionImpl) Field(name string) serialization.FieldDefinition

func (*ClassDefinitionImpl) FieldCount 

func (cd *ClassDefinitionImpl) FieldCount() int

func (*ClassDefinitionImpl) Version 

func (cd *ClassDefinitionImpl) Version() int32

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 FieldDefinitionImpl 

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

func (*FieldDefinitionImpl) ClassID 

func (fd *FieldDefinitionImpl) ClassID() int32

func (*FieldDefinitionImpl) FactoryID 

func (fd *FieldDefinitionImpl) FactoryID() int32

func (*FieldDefinitionImpl) Index 

func (fd *FieldDefinitionImpl) Index() int32

func (*FieldDefinitionImpl) Name 

func (fd *FieldDefinitionImpl) Name() string

func (*FieldDefinitionImpl) Type 

func (fd *FieldDefinitionImpl) Type() int32

func (*FieldDefinitionImpl) Version 

func (fd *FieldDefinitionImpl) Version() int32

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 Integer16ArraySerializer 

type Integer16ArraySerializer struct{}

func (*Integer16ArraySerializer) ID 

func (*Integer16ArraySerializer) ID() int32

func (*Integer16ArraySerializer) Read 

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

func (*Integer16ArraySerializer) Write 

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

type Integer16Serializer 

type Integer16Serializer struct{}

func (*Integer16Serializer) ID 

func (*Integer16Serializer) ID() int32

func (*Integer16Serializer) Read 

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

func (*Integer16Serializer) Write 

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

type Integer32ArraySerializer 

type Integer32ArraySerializer struct{}

func (*Integer32ArraySerializer) ID 

func (*Integer32ArraySerializer) ID() int32

func (*Integer32ArraySerializer) Read 

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

func (*Integer32ArraySerializer) Write 

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

type Integer32Serializer 

type Integer32Serializer struct{}

func (*Integer32Serializer) ID 

func (*Integer32Serializer) ID() int32

func (*Integer32Serializer) Read 

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

func (*Integer32Serializer) Write 

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

type Integer64ArraySerializer 

type Integer64ArraySerializer struct{}

func (*Integer64ArraySerializer) ID 

func (*Integer64ArraySerializer) ID() int32

func (*Integer64ArraySerializer) Read 

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

func (*Integer64ArraySerializer) Write 

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

type Integer64Serializer 

type Integer64Serializer struct{}

func (*Integer64Serializer) ID 

func (*Integer64Serializer) ID() int32

func (*Integer64Serializer) Read 

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

func (*Integer64Serializer) Write 

func (*Integer64Serializer) 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 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) WriteBytes 

func (o *ObjectDataOutput) WriteBytes(v string)

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

func (o *ObjectDataOutput) WriteString(v string)

func (*ObjectDataOutput) WriteStringArray 

func (o *ObjectDataOutput) WriteStringArray(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) (
	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(serializationConfig *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. It can safely be called on an object that is already deserialized. In that case, that instance is returned. If this is called with nil, nil is returned.

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 UInteger16ArraySerializer 

type UInteger16ArraySerializer struct{}

func (*UInteger16ArraySerializer) ID 

func (*UInteger16ArraySerializer) ID() int32

func (*UInteger16ArraySerializer) Read 

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

func (*UInteger16ArraySerializer) Write 

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

type UInteger16Serializer 

type UInteger16Serializer struct{}

func (*UInteger16Serializer) ID 

func (*UInteger16Serializer) ID() int32

func (*UInteger16Serializer) Read 

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

func (*UInteger16Serializer) Write 

func (*UInteger16Serializer) 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.