Versions in this module Expand all Collapse all v1 v1.18.0 Jun 12, 2026 Changes in this version + var ErrExists = errors.New("task already exists") + var ErrNotFound = errors.New("task not found") + var ErrStaleVersion = errors.New("task version is stale") + type Record struct + CreatedAt time.Time + Data []byte + FailedAttempts uint32 + Id uint64 + NextAttemptAt time.Time + ReferenceId *string + State State + TaskId string + Type uint32 + Version uint64 + func (r *Record) Clone() Record + func (r *Record) CopyTo(dst *Record) + func (r *Record) Validate() error + type State uint8 + const StateConfirmed + const StateFailed + const StatePending + const StateUnknown + func (s State) String() string + type Store interface + CountByState func(ctx context.Context, state State) (uint64, error) + GetAllReadyByState func(ctx context.Context, state State, asOf time.Time, cursor query.Cursor, ...) ([]*Record, error) + GetByTaskId func(ctx context.Context, taskId string) (*Record, error) + PutAll func(ctx context.Context, records ...*Record) error + Update func(ctx context.Context, record *Record) error
Go to main page