internal

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

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 NewData 

func NewData(payload []byte) serialization.Data

NewData return serialization Data with the given payload.

func TypeByID 

func TypeByID(fieldType int32) string

Types

type BoolArraySerializer 

type BoolArraySerializer struct{}

func (*BoolArraySerializer) ID 

func (*BoolArraySerializer) ID() int32

func (*BoolArraySerializer) Read 

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

func (*BoolArraySerializer) Write 

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

type BoolSerializer 

type BoolSerializer struct{}

func (*BoolSerializer) ID 

func (*BoolSerializer) ID() int32

func (*BoolSerializer) Read 

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

func (*BoolSerializer) Write 

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

type ByteArraySerializer 

type ByteArraySerializer struct{}

func (*ByteArraySerializer) ID 

func (*ByteArraySerializer) ID() int32

func (*ByteArraySerializer) Read 

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

func (*ByteArraySerializer) Write 

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

type ByteSerializer 

type ByteSerializer struct{}

func (*ByteSerializer) ID 

func (*ByteSerializer) ID() int32

func (*ByteSerializer) Read 

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

func (*ByteSerializer) Write 

func (*ByteSerializer) Write(output serialization.DataOutput, i interface{}) 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) error

func (*ClassDefinitionWriter) WritePortable 

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

func (*ClassDefinitionWriter) WritePortableArray 

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

func (*ClassDefinitionWriter) WriteUInt16 

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

func (*ClassDefinitionWriter) WriteUInt16Array 

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

func (*ClassDefinitionWriter) WriteUTF 

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

func (*ClassDefinitionWriter) WriteUTFArray 

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

type Data 

type Data struct {
	Payload []byte
}

func (*Data) Buffer 

func (d *Data) Buffer() []byte

func (*Data) DataSize 

func (d *Data) DataSize() int

func (*Data) GetPartitionHash 

func (d *Data) GetPartitionHash() int32

func (*Data) GetType 

func (d *Data) GetType() int32

func (*Data) TotalSize 

func (d *Data) TotalSize() int

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

func (pr *DefaultPortableReader) Error() error

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

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

func (*DefaultPortableReader) ReadUInt16Array 

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

func (*DefaultPortableReader) ReadUTF 

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

func (*DefaultPortableReader) ReadUTFArray 

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

type DefaultPortableWriter 

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

func NewDefaultPortableWriter 

func NewDefaultPortableWriter(serializer *PortableSerializer, output serialization.PositionalDataOutput,
	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) error

func (*DefaultPortableWriter) WritePortable 

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

func (*DefaultPortableWriter) WritePortableArray 

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

func (*DefaultPortableWriter) WriteUInt16 

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

func (*DefaultPortableWriter) WriteUInt16Array 

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

func (*DefaultPortableWriter) WriteUTF 

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

func (*DefaultPortableWriter) WriteUTFArray 

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

type Float32ArraySerializer 

type Float32ArraySerializer struct{}

func (*Float32ArraySerializer) ID 

func (*Float32ArraySerializer) ID() int32

func (*Float32ArraySerializer) Read 

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

func (*Float32ArraySerializer) Write 

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

type Float32Serializer 

type Float32Serializer struct{}

func (*Float32Serializer) ID 

func (*Float32Serializer) ID() int32

func (*Float32Serializer) Read 

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

func (*Float32Serializer) Write 

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

type Float64ArraySerializer 

type Float64ArraySerializer struct{}

func (*Float64ArraySerializer) ID 

func (*Float64ArraySerializer) ID() int32

func (*Float64ArraySerializer) Read 

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

func (*Float64ArraySerializer) Write 

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

type Float64Serializer 

type Float64Serializer struct{}

func (*Float64Serializer) ID 

func (*Float64Serializer) ID() int32

func (*Float64Serializer) Read 

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

func (*Float64Serializer) Write 

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

type GobSerializer 

type GobSerializer struct{}

func (*GobSerializer) ID 

func (*GobSerializer) ID() int32

func (*GobSerializer) Read 

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

func (*GobSerializer) Write 

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

type HazelcastJSONSerializer 

type HazelcastJSONSerializer struct{}

func (*HazelcastJSONSerializer) ID 

func (*HazelcastJSONSerializer) ID() (id int32)

func (*HazelcastJSONSerializer) Read 

func (*HazelcastJSONSerializer) Read(input serialization.DataInput) (object interface{}, err error)

func (*HazelcastJSONSerializer) Write 

func (*HazelcastJSONSerializer) Write(output serialization.DataOutput, object interface{}) (err error)

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{}, error)

func (*IdentifiedDataSerializableSerializer) Write 

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

type Integer16ArraySerializer 

type Integer16ArraySerializer struct{}

func (*Integer16ArraySerializer) ID 

func (*Integer16ArraySerializer) ID() int32

func (*Integer16ArraySerializer) Read 

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

func (*Integer16ArraySerializer) Write 

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

type Integer16Serializer 

type Integer16Serializer struct{}

func (*Integer16Serializer) ID 

func (*Integer16Serializer) ID() int32

func (*Integer16Serializer) Read 

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

func (*Integer16Serializer) Write 

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

type Integer32ArraySerializer 

type Integer32ArraySerializer struct{}

func (*Integer32ArraySerializer) ID 

func (*Integer32ArraySerializer) ID() int32

func (*Integer32ArraySerializer) Read 

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

func (*Integer32ArraySerializer) Write 

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

type Integer32Serializer 

type Integer32Serializer struct{}

func (*Integer32Serializer) ID 

func (*Integer32Serializer) ID() int32

func (*Integer32Serializer) Read 

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

func (*Integer32Serializer) Write 

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

type Integer64ArraySerializer 

type Integer64ArraySerializer struct{}

func (*Integer64ArraySerializer) ID 

func (*Integer64ArraySerializer) ID() int32

func (*Integer64ArraySerializer) Read 

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

func (*Integer64ArraySerializer) Write 

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

type Integer64Serializer 

type Integer64Serializer struct{}

func (*Integer64Serializer) ID 

func (*Integer64Serializer) ID() int32

func (*Integer64Serializer) Read 

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

func (*Integer64Serializer) Write 

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

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

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

func (*MorphingPortableReader) ReadUInt16Array 

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

func (*MorphingPortableReader) ReadUTF 

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

func (*MorphingPortableReader) ReadUTFArray 

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

type NilSerializer 

type NilSerializer struct{}

func (*NilSerializer) ID 

func (*NilSerializer) ID() int32

func (*NilSerializer) Read 

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

func (*NilSerializer) Write 

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

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

func (*ObjectDataInput) Available 

func (i *ObjectDataInput) Available() int32

func (*ObjectDataInput) Error 

func (i *ObjectDataInput) Error() error

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

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

func (*ObjectDataInput) ReadBoolWithPosition 

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

func (*ObjectDataInput) ReadByte 

func (i *ObjectDataInput) ReadByte() byte

func (*ObjectDataInput) ReadByteArray 

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

func (*ObjectDataInput) ReadByteArrayWithPosition 

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

func (*ObjectDataInput) ReadByteWithPosition 

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

func (*ObjectDataInput) ReadData 

func (i *ObjectDataInput) ReadData() serialization.Data

func (*ObjectDataInput) ReadFloat32 

func (i *ObjectDataInput) ReadFloat32() float32

func (*ObjectDataInput) ReadFloat32Array 

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

func (*ObjectDataInput) ReadFloat32ArrayWithPosition 

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

func (*ObjectDataInput) ReadFloat32WithPosition 

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

func (*ObjectDataInput) ReadFloat64 

func (i *ObjectDataInput) ReadFloat64() float64

func (*ObjectDataInput) ReadFloat64Array 

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

func (*ObjectDataInput) ReadFloat64ArrayWithPosition 

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

func (*ObjectDataInput) ReadFloat64WithPosition 

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

func (*ObjectDataInput) ReadInt16 

func (i *ObjectDataInput) ReadInt16() int16

func (*ObjectDataInput) ReadInt16Array 

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

func (*ObjectDataInput) ReadInt16ArrayWithPosition 

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

func (*ObjectDataInput) ReadInt16WithPosition 

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

func (*ObjectDataInput) ReadInt32 

func (i *ObjectDataInput) ReadInt32() int32

func (*ObjectDataInput) ReadInt32Array 

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

func (*ObjectDataInput) ReadInt32ArrayWithPosition 

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

func (*ObjectDataInput) ReadInt32WithPosition 

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

func (*ObjectDataInput) ReadInt64 

func (i *ObjectDataInput) ReadInt64() int64

func (*ObjectDataInput) ReadInt64Array 

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

func (*ObjectDataInput) ReadInt64ArrayWithPosition 

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

func (*ObjectDataInput) ReadInt64WithPosition 

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

func (*ObjectDataInput) ReadObject 

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

func (*ObjectDataInput) ReadUInt16 

func (i *ObjectDataInput) ReadUInt16() uint16

func (*ObjectDataInput) ReadUInt16Array 

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

func (*ObjectDataInput) ReadUInt16ArrayWithPosition 

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

func (*ObjectDataInput) ReadUInt16WithPosition 

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

func (*ObjectDataInput) ReadUTF 

func (i *ObjectDataInput) ReadUTF() string

func (*ObjectDataInput) ReadUTFArray 

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

func (*ObjectDataInput) ReadUTFArrayWithPosition 

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

func (*ObjectDataInput) ReadUTFWithPosition 

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

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

func (o *ObjectDataOutput) WriteData(data serialization.Data)

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{}) error

func (*ObjectDataOutput) WriteUInt16 

func (o *ObjectDataOutput) WriteUInt16(v uint16)

func (*ObjectDataOutput) WriteUInt16Array 

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

func (*ObjectDataOutput) WriteUTF 

func (o *ObjectDataOutput) WriteUTF(v string)

func (*ObjectDataOutput) WriteUTFArray 

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

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, error)

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, portableFactories map[int32]serialization.PortableFactory,
	portableVersion int32) *PortableSerializer

func (*PortableSerializer) ID 

func (ps *PortableSerializer) ID() int32

func (*PortableSerializer) Read 

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

func (*PortableSerializer) ReadObject 

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

func (*PortableSerializer) Write 

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

func (*PortableSerializer) WriteObject 

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

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 {
	// 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 *serialization.Config) (*Service, error)

func (*Service) FindSerializerFor 

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

func (*Service) ReadObject 

func (s *Service) ReadObject(input serialization.DataInput) (interface{}, error)

func (*Service) ToData 

func (s *Service) ToData(object interface{}) (serialization.Data, 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 serialization.Data) (interface{}, 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 serialization.DataOutput, object interface{}) error

type StringArraySerializer 

type StringArraySerializer struct{}

func (*StringArraySerializer) ID 

func (*StringArraySerializer) ID() int32

func (*StringArraySerializer) Read 

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

func (*StringArraySerializer) Write 

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

type StringSerializer 

type StringSerializer struct{}

func (*StringSerializer) ID 

func (*StringSerializer) ID() int32

func (*StringSerializer) Read 

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

func (*StringSerializer) Write 

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

type UInteger16ArraySerializer 

type UInteger16ArraySerializer struct{}

func (*UInteger16ArraySerializer) ID 

func (*UInteger16ArraySerializer) ID() int32

func (*UInteger16ArraySerializer) Read 

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

func (*UInteger16ArraySerializer) Write 

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

type UInteger16Serializer 

type UInteger16Serializer struct{}

func (*UInteger16Serializer) ID 

func (*UInteger16Serializer) ID() int32

func (*UInteger16Serializer) Read 

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

func (*UInteger16Serializer) Write 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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