tests

Documentation

Overview

Copyright (c) Microsoft Corporation. Licensed under the MIT License.

Index

• type MockRouter
  • func NewMockRouter(resolver map[string][]string) *MockRouter
  • func (m *MockRouter) Close() error
  • func (m *MockRouter) LookupKey(key string) ([]string, bool)
  • func (m *MockRouter) Net() peernet.Network
  • func (m *MockRouter) Provide(ctx context.Context, keys []string) error
  • func (m *MockRouter) Resolve(ctx context.Context, key string, allowSelf bool, count int) (<-chan routing.PeerInfo, error)
  • func (m *MockRouter) ResolveWithNegativeCacheCallback(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) 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) Provide

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

func (*MockRouter) Resolve

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

func (*MockRouter) ResolveWithNegativeCacheCallback

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

ResolveWithNegativeCacheCallback implements Router.