mock

Documentation

Index

• func NewMockRouter(local *peer.Peer, dstore ds.Datastore) routing.IpfsRouting
• type MockRouter
  • func (mr *MockRouter) FindPeer(ctx context.Context, pid peer.ID) (*peer.Peer, error)
  • func (mr *MockRouter) FindProviders(ctx context.Context, key u.Key) ([]*peer.Peer, error)
  • func (mr *MockRouter) FindProvidersAsync(ctx context.Context, k u.Key, max int) <-chan *peer.Peer
  • func (mr *MockRouter) GetValue(ctx context.Context, key u.Key) ([]byte, error)
  • func (mr *MockRouter) Provide(_ context.Context, key u.Key) error
  • func (mr *MockRouter) PutValue(ctx context.Context, key u.Key, val []byte) error
  • func (mr *MockRouter) SetRoutingServer(rs RoutingServer)
• type RoutingServer
  • func VirtualRoutingServer() RoutingServer

Functions

func NewMockRouter

func NewMockRouter(local *peer.Peer, dstore ds.Datastore) routing.IpfsRouting

Types

type MockRouter

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

func (*MockRouter) FindPeer

func (mr *MockRouter) FindPeer(ctx context.Context, pid peer.ID) (*peer.Peer, error)

func (*MockRouter) FindProviders

func (mr *MockRouter) FindProviders(ctx context.Context, key u.Key) ([]*peer.Peer, error)

func (*MockRouter) FindProvidersAsync

func (mr *MockRouter) FindProvidersAsync(ctx context.Context, k u.Key, max int) <-chan *peer.Peer

func (*MockRouter) GetValue

func (mr *MockRouter) GetValue(ctx context.Context, key u.Key) ([]byte, error)

func (*MockRouter) Provide

func (mr *MockRouter) Provide(_ context.Context, key u.Key) error

func (*MockRouter) PutValue

func (mr *MockRouter) PutValue(ctx context.Context, key u.Key, val []byte) error

func (*MockRouter) SetRoutingServer

func (mr *MockRouter) SetRoutingServer(rs RoutingServer)

type RoutingServer

type RoutingServer interface {
	Announce(*peer.Peer, u.Key) error

	Providers(u.Key) []*peer.Peer

	Client(p *peer.Peer) routing.IpfsRouting
}

func VirtualRoutingServer

func VirtualRoutingServer() RoutingServer