mock

Documentation

Index

• type Connection
  • func (_m *Connection) Receive() (interface{}, error)
  • func (_m *Connection) Send(msg interface{}) error
• type Connector
  • func (_m *Connector) ConnectPeers(ctx context.Context, ids flow.IdentityList) map[flow.Identifier]error
  • func (_m *Connector) DisconnectPeers(ctx context.Context, ids flow.IdentityList) map[flow.Identifier]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() (flow.IdentityList, error)
• type SubscriptionManager
  • func (_m *SubscriptionManager) GetChannelIDs() []string
  • func (_m *SubscriptionManager) GetEngine(channelID string) (network.Engine, error)
  • func (_m *SubscriptionManager) Register(channelID string, engine network.Engine) error
  • func (_m *SubscriptionManager) Unregister(channelID string) 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 Connector

type Connector struct {
	mock.Mock
}

Connector is an autogenerated mock type for the Connector type

func (*Connector) ConnectPeers

func (_m *Connector) ConnectPeers(ctx context.Context, ids flow.IdentityList) map[flow.Identifier]error

ConnectPeers provides a mock function with given fields: ctx, ids

func (*Connector) DisconnectPeers

func (_m *Connector) DisconnectPeers(ctx context.Context, ids flow.IdentityList) map[flow.Identifier]error

DisconnectPeers provides a mock function with given fields: ctx, ids

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() (flow.IdentityList, error)

Topology provides a mock function with given fields:

type SubscriptionManager

type SubscriptionManager struct {
	mock.Mock
}

SubscriptionManager is an autogenerated mock type for the SubscriptionManager type

func (*SubscriptionManager) GetChannelIDs

func (_m *SubscriptionManager) GetChannelIDs() []string

GetChannelIDs provides a mock function with given fields:

func (*SubscriptionManager) GetEngine

func (_m *SubscriptionManager) GetEngine(channelID string) (network.Engine, error)

GetEngine provides a mock function with given fields: channelID

func (*SubscriptionManager) Register

func (_m *SubscriptionManager) Register(channelID string, engine network.Engine) error

Register provides a mock function with given fields: channelID, engine

func (*SubscriptionManager) Unregister

func (_m *SubscriptionManager) Unregister(channelID string) error

Unregister provides a mock function with given fields: channelID

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