statestorage

Oct 1, 2023

Changes in this version

type Offset

+ SnapshotDone bool

+ SnapshotKeyset []byte

Jul 30, 2023

Changes in this version

+ type Manager interface

+ EncodedState func(name string) (encodedState []byte, present bool)

+ Get func() (map[string]*Offset, error)

+ Set func(key string, value *Offset) error

+ SetEncodedState func(name string, encodedState []byte)

+ SnapshotContext func() (*watermark.SnapshotContext, error)

+ SnapshotContextTransaction func(snapshotName string, createIfNotExists bool, ...) error

+ Start func() error

+ StateDecoder func(name string, decoder encoding.BinaryUnmarshaler) (present bool, err error)

+ StateEncoder func(name string, encoder encoding.BinaryMarshaler) error

+ Stop func() error

+ func NewStateStorageManager(stateStorage Storage) Manager

+ type StorageProvider = func(config *config.Config) (Storage, error)

Jul 22, 2023

Changes in this version

type Storage

+ func NewDummyStateStorage() Storage

+ func NewFileStateStorage(path string) (Storage, error)

Jun 30, 2023

Changes in this version

+ func RegisterStateStorage(name config.StateStorageType, provider Provider) bool

+ type Offset struct

+ LSN pgtypes.LSN

+ Snapshot bool

+ SnapshotName *string

+ SnapshotOffset int

+ Timestamp time.Time

+ func (o *Offset) Equal(other *Offset) bool

+ func (o *Offset) MarshalBinary() ([]byte, error)

+ func (o *Offset) UnmarshalBinary(data []byte) error

+ type Provider = func(config *config.Config) (Storage, error)

+ type StateEncoderFunc func() (data []byte, err error)

+ func (sef StateEncoderFunc) MarshalBinary() (data []byte, err error)

+ type Storage interface

+ EncodedState func(name string) (encodedState []byte, present bool)

+ Get func() (map[string]*Offset, error)

+ Load func() error

+ Save func() error

+ Set func(key string, value *Offset) error

+ SetEncodedState func(name string, encodedState []byte)

+ Start func() error

+ StateDecoder func(name string, decoder encoding.BinaryUnmarshaler) (present bool, err error)

+ StateEncoder func(name string, encoder encoding.BinaryMarshaler) error

+ Stop func() error

+ func NewStateStorage(name config.StateStorageType, config *config.Config) (Storage, error)