replication

Documentation

Index

• Constants
• Variables
• func EpochToTime(epoch abi.ChainEpoch) time.Time
• func TimeToEpoch(t time.Time) abi.ChainEpoch
• type DatacapWalletChooser
  • func NewDatacapWalletChooser(db *gorm.DB, cacheTTL time.Duration, lotusAPI string, lotusToken string, ...) DatacapWalletChooser
  • func (w DatacapWalletChooser) Choose(ctx context.Context, wallets []model.Wallet) (model.Wallet, error)
• type DealConfig
  • func (d DealConfig) GetPrice(pieceSize int64, duration time.Duration) big.Int
• type DealMaker
• type DealMakerImpl
  • func NewDealMaker(lotusClient jsonrpc.RPCClient, libp2p host.Host, cacheTTL time.Duration, ...) DealMakerImpl
  • func (d DealMakerImpl) Close() error
  • func (d DealMakerImpl) MakeDeal(ctx context.Context, walletObj model.Wallet, car model.Car, ...) (*model.Deal, error)
• type DealProviderCollateralBound
• type DefaultWalletChooser
  • func (w DefaultWalletChooser) Choose(ctx context.Context, wallets []model.Wallet) (model.Wallet, error)
• type MinerInfo
• type WalletChooser

Constants

const (
	StorageProposalV120 = "/fil/storage/mk/1.2.0"
	StorageProposalV111 = "/fil/storage/mk/1.1.1"
)

Variables

var ErrNoDatacap = errors.New("no wallets have enough datacap")

var ErrNoWallet = errors.New("no wallets to choose from")

Functions

func EpochToTime

func EpochToTime(epoch abi.ChainEpoch) time.Time

func TimeToEpoch

func TimeToEpoch(t time.Time) abi.ChainEpoch

Types

type DatacapWalletChooser

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

func NewDatacapWalletChooser

func NewDatacapWalletChooser(db *gorm.DB, cacheTTL time.Duration,
	lotusAPI string, lotusToken string, min uint64) DatacapWalletChooser

func (DatacapWalletChooser) Choose

func (w DatacapWalletChooser) Choose(ctx context.Context, wallets []model.Wallet) (model.Wallet, error)

type DealConfig

type DealConfig struct {
	Provider        string
	StartDelay      time.Duration
	Duration        time.Duration
	Verified        bool
	HTTPHeaders     []string
	URLTemplate     string
	KeepUnsealed    bool
	AnnounceToIPNI  bool
	PricePerDeal    float64
	PricePerGB      float64
	PricePerGBEpoch float64
}

func (DealConfig) GetPrice

func (d DealConfig) GetPrice(pieceSize int64, duration time.Duration) big.Int

type DealMaker

type DealMaker interface {
	MakeDeal(ctx context.Context, walletObj model.Wallet, car model.Car, dealConfig DealConfig) (*model.Deal, error)
}

type DealMakerImpl

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

func NewDealMaker

func NewDealMaker(
	lotusClient jsonrpc.RPCClient,
	libp2p host.Host,
	cacheTTL time.Duration,
	requestTimeout time.Duration) DealMakerImpl

func (DealMakerImpl) Close

func (d DealMakerImpl) Close() error

func (DealMakerImpl) MakeDeal

func (d DealMakerImpl) MakeDeal(ctx context.Context, walletObj model.Wallet,
	car model.Car, dealConfig DealConfig) (*model.Deal, error)

type DealProviderCollateralBound

type DealProviderCollateralBound struct {
	Min string
	Max string
}

type DefaultWalletChooser

type DefaultWalletChooser struct{}

func (DefaultWalletChooser) Choose

func (w DefaultWalletChooser) Choose(ctx context.Context, wallets []model.Wallet) (model.Wallet, error)

type MinerInfo

type MinerInfo struct {
	PeerIDEncoded           string `json:"PeerID"`
	PeerID                  peer.ID
	MultiaddrsBase64Encoded []string `json:"Multiaddrs"`
	Multiaddrs              []multiaddr.Multiaddr
}

nolint: tagliatelle

type WalletChooser

type WalletChooser interface {
	Choose(ctx context.Context, wallets []model.Wallet) (model.Wallet, error)
}