state_store

Documentation

Index

• type Options
  • func NewOptions() *Options
• type PipelineState
  • func NewPipelineState(ss *StateStore, pipelineID uint64) *PipelineState
  • func (ps *PipelineState) Flush() error
  • func (ps *PipelineState) GetLastSequence() uint64
  • func (ps *PipelineState) Initialize() error
  • func (ps *PipelineState) UpdateLastSequence(lastSeq uint64) error
• type StateStore
  • func NewStateStore(options *Options) *StateStore
  • func NewStateStoreWithStore(gravityStore *store.Store, options *Options) *StateStore
  • func (ss *StateStore) GetPipelineState(pipelineID uint64) (gravity_subscriber.PipelineState, error)
  • func (ss *StateStore) GetPipelines() []uint64
  • func (ss *StateStore) Initialize() error

Types

type Options

type Options struct {
	Core *store.Options
	Name string
}

func NewOptions

func NewOptions() *Options

type PipelineState

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

func NewPipelineState

func NewPipelineState(ss *StateStore, pipelineID uint64) *PipelineState

func (*PipelineState) Flush

func (ps *PipelineState) Flush() error

func (*PipelineState) GetLastSequence

func (ps *PipelineState) GetLastSequence() uint64

func (*PipelineState) Initialize

func (ps *PipelineState) Initialize() error

func (*PipelineState) UpdateLastSequence

func (ps *PipelineState) UpdateLastSequence(lastSeq uint64) error

type StateStore

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

func NewStateStore

func NewStateStore(options *Options) *StateStore

func NewStateStoreWithStore

func NewStateStoreWithStore(gravityStore *store.Store, options *Options) *StateStore

func (*StateStore) GetPipelineState

func (ss *StateStore) GetPipelineState(pipelineID uint64) (gravity_subscriber.PipelineState, error)

func (*StateStore) GetPipelines

func (ss *StateStore) GetPipelines() []uint64

func (*StateStore) Initialize

func (ss *StateStore) Initialize() error