util

Documentation

Index

• func ComputeHeadsEdge(hs []LogHead) uint64
• func DefaultBoostrapPeers() []peer.AddrInfo
• func FreeLocalAddr() ma.Multiaddr
• func GenerateRandomBytes(n int) []byte
• func InstanceFromJSON(b []byte, i interface{})
• func JSONFromInstance(i interface{}) []byte
• func MakeToken(n int) string
• func MustParseAddr(str string) ma.Multiaddr
• func NewBadgerDatastore(dirPath, name string, lowMem bool) (kt.TxnDatastoreExtended, error)
• func NewContextCloser(cancel context.CancelFunc) io.Closer
• func ParseBootstrapPeers(addrs []string) ([]peer.AddrInfo, error)
• func SchemaFromInstance(i interface{}, expandedStruct bool) *jsonschema.Schema
• func SchemaFromSchemaString(s string) *jsonschema.Schema
• func SetJSONID(id core.InstanceID, json []byte) []byte
• func SetJSONProperty(name string, value interface{}, json []byte) []byte
• func SetLogLevels(systems map[string]logging.LogLevel) error
• func SetupDefaultLoggingConfig(repoPath string) error
• func TCPAddrFromMultiAddr(maddr ma.Multiaddr) (addr string, err error)
• type ContextCloser
  • func (cc ContextCloser) Close() error
• type Finalizer
  • func NewFinalizer() *Finalizer
  • func (r *Finalizer) Add(cs ...io.Closer)
  • func (r *Finalizer) Cleanup(err error) error
• type LogHead

Functions

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 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 NewContextCloser

func NewContextCloser(cancel context.CancelFunc) io.Closer

Transform context cancellation function to be used with finalizer.

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(repoPath string) error

SetupDefaultLoggingConfig sets up a standard logging configuration.

func TCPAddrFromMultiAddr

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

Types

type ContextCloser

type ContextCloser struct {
	// contains filtered or unexported fields
}

func (ContextCloser) Close

func (cc ContextCloser) Close() error

type Finalizer

type Finalizer struct {
	// contains filtered or unexported fields
}

func NewFinalizer

func NewFinalizer() *Finalizer

Finalizer collects resources for convenient cleanup.

func (*Finalizer) Add

func (r *Finalizer) Add(cs ...io.Closer)

func (*Finalizer) Cleanup

func (r *Finalizer) Cleanup(err error) error

type LogHead

type LogHead struct {
	LogID peer.ID
	Head  cid.Cid
}