lotus/node/config/def.go

377 lines
10 KiB
Go
Raw Normal View History

package config
import (
"encoding"
"time"
"github.com/ipfs/go-cid"
2021-06-08 13:43:43 +00:00
"github.com/filecoin-project/go-state-types/abi"
"github.com/filecoin-project/go-state-types/big"
2021-05-19 12:32:41 +00:00
miner5 "github.com/filecoin-project/specs-actors/v5/actors/builtin/miner"
2020-08-12 17:47:00 +00:00
"github.com/filecoin-project/lotus/chain/types"
2020-08-17 13:39:33 +00:00
sectorstorage "github.com/filecoin-project/lotus/extern/sector-storage"
)
// Common is common config between full node and miner
type Common struct {
API API
2021-03-09 21:33:01 +00:00
Backup Backup
Libp2p Libp2p
2020-05-04 15:30:54 +00:00
Pubsub Pubsub
}
2019-10-11 02:45:45 +00:00
// FullNode is a full node config
type FullNode struct {
Common
Client Client
Metrics Metrics
Wallet Wallet
Fees FeeConfig
Chainstore Chainstore
}
2019-11-12 17:59:38 +00:00
// // Common
2021-03-09 21:33:01 +00:00
type Backup struct {
DisableMetadataLog bool
}
// StorageMiner is a miner config
type StorageMiner struct {
Common
2019-11-12 17:59:38 +00:00
2020-08-12 17:47:00 +00:00
Dealmaking DealmakingConfig
2020-08-18 14:20:31 +00:00
Sealing SealingConfig
2020-08-12 17:47:00 +00:00
Storage sectorstorage.SealerConfig
Fees MinerFeeConfig
Addresses MinerAddressConfig
}
type DealmakingConfig struct {
ConsiderOnlineStorageDeals bool
ConsiderOfflineStorageDeals bool
ConsiderOnlineRetrievalDeals bool
ConsiderOfflineRetrievalDeals bool
ConsiderVerifiedStorageDeals bool
ConsiderUnverifiedStorageDeals bool
PieceCidBlocklist []cid.Cid
ExpectedSealDuration Duration
2021-01-08 15:28:38 +00:00
// The amount of time to wait for more deals to arrive before
// publishing
PublishMsgPeriod Duration
2021-01-08 15:28:38 +00:00
// The maximum number of deals to include in a single PublishStorageDeals
// message
MaxDealsPerPublishMsg uint64
// The maximum collateral that the provider will put up against a deal,
// as a multiplier of the minimum collateral bound
MaxProviderCollateralMultiplier uint64
2020-07-30 17:36:31 +00:00
Filter string
RetrievalFilter string
}
2020-08-18 14:20:31 +00:00
type SealingConfig struct {
// 0 = no limit
MaxWaitDealsSectors uint64
// includes failed, 0 = no limit
MaxSealingSectors uint64
// includes failed, 0 = no limit
MaxSealingSectorsForDeals uint64
2020-08-18 14:20:31 +00:00
WaitDealsDelay Duration
2021-01-18 13:26:03 +00:00
AlwaysKeepUnsealedCopy bool
2021-05-25 14:20:49 +00:00
// enable / disable precommit batching (takes effect after nv13)
2021-05-25 14:26:59 +00:00
BatchPreCommits bool
2021-05-25 14:20:49 +00:00
// maximum precommit batch size - batches will be sent immediately above this size
2021-05-25 14:26:59 +00:00
MaxPreCommitBatch int
MinPreCommitBatch int
2021-05-25 14:20:49 +00:00
// how long to wait before submitting a batch after crossing the minimum batch size
2021-05-25 14:26:59 +00:00
PreCommitBatchWait Duration
2021-05-25 14:20:49 +00:00
// time buffer for forceful batch submission before sectors in batch would start expiring
2021-05-18 14:51:06 +00:00
PreCommitBatchSlack Duration
2021-05-25 14:20:49 +00:00
// enable / disable commit aggregation (takes effect after nv13)
2021-03-10 15:16:44 +00:00
AggregateCommits bool
2021-05-25 14:20:49 +00:00
// maximum batched commit size - batches will be sent immediately above this size
2021-05-25 14:26:59 +00:00
MinCommitBatch int
MaxCommitBatch int
2021-05-25 14:20:49 +00:00
// how long to wait before submitting a batch after crossing the minimum batch size
2021-05-25 14:26:59 +00:00
CommitBatchWait Duration
2021-05-25 14:20:49 +00:00
// time buffer for forceful batch submission before sectors in batch would start expiring
2021-05-18 14:51:06 +00:00
CommitBatchSlack Duration
TerminateBatchMax uint64
TerminateBatchMin uint64
TerminateBatchWait Duration
2021-03-10 15:16:44 +00:00
2021-01-18 13:26:03 +00:00
// Keep this many sectors in sealing pipeline, start CC if needed
// todo TargetSealingSectors uint64
// todo TargetSectors - stop auto-pleding new sectors after this many sectors are sealed, default CC upgrade for deals sectors if above
2020-08-18 14:20:31 +00:00
}
2021-06-08 13:43:43 +00:00
type BatchFeeConfig struct {
Base types.FIL
PerSector types.FIL
}
func (b *BatchFeeConfig) FeeForSectors(nSectors int) abi.TokenAmount {
return big.Add(big.Int(b.Base), big.Mul(big.NewInt(int64(nSectors)), big.Int(b.PerSector)))
}
2020-08-12 17:47:00 +00:00
type MinerFeeConfig struct {
2021-06-08 13:43:43 +00:00
MaxPreCommitGasFee types.FIL
MaxCommitGasFee types.FIL
// maxBatchFee = maxBase + maxPerSector * nSectors
MaxPreCommitBatchGasFee BatchFeeConfig
MaxCommitBatchGasFee BatchFeeConfig
2021-01-12 23:42:01 +00:00
MaxTerminateGasFee types.FIL
2020-10-02 16:34:50 +00:00
MaxWindowPoStGasFee types.FIL
MaxPublishDealsFee types.FIL
MaxMarketBalanceAddFee types.FIL
2020-08-12 17:47:00 +00:00
}
type MinerAddressConfig struct {
PreCommitControl []string
CommitControl []string
TerminateControl []string
// DisableOwnerFallback disables usage of the owner address for messages
// sent automatically
DisableOwnerFallback bool
// DisableWorkerFallback disables usage of the worker address for messages
2021-03-09 22:42:08 +00:00
// sent automatically, if control addresses are configured.
// A control address that doesn't have enough funds will still be chosen
// over the worker address if this flag is set.
DisableWorkerFallback bool
}
// API contains configs for API endpoint
type API struct {
ListenAddress string
RemoteListenAddress string
Timeout Duration
}
// Libp2p contains configs for libp2p
type Libp2p struct {
ListenAddresses []string
AnnounceAddresses []string
NoAnnounceAddresses []string
BootstrapPeers []string
ProtectedPeers []string
2019-12-17 16:09:43 +00:00
ConnMgrLow uint
ConnMgrHigh uint
ConnMgrGrace Duration
}
2020-05-04 15:30:54 +00:00
type Pubsub struct {
Bootstrapper bool
DirectPeers []string
IPColocationWhitelist []string
RemoteTracer string
2020-05-04 15:30:54 +00:00
}
type Chainstore struct {
EnableSplitstore bool
Splitstore Splitstore
}
type Splitstore struct {
2021-02-28 07:59:11 +00:00
HotStoreType string
TrackingStoreType string
MarkSetType string
EnableFullCompaction bool
EnableGC bool // EXPERIMENTAL
Archival bool
}
2019-11-12 17:59:38 +00:00
// // Full Node
2019-10-11 02:45:45 +00:00
type Metrics struct {
2020-05-04 15:30:54 +00:00
Nickname string
HeadNotifs bool
2019-10-11 02:45:45 +00:00
}
type Client struct {
UseIpfs bool
IpfsOnlineMode bool
IpfsMAddr string
IpfsUseForRetrieval bool
SimultaneousTransfers uint64
}
2020-09-05 19:36:32 +00:00
type Wallet struct {
RemoteBackend string
EnableLedger bool
DisableLocal bool
2020-09-05 19:36:32 +00:00
}
2020-10-29 19:50:04 +00:00
type FeeConfig struct {
DefaultMaxFee types.FIL
}
func defCommon() Common {
return Common{
API: API{
ListenAddress: "/ip4/127.0.0.1/tcp/1234/http",
Timeout: Duration(30 * time.Second),
},
Libp2p: Libp2p{
ListenAddresses: []string{
"/ip4/0.0.0.0/tcp/0",
"/ip6/::/tcp/0",
},
AnnounceAddresses: []string{},
NoAnnounceAddresses: []string{},
2019-12-17 16:09:43 +00:00
ConnMgrLow: 150,
ConnMgrHigh: 180,
2019-12-17 16:09:43 +00:00
ConnMgrGrace: Duration(20 * time.Second),
},
2020-05-04 15:30:54 +00:00
Pubsub: Pubsub{
Bootstrapper: false,
DirectPeers: nil,
2020-08-24 15:01:52 +00:00
RemoteTracer: "/dns4/pubsub-tracer.filecoin.io/tcp/4001/p2p/QmTd6UvR47vUidRNZ1ZKXHrAFhqTJAD27rKL9XYghEKgKX",
2020-05-04 15:30:54 +00:00
},
}
}
2020-10-29 19:50:04 +00:00
var DefaultDefaultMaxFee = types.MustParseFIL("0.007")
var DefaultSimultaneousTransfers = uint64(20)
2020-10-29 19:50:04 +00:00
// DefaultFullNode returns the default config
func DefaultFullNode() *FullNode {
return &FullNode{
Common: defCommon(),
2020-10-29 19:50:04 +00:00
Fees: FeeConfig{
DefaultMaxFee: DefaultDefaultMaxFee,
},
Client: Client{
SimultaneousTransfers: DefaultSimultaneousTransfers,
},
Chainstore: Chainstore{
EnableSplitstore: false,
Splitstore: Splitstore{
HotStoreType: "badger",
},
},
}
}
func DefaultStorageMiner() *StorageMiner {
cfg := &StorageMiner{
Common: defCommon(),
2020-08-18 16:27:28 +00:00
2020-08-18 14:20:31 +00:00
Sealing: SealingConfig{
MaxWaitDealsSectors: 2, // 64G with 32G sectors
MaxSealingSectors: 0,
MaxSealingSectorsForDeals: 0,
WaitDealsDelay: Duration(time.Hour * 6),
AlwaysKeepUnsealedCopy: true,
2021-03-10 15:16:44 +00:00
2021-05-18 14:51:06 +00:00
BatchPreCommits: true,
2021-05-19 13:20:34 +00:00
MinPreCommitBatch: 1, // we must have at least one proof to aggregate
MaxPreCommitBatch: miner5.PreCommitSectorBatchMaxSize, //
PreCommitBatchWait: Duration(24 * time.Hour), // this can be up to 6 days
2021-05-18 19:04:47 +00:00
PreCommitBatchSlack: Duration(3 * time.Hour),
2021-05-18 14:51:06 +00:00
AggregateCommits: true,
MinCommitBatch: miner5.MinAggregatedSectors, // we must have at least four proofs to aggregate
2021-05-19 13:20:34 +00:00
MaxCommitBatch: miner5.MaxAggregatedSectors, // this is the maximum aggregation per FIP13
CommitBatchWait: Duration(24 * time.Hour), // this can be up to 6 days
2021-05-18 19:04:47 +00:00
CommitBatchSlack: Duration(1 * time.Hour),
2021-05-18 14:51:06 +00:00
2021-05-18 11:30:47 +00:00
TerminateBatchMin: 1,
TerminateBatchMax: 100,
2021-05-18 14:51:06 +00:00
TerminateBatchWait: Duration(5 * time.Minute),
2020-08-18 14:20:31 +00:00
},
2019-11-12 17:59:38 +00:00
Storage: sectorstorage.SealerConfig{
2020-08-17 09:39:29 +00:00
AllowAddPiece: true,
AllowPreCommit1: true,
AllowPreCommit2: true,
AllowCommit: true,
AllowUnseal: true,
// Default to 10 - tcp should still be able to figure this out, and
// it's the ratio between 10gbit / 1gbit
ParallelFetchLimit: 10,
},
Dealmaking: DealmakingConfig{
ConsiderOnlineStorageDeals: true,
ConsiderOfflineStorageDeals: true,
ConsiderOnlineRetrievalDeals: true,
ConsiderOfflineRetrievalDeals: true,
ConsiderVerifiedStorageDeals: true,
ConsiderUnverifiedStorageDeals: true,
PieceCidBlocklist: []cid.Cid{},
// TODO: It'd be nice to set this based on sector size
ExpectedSealDuration: Duration(time.Hour * 24),
PublishMsgPeriod: Duration(time.Hour),
MaxDealsPerPublishMsg: 8,
MaxProviderCollateralMultiplier: 2,
},
2020-08-12 17:47:00 +00:00
Fees: MinerFeeConfig{
2021-06-08 13:43:43 +00:00
MaxPreCommitGasFee: types.MustParseFIL("0.025"),
MaxCommitGasFee: types.MustParseFIL("0.05"),
MaxPreCommitBatchGasFee: BatchFeeConfig{
Base: types.MustParseFIL("0.025"), // todo: come up with good values
PerSector: types.MustParseFIL("0.025"),
},
MaxCommitBatchGasFee: BatchFeeConfig{
Base: types.MustParseFIL("0.05"),
PerSector: types.MustParseFIL("0.05"),
},
2021-01-12 23:42:01 +00:00
MaxTerminateGasFee: types.MustParseFIL("0.5"),
2020-10-15 00:46:47 +00:00
MaxWindowPoStGasFee: types.MustParseFIL("5"),
MaxPublishDealsFee: types.MustParseFIL("0.05"),
MaxMarketBalanceAddFee: types.MustParseFIL("0.007"),
2020-08-12 17:47:00 +00:00
},
2020-12-02 20:54:38 +00:00
Addresses: MinerAddressConfig{
PreCommitControl: []string{},
CommitControl: []string{},
},
}
cfg.Common.API.ListenAddress = "/ip4/127.0.0.1/tcp/2345/http"
cfg.Common.API.RemoteListenAddress = "127.0.0.1:2345"
return cfg
}
var _ encoding.TextMarshaler = (*Duration)(nil)
var _ encoding.TextUnmarshaler = (*Duration)(nil)
// Duration is a wrapper type for time.Duration
// for decoding and encoding from/to TOML
type Duration time.Duration
// UnmarshalText implements interface for TOML decoding
func (dur *Duration) UnmarshalText(text []byte) error {
d, err := time.ParseDuration(string(text))
if err != nil {
return err
}
*dur = Duration(d)
return err
}
func (dur Duration) MarshalText() ([]byte, error) {
d := time.Duration(dur)
return []byte(d.String()), nil
}