codec

type Bytes ¶ added in v0.0.3

type Bytes struct{}

func (Bytes) Decode(b []byte) ([]byte, error)

func (Bytes) Encode(b []byte) ([]byte, error)

type CBOR ¶ added in v0.0.3

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

func MustCBOR[V any](deterministic bool) CBOR[V]

func NewCBOR[V any](deterministic bool) (CBOR[V], error)

func (c CBOR[V]) Decode(b []byte) (V, error)

func (c CBOR[V]) Encode(v V) ([]byte, error)

type Codec ¶

type Codec[V any] interface {
	Encode(V) ([]byte, error)
	Decode([]byte) (V, error)
}

Codec encodes/decodes values V to []byte for storage.

type JSON ¶ added in v0.0.3

type JSON[V any] struct{}

func (JSON[V]) Decode(b []byte) (V, error)

func (JSON[V]) Encode(v V) ([]byte, error)

type LimitCodec ¶

type LimitCodec[V any] struct {
	Inner interface {
		Encode(V) ([]byte, error)
		Decode([]byte) (V, error)
	}
	MaxDecode int // bytes
}

func (c LimitCodec[V]) Decode(b []byte) (V, error)

func (c LimitCodec[V]) Encode(v V) ([]byte, error)

type Msgpack ¶ added in v0.0.3

type Msgpack[V any] struct{}

func (Msgpack[V]) Decode(b []byte) (V, error)

func (Msgpack[V]) Encode(v V) ([]byte, error)

type Protobuf ¶ added in v0.0.3

type Protobuf[T proto.Message] struct {
	// contains filtered or unexported fields
}

func NewProtobuf[T proto.Message](ctor func() T) Protobuf[T]

func (c Protobuf[T]) Decode(b []byte) (T, error)

func (c Protobuf[T]) Encode(v T) ([]byte, error)

type String ¶ added in v0.0.3

type String struct{}

For string payloads

func (String) Decode(b []byte) (string, error)

func (String) Encode(s string) ([]byte, error)