mocks

Documentation

Index

• type MockDiscoveryClient
  • func NewDiscoveryClient(h host.Host, server *MockDiscoveryServer) *MockDiscoveryClient
  • func (d *MockDiscoveryClient) Advertise(ctx context.Context, ns string, opts ...discovery.Option) (time.Duration, error)
  • func (d *MockDiscoveryClient) FindPeers(ctx context.Context, ns string, opts ...discovery.Option) (<-chan peer.AddrInfo, error)
• type MockDiscoveryServer
  • func NewDiscoveryServer(clock clock) *MockDiscoveryServer
  • func (s *MockDiscoveryServer) Advertise(ns string, info peer.AddrInfo, ttl time.Duration) (time.Duration, error)
  • func (s *MockDiscoveryServer) FindPeers(ns string, limit int) (<-chan peer.AddrInfo, error)

Types

type MockDiscoveryClient

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

func NewDiscoveryClient

func NewDiscoveryClient(h host.Host, server *MockDiscoveryServer) *MockDiscoveryClient

func (*MockDiscoveryClient) Advertise

func (d *MockDiscoveryClient) Advertise(ctx context.Context, ns string, opts ...discovery.Option) (time.Duration, error)

func (*MockDiscoveryClient) FindPeers

func (d *MockDiscoveryClient) FindPeers(ctx context.Context, ns string, opts ...discovery.Option) (<-chan peer.AddrInfo, error)

type MockDiscoveryServer

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

func NewDiscoveryServer

func NewDiscoveryServer(clock clock) *MockDiscoveryServer

func (*MockDiscoveryServer) Advertise

func (s *MockDiscoveryServer) Advertise(ns string, info peer.AddrInfo, ttl time.Duration) (time.Duration, error)

func (*MockDiscoveryServer) FindPeers

func (s *MockDiscoveryServer) FindPeers(ns string, limit int) (<-chan peer.AddrInfo, error)