codec

type ForwardCodec ¶

type ForwardCodec[V any] struct {
}

ForwardCodec is a Codec that returns the same object passed.

func (c ForwardCodec[V]) Decode(ctx context.Context, data any) (V, error)

func (c ForwardCodec[V]) Encode(ctx context.Context, data V) (any, error)

type FuncCodec ¶

type FuncCodec[V any] struct {
	// contains filtered or unexported fields
}

FuncCodec is a Codec that uses the passed functions as its methods.

func (c FuncCodec[V]) Decode(ctx context.Context, data any) (V, error)

func (c FuncCodec[V]) Encode(ctx context.Context, data V) (any, error)

type GOBCodec ¶

type GOBCodec[V any] struct {
	// contains filtered or unexported fields
}

GOBCodec is a Codec that marshals from/to encoding/gob.

func (c GOBCodec[V]) Decode(ctx context.Context, data any) (V, error)

func (c GOBCodec[V]) Encode(ctx context.Context, data V) (any, error)

type GOBCodecOption ¶

type GOBCodecOption func(*gobCodecOptions)

func WithGOBCodecReturnString(returnString bool) GOBCodecOption

type JSONCodec ¶

type JSONCodec[V any] struct {
	// contains filtered or unexported fields
}

JSONCodec is a Codec that marshals from/to JSON.

func (c JSONCodec[V]) Decode(ctx context.Context, data any) (V, error)

func (c JSONCodec[V]) Encode(ctx context.Context, data V) (any, error)

type JSONCodecOption ¶

type JSONCodecOption func(*jsonCodecOptions)

func WithJSONCodecReturnBytes(returnBytes bool) JSONCodecOption

type StringKeyCodec ¶

type StringKeyCodec[K comparable] struct {
}

StringKeyCodec is a key codec that converts all values to string.

func NewStringKeyCodec[K comparable]() *StringKeyCodec[K]

func (s *StringKeyCodec[K]) Convert(ctx context.Context, key K) (any, error)