Versions in this module Expand all Collapse all v0 v0.1.1 Oct 29, 2026 v0.1.0 Oct 20, 2026 Changes in this version + const CommitQueueWaitReason + const DefaultAttentionAfter + const DefaultRequestTimeout + const MaxSubmittedRequestsPerDataSet + const ProviderRejectedWaitReason + var ErrNotEligible = errors.New("storage commit request cannot be sent yet") + func DataSetRefusesWrites(err error) bool + func ExtraDataNonce(extraData []byte) (sdktypes.BigInt, error) + func MaxPieces(dataSetID idtypes.OnChainID, legacyPieceStorageIDLimit uint64, configured int) int + func NewRequestID() (string, error) + func ShouldSeal(in SealInput) (bool, time.Duration) + type Advancer struct + AttentionAfter time.Duration + Nonces synapse.CommitNonceReader + Now func() time.Time + RequestTimeout time.Duration + func (a *Advancer) Observe(ctx context.Context, c Commit) (observation Observation, observeErr error) + func (a *Advancer) Prepare(ctx context.Context, c Commit) Prepared + func (a *Advancer) Prove(ctx context.Context, c Commit) (Proof, error) + func (a *Advancer) Send(ctx context.Context, c Commit, onSubmitted func(storage.CommitSubmission)) SendResult + type AttentionCode string + const AttentionConfirmationTimeout + const AttentionDataSetUnavailable + const AttentionSubmissionMismatch + func ParseAttentionCode(value string) (AttentionCode, error) + func (c AttentionCode) Valid() bool + type AttentionRecord struct + AttentionAt time.Time + Code AttentionCode + ConfirmedTxHash *string + DataSetID string + DataSetRowID int64 + PieceCIDs []string + ProviderID string + RequestID string + SubmitError string + SubmittedAt time.Time + TaskID *int64 + TxHash *string + type Commit struct + Pieces []cid.Cid + Request Request + Target synapse.DataSetTarget + type Confirmation struct + ConfirmedTxHash string + FirstPieceID sdktypes.BigInt + TxHash string + type Observation struct + Attention AttentionCode + Cause error + Confirmation *Confirmation + Diagnostic error + DropEvidence bool + Kind ObserveKind + type ObserveKind uint8 + const ObserveAbandon + const ObserveConfirmed + const ObservePending + const ObserveResendDue + const ObserveStop + type PrepareOutcome uint8 + const PrepareAbandon + const PrepareConfirmed + const PrepareConflict + const PrepareRetry + const PrepareSend + type Prepared struct + Cause error + Outcome PrepareOutcome + Proof Proof + type Proof struct + FirstPieceID sdktypes.BigInt + Outcome ProofOutcome + type ProofOutcome uint8 + const ProofConflict + const ProofLanded + const ProofUnused + type Request struct + AttentionAt *time.Time + AttentionCode *string + ConfirmedAt *time.Time + ConfirmedTxHash *string + CreatedAt time.Time + ExtraDataHex *string + FirstPieceID *idtypes.OnChainID + FirstSentAt *time.Time + LastError *string + LastSentAt *time.Time + PieceCount int + Refusals int + RequestID string + RetryAt *time.Time + SealRequestedAt *time.Time + SealedAt *time.Time + Sends int + Status RequestStatus + StatusURL *string + StorageDataSetID int64 + SubmitError *string + SubmittedAt *time.Time + TaskID *int64 + TxHash *string + UpdatedAt time.Time + func (r *Request) BeforeAppendModel(_ context.Context, query bun.Query) error + func (r Request) Sent() bool + type RequestPiece struct + ContentID int64 + CreatedAt time.Time + ID int64 + PieceCID string + Position int + RequestID string + StorageDataSetID int64 + func (p *RequestPiece) BeforeAppendModel(_ context.Context, query bun.Query) error + type RequestStatus string + const RequestStatusAbandoned + const RequestStatusCollecting + const RequestStatusConfirmed + const RequestStatusReady + const RequestStatusSubmitted + func (s RequestStatus) Terminal() bool + func (s RequestStatus) Valid() bool + type SealInput struct + CachePressure bool + Draining bool + ManualRequested bool + MaxPieces int + MaxWait time.Duration + Members int + Now time.Time + OldestJoinedAt time.Time + type SendKind uint8 + const SendAccepted + const SendNotSent + const SendRefused + const SendUnknown + type SendResult struct + Err error + Kind SendKind + Submission *storage.CommitSubmission v0.1.0-beta.1 Aug 31, 2026
Go to main page