autopilot

Documentation

Index

• type Autopilot
  • func New(cfg config.Autopilot, bus Bus, workers []Worker, logger *zap.Logger) (_ *Autopilot, err error)
  • func (ap *Autopilot) Config(ctx context.Context) (api.Autopilot, error)
  • func (ap *Autopilot) DismissAlert(ctx context.Context, ids ...types.Hash256)
  • func (ap *Autopilot) Handler() http.Handler
  • func (ap *Autopilot) RegisterAlert(ctx context.Context, a alerts.Alert)
  • func (ap *Autopilot) Run()
  • func (ap *Autopilot) Shutdown(ctx context.Context) error
  • func (ap *Autopilot) StartTime() time.Time
  • func (ap *Autopilot) Trigger(forceScan bool) bool
  • func (ap *Autopilot) Uptime() (dur time.Duration)
• type Bus
• type Client
  • func NewClient(addr, password string) *Client
  • func (c *Client) Config() (cfg api.AutopilotConfig, err error)
  • func (c *Client) EvaluateConfig(ctx context.Context, cfg api.AutopilotConfig, gs api.GougingSettings, ...) (resp api.ConfigEvaluationResponse, err error)
  • func (c *Client) HostInfo(hostKey types.PublicKey) (resp api.HostResponse, err error)
  • func (c *Client) HostInfos(ctx context.Context, filterMode, usabilityMode, addressContains string, ...) (resp []api.HostResponse, err error)
  • func (c *Client) State() (state api.AutopilotStateResponse, err error)
  • func (c *Client) Trigger(forceScan bool) (_ bool, err error)
  • func (c *Client) UpdateConfig(cfg api.AutopilotConfig) error
• type Worker

Types

type Autopilot

type Autopilot struct {
	// contains filtered or unexported fields
}

func New

func New(cfg config.Autopilot, bus Bus, workers []Worker, logger *zap.Logger) (_ *Autopilot, err error)

New initializes an Autopilot.

func (*Autopilot) Config

func (ap *Autopilot) Config(ctx context.Context) (api.Autopilot, error)

func (*Autopilot) DismissAlert

func (ap *Autopilot) DismissAlert(ctx context.Context, ids ...types.Hash256)

func (*Autopilot) Handler

func (ap *Autopilot) Handler() http.Handler

Handler returns an HTTP handler that serves the autopilot api.

func (*Autopilot) RegisterAlert

func (ap *Autopilot) RegisterAlert(ctx context.Context, a alerts.Alert)

func (*Autopilot) Run

func (ap *Autopilot) Run()

func (*Autopilot) Shutdown

func (ap *Autopilot) Shutdown(ctx context.Context) error

Shutdown shuts down the autopilot.

func (*Autopilot) StartTime

func (ap *Autopilot) StartTime() time.Time

func (*Autopilot) Trigger

func (ap *Autopilot) Trigger(forceScan bool) bool

func (*Autopilot) Uptime

func (ap *Autopilot) Uptime() (dur time.Duration)

type Bus

type Bus interface {
	alerts.Alerter
	webhooks.Broadcaster

	// Accounts
	Accounts(ctx context.Context, owner string) (accounts []api.Account, err error)

	// Autopilots
	Autopilot(ctx context.Context, id string) (autopilot api.Autopilot, err error)
	UpdateAutopilot(ctx context.Context, autopilot api.Autopilot) error

	// consensus
	ConsensusState(ctx context.Context) (api.ConsensusState, error)

	// contracts
	AncestorContracts(ctx context.Context, id types.FileContractID, minStartHeight uint64) ([]api.ArchivedContract, error)
	ArchiveContracts(ctx context.Context, toArchive map[types.FileContractID]string) error
	BroadcastContract(ctx context.Context, fcid types.FileContractID) (types.TransactionID, error)
	Contract(ctx context.Context, id types.FileContractID) (api.ContractMetadata, error)
	Contracts(ctx context.Context, opts api.ContractsOpts) (contracts []api.ContractMetadata, err error)
	FileContractTax(ctx context.Context, payout types.Currency) (types.Currency, error)
	FormContract(ctx context.Context, renterAddress types.Address, renterFunds types.Currency, hostKey types.PublicKey, hostIP string, hostCollateral types.Currency, endHeight uint64) (api.ContractMetadata, error)
	RenewContract(ctx context.Context, fcid types.FileContractID, endHeight uint64, renterFunds, minNewCollateral, maxFundAmount types.Currency, expectedNewStorage uint64) (api.ContractMetadata, error)
	UpdateContractSet(ctx context.Context, set string, toAdd, toRemove []types.FileContractID) error
	PrunableData(ctx context.Context) (prunableData api.ContractsPrunableDataResponse, err error)
	PruneContract(ctx context.Context, id types.FileContractID, timeout time.Duration) (api.ContractPruneResponse, error)

	// hostdb
	Host(ctx context.Context, hostKey types.PublicKey) (api.Host, error)
	HostsForScanning(ctx context.Context, opts api.HostsForScanningOptions) ([]api.HostAddress, error)
	RemoveOfflineHosts(ctx context.Context, maxConsecutiveScanFailures uint64, maxDowntime time.Duration) (uint64, error)
	SearchHosts(ctx context.Context, opts api.SearchHostOptions) ([]api.Host, error)
	UpdateHostCheck(ctx context.Context, autopilotID string, hostKey types.PublicKey, hostCheck api.HostCheck) error

	// metrics
	RecordContractSetChurnMetric(ctx context.Context, metrics ...api.ContractSetChurnMetric) error
	RecordContractPruneMetric(ctx context.Context, metrics ...api.ContractPruneMetric) error

	// buckets
	ListBuckets(ctx context.Context) ([]api.Bucket, error)

	// objects
	ObjectsBySlabKey(ctx context.Context, bucket string, key object.EncryptionKey) (objects []api.ObjectMetadata, err error)
	RefreshHealth(ctx context.Context) error
	Slab(ctx context.Context, key object.EncryptionKey) (object.Slab, error)
	SlabsForMigration(ctx context.Context, healthCutoff float64, set string, limit int) ([]api.UnhealthySlab, error)

	// settings
	UpdateSetting(ctx context.Context, key string, value interface{}) error
	GougingSettings(ctx context.Context) (gs api.GougingSettings, err error)
	RedundancySettings(ctx context.Context) (rs api.RedundancySettings, err error)

	// syncer
	SyncerPeers(ctx context.Context) (resp []string, err error)

	// txpool
	RecommendedFee(ctx context.Context) (types.Currency, error)
	TransactionPool(ctx context.Context) (txns []types.Transaction, err error)

	// wallet
	Wallet(ctx context.Context) (api.WalletResponse, error)
	WalletDiscard(ctx context.Context, txn types.Transaction) error
	WalletOutputs(ctx context.Context) (resp []api.SiacoinElement, err error)
	WalletPending(ctx context.Context) (resp []types.Transaction, err error)
	WalletRedistribute(ctx context.Context, outputs int, amount types.Currency) (ids []types.TransactionID, err error)
}

type Client

type Client struct {
	// contains filtered or unexported fields
}

A Client provides methods for interacting with an autopilot.

func NewClient

func NewClient(addr, password string) *Client

NewClient returns a new autopilot client.

func (*Client) Config

func (c *Client) Config() (cfg api.AutopilotConfig, err error)

Config returns the autopilot config.

func (*Client) EvaluateConfig

func (c *Client) EvaluateConfig(ctx context.Context, cfg api.AutopilotConfig, gs api.GougingSettings, rs api.RedundancySettings) (resp api.ConfigEvaluationResponse, err error)

EvalutateConfig evaluates an autopilot config using the given gouging and redundancy settings.

func (*Client) HostInfo

func (c *Client) HostInfo(hostKey types.PublicKey) (resp api.HostResponse, err error)

HostInfo returns information about the host with given host key.

func (*Client) HostInfos

func (c *Client) HostInfos(ctx context.Context, filterMode, usabilityMode, addressContains string, keyIn []types.PublicKey, offset, limit int) (resp []api.HostResponse, err error)

HostInfo returns information about all hosts.

func (*Client) State

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

State returns the current state of the autopilot.

func (*Client) Trigger

func (c *Client) Trigger(forceScan bool) (_ bool, err error)

Trigger triggers an iteration of the autopilot's main loop.

func (*Client) UpdateConfig

func (c *Client) UpdateConfig(cfg api.AutopilotConfig) error

UpdateConfig updates the autopilot config.

type Worker

type Worker interface {
	Account(ctx context.Context, hostKey types.PublicKey) (rhpv3.Account, error)
	Contracts(ctx context.Context, hostTimeout time.Duration) (api.ContractsResponse, error)
	ID(ctx context.Context) (string, error)
	MigrateSlab(ctx context.Context, s object.Slab, set string) (api.MigrateSlabResponse, error)

	RHPPriceTable(ctx context.Context, hostKey types.PublicKey, siamuxAddr string, timeout time.Duration) (api.HostPriceTable, error)
	RHPScan(ctx context.Context, hostKey types.PublicKey, hostIP string, timeout time.Duration) (api.RHPScanResponse, error)
}