mock

Documentation

Index

• type Option
  • func WithAddProtocolFunc(f func(p2p.ProtocolSpec) error) Option
  • func WithAddressesFunc(f func() ([]ma.Multiaddr, error)) Option
  • func WithBlocklistFunc(f func(swarm.Address, time.Duration, string) error) Option
  • func WithBlocklistedPeersFunc(f func() ([]p2p.Peer, error)) Option
  • func WithConnectFunc(...) Option
  • func WithDisconnectFunc(f func(overlay swarm.Address, reason string) error) Option
  • func WithGetWelcomeMessageFunc(f func() string) Option
  • func WithPeersFunc(f func() []p2p.Peer) Option
  • func WithSetWelcomeMessageFunc(f func(string) error) Option
• type Service
  • func New(opts ...Option) *Service
  • func (s *Service) AddProtocol(spec p2p.ProtocolSpec) error
  • func (s *Service) Addresses() ([]ma.Multiaddr, error)
  • func (s *Service) Blocklist(overlay swarm.Address, duration time.Duration, reason string) error
  • func (s *Service) BlocklistedPeers() ([]p2p.Peer, error)
  • func (s *Service) Connect(ctx context.Context, addr ma.Multiaddr) (address *bzz.Address, err error)
  • func (s *Service) Disconnect(overlay swarm.Address, reason string) error
  • func (s *Service) GetWelcomeMessage() string
  • func (s *Service) Halt()
  • func (s *Service) Peers() []p2p.Peer
  • func (s *Service) SetPickyNotifier(f p2p.PickyNotifier)
  • func (s *Service) SetWelcomeMessage(val string) error

Types

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithAddProtocolFunc

func WithAddProtocolFunc(f func(p2p.ProtocolSpec) error) Option

WithAddProtocolFunc sets the mock implementation of the AddProtocol function

func WithAddressesFunc

func WithAddressesFunc(f func() ([]ma.Multiaddr, error)) Option

WithAddressesFunc sets the mock implementation of the Adresses function

func WithBlocklistFunc

func WithBlocklistFunc(f func(swarm.Address, time.Duration, string) error) Option

func WithBlocklistedPeersFunc

func WithBlocklistedPeersFunc(f func() ([]p2p.Peer, error)) Option

WithBlocklistedPeersFunc sets the mock implementation of the BlocklistedPeers function

func WithConnectFunc

func WithConnectFunc(f func(ctx context.Context, addr ma.Multiaddr) (address *bzz.Address, err error)) Option

WithConnectFunc sets the mock implementation of the Connect function

func WithDisconnectFunc

func WithDisconnectFunc(f func(overlay swarm.Address, reason string) error) Option

WithDisconnectFunc sets the mock implementation of the Disconnect function

func WithGetWelcomeMessageFunc

func WithGetWelcomeMessageFunc(f func() string) Option

WithGetWelcomeMessageFunc sets the mock implementation of the GetWelcomeMessage function

func WithPeersFunc

func WithPeersFunc(f func() []p2p.Peer) Option

WithPeersFunc sets the mock implementation of the Peers function

func WithSetWelcomeMessageFunc

func WithSetWelcomeMessageFunc(f func(string) error) Option

WithSetWelcomeMessageFunc sets the mock implementation of the SetWelcomeMessage function

type Service

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

Service is the mock of a P2P Service

func New

func New(opts ...Option) *Service

New will create a new mock P2P Service with the given options

func (*Service) AddProtocol

func (s *Service) AddProtocol(spec p2p.ProtocolSpec) error

func (*Service) Addresses

func (s *Service) Addresses() ([]ma.Multiaddr, error)

func (*Service) Blocklist

func (s *Service) Blocklist(overlay swarm.Address, duration time.Duration, reason string) error

func (*Service) BlocklistedPeers

func (s *Service) BlocklistedPeers() ([]p2p.Peer, error)

func (*Service) Connect

func (s *Service) Connect(ctx context.Context, addr ma.Multiaddr) (address *bzz.Address, err error)

func (*Service) Disconnect

func (s *Service) Disconnect(overlay swarm.Address, reason string) error

func (*Service) GetWelcomeMessage

func (s *Service) GetWelcomeMessage() string

func (*Service) Halt

func (s *Service) Halt()

func (*Service) Peers

func (s *Service) Peers() []p2p.Peer

func (*Service) SetPickyNotifier

func (s *Service) SetPickyNotifier(f p2p.PickyNotifier)

func (*Service) SetWelcomeMessage

func (s *Service) SetWelcomeMessage(val string) error