Documentation
¶
Index ¶
Constants ¶
View Source
const DefaultWebsocketAddr = "/ip4/0.0.0.0/tcp/6747/ws"
Variables ¶
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 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"`
EnableAutoRetrieve bool `json:"enable_autoretrieve"`
LightstepToken string `json:"lightstep_token"`
Hostname string `json:"hostname"`
Node Node `json:"node"`
Jaeger Jaeger `json:"jaeger"`
Deal Deal `json:"deal"`
Content Content `json:"content"`
LowMem bool `json:"low_mem"`
DisableFilecoinStorage bool `json:"disable_filecoin_storage"`
Replication int `json:"replication"`
Logging Logging `json:"logging"`
FilClient FilClient `json:"fil_client"`
}
func NewEstuary ¶
func (*Estuary) SetRequiredOptions ¶
type EstuaryRemote ¶
type EventRateLimiter ¶
type FilClient ¶
type FilClient struct {
EventRateLimiter EventRateLimiter `json:"event_rate_limiter"`
}
type Limits ¶
type Limits struct {
SystemLimit SystemLimit `json:"system_limit"`
TransientLimit TransientLimit `json:"transient_limit"`
}
type Node ¶
type Node struct {
ListenAddrs []string `json:"listen_addrs"`
AnnounceAddrs []string `json:"announce_addrs"`
EnableWebsocketListenAddr bool `json:"enable_websocket_listen_addr"`
Blockstore string `json:"blockstore"`
WriteLogDir string `json:"write_log_dir"`
HardFlushWriteLog bool `json:"hard_flush_write_log"`
WriteLogTruncate bool `json:"write_log_truncate"`
NoBlockstoreCache bool `json:"no_blockstore_cache"`
NoLimiter bool `json:"no_limiter"`
Libp2pKeyFile string `json:"libp2p_key_file"`
DatastoreDir string `json:"datastore_dir"`
WalletDir string `json:"wallet_dir"`
ApiURL string `json:"api_url"`
Bitswap Bitswap `json:"bitswap"`
Limits Limits `json:"limits"`
ConnectionManager ConnectionManager `json:"connection_manager"`
}
func (*Node) GetLimiter ¶
func (cfg *Node) GetLimiter() *rcmgr.BasicLimiter
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"`
FilClient FilClient `json:"fil_client"`
}
func NewShuttle ¶
func (*Shuttle) SetRequiredOptions ¶
type SystemLimit ¶
type SystemLimit struct {
MinMemory int64 `json:"min_memory"`
MaxMemory int64 `json:"max_memory"`
MemoryFraction float64 `json:"memory_fraction"`
StreamsInbound int `json:"streams_inbound"`
StreamsOutbound int `json:"streams_outbound"`
Streams int `json:"streams"`
ConnsInbound int `json:"conns_inbound"`
ConnsOutbound int `json:"conns_outbound"`
Conns int `json:"conns"`
FD int `json:"fd"`
}
Click to show internal directories.
Click to hide internal directories.