pkg

Documentation

Index

• Variables
• func CheckError(log *logging.ZapEventLogger, f func() error)
• func CheckErrors(fs ...func() error)
• func Init(root, port string) error
• type Common
  • func New(ctx context.Context, root, port string, en Encryption) (*Common, error)
  • func (comm *Common) GetPort() string
  • func (comm *Common) GetRoot() string
  • func (comm *Common) Start(key string, autoDownload bool) (<-chan struct{}, error)
  • func (comm *Common) Stop()
• type Encryption
• type Node

Variables

var (
	// ErrNoPeersConnected is returned if there is no peer connected
	ErrNoPeersConnected = errors.New("no Peers connected")

	// ErrNoPeerAddress re returned if peer address is not available
	ErrNoPeerAddress = errors.New("could not get peer address")
)

Functions

func CheckError

func CheckError(log *logging.ZapEventLogger, f func() error)

func CheckErrors

func CheckErrors(fs ...func() error)

func Init

func Init(root, port string) error

Types

type Common

type Common struct {
	Repo    repo.Repo
	Context context.Context

	Node       Node
	Encryption Encryption
	// contains filtered or unexported fields
}

Common features for cli commands

func New

func New(ctx context.Context, root, port string, en Encryption) (*Common, error)

func (*Common) GetPort

func (comm *Common) GetPort() string

func (*Common) GetRoot

func (comm *Common) GetRoot() string

func (*Common) Start

func (comm *Common) Start(key string, autoDownload bool) (<-chan struct{}, error)

func (*Common) Stop

func (comm *Common) Stop()

type Encryption

type Encryption interface {
	EncryptContent([]byte, string) ([]byte, error)
	DecryptContent([]byte, string) ([]byte, error)
}

type Node

type Node interface {
	Stop()
	NetworkNotifiee(network.Notifiee)
	Bootstrap([]peer.AddrInfo)
	NewFloodsubWithProtocols([]protocol.ID, ...pubsub.Option) (*pubsub.PubSub, error)
	Peers() []string
	Connect(peer.AddrInfo) error
	AddrInfo() *peer.AddrInfo
	IsOnline() bool
	ReplManager() *replication.Manager
	IsPeerConnected(string) bool
	GetPrivKey() crypto.PrivKey
	GetPubKey(id peer.ID) crypto.PubKey

	store.Store
}