Documentation ¶
Index ¶
- func CreateDHTAndWaitForPeers(ctx context.Context, logger tmlog.Logger, p2pKeyStore *keystore2.FSKeystore, ...) (*p2p.BlobstreamDHT, error)
- func NewTmAndAppQuerier(logger tmlog.Logger, tendermintRPC string, celesGRPC string, grpcInsecure bool) (*rpc.TmQuerier, *rpc.AppQuerier, []func() error, error)
- func OpenStore(logger tmlog.Logger, home string, openOptions store.OpenOptions) (*store.Store, []func() error, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateDHTAndWaitForPeers ¶
func CreateDHTAndWaitForPeers( ctx context.Context, logger tmlog.Logger, p2pKeyStore *keystore2.FSKeystore, p2pNickname string, p2pListenAddr string, bootstrappers string, dataStore ds.Batching, registerer prometheus.Registerer, ) (*p2p.BlobstreamDHT, error)
CreateDHTAndWaitForPeers helper function that creates a new Blobstream DHT and waits for some peers to connect to it.
func NewTmAndAppQuerier ¶
func NewTmAndAppQuerier(logger tmlog.Logger, tendermintRPC string, celesGRPC string, grpcInsecure bool) (*rpc.TmQuerier, *rpc.AppQuerier, []func() error, error)
NewTmAndAppQuerier helper function that creates a new TmQuerier and AppQuerier and registers their stop functions in the stopFuncs slice.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.