mock

Documentation

Index

• type Connection
  • func (_m *Connection) Receive() (interface{}, error)
  • func (_m *Connection) Send(msg interface{}) error
• type Middleware
  • func (_m *Middleware) Ping(targetID flow.Identifier) (time.Duration, error)
  • func (_m *Middleware) Publish(msg *message.Message, channelID string) error
  • func (_m *Middleware) Send(channelID string, msg *message.Message, targetIDs ...flow.Identifier) error
  • func (_m *Middleware) SendDirect(msg *message.Message, targetID flow.Identifier) error
  • func (_m *Middleware) Start(overlay middleware.Overlay) error
  • func (_m *Middleware) Stop()
  • func (_m *Middleware) Subscribe(channelID string) error
  • func (_m *Middleware) Unsubscribe(channelID string) error
  • func (_m *Middleware) UpdateAllowList() error
• type Overlay
  • func (_m *Overlay) Identity() (map[flow.Identifier]flow.Identity, error)
  • func (_m *Overlay) Receive(nodeID flow.Identifier, msg *message.Message) error
  • func (_m *Overlay) Topology() (map[flow.Identifier]flow.Identity, error)
• type Topology
  • func (_m *Topology) Subset(idList flow.IdentityList, size int, seed string) (map[flow.Identifier]flow.Identity, error)

Types

type Connection

type Connection struct {
	mock.Mock
}

Connection is an autogenerated mock type for the Connection type

func (*Connection) Receive

func (_m *Connection) Receive() (interface{}, error)

Receive provides a mock function with given fields:

func (*Connection) Send

func (_m *Connection) Send(msg interface{}) error

Send provides a mock function with given fields: msg

type Middleware

type Middleware struct {
	mock.Mock
}

Middleware is an autogenerated mock type for the Middleware type

func (*Middleware) Ping

func (_m *Middleware) Ping(targetID flow.Identifier) (time.Duration, error)

Ping provides a mock function with given fields: targetID

func (*Middleware) Publish

func (_m *Middleware) Publish(msg *message.Message, channelID string) error

Publish provides a mock function with given fields: msg, channelID

func (*Middleware) Send

func (_m *Middleware) Send(channelID string, msg *message.Message, targetIDs ...flow.Identifier) error

Send provides a mock function with given fields: channelID, msg, targetIDs

func (*Middleware) SendDirect

func (_m *Middleware) SendDirect(msg *message.Message, targetID flow.Identifier) error

SendDirect provides a mock function with given fields: msg, targetID

func (*Middleware) Start

func (_m *Middleware) Start(overlay middleware.Overlay) error

Start provides a mock function with given fields: overlay

func (*Middleware) Stop

func (_m *Middleware) Stop()

Stop provides a mock function with given fields:

func (*Middleware) Subscribe

func (_m *Middleware) Subscribe(channelID string) error

Subscribe provides a mock function with given fields: channelID

func (*Middleware) Unsubscribe

func (_m *Middleware) Unsubscribe(channelID string) error

Unsubscribe provides a mock function with given fields: channelID

func (*Middleware) UpdateAllowList

func (_m *Middleware) UpdateAllowList() error

UpdateAllowList provides a mock function with given fields:

type Overlay

type Overlay struct {
	mock.Mock
}

Overlay is an autogenerated mock type for the Overlay type

func (*Overlay) Identity

func (_m *Overlay) Identity() (map[flow.Identifier]flow.Identity, error)

Identity provides a mock function with given fields:

func (*Overlay) Receive

func (_m *Overlay) Receive(nodeID flow.Identifier, msg *message.Message) error

Receive provides a mock function with given fields: nodeID, msg

func (*Overlay) Topology

func (_m *Overlay) Topology() (map[flow.Identifier]flow.Identity, error)

Topology provides a mock function with given fields:

type Topology

type Topology struct {
	mock.Mock
}

Topology is an autogenerated mock type for the Topology type

func (*Topology) Subset

func (_m *Topology) Subset(idList flow.IdentityList, size int, seed string) (map[flow.Identifier]flow.Identity, error)

Subset provides a mock function with given fields: idList, size, seed