Versions in this module Expand all Collapse all v0 v0.1.1 Jan 27, 2023 Changes in this version + const AcquireRemainingLife + const BatchBucket + const MaxObjectSize + const TxsBucket + func FindCOSEVerifier(ks signer.Keys, kid []byte) key.Verifier + func TxFrom(obj *Object, verify bool) (*ld.Transaction, error) + func TxsFrom(os Objects, verify bool) (ld.Txs, error) + type Chain interface + GetAccount func(context.Context, ids.Address) (*ld.Account, error) + GetGenesisTxs func(context.Context) (ld.Txs, error) + PreVerifyTxs func(context.Context, ld.Txs) error + func NewChainAPI(endpoint string, opts *httprpc.CBORClientOptions) Chain + type MemStorage struct + func (m *MemStorage) BatchAccept(ctx context.Context, bucket string, height uint64, ...) error + func (m *MemStorage) BatchAcquire(ctx context.Context, bucket string, hashList ids.IDList[ids.ID32]) error + func (m *MemStorage) GetObject(ctx context.Context, bucket string, hash ids.ID32) (*Object, error) + func (m *MemStorage) ListUnaccept(ctx context.Context, bucket, token string) (hashList ids.IDList[ids.ID32], nextToken string, err error) + func (m *MemStorage) PutObject(ctx context.Context, bucket string, objectRaw []byte) error + func (m *MemStorage) RemoveObject(ctx context.Context, bucket string, hash ids.ID32) error + type Object struct + Height int64 + Raw []byte + func (obj *Object) Hash() ids.ID32 + type Objects []*Object + func (os Objects) ToRawList() []cbor.RawMessage + type POS interface + BatchAccept func(ctx context.Context, bucket string, height uint64, ...) error + BatchAcquire func(ctx context.Context, bucket string, hashList ids.IDList[ids.ID32]) error + GetObject func(ctx context.Context, bucket string, hash ids.ID32) (*Object, error) + ListUnaccept func(ctx context.Context, bucket, token string) (hashList ids.IDList[ids.ID32], nextToken string, err error) + PutObject func(ctx context.Context, bucket string, objectRaw []byte) error + RemoveObject func(ctx context.Context, bucket string, hash ids.ID32) error + func NewMemStorage(expiration time.Duration) POS + type RequestParams struct + CWT *cose.Sign1Message[cwt.Claims] + Payload cbor.RawMessage + type TxOrBatch struct + Batch ld.Txs + ExSignatures signer.Sigs + Signatures signer.Sigs + Tx *ld.TxData + func (t *TxOrBatch) ToTransaction() (*ld.Transaction, error) + type TxPool struct + func NewTxPool(pos POS, chain Chain, opts TxPoolOptions) *TxPool + func (p *TxPool) Bootstrap(ctx context.Context) error + func (p *TxPool) ServeRPC(ctx context.Context, req *cborrpc.Request) *cborrpc.Response + func (p *TxPool) SetChain(chain Chain) + type TxPoolOptions struct + Builder ids.Address + CWTAudience string + CWTExData []byte + type TxsBuildStatus struct + Rejected ids.IDList[ids.ID32] + Unknown ids.IDList[ids.ID32]