p2p

Documentation

Overview

Package P2P represent a peer to peer linked on go-libp2p.

Index

• type EndPoint
  • func New(cfg config.P2P, per persistenceadapter.Adapter, wallets wallet.IWallets, ...) *EndPoint
  • func (e *EndPoint) Enabled() bool
  • func (e *EndPoint) Handle(err error)
  • func (e *EndPoint) HasTarget() bool
  • func (e *EndPoint) Listen(stop chan error)
  • func (e *EndPoint) PushMsgForFiles(stop chan error)
  • func (e *EndPoint) SetTarget(target string)
  • func (e *EndPoint) Shutdown()
  • func (e *EndPoint) Target() string
• type Option
  • func WithXCache(cfg config.XCache) Option

Types

type EndPoint

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

func New

func New(
	cfg config.P2P,
	per persistenceadapter.Adapter,
	wallets wallet.IWallets,
	logs *zap.Logger,
	evt *event.Event,
	opts ...Option,
) *EndPoint

New represent a new peer to peer adapter.

func (*EndPoint) Enabled

func (e *EndPoint) Enabled() bool

Enabled lets you know if the peer to peer system is activated.

func (*EndPoint) Handle

func (e *EndPoint) Handle(err error)

func (*EndPoint) HasTarget

func (e *EndPoint) HasTarget() bool

func (*EndPoint) Listen

func (e *EndPoint) Listen(stop chan error)

Listen start to listen the peer to peer connexion.

func (*EndPoint) PushMsgForFiles

func (e *EndPoint) PushMsgForFiles(stop chan error)

func (*EndPoint) SetTarget

func (e *EndPoint) SetTarget(target string)

func (*EndPoint) Shutdown

func (e *EndPoint) Shutdown()

func (*EndPoint) Target

func (e *EndPoint) Target() string

type Option

type Option func(e *EndPoint)

Option is the type of option passed to the constructor.

func WithXCache

func WithXCache(cfg config.XCache) Option

WithXCache offer the possibility to add a cache system to the peer to peer adapter.