memrecordstore

Documentation

Index

• type Store
  • func New() *Store
  • func (s *Store) Latest(ctx context.Context, workflowName, foreignID string) (*workflow.WireRecord, error)
  • func (s *Store) Lookup(ctx context.Context, id int64) (*workflow.WireRecord, error)
  • func (s *Store) SetSnapshotOffset(workflowName, foreignID, runID string, offset int)
  • func (s *Store) SnapshotOffset(workflowName, foreignID, runID string) int
  • func (s *Store) Snapshots(workflowName, foreignID, runID string) []*workflow.WireRecord
  • func (s *Store) Store(ctx context.Context, record *workflow.WireRecord, ...) error

Types

type Store

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

func New

func New() *Store

func (*Store) Latest

func (s *Store) Latest(ctx context.Context, workflowName, foreignID string) (*workflow.WireRecord, error)

func (*Store) Lookup

func (s *Store) Lookup(ctx context.Context, id int64) (*workflow.WireRecord, error)

func (*Store) SetSnapshotOffset

func (s *Store) SetSnapshotOffset(workflowName, foreignID, runID string, offset int)

func (*Store) SnapshotOffset

func (s *Store) SnapshotOffset(workflowName, foreignID, runID string) int

func (*Store) Snapshots

func (s *Store) Snapshots(workflowName, foreignID, runID string) []*workflow.WireRecord

func (*Store) Store

func (s *Store) Store(ctx context.Context, record *workflow.WireRecord, emitter workflow.EventEmitter) error