util

Documentation

Index

• func CanDial(addr ma.Multiaddr, s *swarm.Swarm) bool
• 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 LoadKey(pth string) crypto.PrivKey
• func MustParseAddr(str string) ma.Multiaddr
• 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

Functions

func CanDial

func CanDial(addr ma.Multiaddr, s *swarm.Swarm) bool

CanDial returns whether or not the address is dialable.

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 LoadKey

func LoadKey(pth string) crypto.PrivKey

func MustParseAddr

func MustParseAddr(str string) ma.Multiaddr

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