common

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.

func OpenStore ¶

func OpenStore(logger tmlog.Logger, home string, openOptions store.OpenOptions) (*store.Store, []func() error, error)