sqltimeout

Documentation

Index

• type Store
  • func New(writer, reader *sql.DB, tableName string) *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)

Types

type Store

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

func New

func New(writer, reader *sql.DB, tableName string) *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)