mock

package

v1.3.6 Latest Latest Go to latest Published: May 25, 2022 License: BSD-3-Clause Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gauss-project/aurorafs

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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(boson.Address, time.Duration, string) error) Option

func WithBlocklistedPeersFunc ¶

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

WithBlocklistedPeersFunc sets the mock implementation of the BlocklistedPeers function

func WithConnectFunc ¶

func WithConnectFunc(f func(ctx context.Context, addr ma.Multiaddr) (peer *p2p.Peer, err error)) Option

WithConnectFunc sets the mock implementation of the Connect function

func WithDisconnectFunc ¶

func WithDisconnectFunc(f func(overlay boson.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 boson.Address, duration time.Duration, reason string) error

func (*Service) BlocklistRemove ¶ added in v1.3.2

func (s *Service) BlocklistRemove(overlay boson.Address) error

func (*Service) BlocklistedPeers ¶

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

func (*Service) CallHandler ¶ added in v1.2.0

func (s *Service) CallHandler(ctx context.Context, last p2p.Peer, stream p2p.Stream) (relayData *pb.RouteRelayReq, w *p2p.WriterChan, r *p2p.ReaderChan, forward bool, err error)

func (*Service) CallHandlerWithConnChain ¶ added in v1.3.5

func (s *Service) CallHandlerWithConnChain(ctx context.Context, last, src p2p.Peer, stream p2p.Stream, protocolName, protocolVersion, streamName string) error

func (*Service) Connect ¶

func (s *Service) Connect(ctx context.Context, addr ma.Multiaddr) (peer *p2p.Peer, err error)

func (*Service) Disconnect ¶

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

func (*Service) GetWelcomeMessage ¶

func (s *Service) GetWelcomeMessage() string

func (*Service) Halt ¶

func (s *Service) Halt()

func (*Service) NATAddresses ¶ added in v1.1.6

func (s *Service) NATAddresses() ([]net.Addr, error)

func (*Service) NetworkStatus ¶ added in v1.3.4

func (s *Service) NetworkStatus() p2p.NetworkStatus

NetworkStatus implements p2p.NetworkStatuser interface. It always returns p2p.NetworkStatusAvailable.

func (*Service) PeerID ¶ added in v1.3.3

func (s *Service) PeerID(overlay boson.Address) (id libp2ppeer.ID, found bool)

func (*Service) Peers ¶

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

func (*Service) ResourceManager ¶ added in v1.3.3

func (s *Service) ResourceManager() network.ResourceManager

func (*Service) SetConnectFunc ¶

func (s *Service) SetConnectFunc(f func(ctx context.Context, addr ma.Multiaddr) (peer *p2p.Peer, err error))

func (*Service) SetPickyNotifier ¶

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

func (*Service) SetWelcomeMessage ¶

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

Source Files ¶

View all Source files

mock.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL