discovery

Documentation

Overview

Package discovery is a generated GoMock package.

Index

• type Discovery
  • func New(peerKey ed25519.PrivateKey, node *vnode.Node, bootNodes, bootSeeds []string, ...) *Discovery
  • func (d *Discovery) Delete(id vnode.NodeID, reason error)
  • func (d *Discovery) GetNodes(count int) (nodes []*vnode.Node)
  • func (d *Discovery) Nodes() []*vnode.Node
  • func (d *Discovery) NodesCount() int
  • func (d *Discovery) SetFinder(f Finder)
  • func (d *Discovery) Start() (err error)
  • func (d *Discovery) Stop() (err error)
  • func (d *Discovery) SubscribeNode(receiver func(n *vnode.Node)) (subId int)
  • func (d *Discovery) Unsubscribe(subId int)
• type Finder
• type Mockreceiver
  • func NewMockreceiver(ctrl *gomock.Controller) *Mockreceiver
  • func (m *Mockreceiver) EXPECT() *MockreceiverMockRecorder
• type MockreceiverMockRecorder
• type Mocksender
  • func NewMocksender(ctrl *gomock.Controller) *Mocksender
  • func (m *Mocksender) EXPECT() *MocksenderMockRecorder
• type MocksenderMockRecorder
• type Mocksocket
  • func NewMocksocket(ctrl *gomock.Controller) *Mocksocket
  • func (m *Mocksocket) EXPECT() *MocksocketMockRecorder
• type MocksocketMockRecorder
• type Node
• type NodeDB
• type Observer
• type Request
• type Result
• type Subscriber

Types

type Discovery

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

func New

func New(peerKey ed25519.PrivateKey, node *vnode.Node, bootNodes, bootSeeds []string, listenAddress string, db NodeDB) *Discovery

New create a Discovery implementation

func (*Discovery) Delete

func (d *Discovery) Delete(id vnode.NodeID, reason error)

func (*Discovery) GetNodes

func (d *Discovery) GetNodes(count int) (nodes []*vnode.Node)

func (*Discovery) Nodes

func (d *Discovery) Nodes() []*vnode.Node

func (*Discovery) NodesCount

func (d *Discovery) NodesCount() int

func (*Discovery) SetFinder

func (d *Discovery) SetFinder(f Finder)

func (*Discovery) Start

func (d *Discovery) Start() (err error)

func (*Discovery) Stop

func (d *Discovery) Stop() (err error)

func (*Discovery) SubscribeNode

func (d *Discovery) SubscribeNode(receiver func(n *vnode.Node)) (subId int)

func (*Discovery) Unsubscribe

func (d *Discovery) Unsubscribe(subId int)

type Finder

type Finder interface {
	Observer
	SetResolver(discv interface {
		GetNodes(count int) (nodes []*vnode.Node)
	})
	FindNeighbors(fromId, target vnode.NodeID, count int) []*vnode.EndPoint
}

type Mockreceiver

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

Mockreceiver is a mock of receiver interface.

func NewMockreceiver

func NewMockreceiver(ctrl *gomock.Controller) *Mockreceiver

NewMockreceiver creates a new mock instance.

func (*Mockreceiver) EXPECT

func (m *Mockreceiver) EXPECT() *MockreceiverMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockreceiverMockRecorder

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

MockreceiverMockRecorder is the mock recorder for Mockreceiver.

type Mocksender

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

Mocksender is a mock of sender interface.

func NewMocksender

func NewMocksender(ctrl *gomock.Controller) *Mocksender

NewMocksender creates a new mock instance.

func (*Mocksender) EXPECT

func (m *Mocksender) EXPECT() *MocksenderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MocksenderMockRecorder

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

MocksenderMockRecorder is the mock recorder for Mocksender.

type Mocksocket

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

Mocksocket is a mock of socket interface.

func NewMocksocket

func NewMocksocket(ctrl *gomock.Controller) *Mocksocket

NewMocksocket creates a new mock instance.

func (*Mocksocket) EXPECT

func (m *Mocksocket) EXPECT() *MocksocketMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MocksocketMockRecorder

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

MocksocketMockRecorder is the mock recorder for Mocksocket.

type Node

type Node struct {
	vnode.Node
	// contains filtered or unexported fields
}

type NodeDB

type NodeDB interface {
	StoreNode(node *vnode.Node) (err error)
	RemoveNode(id vnode.NodeID)
	ReadNodes(expiration int64) []*vnode.Node
	RetrieveActiveAt(id vnode.NodeID) int64
	StoreActiveAt(id vnode.NodeID, v int64)
	RetrieveCheckAt(id vnode.NodeID) int64
	StoreCheckAt(id vnode.NodeID, v int64)
	Close() error
	Clean(expiration int64)
}

type Observer

type Observer interface {
	Sub(sub Subscriber)
	UnSub(sub Subscriber)
}

type Request

type Request struct {
	Node  *vnode.Node `json:"node"`
	Count int         `json:"count"`
}

type Result

type Result struct {
	Code    int      `json:"code"`
	Message string   `json:"message"`
	Data    []string `json:"data"`
}

type Subscriber

type Subscriber interface {
	// Sub return the unique id
	Sub(receiver func(n *vnode.Node)) (subId int)
	// UnSub received the id returned by Sub
	UnSub(subId int)
}

Subscriber can be subscribed by observer