internal

package
v0.10.0 Latest Latest
Warning

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

Go to latest
Published: Jan 18, 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 (*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) 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) 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 (*IdentifiedDataSerializableSerializer) ID

func (*IdentifiedDataSerializableSerializer) Read

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

func (*IdentifiedDataSerializableSerializer) Write

type Integer16ArraySerializer

type Integer16ArraySerializer struct{}

func (*Integer16ArraySerializer) ID

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

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

func (*UInteger16Serializer) Write

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL