Documentation ¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func (*Store) SetSnapshotOffset ¶
func (*Store) SnapshotOffset ¶
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
Click to show internal directories.
Click to hide internal directories.