memtimeoutstore

Jan 16, 2024

Changes in this version

+ type Option func(s *Store)

+ func WithClock(c clock.Clock) Option

+ type Store struct

+ func New(opts ...Option) *Store

+ func (s *Store) Cancel(ctx context.Context, id int64) error

+ func (s *Store) Complete(ctx context.Context, id int64) error

+ func (s *Store) Create(ctx context.Context, workflowName, foreignID, runID string, status int, ...) error

+ func (s *Store) List(ctx context.Context, workflowName string) ([]workflow.Timeout, error)

+ func (s *Store) ListValid(ctx context.Context, workflowName string, status int, now time.Time) ([]workflow.Timeout, error)