memtimeoutstore

package
v0.4.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 30, 2023 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.Timeout, error)

func (*Store) ListValid

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL