Documentation
¶
Index ¶
Constants ¶
View Source
const DefaultWebsocketAddr = "/ip4/0.0.0.0/tcp/6747/ws"
Variables ¶
View Source
var DealProtocolsVersionsMap = map[string]protocol.ID{ // contains filtered or unexported fields }
View Source
var ErrEmptyPath = errors.New("node not initialized, please run configure")
View Source
var ErrNotInitialized = errors.New("node not initialized, please run configure")
Functions ¶
This section is empty.
Types ¶
type ConnectionManager ¶
type Deal ¶
type Deal struct {
FailOnTransferFailure bool `json:"fail_on_transfer_failure"`
IsDisabled bool `json:"disabled"`
IsVerified bool `json:"verified"`
Duration abi.ChainEpoch `json:"duration"`
EnabledDealProtocolsVersions map[protocol.ID]bool `json:"enabled_deal_protocol_versions"`
MaxVerifiedPrice big.Int `json:"max_verified_price"`
MaxPrice big.Int `json:"max_price"`
}
type Estuary ¶
type Estuary struct {
AppVersion string `json:"app_version"`
DatabaseConnString string `json:"database_conn_string"`
StagingDataDir string `json:"staging_data_dir"`
ServerCacheDir string `json:"server_cache_dir"`
DataDir string `json:"data_dir"`
ApiListen string `json:"api_listen"`
LightstepToken string `json:"lightstep_token"`
Hostname string `json:"hostname"`
DisableAutoRetrieve bool `json:"enable_autoretrieve"`
LowMem bool `json:"low_mem"`
DisableFilecoinStorage bool `json:"disable_filecoin_storage"`
DisableSwaggerEndpoint bool `json:"disable_swagger_endpoint"`
Node Node `json:"node"`
Jaeger Jaeger `json:"jaeger"`
Deal Deal `json:"deal"`
Content Content `json:"content"`
Logging Logging `json:"logging"`
StagingBucket StagingBucket `json:"staging_bucket"`
Replication int `json:"replication"`
RpcEngine RpcEngine `json:"rpc_engine"`
Pinning Pinning `json:"pinning"`
}
func NewEstuary ¶
func (*Estuary) SetRequiredOptions ¶
type EstuaryRemote ¶
type Node ¶
type Node struct {
ListenAddrs []string `json:"listen_addrs"`
AnnounceAddrs []string `json:"announce_addrs"`
PeeringPeers []peering.PeeringPeer `json:"peering_peers"`
IndexerAdvertisementInterval time.Duration `json:"indexer_advertisement_interval"`
AdvertiseOfflineAutoretrieves bool `json:"advertise_offline_autoretrieve"`
EnableWebsocketListenAddr bool `json:"enable_websocket_listen_addr"`
HardFlushWriteLog bool `json:"hard_flush_write_log"`
WriteLogTruncate bool `json:"write_log_truncate"`
NoBlockstoreCache bool `json:"no_blockstore_cache"`
NoLimiter bool `json:"no_limiter"`
IndexerURL string `json:"indexer_url"`
Blockstore string `json:"blockstore"`
WriteLogDir string `json:"write_log_dir"`
Libp2pKeyFile string `json:"libp2p_key_file"`
DatastoreDir string `json:"datastore_dir"`
WalletDir string `json:"wallet_dir"`
ApiURL string `json:"api_url"`
Libp2pThrottleLimit uint `json:"libp2p_http_server_throttle_limit"`
Bitswap Bitswap `json:"bitswap"`
Limits rcmgr.ScalingLimitConfig `json:"limits"`
ConnectionManager ConnectionManager `json:"connection_manager"`
}
type Pinning ¶ added in v0.2.0
type Pinning struct {
RetryWorker RetryWorker `json:"retry_worker"`
}
type QueueEngine ¶ added in v0.3.0
type RetryWorker ¶ added in v0.2.0
type RpcEngine ¶ added in v0.3.0
type RpcEngine struct {
Queue QueueEngine `json:"queue"`
Websocket WebsocketEngine `json:"websocket"`
}
type Shuttle ¶
type Shuttle struct {
AppVersion string `json:"app_version"`
DatabaseConnString string `json:"database_conn_string"`
StagingDataDir string `json:"staging_data_dir"`
DataDir string `json:"data_dir"`
ApiListen string `json:"api_listen"`
Hostname string `json:"hostname"`
Private bool `json:"private"`
Dev bool `json:"dev"`
NoReloadPinQueue bool `json:"no_reload_pin_queue"`
Node Node `json:"node"`
Jaeger Jaeger `json:"jaeger"`
Content Content `json:"content"`
Logging Logging `json:"logging"`
EstuaryRemote EstuaryRemote `json:"estuary_remote"`
RpcEngine RpcEngine `json:"rpc_engine"`
}
func NewShuttle ¶
func (*Shuttle) SetRequiredOptions ¶
type StagingBucket ¶ added in v0.1.9
type StagingBucket struct {
Enabled bool `json:"enabled"`
AggregateInterval time.Duration `json:"aggregate_interval"`
}
MinSize - minimum staging bucket size before it can be aggregated MaxSize - maximum staging bucket size before it can be aggregated AggregateInterval - interval to aggregate staging contents
type WebsocketEngine ¶ added in v0.3.0
Click to show internal directories.
Click to hide internal directories.