serde

package
v0.0.142 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2024 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetSerdeType 

func GetSerdeType[T any]() reflect.Type

func IsTypePtr 

func IsTypePtr[T any]() bool

Types

type ArraySerde 

type ArraySerde[T any] struct {
	// contains filtered or unexported fields
}

func MakeTypedArraySerde 

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

func (*ArraySerde[T]) Deserialize 

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

func (*ArraySerde) DeserializeObj 

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

func (*ArraySerde) IsStubSerde added in v0.0.140 

func (s *ArraySerde) IsStubSerde() bool

func (*ArraySerde[T]) Serialize 

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

func (*ArraySerde) SerializeObj 

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

type BaseType added in v0.0.138 

type BaseType interface {
	int32 | int64 | int16 | uint32 | uint64 | uint16 | float32 | float64 | bool
}

type BoolSerde 

type BoolSerde struct {
}

func (*BoolSerde) Deserialize 

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

func (*BoolSerde) DeserializeObj 

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

func (*BoolSerde) IsStubSerde added in v0.0.140 

func (s *BoolSerde) IsStubSerde() bool

func (*BoolSerde) Serialize 

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

func (*BoolSerde) SerializeObj 

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

type BytesSerde added in v0.0.138 

type BytesSerde struct {
}

func (*BytesSerde) Deserialize added in v0.0.138 

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

func (*BytesSerde) DeserializeObj added in v0.0.138 

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

func (*BytesSerde) IsStubSerde added in v0.0.140 

func (s *BytesSerde) IsStubSerde() bool

func (*BytesSerde) Serialize added in v0.0.138 

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

func (*BytesSerde) SerializeObj added in v0.0.138 

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

type FixedSizeTypeArraySerde added in v0.0.141 

type FixedSizeTypeArraySerde[T BaseType] struct {
}

func (*FixedSizeTypeArraySerde[T]) Deserialize added in v0.0.141 

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

func (*FixedSizeTypeArraySerde[T]) DeserializeObj added in v0.0.141 

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

func (*FixedSizeTypeArraySerde[T]) IsStubSerde added in v0.0.141 

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

func (*FixedSizeTypeArraySerde[T]) Serialize added in v0.0.141 

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

func (*FixedSizeTypeArraySerde[T]) SerializeObj added in v0.0.141 

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

type Float32Serde 

type Float32Serde struct {
}

func (*Float32Serde) Deserialize 

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

func (*Float32Serde) DeserializeObj 

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

func (*Float32Serde) IsStubSerde added in v0.0.140 

func (s *Float32Serde) IsStubSerde() bool

func (*Float32Serde) Serialize 

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

func (*Float32Serde) SerializeObj 

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

type Float64Serde 

type Float64Serde struct {
}

func (*Float64Serde) Deserialize 

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

func (*Float64Serde) DeserializeObj 

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

func (*Float64Serde) IsStubSerde added in v0.0.140 

func (s *Float64Serde) IsStubSerde() bool

func (*Float64Serde) Serialize 

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

func (*Float64Serde) SerializeObj 

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

type Int16Serde 

type Int16Serde struct {
}

func (*Int16Serde) Deserialize 

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

func (*Int16Serde) DeserializeObj 

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

func (*Int16Serde) IsStubSerde added in v0.0.140 

func (s *Int16Serde) IsStubSerde() bool

func (*Int16Serde) Serialize 

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

func (*Int16Serde) SerializeObj 

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

type Int32Serde 

type Int32Serde struct {
}

func (*Int32Serde) Deserialize 

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

func (*Int32Serde) DeserializeObj 

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

func (*Int32Serde) IsStubSerde added in v0.0.140 

func (s *Int32Serde) IsStubSerde() bool

func (*Int32Serde) Serialize 

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

func (*Int32Serde) SerializeObj 

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

type Int64Serde 

type Int64Serde struct {
}

func (*Int64Serde) Deserialize 

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

func (*Int64Serde) DeserializeObj 

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

func (*Int64Serde) IsStubSerde added in v0.0.140 

func (s *Int64Serde) IsStubSerde() bool

func (*Int64Serde) Serialize 

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

func (*Int64Serde) SerializeObj 

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

type Int8Serde 

type Int8Serde struct {
}

func (*Int8Serde) Deserialize 

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

func (*Int8Serde) DeserializeObj 

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

func (*Int8Serde) IsStubSerde added in v0.0.140 

func (s *Int8Serde) IsStubSerde() bool

func (*Int8Serde) Serialize 

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

func (*Int8Serde) SerializeObj 

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

type IntArraySerde added in v0.0.141 

type IntArraySerde struct {
}

func (*IntArraySerde) Deserialize added in v0.0.141 

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

func (*IntArraySerde) DeserializeObj added in v0.0.141 

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

func (*IntArraySerde) IsStubSerde added in v0.0.141 

func (s *IntArraySerde) IsStubSerde() bool

func (*IntArraySerde) Serialize added in v0.0.141 

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

func (*IntArraySerde) SerializeObj added in v0.0.141 

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

type IntSerde 

type IntSerde struct {
}

func (*IntSerde) Deserialize 

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

func (*IntSerde) DeserializeObj 

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

func (*IntSerde) IsStubSerde added in v0.0.140 

func (s *IntSerde) IsStubSerde() bool

func (*IntSerde) Serialize 

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

func (*IntSerde) SerializeObj 

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

type MapSerde 

type MapSerde[T any] struct {
	// contains filtered or unexported fields
}

func (*MapSerde[T]) Deserialize 

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

func (*MapSerde) DeserializeObj 

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

func (*MapSerde) IsStubSerde added in v0.0.140 

func (s *MapSerde) IsStubSerde() bool

func (*MapSerde[T]) Serialize 

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

func (*MapSerde) SerializeObj 

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

type RuneSerde 

type RuneSerde struct {
}

func (*RuneSerde) Deserialize 

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

func (*RuneSerde) DeserializeObj 

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

func (*RuneSerde) IsStubSerde added in v0.0.140 

func (s *RuneSerde) IsStubSerde() bool

func (*RuneSerde) Serialize 

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

func (*RuneSerde) SerializeObj 

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

type Serde 

type Serde[T any] interface {
	Serializer
	Serialize(T, []byte) ([]byte, error)
	Deserialize([]byte) (T, error)
}

func MakeTypedMapSerde 

func MakeTypedMapSerde[T any](keyArraySerde Serializer, valueArraySerde Serializer) Serde[T]

type Serializer 

type Serializer interface {
	SerializeObj(interface{}, []byte) ([]byte, error)
	DeserializeObj([]byte) (interface{}, error)
	IsStubSerde() bool
}

func MakeArraySerde 

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

func MakeDefaultSerde 

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

func MakeMapSerde 

func MakeMapSerde(mapType reflect.Type,
	keyArraySerde Serializer,
	valueArraySerde Serializer) Serializer

type StreamKeyValueSerde 

type StreamKeyValueSerde[T any] interface {
	StreamSerde[T]
	SerializeKey(T) ([]byte, error)
	SerializeValue(T) ([]byte, error)
	KeySerializer() Serializer
	DeserializeKeyValue([]byte, []byte) (T, error)
}

func MakeStreamKeyValueSerde 

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

type StreamSerde 

type StreamSerde[T any] interface {
	StreamSerializer
	ValueSerializer() Serializer
	Serialize(T) ([]byte, error)
	Deserialize([]byte) (T, error)
}

func MakeStreamSerde 

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

type StreamSerializer 

type StreamSerializer interface {
	IsKeyValue() bool
}

type StringSerde 

type StringSerde struct {
}

func (*StringSerde) Deserialize 

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

func (*StringSerde) DeserializeObj 

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

func (*StringSerde) IsStubSerde added in v0.0.140 

func (s *StringSerde) IsStubSerde() bool

func (*StringSerde) Serialize 

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

func (*StringSerde) SerializeObj 

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

type StubSerde added in v0.0.138 

type StubSerde[T any] struct {
}

func MakeStubSerde 

func MakeStubSerde[T any]() *StubSerde[T]

func (*StubSerde[T]) Deserialize added in v0.0.138 

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

func (*StubSerde[T]) DeserializeObj added in v0.0.138 

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

func (*StubSerde[T]) IsStubSerde added in v0.0.140 

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

func (*StubSerde[T]) Serialize added in v0.0.138 

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

func (*StubSerde[T]) SerializeObj added in v0.0.138 

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

type UInt16Serde 

type UInt16Serde struct {
}

func (*UInt16Serde) Deserialize 

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

func (*UInt16Serde) DeserializeObj 

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

func (*UInt16Serde) IsStubSerde added in v0.0.140 

func (s *UInt16Serde) IsStubSerde() bool

func (*UInt16Serde) Serialize 

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

func (*UInt16Serde) SerializeObj 

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

type UInt32Serde 

type UInt32Serde struct {
}

func (*UInt32Serde) Deserialize 

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

func (*UInt32Serde) DeserializeObj 

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

func (*UInt32Serde) IsStubSerde added in v0.0.140 

func (s *UInt32Serde) IsStubSerde() bool

func (*UInt32Serde) Serialize 

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

func (*UInt32Serde) SerializeObj 

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

type UInt64Serde 

type UInt64Serde struct {
}

func (*UInt64Serde) Deserialize 

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

func (*UInt64Serde) DeserializeObj 

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

func (*UInt64Serde) IsStubSerde added in v0.0.140 

func (s *UInt64Serde) IsStubSerde() bool

func (*UInt64Serde) Serialize 

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

func (*UInt64Serde) SerializeObj 

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

type UInt8Serde 

type UInt8Serde struct {
}

func (*UInt8Serde) Deserialize 

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

func (*UInt8Serde) DeserializeObj 

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

func (*UInt8Serde) IsStubSerde added in v0.0.140 

func (s *UInt8Serde) IsStubSerde() bool

func (*UInt8Serde) Serialize 

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

func (*UInt8Serde) SerializeObj 

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

type UIntArraySerde added in v0.0.141 

type UIntArraySerde struct {
}

func (*UIntArraySerde) Deserialize added in v0.0.141 

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

func (*UIntArraySerde) DeserializeObj added in v0.0.141 

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

func (*UIntArraySerde) IsStubSerde added in v0.0.141 

func (s *UIntArraySerde) IsStubSerde() bool

func (*UIntArraySerde) Serialize added in v0.0.141 

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

func (*UIntArraySerde) SerializeObj added in v0.0.141 

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

type UIntSerde 

type UIntSerde struct {
}

func (*UIntSerde) Deserialize 

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

func (*UIntSerde) DeserializeObj 

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

func (*UIntSerde) IsStubSerde added in v0.0.140 

func (s *UIntSerde) IsStubSerde() bool

func (*UIntSerde) Serialize 

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

func (*UIntSerde) SerializeObj 

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

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.