tests

Documentation

Index

• type MockRouter
  • func NewMockRouter(resolver map[string][]string) *MockRouter
  • func (m *MockRouter) Advertise(ctx context.Context, keys []string) error
  • func (m *MockRouter) Close() error
  • func (m *MockRouter) LookupKey(key string) ([]string, bool)
  • func (m *MockRouter) Net() peernet.Network
  • func (m *MockRouter) Resolve(ctx context.Context, key string, allowSelf bool, count int) (<-chan routing.PeerInfo, error)
  • func (m *MockRouter) ResolveWithCache(ctx context.Context, key string, allowSelf bool, count int) (<-chan routing.PeerInfo, func(), error)

Types

type MockRouter

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

func NewMockRouter

func NewMockRouter(resolver map[string][]string) *MockRouter

func (*MockRouter) Advertise

func (m *MockRouter) Advertise(ctx context.Context, keys []string) error

func (*MockRouter) Close

func (m *MockRouter) Close() error

func (*MockRouter) LookupKey

func (m *MockRouter) LookupKey(key string) ([]string, bool)

func (*MockRouter) Net

func (m *MockRouter) Net() peernet.Network

Net implements routing.Router.

func (*MockRouter) Resolve

func (m *MockRouter) Resolve(ctx context.Context, key string, allowSelf bool, count int) (<-chan routing.PeerInfo, error)

func (*MockRouter) ResolveWithCache

func (m *MockRouter) ResolveWithCache(ctx context.Context, key string, allowSelf bool, count int) (<-chan routing.PeerInfo, func(), error)

ResolveWithCache implements Router.