memtimeoutstore

Documentation

Index

• type Option
  • func WithClock(c clock.Clock) Option
• type Store
  • 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.TimeoutRecord, error)
  • func (s *Store) ListValid(ctx context.Context, workflowName string, status int, now time.Time) ([]workflow.TimeoutRecord, error)

Types

type Option

type Option func(s *Store)

func WithClock

func WithClock(c clock.Clock) Option

type Store

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

func New

func New(opts ...Option) *Store

func (*Store) Cancel

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

func (*Store) Complete

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

func (*Store) Create

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

func (*Store) List

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

func (*Store) ListValid

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