bus

package

Go to main page

Versions in this module

v1

v1.1.1

Dec 17, 2024

v1.1.1-alpha.1

Dec 17, 2024

v1.1.0

Nov 19, 2024

Changes in this version

+ type AccountStore interface

+ Accounts func(context.Context, string) ([]api.Account, error)

+ SaveAccounts func(context.Context, []api.Account) error

+ type AlertManager interface

+ RegisterWebhookBroadcaster func(b webhooks.Broadcaster)

+ type Bus struct

+ func (b *Bus) Handler() http.Handler

+ func (b *Bus) Shutdown(ctx context.Context) error

type ChainManager

+ AddBlocks func(blocks []types.Block) error

+ AddPoolTransactions func(txns []types.Transaction) (bool, error)

+ AddV2PoolTransactions func(basis types.ChainIndex, txns []types.V2Transaction) (known bool, err error)

+ Block func(id types.BlockID) (types.Block, bool)

+ OnReorg func(fn func(types.ChainIndex)) (cancel func())

+ PoolTransaction func(txid types.TransactionID) (types.Transaction, bool)

+ PoolTransactions func() []types.Transaction

+ RecommendedFee func() types.Currency

+ Tip func() types.ChainIndex

+ UnconfirmedParents func(txn types.Transaction) []types.Transaction

+ UpdatesSince func(index types.ChainIndex, max int) (rus []chain.RevertUpdate, aus []chain.ApplyUpdate, err error)

+ V2PoolTransactions func() []types.V2Transaction

+ V2TransactionSet func(basis types.ChainIndex, txn types.V2Transaction) (types.ChainIndex, []types.V2Transaction, error)

+ type ChainStore interface

+ ChainIndex func(ctx context.Context) (types.ChainIndex, error)

+ ProcessChainUpdate func(ctx context.Context, applyFn func(sql.ChainUpdateTx) error) error

+ type ChainSubscriber interface

+ ChainIndex func(context.Context) (types.ChainIndex, error)

+ Shutdown func(context.Context) error

+ type ContractLocker interface

+ Acquire func(ctx context.Context, priority int, id types.FileContractID, d time.Duration) (uint64, error)

+ KeepAlive func(id types.FileContractID, lockID uint64, d time.Duration) error

+ Release func(id types.FileContractID, lockID uint64) error

+ type HostStore interface

+ Host func(ctx context.Context, hostKey types.PublicKey) (api.Host, error)

+ HostAllowlist func(ctx context.Context) ([]types.PublicKey, error)

+ HostBlocklist func(ctx context.Context) ([]string, error)

+ HostsForScanning func(ctx context.Context, maxLastScan time.Time, offset, limit int) ([]api.HostAddress, error)

+ RecordHostScans func(ctx context.Context, scans []api.HostScan) error

+ RecordPriceTables func(ctx context.Context, priceTableUpdate []api.HostPriceTableUpdate) error

+ RemoveOfflineHosts func(ctx context.Context, maxConsecutiveScanFailures uint64, ...) (uint64, error)

+ ResetLostSectors func(ctx context.Context, hk types.PublicKey) error

+ SearchHosts func(ctx context.Context, ...) ([]api.Host, error)

+ UpdateHostAllowlistEntries func(ctx context.Context, add, remove []types.PublicKey, clear bool) error

+ UpdateHostBlocklistEntries func(ctx context.Context, add, remove []string, clear bool) error

+ UpdateHostCheck func(ctx context.Context, autopilotID string, hk types.PublicKey, ...) error

type MetadataStore

+ PrunableContractRoots func(ctx context.Context, id types.FileContractID, roots []types.Hash256) ([]uint64, error)

+ UpdateContractSet func(ctx context.Context, set string, toAdd, toRemove []types.FileContractID) error

type MetricsStore

+ RecordWalletMetric func(ctx context.Context, metrics ...api.WalletMetric) error

+ type PinManager interface

+ Shutdown func(context.Context) error

+ TriggerUpdate func()

+ type Store interface

type Syncer

+ Addr func() string

+ BroadcastHeader func(h gateway.BlockHeader)

+ BroadcastTransactionSet func([]types.Transaction)

+ BroadcastV2BlockOutline func(bo gateway.V2BlockOutline)

+ BroadcastV2TransactionSet func(index types.ChainIndex, txns []types.V2Transaction)

+ type UploadingSectorsCache interface

+ AddSector func(uID api.UploadID, fcid types.FileContractID, root types.Hash256) error

+ FinishUpload func(uID api.UploadID)

+ HandleRenewal func(fcid, renewedFrom types.FileContractID)

+ Pending func(fcid types.FileContractID) (size uint64)

+ Sectors func(fcid types.FileContractID) (roots []types.Hash256)

+ StartUpload func(uID api.UploadID) error

type Wallet

+ Close func() error

+ Events func(offset, limit int) ([]wallet.Event, error)

+ FundV2Transaction func(txn *types.V2Transaction, amount types.Currency, useUnconfirmed bool) (types.ChainIndex, []int, error)

+ RedistributeV2 func(outputs int, amount, feePerByte types.Currency) (txns []types.V2Transaction, toSign [][]int, err error)

+ SignV2Inputs func(txn *types.V2Transaction, toSign []int)

+ SpendableOutputs func() ([]types.SiacoinElement, error)

+ Tip func() types.ChainIndex

+ UnconfirmedEvents func() ([]wallet.Event, error)

+ UpdateChainState func(tx wallet.UpdateTx, reverted []chain.RevertUpdate, applied []chain.ApplyUpdate) error

+ type WalletMetricsRecorder interface

+ Shutdown func(context.Context) error

+ type WebhooksManager interface

+ Delete func(context.Context, webhooks.Webhook) error

+ Info func() ([]webhooks.Webhook, []webhooks.WebhookQueueInfo)

+ Register func(context.Context, webhooks.Webhook) error

+ Shutdown func(context.Context) error

v1.1.0-beta.6

Nov 19, 2024

v1.1.0-beta.5

Oct 2, 2024

v1.1.0-beta.4

Sep 19, 2024

v1.1.0-beta.3

Sep 16, 2024

v1.1.0-beta.2

Aug 28, 2024

v1.1.0-beta.1

Aug 26, 2024

v1.0.8

Jul 3, 2024

v1.0.8-beta.2

Jul 3, 2024

v1.0.8-beta.1

Jun 28, 2024

v1.0.7

Apr 24, 2024

Changes in this version

type HostDB

+ UpdateHostCheck func(ctx context.Context, autopilotID string, hk types.PublicKey, ...) error

v1.0.7-beta.3

Apr 24, 2024

v1.0.7-beta.2

Apr 23, 2024

v1.0.7-beta.1

Apr 22, 2024

v1.0.6

Mar 12, 2024

Changes in this version

type MetadataStore

+ ObjectMetadata func(ctx context.Context, bucketName, path string) (api.Object, error)

v1.0.6-beta.1

Mar 12, 2024

v1.0.5

Feb 14, 2024

v1.0.4

Feb 12, 2024

v1.0.3

Feb 6, 2024

v1.0.2

Jan 19, 2024

v1.0.1

Jan 10, 2024

v1.0.0

Dec 21, 2023

v0

v0.7.2

Dec 21, 2023

v0.7.1

Dec 15, 2023

v0.7.0

Dec 13, 2023

Changes in this version

type ChainManager

+ BlockAtHeight func(height uint64) (types.Block, bool)

+ IndexAtHeight func(height uint64) (types.ChainIndex, error)

+ Subscribe func(s modules.ConsensusSetSubscriber, ccID modules.ConsensusChangeID, ...) error

type HostDB

+ ResetLostSectors func(ctx context.Context, hk types.PublicKey) error

type MetadataStore

+ DeleteHostSector func(ctx context.Context, hk types.PublicKey, root types.Hash256) error

+ type MetricsStore interface

+ ContractMetrics func(ctx context.Context, start time.Time, n uint64, interval time.Duration, ...) ([]api.ContractMetric, error)

+ ContractPruneMetrics func(ctx context.Context, start time.Time, n uint64, interval time.Duration, ...) ([]api.ContractPruneMetric, error)

+ ContractSetChurnMetrics func(ctx context.Context, start time.Time, n uint64, interval time.Duration, ...) ([]api.ContractSetChurnMetric, error)

+ ContractSetMetrics func(ctx context.Context, start time.Time, n uint64, interval time.Duration, ...) ([]api.ContractSetMetric, error)

+ PruneMetrics func(ctx context.Context, metric string, cutoff time.Time) error

+ RecordContractMetric func(ctx context.Context, metrics ...api.ContractMetric) error

+ RecordContractPruneMetric func(ctx context.Context, metrics ...api.ContractPruneMetric) error

+ RecordContractSetChurnMetric func(ctx context.Context, metrics ...api.ContractSetChurnMetric) error

+ WalletMetrics func(ctx context.Context, start time.Time, n uint64, interval time.Duration, ...) ([]api.WalletMetric, error)

type TransactionPool

+ AcceptTransactionSet func(txns []types.Transaction) error

+ Close func() error

+ Subscribe func(subscriber modules.TransactionPoolSubscriber)

v0.6.0

Oct 3, 2023

Changes in this version

type Client

+ func (c *Client) AbortMultipartUpload(ctx context.Context, bucket, path string, uploadID string) (err error)

+ func (c *Client) AddMultipartPart(ctx context.Context, bucket, path, contractSet, eTag, uploadID string, ...) (err error)

+ func (c *Client) Bucket(ctx context.Context, name string) (resp api.Bucket, err error)

+ func (c *Client) CompleteMultipartUpload(ctx context.Context, bucket, path, uploadID string, ...) (resp api.MultipartCompleteResponse, err error)

+ func (c *Client) CopyObject(ctx context.Context, srcBucket, dstBucket, srcPath, dstPath string, ...) (om api.ObjectMetadata, err error)

+ func (c *Client) CreateBucket(ctx context.Context, name string, policy api.BucketPolicy) error

+ func (c *Client) CreateMultipartUpload(ctx context.Context, bucket, path string, opts api.CreateMultipartOptions) (resp api.MultipartCreateResponse, err error)

+ func (c *Client) DeleteBucket(ctx context.Context, name string) error

+ func (c *Client) ListBuckets(ctx context.Context) (buckets []api.Bucket, err error)

+ func (c *Client) ListObjects(ctx context.Context, bucket, prefix, marker string, limit int) (resp api.ObjectsListResponse, err error)

+ func (c *Client) MultipartUpload(ctx context.Context, uploadID string) (resp api.MultipartUpload, err error)

+ func (c *Client) MultipartUploadParts(ctx context.Context, bucket, object string, uploadID string, marker int, ...) (resp api.MultipartListPartsResponse, err error)

+ func (c *Client) MultipartUploads(ctx context.Context, bucket, prefix, keyMarker, uploadIDMarker string, ...) (resp api.MultipartListUploadsResponse, err error)

+ func (c *Client) S3AuthenticationSettings(ctx context.Context) (as api.S3AuthenticationSettings, err error)

+ func (c *Client) UpdateBucketPolicy(ctx context.Context, bucket string, policy api.BucketPolicy) error

type EphemeralAccountStore

+ SetUncleanShutdown func() error

type MetadataStore

+ AbortMultipartUpload func(ctx context.Context, bucket, path string, uploadID string) (err error)

+ AddMultipartPart func(ctx context.Context, bucket, path, contractSet, eTag, uploadID string, ...) (err error)

+ Bucket func(_ context.Context, bucket string) (api.Bucket, error)

+ CompleteMultipartUpload func(ctx context.Context, bucket, path, uploadID string, ...) (_ api.MultipartCompleteResponse, err error)

+ CopyObject func(ctx context.Context, srcBucket, dstBucket, srcPath, dstPath, mimeType string) (api.ObjectMetadata, error)

+ CreateBucket func(_ context.Context, bucket string, policy api.BucketPolicy) error

+ CreateMultipartUpload func(ctx context.Context, bucket, path string, ec object.EncryptionKey, ...) (api.MultipartCreateResponse, error)

+ DeleteBucket func(_ context.Context, bucket string) error

+ ListBuckets func(_ context.Context) ([]api.Bucket, error)

+ ListObjects func(ctx context.Context, bucket, prefix, marker string, limit int) (api.ObjectsListResponse, error)

+ MultipartUpload func(ctx context.Context, uploadID string) (resp api.MultipartUpload, _ error)

+ MultipartUploadParts func(ctx context.Context, bucket, object string, uploadID string, marker int, ...) (resp api.MultipartListPartsResponse, _ error)

+ MultipartUploads func(ctx context.Context, bucket, prefix, keyMarker, uploadIDMarker string, ...) (resp api.MultipartListUploadsResponse, _ error)

+ UpdateBucketPolicy func(ctx context.Context, bucket string, policy api.BucketPolicy) error

v0.5.0

Sep 4, 2023

Changes in this version

+ var ErrAcquireContractTimeout = errors.New("acquiring the lock timed out")

+ func New(s Syncer, am *alerts.Manager, hm *webhooks.Manager, cm ChainManager, ...) (*bus, error)

+ type AutopilotStore interface

+ Autopilot func(ctx context.Context, id string) (api.Autopilot, error)

+ Autopilots func(ctx context.Context) ([]api.Autopilot, error)

+ UpdateAutopilot func(ctx context.Context, ap api.Autopilot) error

+ type ChainManager interface

+ AcceptBlock func(context.Context, types.Block) error

+ LastBlockTime func() time.Time

+ Synced func(ctx context.Context) bool

+ TipState func(ctx context.Context) consensus.State

+ type Client struct

+ func NewClient(addr, password string) *Client

+ func (c *Client) AcceptBlock(ctx context.Context, b types.Block) (err error)

+ func (c *Client) Account(ctx context.Context, id rhpv3.Account, host types.PublicKey) (account api.Account, err error)

+ func (c *Client) Accounts(ctx context.Context) (accounts []api.Account, err error)

+ func (c *Client) AcquireContract(ctx context.Context, fcid types.FileContractID, priority int, d time.Duration) (lockID uint64, err error)

+ func (c *Client) AddBalance(ctx context.Context, id rhpv3.Account, hk types.PublicKey, amount *big.Int) (err error)

+ func (c *Client) AddContract(ctx context.Context, contract rhpv2.ContractRevision, totalCost types.Currency, ...) (added api.ContractMetadata, err error)

+ func (c *Client) AddObject(ctx context.Context, path, contractSet string, o object.Object, ...) (err error)

+ func (c *Client) AddPartialSlab(ctx context.Context, data []byte, minShards, totalShards uint8, ...) (slabs []object.PartialSlab, err error)

+ func (c *Client) AddRenewedContract(ctx context.Context, contract rhpv2.ContractRevision, totalCost types.Currency, ...) (renewed api.ContractMetadata, err error)

+ func (c *Client) AddUploadingSector(ctx context.Context, uID api.UploadID, id types.FileContractID, ...) (err error)

+ func (c *Client) Alerts() (alerts []alerts.Alert, err error)

+ func (c *Client) AncestorContracts(ctx context.Context, fcid types.FileContractID, minStartHeight uint64) (contracts []api.ArchivedContract, err error)

+ func (c *Client) ArchiveContracts(ctx context.Context, toArchive map[types.FileContractID]string) (err error)

+ func (c *Client) Autopilot(ctx context.Context, id string) (autopilot api.Autopilot, err error)

+ func (c *Client) Autopilots(ctx context.Context) (autopilots []api.Autopilot, err error)

+ func (c *Client) BroadcastAction(ctx context.Context, action webhooks.Event) error

+ func (c *Client) BroadcastTransaction(ctx context.Context, txns []types.Transaction) error

+ func (c *Client) ConsensusNetwork(ctx context.Context) (resp api.ConsensusNetwork, err error)

+ func (c *Client) ConsensusState(ctx context.Context) (resp api.ConsensusState, err error)

+ func (c *Client) Contract(ctx context.Context, id types.FileContractID) (contract api.ContractMetadata, err error)

+ func (c *Client) ContractRoots(ctx context.Context, fcid types.FileContractID) (roots, uploading []types.Hash256, err error)

+ func (c *Client) ContractSetContracts(ctx context.Context, set string) (contracts []api.ContractMetadata, err error)

+ func (c *Client) ContractSetSettings(ctx context.Context) (gs api.ContractSetSetting, err error)

+ func (c *Client) ContractSets(ctx context.Context) (sets []string, err error)

+ func (c *Client) ContractSize(ctx context.Context, fcid types.FileContractID) (size api.ContractSize, err error)

+ func (c *Client) Contracts(ctx context.Context) (contracts []api.ContractMetadata, err error)

+ func (c *Client) DeleteAllContracts(ctx context.Context) (err error)

+ func (c *Client) DeleteContract(ctx context.Context, id types.FileContractID) (err error)

+ func (c *Client) DeleteContractSet(ctx context.Context, set string) (err error)

+ func (c *Client) DeleteContracts(ctx context.Context, ids []types.FileContractID) error

+ func (c *Client) DeleteObject(ctx context.Context, path string, batch bool) (err error)

+ func (c *Client) DeleteSetting(ctx context.Context, key string) error

+ func (c *Client) DeleteWebhook(ctx context.Context, url, module, event string) error

+ func (c *Client) DismissAlerts(ctx context.Context, ids ...types.Hash256) error

+ func (c *Client) FetchPartialSlab(ctx context.Context, key object.EncryptionKey, offset, length uint32) ([]byte, error)

+ func (c *Client) FileContractTax(ctx context.Context, payout types.Currency) (tax types.Currency, err error)

+ func (c *Client) FinishUpload(ctx context.Context, uID api.UploadID) (err error)

+ func (c *Client) GougingParams(ctx context.Context) (gp api.GougingParams, err error)

+ func (c *Client) GougingSettings(ctx context.Context) (gs api.GougingSettings, err error)

+ func (c *Client) Host(ctx context.Context, hostKey types.PublicKey) (h hostdb.HostInfo, err error)

+ func (c *Client) HostAllowlist(ctx context.Context) (allowlist []types.PublicKey, err error)

+ func (c *Client) HostBlocklist(ctx context.Context) (blocklist []string, err error)

+ func (c *Client) Hosts(ctx context.Context, offset, limit int) (hosts []hostdb.Host, err error)

+ func (c *Client) HostsForScanning(ctx context.Context, maxLastScan time.Time, offset, limit int) (hosts []hostdb.HostAddress, err error)

+ func (c *Client) KeepaliveContract(ctx context.Context, fcid types.FileContractID, lockID uint64, d time.Duration) (err error)

+ func (c *Client) LockAccount(ctx context.Context, id rhpv3.Account, hostKey types.PublicKey, exclusive bool, ...) (account api.Account, lockID uint64, err error)

+ func (c *Client) MarkPackedSlabsUploaded(ctx context.Context, slabs []api.UploadedPackedSlab, ...) (err error)

+ func (c *Client) Object(ctx context.Context, path string, opts ...api.ObjectsOption) (o api.Object, entries []api.ObjectMetadata, err error)

+ func (c *Client) ObjectsBySlabKey(ctx context.Context, key object.EncryptionKey) (objects []api.ObjectMetadata, err error)

+ func (c *Client) ObjectsStats() (osr api.ObjectsStatsResponse, err error)

+ func (c *Client) PackedSlabsForUpload(ctx context.Context, lockingDuration time.Duration, ...) (slabs []api.PackedSlab, err error)

+ func (c *Client) PrunableData(ctx context.Context) (prunableData api.ContractsPrunableDataResponse, err error)

+ func (c *Client) RecommendedFee(ctx context.Context) (fee types.Currency, err error)

+ func (c *Client) RecordContractSpending(ctx context.Context, records []api.ContractSpendingRecord) (err error)

+ func (c *Client) RecordHostScans(ctx context.Context, scans []hostdb.HostScan) (err error)

+ func (c *Client) RecordPriceTables(ctx context.Context, priceTableUpdates []hostdb.PriceTableUpdate) (err error)

+ func (c *Client) RedundancySettings(ctx context.Context) (rs api.RedundancySettings, err error)

+ func (c *Client) RefreshHealth(ctx context.Context) error

+ func (c *Client) RegisterAlert(ctx context.Context, alert alerts.Alert) error

+ func (c *Client) RegisterWebhook(ctx context.Context, url, module, event string) error

+ func (c *Client) ReleaseContract(ctx context.Context, fcid types.FileContractID, lockID uint64) (err error)

+ func (c *Client) RemoveOfflineHosts(ctx context.Context, minRecentScanFailures uint64, maxDowntime time.Duration) (removed uint64, err error)

+ func (c *Client) RenameObject(ctx context.Context, from, to string) (err error)

+ func (c *Client) RenameObjects(ctx context.Context, from, to string) (err error)

+ func (c *Client) RenewedContract(ctx context.Context, renewedFrom types.FileContractID) (contract api.ContractMetadata, err error)

+ func (c *Client) ResetDrift(ctx context.Context, id rhpv3.Account) (err error)

+ func (c *Client) ScheduleSync(ctx context.Context, id rhpv3.Account, hk types.PublicKey) (err error)

+ func (c *Client) SearchHosts(ctx context.Context, filterMode string, addressContains string, ...) (hosts []hostdb.Host, err error)

+ func (c *Client) SearchObjects(ctx context.Context, key string, offset, limit int) (entries []api.ObjectMetadata, err error)

+ func (c *Client) SendSiacoins(ctx context.Context, scos []types.SiacoinOutput) (err error)

+ func (c *Client) SetBalance(ctx context.Context, id rhpv3.Account, hk types.PublicKey, amount *big.Int) (err error)

+ func (c *Client) SetContractSet(ctx context.Context, set string, contracts []types.FileContractID) (err error)

+ func (c *Client) Setting(ctx context.Context, key string, value interface{}) (err error)

+ func (c *Client) Settings(ctx context.Context) (settings []string, err error)

+ func (c *Client) Slab(ctx context.Context, key object.EncryptionKey) (slab object.Slab, err error)

+ func (c *Client) SlabBuffers() (buffers []api.SlabBuffer, err error)

+ func (c *Client) SlabsForMigration(ctx context.Context, healthCutoff float64, set string, limit int) (slabs []api.UnhealthySlab, err error)

+ func (c *Client) State() (state api.BusStateResponse, err error)

+ func (c *Client) SyncerAddress(ctx context.Context) (addr string, err error)

+ func (c *Client) SyncerConnect(ctx context.Context, addr string) (err error)

+ func (c *Client) SyncerPeers(ctx context.Context) (resp []string, err error)

+ func (c *Client) TrackUpload(ctx context.Context, uID api.UploadID) (err error)

+ func (c *Client) TransactionPool(ctx context.Context) (txns []types.Transaction, err error)

+ func (c *Client) UnlockAccount(ctx context.Context, id rhpv3.Account, lockID uint64) (err error)

+ func (c *Client) UpdateAutopilot(ctx context.Context, autopilot api.Autopilot) (err error)

+ func (c *Client) UpdateHostAllowlist(ctx context.Context, add, remove []types.PublicKey, clear bool) (err error)

+ func (c *Client) UpdateHostBlocklist(ctx context.Context, add, remove []string, clear bool) (err error)

+ func (c *Client) UpdateSetting(ctx context.Context, key string, value interface{}) error

+ func (c *Client) UpdateSlab(ctx context.Context, slab object.Slab, contractSet string, ...) (err error)

+ func (c *Client) UploadPackingSettings(ctx context.Context) (ups api.UploadPackingSettings, err error)

+ func (c *Client) UploadParams(ctx context.Context) (up api.UploadParams, err error)

+ func (c *Client) Wallet(ctx context.Context) (resp api.WalletResponse, err error)

+ func (c *Client) WalletAddress(ctx context.Context) (resp types.Address, err error)

+ func (c *Client) WalletBalance(ctx context.Context) (bal types.Currency, err error)

+ func (c *Client) WalletDiscard(ctx context.Context, txn types.Transaction) error

+ func (c *Client) WalletFund(ctx context.Context, txn *types.Transaction, amount types.Currency) ([]types.Hash256, []types.Transaction, error)

+ func (c *Client) WalletOutputs(ctx context.Context) (resp []wallet.SiacoinElement, err error)

+ func (c *Client) WalletPending(ctx context.Context) (resp []types.Transaction, err error)

+ func (c *Client) WalletPrepareForm(ctx context.Context, renterAddress types.Address, renterKey types.PublicKey, ...) (txns []types.Transaction, err error)

+ func (c *Client) WalletPrepareRenew(ctx context.Context, revision types.FileContractRevision, ...) (api.WalletPrepareRenewResponse, error)

+ func (c *Client) WalletRedistribute(ctx context.Context, outputs int, amount types.Currency) (id types.TransactionID, err error)

+ func (c *Client) WalletSign(ctx context.Context, txn *types.Transaction, toSign []types.Hash256, ...) error

+ func (c *Client) WalletTransactions(ctx context.Context, opts ...api.WalletTransactionsOption) (resp []wallet.Transaction, err error)

+ func (c *Client) Webhooks(ctx context.Context) (resp api.WebHookResponse, err error)

+ type EphemeralAccountStore interface

+ Accounts func(context.Context) ([]api.Account, error)

+ SaveAccounts func(context.Context, []api.Account) error

+ type HostDB interface

+ Host func(ctx context.Context, hostKey types.PublicKey) (hostdb.HostInfo, error)

+ HostAllowlist func(ctx context.Context) ([]types.PublicKey, error)

+ HostBlocklist func(ctx context.Context) ([]string, error)

+ Hosts func(ctx context.Context, offset, limit int) ([]hostdb.Host, error)

+ HostsForScanning func(ctx context.Context, maxLastScan time.Time, offset, limit int) ([]hostdb.HostAddress, error)

+ RecordHostScans func(ctx context.Context, scans []hostdb.HostScan) error

+ RecordPriceTables func(ctx context.Context, priceTableUpdate []hostdb.PriceTableUpdate) error

+ RemoveOfflineHosts func(ctx context.Context, minRecentScanFailures uint64, maxDowntime time.Duration) (uint64, error)

+ SearchHosts func(ctx context.Context, filterMode, addressContains string, ...) ([]hostdb.Host, error)

+ UpdateHostAllowlistEntries func(ctx context.Context, add, remove []types.PublicKey, clear bool) error

+ UpdateHostBlocklistEntries func(ctx context.Context, add, remove []string, clear bool) error

+ type MetadataStore interface

+ AddContract func(ctx context.Context, c rhpv2.ContractRevision, totalCost types.Currency, ...) (api.ContractMetadata, error)

+ AddPartialSlab func(ctx context.Context, data []byte, minShards, totalShards uint8, ...) (slabs []object.PartialSlab, err error)

+ AddRenewedContract func(ctx context.Context, c rhpv2.ContractRevision, totalCost types.Currency, ...) (api.ContractMetadata, error)

+ AncestorContracts func(ctx context.Context, fcid types.FileContractID, minStartHeight uint64) ([]api.ArchivedContract, error)

+ ArchiveAllContracts func(ctx context.Context, reason string) error

+ ArchiveContract func(ctx context.Context, id types.FileContractID, reason string) error

+ ArchiveContracts func(ctx context.Context, toArchive map[types.FileContractID]string) error

+ Contract func(ctx context.Context, id types.FileContractID) (api.ContractMetadata, error)

+ ContractRoots func(ctx context.Context, id types.FileContractID) ([]types.Hash256, error)

+ ContractSetContracts func(ctx context.Context, set string) ([]api.ContractMetadata, error)

+ ContractSets func(ctx context.Context) ([]string, error)

+ ContractSize func(ctx context.Context, id types.FileContractID) (api.ContractSize, error)

+ ContractSizes func(ctx context.Context) (map[types.FileContractID]api.ContractSize, error)

+ Contracts func(ctx context.Context) ([]api.ContractMetadata, error)

+ FetchPartialSlab func(ctx context.Context, key object.EncryptionKey, offset, length uint32) ([]byte, error)

+ MarkPackedSlabsUploaded func(ctx context.Context, slabs []api.UploadedPackedSlab, ...) error

+ Object func(ctx context.Context, path string) (api.Object, error)

+ ObjectEntries func(ctx context.Context, path, prefix string, offset, limit int) ([]api.ObjectMetadata, error)

+ ObjectsBySlabKey func(ctx context.Context, slabKey object.EncryptionKey) ([]api.ObjectMetadata, error)

+ ObjectsStats func(ctx context.Context) (api.ObjectsStatsResponse, error)

+ PackedSlabsForUpload func(ctx context.Context, lockingDuration time.Duration, ...) ([]api.PackedSlab, error)

+ RecordContractSpending func(ctx context.Context, records []api.ContractSpendingRecord) error

+ RefreshHealth func(ctx context.Context) error

+ RemoveContractSet func(ctx context.Context, name string) error

+ RemoveObject func(ctx context.Context, path string) error

+ RemoveObjects func(ctx context.Context, prefix string) error

+ RenameObject func(ctx context.Context, from, to string) error

+ RenameObjects func(ctx context.Context, from, to string) error

+ RenewedContract func(ctx context.Context, renewedFrom types.FileContractID) (api.ContractMetadata, error)

+ SearchObjects func(ctx context.Context, substring string, offset, limit int) ([]api.ObjectMetadata, error)

+ SetContractSet func(ctx context.Context, set string, contracts []types.FileContractID) error

+ Slab func(ctx context.Context, key object.EncryptionKey) (object.Slab, error)

+ SlabBuffers func(ctx context.Context) ([]api.SlabBuffer, error)

+ UnhealthySlabs func(ctx context.Context, healthCutoff float64, set string, limit int) ([]api.UnhealthySlab, error)

+ UpdateObject func(ctx context.Context, path, contractSet string, o object.Object, ...) error

+ UpdateSlab func(ctx context.Context, s object.Slab, contractSet string, ...) error

+ type SettingStore interface

+ DeleteSetting func(ctx context.Context, key string) error

+ Setting func(ctx context.Context, key string) (string, error)

+ Settings func(ctx context.Context) ([]string, error)

+ UpdateSetting func(ctx context.Context, key, value string) error

+ type Syncer interface

+ BroadcastTransaction func(txn types.Transaction, dependsOn []types.Transaction)

+ Connect func(addr string) error

+ Peers func() []string

+ SyncerAddress func(ctx context.Context) (string, error)

+ type TransactionPool interface

+ AddTransactionSet func(txns []types.Transaction) error

+ RecommendedFee func() types.Currency

+ Transactions func() []types.Transaction

+ UnconfirmedParents func(txn types.Transaction) ([]types.Transaction, error)

+ type Wallet interface

+ Address func() types.Address

+ Balance func() (spendable, confirmed, unconfirmed types.Currency, _ error)

+ FundTransaction func(cs consensus.State, txn *types.Transaction, amount types.Currency, ...) ([]types.Hash256, error)

+ Height func() uint64

+ Redistribute func(cs consensus.State, outputs int, amount, feePerByte types.Currency, ...) (types.Transaction, []types.Hash256, error)

+ ReleaseInputs func(txn types.Transaction)

+ SignTransaction func(cs consensus.State, txn *types.Transaction, toSign []types.Hash256, ...) error

+ Transactions func(before, since time.Time, offset, limit int) ([]wallet.Transaction, error)

+ UnspentOutputs func() ([]wallet.SiacoinElement, error)

v0.4.0-beta

Jul 10, 2023

v0.3.0-beta

Apr 28, 2023

v0.2.0-beta

Apr 14, 2023

v0.1.0-beta

Apr 1, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL