serde

Oct 21, 2024

Changes in this version

+ func GetSerdeTypeName[T any]() string

+ func GetSerdeTypeWithoutPtr[T any]() reflect.Type

type ArraySerde

+ func (s *ArraySerde) IsStub() bool

type BoolSerde

+ func (s *BoolSerde) IsStub() bool

type BytesSerde

+ func (s *BytesSerde) IsStub() bool

type FixedSizeTypeArraySerde

+ func (s *FixedSizeTypeArraySerde[T]) IsStub() bool

type Float32Serde

+ func (s *Float32Serde) IsStub() bool

type Float64Serde

+ func (s *Float64Serde) IsStub() bool

type Int16Serde

+ func (s *Int16Serde) IsStub() bool

type Int32Serde

+ func (s *Int32Serde) IsStub() bool

type Int64Serde

+ func (s *Int64Serde) IsStub() bool

type Int8Serde

+ func (s *Int8Serde) IsStub() bool

type IntArraySerde

+ func (s *IntArraySerde) IsStub() bool

type IntSerde

+ func (s *IntSerde) IsStub() bool

type MapSerde

+ func (s *MapSerde) IsStub() bool

type RuneSerde

+ func (s *RuneSerde) IsStub() bool

type Serializer

+ IsStub func() bool

type StringSerde

+ func (s *StringSerde) IsStub() bool

type StubSerde

+ func (s *StubSerde[T]) IsStub() bool

type UInt16Serde

+ func (s *UInt16Serde) IsStub() bool

type UInt32Serde

+ func (s *UInt32Serde) IsStub() bool

type UInt64Serde

+ func (s *UInt64Serde) IsStub() bool

type UInt8Serde

+ func (s *UInt8Serde) IsStub() bool

type UIntArraySerde

+ func (s *UIntArraySerde) IsStub() bool

type UIntSerde

+ func (s *UIntSerde) IsStub() bool

Oct 15, 2024

Changes in this version

+ type FixedSizeTypeArraySerde struct

+ func (s *FixedSizeTypeArraySerde[T]) Deserialize(data []byte) ([]T, error)

+ func (s *FixedSizeTypeArraySerde[T]) DeserializeObj(data []byte) (interface{}, error)

+ func (s *FixedSizeTypeArraySerde[T]) IsStubSerde() bool

+ func (s *FixedSizeTypeArraySerde[T]) Serialize(value []T, b []byte) ([]byte, error)

+ func (s *FixedSizeTypeArraySerde[T]) SerializeObj(value interface{}, b []byte) ([]byte, error)

+ type IntArraySerde struct

+ func (s *IntArraySerde) Deserialize(data []byte) ([]int, error)

+ func (s *IntArraySerde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *IntArraySerde) IsStubSerde() bool

+ func (s *IntArraySerde) Serialize(value []int, b []byte) ([]byte, error)

+ func (s *IntArraySerde) SerializeObj(value interface{}, b []byte) ([]byte, error)

+ type UIntArraySerde struct

+ func (s *UIntArraySerde) Deserialize(data []byte) ([]uint, error)

+ func (s *UIntArraySerde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *UIntArraySerde) IsStubSerde() bool

+ func (s *UIntArraySerde) Serialize(value []uint, b []byte) ([]byte, error)

+ func (s *UIntArraySerde) SerializeObj(value interface{}, b []byte) ([]byte, error)

Oct 12, 2024

Changes in this version

type ArraySerde

+ func (s *ArraySerde) IsStubSerde() bool

type BaseTypeArraySerde

+ func (s *BaseTypeArraySerde[T]) IsStubSerde() bool

type BoolSerde

+ func (s *BoolSerde) IsStubSerde() bool

type BytesSerde

+ func (s *BytesSerde) IsStubSerde() bool

type Float32Serde

+ func (s *Float32Serde) IsStubSerde() bool

type Float64Serde

+ func (s *Float64Serde) IsStubSerde() bool

type Int16Serde

+ func (s *Int16Serde) IsStubSerde() bool

type Int32Serde

+ func (s *Int32Serde) IsStubSerde() bool

type Int64Serde

+ func (s *Int64Serde) IsStubSerde() bool

type Int8Serde

+ func (s *Int8Serde) IsStubSerde() bool

type IntSerde

+ func (s *IntSerde) IsStubSerde() bool

type MapSerde

+ func (s *MapSerde) IsStubSerde() bool

type RuneSerde

+ func (s *RuneSerde) IsStubSerde() bool

type Serializer

+ IsStubSerde func() bool

type StreamSerde

+ ValueSerializer func() Serializer

type StringSerde

+ func (s *StringSerde) IsStubSerde() bool

type StubSerde

+ func (s *StubSerde[T]) IsStubSerde() bool

type UInt16Serde

+ func (s *UInt16Serde) IsStubSerde() bool

type UInt32Serde

+ func (s *UInt32Serde) IsStubSerde() bool

type UInt64Serde

+ func (s *UInt64Serde) IsStubSerde() bool

type UInt8Serde

+ func (s *UInt8Serde) IsStubSerde() bool

type UIntSerde

+ func (s *UIntSerde) IsStubSerde() bool

Oct 11, 2024

Changes in this version

+ type BaseType interface

+ type BaseTypeArraySerde struct

+ func (s *BaseTypeArraySerde[T]) Deserialize(data []byte) ([]T, error)

+ func (s *BaseTypeArraySerde[T]) DeserializeObj(data []byte) (interface{}, error)

+ func (s *BaseTypeArraySerde[T]) Serialize(value []T) ([]byte, error)

+ func (s *BaseTypeArraySerde[T]) SerializeObj(value interface{}) ([]byte, error)

+ type BytesSerde struct

+ func (s *BytesSerde) Deserialize(data []byte) ([]byte, error)

+ func (s *BytesSerde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *BytesSerde) Serialize(value []byte) ([]byte, error)

+ func (s *BytesSerde) SerializeObj(value interface{}) ([]byte, error)

+ type StubSerde struct

+ func (s *StubSerde[T]) Deserialize([]byte) (T, error)

+ func (s *StubSerde[T]) DeserializeObj(data []byte) (interface{}, error)

+ func (s *StubSerde[T]) Serialize(T) ([]byte, error)

+ func (s *StubSerde[T]) SerializeObj(value interface{}) ([]byte, error)

Sep 1, 2024

Changes in this version

+ func GetSerdeType[T any]() reflect.Type

+ func IsTypePtr[T any]() bool

+ type ArraySerde struct

+ func MakeTypedArraySerde[T any](valueSerde Serializer) *ArraySerde[T]

+ func (s *ArraySerde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *ArraySerde) SerializeObj(value interface{}) ([]byte, error)

+ func (s *ArraySerde[T]) Deserialize(data []byte) (T, error)

+ func (s *ArraySerde[T]) Serialize(value T) ([]byte, error)

+ type BoolSerde struct

+ func (s *BoolSerde) Deserialize(data []byte) (bool, error)

+ func (s *BoolSerde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *BoolSerde) Serialize(value bool) ([]byte, error)

+ func (s *BoolSerde) SerializeObj(value interface{}) ([]byte, error)

+ type Float32Serde struct

+ func (s *Float32Serde) Deserialize(data []byte) (float32, error)

+ func (s *Float32Serde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *Float32Serde) Serialize(value float32) ([]byte, error)

+ func (s *Float32Serde) SerializeObj(value interface{}) ([]byte, error)

+ type Float64Serde struct

+ func (s *Float64Serde) Deserialize(data []byte) (float64, error)

+ func (s *Float64Serde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *Float64Serde) Serialize(value float64) ([]byte, error)

+ func (s *Float64Serde) SerializeObj(value interface{}) ([]byte, error)

+ type Int16Serde struct

+ func (s *Int16Serde) Deserialize(data []byte) (int16, error)

+ func (s *Int16Serde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *Int16Serde) Serialize(value int16) ([]byte, error)

+ func (s *Int16Serde) SerializeObj(value interface{}) ([]byte, error)

+ type Int32Serde struct

+ func (s *Int32Serde) Deserialize(data []byte) (int32, error)

+ func (s *Int32Serde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *Int32Serde) Serialize(value int32) ([]byte, error)

+ func (s *Int32Serde) SerializeObj(value interface{}) ([]byte, error)

+ type Int64Serde struct

+ func (s *Int64Serde) Deserialize(data []byte) (int64, error)

+ func (s *Int64Serde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *Int64Serde) Serialize(value int64) ([]byte, error)

+ func (s *Int64Serde) SerializeObj(value interface{}) ([]byte, error)

+ type Int8Serde struct

+ func (s *Int8Serde) Deserialize(data []byte) (int8, error)

+ func (s *Int8Serde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *Int8Serde) Serialize(value int8) ([]byte, error)

+ func (s *Int8Serde) SerializeObj(value interface{}) ([]byte, error)

+ type IntSerde struct

+ func (s *IntSerde) Deserialize(data []byte) (int, error)

+ func (s *IntSerde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *IntSerde) Serialize(value int) ([]byte, error)

+ func (s *IntSerde) SerializeObj(value interface{}) ([]byte, error)

+ type MapSerde struct

+ func (s *MapSerde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *MapSerde) SerializeObj(value interface{}) ([]byte, error)

+ func (s *MapSerde[T]) Deserialize(data []byte) (T, error)

+ func (s *MapSerde[T]) Serialize(value T) ([]byte, error)

+ type RuneSerde struct

+ func (s *RuneSerde) Deserialize(data []byte) (rune, error)

+ func (s *RuneSerde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *RuneSerde) Serialize(value rune) ([]byte, error)

+ func (s *RuneSerde) SerializeObj(value interface{}) ([]byte, error)

+ type Serde interface

+ Deserialize func([]byte) (T, error)

+ Serialize func(T) ([]byte, error)

+ func MakeTypedMapSerde[T any](keySerde Serializer, valueSerde Serializer) Serde[T]

+ type SerdeStub struct

+ func MakeStubSerde[T any]() *SerdeStub[T]

+ func (s *SerdeStub[T]) Deserialize([]byte) (T, error)

+ func (s *SerdeStub[T]) DeserializeObj(data []byte) (interface{}, error)

+ func (s *SerdeStub[T]) Serialize(T) ([]byte, error)

+ func (s *SerdeStub[T]) SerializeObj(value interface{}) ([]byte, error)

+ type Serializer interface

+ DeserializeObj func([]byte) (interface{}, error)

+ SerializeObj func(interface{}) ([]byte, error)

+ func MakeArraySerde(arrayType reflect.Type, valueSerde Serializer) Serializer

+ func MakeDefaultSerde(valueType reflect.Type) (Serializer, error)

+ func MakeMapSerde(mapType reflect.Type, keySerde Serializer, valueSerde Serializer) Serializer

+ type StreamKeyValueSerde interface

+ DeserializeKeyValue func([]byte, []byte) (T, error)

+ KeySerializer func() Serializer

+ SerializeKey func(T) ([]byte, error)

+ SerializeValue func(T) ([]byte, error)

+ ValueSerializer func() Serializer

+ func MakeStreamKeyValueSerde[K comparable, V any](serdeKey Serde[K], serdeValue Serde[V]) StreamKeyValueSerde[datastruct.KeyValue[K, V]]

+ type StreamSerde interface

+ Deserialize func([]byte) (T, error)

+ Serialize func(T) ([]byte, error)

+ func MakeStreamSerde[T any](serde Serde[T]) StreamSerde[T]

+ type StreamSerializer interface

+ IsKeyValue func() bool

+ type StringSerde struct

+ func (s *StringSerde) Deserialize(data []byte) (string, error)

+ func (s *StringSerde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *StringSerde) Serialize(value string) ([]byte, error)

+ func (s *StringSerde) SerializeObj(value interface{}) ([]byte, error)

+ type UInt16Serde struct

+ func (s *UInt16Serde) Deserialize(data []byte) (uint16, error)

+ func (s *UInt16Serde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *UInt16Serde) Serialize(value uint16) ([]byte, error)

+ func (s *UInt16Serde) SerializeObj(value interface{}) ([]byte, error)

+ type UInt32Serde struct

+ func (s *UInt32Serde) Deserialize(data []byte) (uint32, error)

+ func (s *UInt32Serde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *UInt32Serde) Serialize(value uint32) ([]byte, error)

+ func (s *UInt32Serde) SerializeObj(value interface{}) ([]byte, error)

+ type UInt64Serde struct

+ func (s *UInt64Serde) Deserialize(data []byte) (uint64, error)

+ func (s *UInt64Serde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *UInt64Serde) Serialize(value uint64) ([]byte, error)

+ func (s *UInt64Serde) SerializeObj(value interface{}) ([]byte, error)

+ type UInt8Serde struct

+ func (s *UInt8Serde) Deserialize(data []byte) (uint8, error)

+ func (s *UInt8Serde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *UInt8Serde) Serialize(value uint8) ([]byte, error)

+ func (s *UInt8Serde) SerializeObj(value interface{}) ([]byte, error)

+ type UIntSerde struct

+ func (s *UIntSerde) Deserialize(data []byte) (uint, error)

+ func (s *UIntSerde) DeserializeObj(data []byte) (interface{}, error)

+ func (s *UIntSerde) Serialize(value uint) ([]byte, error)

+ func (s *UIntSerde) SerializeObj(value interface{}) ([]byte, error)