mocknetwork

Documentation

Index

• type Codec
  • func (_m *Codec) Decode(data []byte) (interface{}, error)
  • func (_m *Codec) Encode(v interface{}) ([]byte, error)
  • func (_m *Codec) NewDecoder(r io.Reader) network.Decoder
  • func (_m *Codec) NewEncoder(w io.Writer) network.Encoder
• type Conduit
  • func (_m *Conduit) Close() error
  • func (_m *Conduit) Multicast(event interface{}, num uint, targetIDs ...flow.Identifier) error
  • func (_m *Conduit) Publish(event interface{}, targetIDs ...flow.Identifier) error
  • func (_m *Conduit) Submit(event interface{}, targetIDs ...flow.Identifier) error
  • func (_m *Conduit) Unicast(event interface{}, targetID flow.Identifier) error
• 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 Decoder
  • func (_m *Decoder) Decode() (interface{}, error)
• type Encoder
  • func (_m *Encoder) Encode(v interface{}) error
• type Engine
  • func (_m *Engine) Process(originID flow.Identifier, event interface{}) error
  • func (_m *Engine) ProcessLocal(event interface{}) error
  • func (_m *Engine) Submit(originID flow.Identifier, event interface{})
  • func (_m *Engine) SubmitLocal(event interface{})
• type MessageQueue
  • func (_m *MessageQueue) Insert(message interface{}) error
  • func (_m *MessageQueue) Len() int
  • func (_m *MessageQueue) Remove() interface{}
• type MessageValidator
  • func (_m *MessageValidator) Validate(msg message.Message) bool
• 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 network.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) GenerateFanout(ids flow.IdentityList) (flow.IdentityList, error)

Types

type Codec

type Codec struct {
	mock.Mock
}

Codec is an autogenerated mock type for the Codec type

func (*Codec) Decode

func (_m *Codec) Decode(data []byte) (interface{}, error)

Decode provides a mock function with given fields: data

func (*Codec) Encode

func (_m *Codec) Encode(v interface{}) ([]byte, error)

Encode provides a mock function with given fields: v

func (*Codec) NewDecoder

func (_m *Codec) NewDecoder(r io.Reader) network.Decoder

NewDecoder provides a mock function with given fields: r

func (*Codec) NewEncoder

func (_m *Codec) NewEncoder(w io.Writer) network.Encoder

NewEncoder provides a mock function with given fields: w

type Conduit

type Conduit struct {
	mock.Mock
}

Conduit is an autogenerated mock type for the Conduit type

func (*Conduit) Close

func (_m *Conduit) Close() error

Close provides a mock function with given fields:

func (*Conduit) Multicast

func (_m *Conduit) Multicast(event interface{}, num uint, targetIDs ...flow.Identifier) error

Multicast provides a mock function with given fields: event, num, targetIDs

func (*Conduit) Publish

func (_m *Conduit) Publish(event interface{}, targetIDs ...flow.Identifier) error

Publish provides a mock function with given fields: event, targetIDs

func (*Conduit) Submit

func (_m *Conduit) Submit(event interface{}, targetIDs ...flow.Identifier) error

Submit provides a mock function with given fields: event, targetIDs

func (*Conduit) Unicast

func (_m *Conduit) Unicast(event interface{}, targetID flow.Identifier) error

Unicast provides a mock function with given fields: event, targetID

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 Decoder

type Decoder struct {
	mock.Mock
}

Decoder is an autogenerated mock type for the Decoder type

func (*Decoder) Decode

func (_m *Decoder) Decode() (interface{}, error)

Decode provides a mock function with given fields:

type Encoder

type Encoder struct {
	mock.Mock
}

Encoder is an autogenerated mock type for the Encoder type

func (*Encoder) Encode

func (_m *Encoder) Encode(v interface{}) error

Encode provides a mock function with given fields: v

type Engine

type Engine struct {
	mock.Mock
}

Engine is an autogenerated mock type for the Engine type

func (*Engine) Process

func (_m *Engine) Process(originID flow.Identifier, event interface{}) error

Process provides a mock function with given fields: originID, event

func (*Engine) ProcessLocal

func (_m *Engine) ProcessLocal(event interface{}) error

ProcessLocal provides a mock function with given fields: event

func (*Engine) Submit

func (_m *Engine) Submit(originID flow.Identifier, event interface{})

Submit provides a mock function with given fields: originID, event

func (*Engine) SubmitLocal

func (_m *Engine) SubmitLocal(event interface{})

SubmitLocal provides a mock function with given fields: event

type MessageQueue

type MessageQueue struct {
	mock.Mock
}

MessageQueue is an autogenerated mock type for the MessageQueue type

func (*MessageQueue) Insert

func (_m *MessageQueue) Insert(message interface{}) error

Insert provides a mock function with given fields: message

func (*MessageQueue) Len

func (_m *MessageQueue) Len() int

Len provides a mock function with given fields:

func (*MessageQueue) Remove

func (_m *MessageQueue) Remove() interface{}

Remove provides a mock function with given fields:

type MessageValidator

type MessageValidator struct {
	mock.Mock
}

MessageValidator is an autogenerated mock type for the MessageValidator type

func (*MessageValidator) Validate

func (_m *MessageValidator) Validate(msg message.Message) bool

Validate 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 network.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) GenerateFanout

func (_m *Topology) GenerateFanout(ids flow.IdentityList) (flow.IdentityList, error)

GenerateFanout provides a mock function with given fields: ids