common

Documentation

Index

• type LogstoreType
• type NetBoostrapper
  • func DefaultNetwork(opts ...NetOption) (NetBoostrapper, error)
• type NetConfig
• type NetOption
  • func WithConnectionManager(cm cconnmgr.ConnManager) NetOption
  • func WithNetBadgerPersistence(repoPath string) NetOption
  • func WithNetDebug(enabled bool) NetOption
  • func WithNetGRPCDialOptions(opts ...grpc.DialOption) NetOption
  • func WithNetGRPCServerOptions(opts ...grpc.ServerOption) NetOption
  • func WithNetHostAddr(addr ma.Multiaddr) NetOption
  • func WithNetLogstore(lt LogstoreType) NetOption
  • func WithNetMongoPersistence(uri, db string) NetOption
  • func WithNetPubSub(enabled bool) NetOption

Types

type LogstoreType

type LogstoreType string

const (
	LogstoreInMemory   LogstoreType = "in-memory"
	LogstorePersistent LogstoreType = "persistent"
	LogstoreHybrid     LogstoreType = "hybrid"
)

type NetBoostrapper

type NetBoostrapper interface {
	app.Net
	GetIpfsLite() *ipfslite.Peer
	Bootstrap(addrs []peer.AddrInfo)
}

DefaultNetwork is a boostrapable default Net with sane defaults.

func DefaultNetwork

func DefaultNetwork(opts ...NetOption) (NetBoostrapper, error)

type NetConfig

type NetConfig struct {
	HostAddr          ma.Multiaddr
	ConnManager       cconnmgr.ConnManager
	GRPCServerOptions []grpc.ServerOption
	GRPCDialOptions   []grpc.DialOption
	LSType            LogstoreType
	BadgerRepoPath    string
	MongoUri          string
	MongoDB           string
	PubSub            bool
	Debug             bool
}

type NetOption

type NetOption func(c *NetConfig) error

func WithConnectionManager

func WithConnectionManager(cm cconnmgr.ConnManager) NetOption

func WithNetBadgerPersistence

func WithNetBadgerPersistence(repoPath string) NetOption

func WithNetDebug

func WithNetDebug(enabled bool) NetOption

func WithNetGRPCDialOptions

func WithNetGRPCDialOptions(opts ...grpc.DialOption) NetOption

func WithNetGRPCServerOptions

func WithNetGRPCServerOptions(opts ...grpc.ServerOption) NetOption

func WithNetHostAddr

func WithNetHostAddr(addr ma.Multiaddr) NetOption

func WithNetLogstore

func WithNetLogstore(lt LogstoreType) NetOption

func WithNetMongoPersistence

func WithNetMongoPersistence(uri, db string) NetOption

func WithNetPubSub

func WithNetPubSub(enabled bool) NetOption