util

func ComputeAddrsEdge ¶

func ComputeAddrsEdge(as []PeerAddr) uint64

func ComputeHeadsEdge ¶

func ComputeHeadsEdge(hs []LogHead) uint64

func DefaultBoostrapPeers ¶

func DefaultBoostrapPeers() []peer.AddrInfo

func FreeLocalAddr ¶

func FreeLocalAddr() ma.Multiaddr

func GenerateRandomBytes ¶

func GenerateRandomBytes(n int) []byte

func InstanceFromJSON ¶

func InstanceFromJSON(b []byte, i interface{})

func JSONFromInstance ¶

func JSONFromInstance(i interface{}) []byte

func LevelFromDebugFlag ¶

func LevelFromDebugFlag(debug bool) logging.LogLevel

LevelFromDebugFlag returns the debug or info log level.

func MakeToken ¶

func MakeToken(n int) string

func MustParseAddr ¶

func MustParseAddr(str string) ma.Multiaddr

func NewBadgerDatastore ¶

func NewBadgerDatastore(dirPath, name string, lowMem bool) (kt.TxnDatastoreExtended, error)

NewBadgerDatastore returns a badger based datastore.

func NewDatastore ¶ added in v0.0.2

func NewDatastore(repoPath string, opts *badger.Options) (kt.TxnDatastoreExtended, error)

NewDatastore returns a badger based datastore.

func ParseBootstrapPeers ¶

func ParseBootstrapPeers(addrs []string) ([]peer.AddrInfo, error)

func SchemaFromInstance ¶

func SchemaFromInstance(i interface{}, expandedStruct bool) *jsonschema.Schema

func SchemaFromSchemaString ¶

func SchemaFromSchemaString(s string) *jsonschema.Schema

func SetJSONID ¶

func SetJSONID(id core.InstanceID, json []byte) []byte

func SetJSONProperty ¶

func SetJSONProperty(name string, value interface{}, json []byte) []byte

func SetLogLevels ¶

func SetLogLevels(systems map[string]logging.LogLevel) error

SetLogLevels sets levels for the given systems.

func SetupDefaultLoggingConfig ¶

func SetupDefaultLoggingConfig(file string) error

SetupDefaultLoggingConfig sets up a standard logging configuration.

func StopGRPCServer ¶

func StopGRPCServer(server *grpc.Server)

func TCPAddrFromMultiAddr ¶

func TCPAddrFromMultiAddr(maddr ma.Multiaddr) (addr string, err error)