Versions in this module Expand all Collapse all v0 v0.2.0 Dec 1, 2025 v0.1.0 Nov 28, 2025 Changes in this version + var ErrFulfillmentExists = errors.New("fulfillment exists") + var ErrFulfillmentNotFound = errors.New("no fulfillment could be found") + var ErrStaleVersion = errors.New("fulfillment version is stale") + type BySchedulingOrder []*Record + func (a BySchedulingOrder) Len() int + func (a BySchedulingOrder) Less(i, j int) bool + func (a BySchedulingOrder) Swap(i, j int) + type Record struct + ActionId uint32 + ActionOrderingIndex uint32 + ActionType action.Type + Blockhash *string + CreatedAt time.Time + Data []byte + Destination *string + DisableActiveScheduling bool + FulfillmentOrderingIndex uint32 + FulfillmentType Type + Id uint64 + Intent string + IntentOrderingIndex uint64 + IntentType intent.Type + Nonce *string + Signature *string + Source string + State State + Version uint64 + VirtualBlockhash *string + VirtualNonce *string + VirtualSignature *string + func (r *Record) Clone() Record + func (r *Record) CopyTo(dst *Record) + func (r *Record) IsFulfilled() bool + func (r *Record) ScheduledBefore(other *Record) bool + func (r *Record) Validate() error + type State uint8 + const StateConfirmed + const StateFailed + const StatePending + const StateRevoked + const StateUnknown + func (s State) IsTerminal() bool + func (s State) String() string + type Store interface + Count func(ctx context.Context) (uint64, error) + CountByIntent func(ctx context.Context, intent string) (uint64, error) + CountByIntentAndState func(ctx context.Context, intent string, state State) (uint64, error) + CountByState func(ctx context.Context, state State) (uint64, error) + CountByStateAndAddress func(ctx context.Context, state State, address string) (uint64, error) + CountByStateGroupedByType func(ctx context.Context, state State) (map[Type]uint64, error) + CountByTypeActionAndState func(ctx context.Context, intentId string, actionId uint32, fulfillmentType Type, ...) (uint64, error) + CountByTypeStateAndAddress func(ctx context.Context, fulfillmentType Type, state State, address string) (uint64, error) + CountByTypeStateAndAddressAsSource func(ctx context.Context, fulfillmentType Type, state State, address string) (uint64, error) + CountForMetrics func(ctx context.Context, state State) (map[Type]uint64, error) + CountPendingByType func(ctx context.Context) (map[Type]uint64, error) + GetAllByAction func(ctx context.Context, intentId string, actionId uint32) ([]*Record, error) + GetAllByIntent func(ctx context.Context, intent string, cursor query.Cursor, limit uint64, ...) ([]*Record, error) + GetAllByState func(ctx context.Context, state State, includeDisabledActiveScheduling bool, ...) ([]*Record, error) + GetAllByTypeAndAction func(ctx context.Context, fulfillmentType Type, intentId string, actionId uint32) ([]*Record, error) + GetById func(ctx context.Context, id uint64) (*Record, error) + GetBySignature func(ctx context.Context, signature string) (*Record, error) + GetByVirtualSignature func(ctx context.Context, signature string) (*Record, error) + GetFirstSchedulableByAddressAsDestination func(ctx context.Context, address string) (*Record, error) + GetFirstSchedulableByAddressAsSource func(ctx context.Context, address string) (*Record, error) + GetFirstSchedulableByType func(ctx context.Context, fulfillmentType Type) (*Record, error) + GetNextSchedulableByAddress func(ctx context.Context, address string, intentOrderingIndex uint64, ...) (*Record, error) + PutAll func(ctx context.Context, records ...*Record) error + Update func(ctx context.Context, record *Record) error + type Type uint8 + const CloseCommitment + const CloseDormantTimelockAccount + const CloseEmptyTimelockAccount + const InitializeCommitmentProof + const InitializeLockedTimelockAccount + const NoPrivacyTransferWithAuthority + const NoPrivacyWithdraw + const OpenCommitmentVault + const PermanentPrivacyTransferWithAuthority + const SaveRecentRoot + const TemporaryPrivacyTransferWithAuthority + const TransferWithCommitment + const UnknownType + const UploadCommitmentProof + const VerifyCommitmentProof + func (s Type) String() string