snapshot

Documentation

Index

• Variables
• type Codec
  • func New() *Codec
  • func (s *Codec) Decode(ctx context.Context, streamType string, b []byte) (es.Stream, error)
  • func (s *Codec) Encode(ctx context.Context, stream es.Stream) ([]byte, error)
  • func (s *Codec) EncodeDecodeFunc(streamType string, enc EncodeSnapshotFunc, dec DecodeSnapshotFunc) *Codec
• type DecodeSnapshotFunc
• type EncodeSnapshotFunc
• type Snapshot

Variables

var ErrNoStream = errors.New("no stream type")

Types

type Codec

type Codec struct {
	// contains filtered or unexported fields
}

func New

func New() *Codec

func (*Codec) Decode

func (s *Codec) Decode(ctx context.Context, streamType string, b []byte) (es.Stream, error)

func (*Codec) Encode

func (s *Codec) Encode(ctx context.Context, stream es.Stream) ([]byte, error)

func (*Codec) EncodeDecodeFunc

func (s *Codec) EncodeDecodeFunc(streamType string, enc EncodeSnapshotFunc, dec DecodeSnapshotFunc) *Codec

type DecodeSnapshotFunc

type DecodeSnapshotFunc func(ctx context.Context, b []byte) (s es.Stream, err error)

type EncodeSnapshotFunc

type EncodeSnapshotFunc func(ctx context.Context, s es.Stream) (b []byte, err error)

type Snapshot

type Snapshot struct {
	// contains filtered or unexported fields
}