nodebuilder

Aug 7, 2024

Changes in this version

+ const TestKeyringName1

type Node

+ BlobstreamMod blobstream.Module

Jun 14, 2024

Changes in this version

+ var DefaultNodeStorePath = func(tp, network string) (string, error)

+ var ErrNoOpenStore = errors.New("no opened Node Store found (no node is running)")

+ func DiscoverOpened() (string, error)

+ func IsOpened(path string) (bool, error)

type Config

+ Pruner pruner.Config

type Node

+ EDSStore *eds.Store

Jun 11, 2024

Changes in this version

+ const TestKeyringName

Feb 6, 2024

Changes in this version

type Node

+ DAMod da.Module

Oct 16, 2023

Changes in this version

+ var PrintKeyringInfo = true

+ func WithTraces(opts []otlptracehttp.Option, pyroOpts []otelpyroscope.Option) fx.Option

type Config

+ Node node.Config

type Node

+ AdminServ node.Module

+ AdminSigner jwt.Signer

+ BlobServ blob.Module

Jun 2, 2023

Changes in this version

+ var DefaultLifecycleTimeout = time.Minute * 2

Apr 17, 2023

Changes in this version

+ func RemoveConfig(path string) (err error)

+ func UpdateConfig(tp node.Type, path string) (err error)

Apr 14, 2023

Changes in this version

+ func Reset(path string, tp node.Type) error

Apr 5, 2023

Changes in this version

+ func WithP2PMetrics() fx.Option

+ func WithPyroscope(endpoint string, nodeType node.Type) fx.Option

Dec 13, 2022

Changes in this version

+ var PackageToAPI = map[string]interface

type Config

+ DASer das.Config

+ Gateway gateway.Config

type Node

+ GatewayServer *gateway.Server

Oct 17, 2022

Changes in this version

+ const Timeout

+ var ErrNotInited = errors.New("node: store is not initialized")

+ var ErrOpened = errors.New("node: store is in use")

+ func ConstructModule(tp node.Type, cfg *Config, store Store) fx.Option

+ func Init(cfg Config, path string, tp node.Type) error

+ func IsInit(path string) bool

+ func SaveConfig(path string, cfg *Config) error

+ func TestKeyringSigner(t *testing.T) *apptypes.KeyringSigner

+ func WithBootstrappers(peers params.Bootstrappers) fx.Option

+ func WithMetrics(metricOpts []otlpmetrichttp.Option, nodeType node.Type) fx.Option

+ func WithNetwork(net params.Network) fx.Option

+ type Config struct

+ Core core.Config

+ Header header.Config

+ P2P p2p.Config

+ RPC rpc.Config

+ Share share.Config

+ State state.Config

+ func DefaultConfig(tp node.Type) *Config

+ func LoadConfig(path string) (*Config, error)

+ func (cfg *Config) Decode(r io.Reader) error

+ func (cfg *Config) Encode(w io.Writer) error

+ type ConfigLoader func() (*Config, error)

+ type Node struct

+ BlockService blockservice.BlockService

+ Bootstrappers params.Bootstrappers

+ Config *Config

+ ConnGater *conngater.BasicConnectionGater

+ DASer *das.DASer

+ DataExchange exchange.Interface

+ FraudServ fraud.Module

+ HeaderServ header.Module

+ Host host.Host

+ Network params.Network

+ PubSub *pubsub.PubSub

+ RPCServer *rpc.Server

+ Routing routing.PeerRouting

+ ShareServ share.Module

+ StateServ state.Module

+ Type node.Type

+ func New(tp node.Type, store Store, options ...fx.Option) (*Node, error)

+ func NewWithConfig(tp node.Type, store Store, cfg *Config, options ...fx.Option) (*Node, error)

+ func TestNode(t *testing.T, tp node.Type, opts ...fx.Option) *Node

+ func TestNodeWithConfig(t *testing.T, tp node.Type, cfg *Config, opts ...fx.Option) *Node

+ func (n *Node) Run(ctx context.Context) error

+ func (n *Node) Start(ctx context.Context) error

+ func (n *Node) Stop(ctx context.Context) error

+ type Store interface

+ Close func() error

+ Config func() (*Config, error)

+ Datastore func() (datastore.Batching, error)

+ Keystore func() (keystore.Keystore, error)

+ Path func() string

+ PutConfig func(*Config) error

+ func MockStore(t *testing.T, cfg *Config) Store

+ func NewMemStore() Store

+ func OpenStore(path string) (Store, error)