Help us shape the future of Go! Take the 2026 Go Developer Survey

mocknetwork

package
v0.40.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 11, 2025 License: AGPL-3.0 Imports: 20 Imported by: 0

Documentation

Overview

Package mocknetwork is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Adapter added in v0.24.5 

type Adapter struct {
	mock.Mock
}

Adapter is an autogenerated mock type for the Adapter type

func NewAdapter added in v0.26.1 

func NewAdapter(t mockConstructorTestingTNewAdapter) *Adapter

NewAdapter creates a new instance of Adapter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Adapter) MulticastOnChannel added in v0.24.5 

func (_m *Adapter) MulticastOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 uint, _a3 ...flow.Identifier) error

MulticastOnChannel provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Adapter) PublishOnChannel added in v0.24.5 

func (_m *Adapter) PublishOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 ...flow.Identifier) error

PublishOnChannel provides a mock function with given fields: _a0, _a1, _a2

func (*Adapter) ReportMisbehaviorOnChannel added in v0.31.0 

func (_m *Adapter) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)

ReportMisbehaviorOnChannel provides a mock function with given fields: channel, report

func (*Adapter) UnRegisterChannel added in v0.24.5 

func (_m *Adapter) UnRegisterChannel(channel channels.Channel) error

UnRegisterChannel provides a mock function with given fields: channel

func (*Adapter) UnicastOnChannel added in v0.24.5 

func (_m *Adapter) UnicastOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 flow.Identifier) error

UnicastOnChannel provides a mock function with given fields: _a0, _a1, _a2

type BasicResolver added in v0.21.0 

type BasicResolver struct {
	mock.Mock
}

BasicResolver is an autogenerated mock type for the BasicResolver type

func NewBasicResolver added in v0.26.1 

func NewBasicResolver(t interface {
	mock.TestingT
	Cleanup(func())
}) *BasicResolver

NewBasicResolver creates a new instance of BasicResolver. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*BasicResolver) LookupIPAddr added in v0.21.0 

func (_m *BasicResolver) LookupIPAddr(_a0 context.Context, _a1 string) ([]net.IPAddr, error)

LookupIPAddr provides a mock function with given fields: _a0, _a1

func (*BasicResolver) LookupTXT added in v0.21.0 

func (_m *BasicResolver) LookupTXT(_a0 context.Context, _a1 string) ([]string, error)

LookupTXT provides a mock function with given fields: _a0, _a1

type BlobGetter added in v0.23.9 

type BlobGetter struct {
	mock.Mock
}

BlobGetter is an autogenerated mock type for the BlobGetter type

func NewBlobGetter added in v0.26.1 

func NewBlobGetter(t interface {
	mock.TestingT
	Cleanup(func())
}) *BlobGetter

NewBlobGetter creates a new instance of BlobGetter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*BlobGetter) GetBlob added in v0.23.9 

func (_m *BlobGetter) GetBlob(ctx context.Context, c cid.Cid) (blocks.Block, error)

GetBlob provides a mock function with given fields: ctx, c

func (*BlobGetter) GetBlobs added in v0.23.9 

func (_m *BlobGetter) GetBlobs(ctx context.Context, ks []cid.Cid) <-chan blocks.Block

GetBlobs provides a mock function with given fields: ctx, ks

type BlobService added in v0.23.9 

type BlobService struct {
	mock.Mock
}

BlobService is an autogenerated mock type for the BlobService type

func NewBlobService added in v0.26.1 

func NewBlobService(t interface {
	mock.TestingT
	Cleanup(func())
}) *BlobService

NewBlobService creates a new instance of BlobService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*BlobService) AddBlob added in v0.23.9 

func (_m *BlobService) AddBlob(ctx context.Context, b blocks.Block) error

AddBlob provides a mock function with given fields: ctx, b

func (*BlobService) AddBlobs added in v0.23.9 

func (_m *BlobService) AddBlobs(ctx context.Context, bs []blocks.Block) error

AddBlobs provides a mock function with given fields: ctx, bs

func (*BlobService) DeleteBlob added in v0.23.9 

func (_m *BlobService) DeleteBlob(ctx context.Context, c cid.Cid) error

DeleteBlob provides a mock function with given fields: ctx, c

func (*BlobService) Done added in v0.23.9 

func (_m *BlobService) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*BlobService) GetBlob added in v0.23.9 

func (_m *BlobService) GetBlob(ctx context.Context, c cid.Cid) (blocks.Block, error)

GetBlob provides a mock function with given fields: ctx, c

func (*BlobService) GetBlobs added in v0.23.9 

func (_m *BlobService) GetBlobs(ctx context.Context, ks []cid.Cid) <-chan blocks.Block

GetBlobs provides a mock function with given fields: ctx, ks

func (*BlobService) GetSession added in v0.23.9 

func (_m *BlobService) GetSession(ctx context.Context) network.BlobGetter

GetSession provides a mock function with given fields: ctx

func (*BlobService) Ready added in v0.23.9 

func (_m *BlobService) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*BlobService) Start added in v0.23.9 

func (_m *BlobService) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

func (*BlobService) TriggerReprovide added in v0.23.9 

func (_m *BlobService) TriggerReprovide(ctx context.Context) error

TriggerReprovide provides a mock function with given fields: ctx

type BlobServiceOption added in v0.26.1 

type BlobServiceOption struct {
	mock.Mock
}

BlobServiceOption is an autogenerated mock type for the BlobServiceOption type

func NewBlobServiceOption added in v0.26.1 

func NewBlobServiceOption(t interface {
	mock.TestingT
	Cleanup(func())
}) *BlobServiceOption

NewBlobServiceOption creates a new instance of BlobServiceOption. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*BlobServiceOption) Execute added in v0.26.1 

func (_m *BlobServiceOption) Execute(_a0 network.BlobService)

Execute provides a mock function with given fields: _a0

type Codec 

type Codec struct {
	mock.Mock
}

Codec is an autogenerated mock type for the Codec type

func NewCodec added in v0.26.1 

func NewCodec(t interface {
	mock.TestingT
	Cleanup(func())
}) *Codec

NewCodec creates a new instance of Codec. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

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 Compressor added in v0.23.1 

type Compressor struct {
	mock.Mock
}

Compressor is an autogenerated mock type for the Compressor type

func NewCompressor added in v0.26.1 

func NewCompressor(t interface {
	mock.TestingT
	Cleanup(func())
}) *Compressor

NewCompressor creates a new instance of Compressor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Compressor) NewReader added in v0.23.1 

func (_m *Compressor) NewReader(_a0 io.Reader) (io.ReadCloser, error)

NewReader provides a mock function with given fields: _a0

func (*Compressor) NewWriter added in v0.23.1 

func (_m *Compressor) NewWriter(_a0 io.Writer) (network.WriteCloseFlusher, error)

NewWriter provides a mock function with given fields: _a0

type Conduit 

type Conduit struct {
	mock.Mock
}

Conduit is an autogenerated mock type for the Conduit type

func NewConduit added in v0.26.1 

func NewConduit(t interface {
	mock.TestingT
	Cleanup(func())
}) *Conduit

NewConduit creates a new instance of Conduit. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

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) ReportMisbehavior added in v0.31.0 

func (_m *Conduit) ReportMisbehavior(_a0 network.MisbehaviorReport)

ReportMisbehavior provides a mock function with given fields: _a0

func (*Conduit) Unicast 

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

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

type ConduitAdapter added in v0.32.0 

type ConduitAdapter struct {
	mock.Mock
}

ConduitAdapter is an autogenerated mock type for the ConduitAdapter type

func NewConduitAdapter added in v0.32.0 

func NewConduitAdapter(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConduitAdapter

NewConduitAdapter creates a new instance of ConduitAdapter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConduitAdapter) MulticastOnChannel added in v0.32.0 

func (_m *ConduitAdapter) MulticastOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 uint, _a3 ...flow.Identifier) error

MulticastOnChannel provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*ConduitAdapter) PublishOnChannel added in v0.32.0 

func (_m *ConduitAdapter) PublishOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 ...flow.Identifier) error

PublishOnChannel provides a mock function with given fields: _a0, _a1, _a2

func (*ConduitAdapter) ReportMisbehaviorOnChannel added in v0.32.0 

func (_m *ConduitAdapter) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)

ReportMisbehaviorOnChannel provides a mock function with given fields: channel, report

func (*ConduitAdapter) UnRegisterChannel added in v0.32.0 

func (_m *ConduitAdapter) UnRegisterChannel(channel channels.Channel) error

UnRegisterChannel provides a mock function with given fields: channel

func (*ConduitAdapter) UnicastOnChannel added in v0.32.0 

func (_m *ConduitAdapter) UnicastOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 flow.Identifier) error

UnicastOnChannel provides a mock function with given fields: _a0, _a1, _a2

type ConduitFactory added in v0.25.0 

type ConduitFactory struct {
	mock.Mock
}

ConduitFactory is an autogenerated mock type for the ConduitFactory type

func NewConduitFactory added in v0.26.1 

func NewConduitFactory(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConduitFactory

NewConduitFactory creates a new instance of ConduitFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConduitFactory) NewConduit added in v0.25.0 

func (_m *ConduitFactory) NewConduit(_a0 context.Context, _a1 channels.Channel) (network.Conduit, error)

NewConduit provides a mock function with given fields: _a0, _a1

func (*ConduitFactory) RegisterAdapter added in v0.25.0 

func (_m *ConduitFactory) RegisterAdapter(_a0 network.ConduitAdapter) error

RegisterAdapter provides a mock function with given fields: _a0

type Connection 

type Connection struct {
	mock.Mock
}

Connection is an autogenerated mock type for the Connection type

func NewConnection added in v0.26.1 

func NewConnection(t interface {
	mock.TestingT
	Cleanup(func())
}) *Connection

NewConnection creates a new instance of Connection. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

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 NewConnector added in v0.26.1 

func NewConnector(t interface {
	mock.TestingT
	Cleanup(func())
}) *Connector

NewConnector creates a new instance of Connector. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Connector) Connect added in v0.32.0 

func (_m *Connector) Connect(ctx context.Context, peerChan <-chan peer.AddrInfo)

Connect provides a mock function with given fields: ctx, peerChan

type ConnectorFactory added in v0.32.0 

type ConnectorFactory struct {
	mock.Mock
}

ConnectorFactory is an autogenerated mock type for the ConnectorFactory type

func NewConnectorFactory added in v0.32.0 

func NewConnectorFactory(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConnectorFactory

NewConnectorFactory creates a new instance of ConnectorFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConnectorFactory) Execute added in v0.32.0 

func (_m *ConnectorFactory) Execute(_a0 host.Host) (p2p.Connector, error)

Execute provides a mock function with given fields: _a0

type ConnectorHost added in v0.31.0 

type ConnectorHost struct {
	mock.Mock
}

ConnectorHost is an autogenerated mock type for the ConnectorHost type

func NewConnectorHost added in v0.31.0 

func NewConnectorHost(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConnectorHost

NewConnectorHost creates a new instance of ConnectorHost. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConnectorHost) ClosePeer added in v0.31.0 

func (_m *ConnectorHost) ClosePeer(peerId peer.ID) error

ClosePeer provides a mock function with given fields: peerId

func (*ConnectorHost) Connections added in v0.31.0 

func (_m *ConnectorHost) Connections() []network.Conn

Connections provides a mock function with given fields:

func (*ConnectorHost) ID added in v0.31.0 

func (_m *ConnectorHost) ID() peer.ID

ID provides a mock function with given fields:

func (*ConnectorHost) IsConnectedTo added in v0.32.0 

func (_m *ConnectorHost) IsConnectedTo(peerId peer.ID) bool

IsConnectedTo provides a mock function with given fields: peerId

func (*ConnectorHost) IsProtected added in v0.31.0 

func (_m *ConnectorHost) IsProtected(peerId peer.ID) bool

IsProtected provides a mock function with given fields: peerId

func (*ConnectorHost) PeerInfo added in v0.31.0 

func (_m *ConnectorHost) PeerInfo(peerId peer.ID) peer.AddrInfo

PeerInfo provides a mock function with given fields: peerId

type Decoder 

type Decoder struct {
	mock.Mock
}

Decoder is an autogenerated mock type for the Decoder type

func NewDecoder added in v0.26.1 

func NewDecoder(t interface {
	mock.TestingT
	Cleanup(func())
}) *Decoder

NewDecoder creates a new instance of Decoder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Decoder) Decode 

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

Decode provides a mock function with given fields:

type DisallowListNotificationConsumer added in v0.32.0 

type DisallowListNotificationConsumer struct {
	mock.Mock
}

DisallowListNotificationConsumer is an autogenerated mock type for the DisallowListNotificationConsumer type

func NewDisallowListNotificationConsumer added in v0.32.0 

func NewDisallowListNotificationConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *DisallowListNotificationConsumer

NewDisallowListNotificationConsumer creates a new instance of DisallowListNotificationConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*DisallowListNotificationConsumer) OnAllowListNotification added in v0.32.0 

func (_m *DisallowListNotificationConsumer) OnAllowListNotification(_a0 *network.AllowListingUpdate)

OnAllowListNotification provides a mock function with given fields: _a0

func (*DisallowListNotificationConsumer) OnDisallowListNotification added in v0.32.0 

func (_m *DisallowListNotificationConsumer) OnDisallowListNotification(_a0 *network.DisallowListingUpdate)

OnDisallowListNotification provides a mock function with given fields: _a0

type DisallowListOracle added in v0.32.0 

type DisallowListOracle struct {
	mock.Mock
}

DisallowListOracle is an autogenerated mock type for the DisallowListOracle type

func NewDisallowListOracle added in v0.32.0 

func NewDisallowListOracle(t mockConstructorTestingTNewDisallowListOracle) *DisallowListOracle

NewDisallowListOracle creates a new instance of DisallowListOracle. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*DisallowListOracle) GetAllDisallowedListCausesFor added in v0.32.0 

func (_m *DisallowListOracle) GetAllDisallowedListCausesFor(_a0 peer.ID) []network.DisallowListedCause

GetAllDisallowedListCausesFor provides a mock function with given fields: _a0

type Encoder 

type Encoder struct {
	mock.Mock
}

Encoder is an autogenerated mock type for the Encoder type

func NewEncoder added in v0.26.1 

func NewEncoder(t interface {
	mock.TestingT
	Cleanup(func())
}) *Encoder

NewEncoder creates a new instance of Encoder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

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 NewEngine added in v0.26.1 

func NewEngine(t interface {
	mock.TestingT
	Cleanup(func())
}) *Engine

NewEngine creates a new instance of Engine. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Engine) Done added in v0.23.0 

func (_m *Engine) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*Engine) Process 

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

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

func (*Engine) ProcessLocal 

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

ProcessLocal provides a mock function with given fields: event

func (*Engine) Ready added in v0.23.0 

func (_m *Engine) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*Engine) Submit 

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

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

func (*Engine) SubmitLocal 

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

SubmitLocal provides a mock function with given fields: event

type EngineRegistry added in v0.32.0 

type EngineRegistry struct {
	mock.Mock
}

EngineRegistry is an autogenerated mock type for the EngineRegistry type

func NewEngineRegistry added in v0.32.0 

func NewEngineRegistry(t interface {
	mock.TestingT
	Cleanup(func())
}) *EngineRegistry

NewEngineRegistry creates a new instance of EngineRegistry. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*EngineRegistry) Done added in v0.32.0 

func (_m *EngineRegistry) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*EngineRegistry) Ready added in v0.32.0 

func (_m *EngineRegistry) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*EngineRegistry) Register added in v0.32.0 

func (_m *EngineRegistry) Register(channel channels.Channel, messageProcessor network.MessageProcessor) (network.Conduit, error)

Register provides a mock function with given fields: channel, messageProcessor

func (*EngineRegistry) RegisterBlobService added in v0.32.0 

func (_m *EngineRegistry) RegisterBlobService(channel channels.Channel, store datastore.Batching, opts ...network.BlobServiceOption) (network.BlobService, error)

RegisterBlobService provides a mock function with given fields: channel, store, opts

func (*EngineRegistry) RegisterPingService added in v0.32.0 

func (_m *EngineRegistry) RegisterPingService(pingProtocolID protocol.ID, pingInfoProvider network.PingInfoProvider) (network.PingService, error)

RegisterPingService provides a mock function with given fields: pingProtocolID, pingInfoProvider

func (*EngineRegistry) Start added in v0.32.0 

func (_m *EngineRegistry) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

type IncomingMessageScope added in v0.32.0 

type IncomingMessageScope struct {
	mock.Mock
}

IncomingMessageScope is an autogenerated mock type for the IncomingMessageScope type

func NewIncomingMessageScope added in v0.32.0 

func NewIncomingMessageScope(t interface {
	mock.TestingT
	Cleanup(func())
}) *IncomingMessageScope

NewIncomingMessageScope creates a new instance of IncomingMessageScope. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*IncomingMessageScope) Channel added in v0.32.0 

func (_m *IncomingMessageScope) Channel() channels.Channel

Channel provides a mock function with given fields:

func (*IncomingMessageScope) DecodedPayload added in v0.32.0 

func (_m *IncomingMessageScope) DecodedPayload() interface{}

DecodedPayload provides a mock function with given fields:

func (*IncomingMessageScope) EventID added in v0.32.0 

func (_m *IncomingMessageScope) EventID() []byte

EventID provides a mock function with given fields:

func (*IncomingMessageScope) OriginId added in v0.32.0 

func (_m *IncomingMessageScope) OriginId() flow.Identifier

OriginId provides a mock function with given fields:

func (*IncomingMessageScope) PayloadType added in v0.32.0 

func (_m *IncomingMessageScope) PayloadType() string

PayloadType provides a mock function with given fields:

func (*IncomingMessageScope) Proto added in v0.32.0 

func (_m *IncomingMessageScope) Proto() *message.Message

Proto provides a mock function with given fields:

func (*IncomingMessageScope) Protocol added in v0.32.0 

func (_m *IncomingMessageScope) Protocol() message.ProtocolType

Protocol provides a mock function with given fields:

func (*IncomingMessageScope) Size added in v0.32.0 

func (_m *IncomingMessageScope) Size() int

Size provides a mock function with given fields:

func (*IncomingMessageScope) TargetIDs added in v0.32.0 

func (_m *IncomingMessageScope) TargetIDs() flow.IdentifierList

TargetIDs provides a mock function with given fields:

type MessageProcessor added in v0.17.6 

type MessageProcessor struct {
	mock.Mock
}

MessageProcessor is an autogenerated mock type for the MessageProcessor type

func NewMessageProcessor added in v0.26.1 

func NewMessageProcessor(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageProcessor

NewMessageProcessor creates a new instance of MessageProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MessageProcessor) Process added in v0.17.6 

func (_m *MessageProcessor) Process(channel channels.Channel, originID flow.Identifier, message interface{}) error

Process provides a mock function with given fields: channel, originID, message

type MessageQueue 

type MessageQueue struct {
	mock.Mock
}

MessageQueue is an autogenerated mock type for the MessageQueue type

func NewMessageQueue added in v0.26.1 

func NewMessageQueue(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageQueue

NewMessageQueue creates a new instance of MessageQueue. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

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 NewMessageValidator added in v0.26.1 

func NewMessageValidator(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageValidator

NewMessageValidator creates a new instance of MessageValidator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MessageValidator) Validate 

func (_m *MessageValidator) Validate(msg network.IncomingMessageScope) 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 NewMiddleware added in v0.26.1 

func NewMiddleware(t mockConstructorTestingTNewMiddleware) *Middleware

NewMiddleware creates a new instance of Middleware. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Middleware) Done added in v0.23.0 

func (_m *Middleware) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*Middleware) OnAllowListNotification added in v0.32.0 

func (_m *Middleware) OnAllowListNotification(_a0 *network.AllowListingUpdate)

OnAllowListNotification provides a mock function with given fields: _a0

func (*Middleware) OnDisallowListNotification added in v0.32.0 

func (_m *Middleware) OnDisallowListNotification(_a0 *network.DisallowListingUpdate)

OnDisallowListNotification provides a mock function with given fields: _a0

func (*Middleware) Ready added in v0.23.0 

func (_m *Middleware) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*Middleware) Subscribe 

func (_m *Middleware) Subscribe(channel channels.Channel) error

Subscribe provides a mock function with given fields: channel

func (*Middleware) Unsubscribe 

func (_m *Middleware) Unsubscribe(channel channels.Channel) error

Unsubscribe provides a mock function with given fields: channel

func (*Middleware) UpdateNodeAddresses added in v0.21.1 

func (_m *Middleware) UpdateNodeAddresses()

UpdateNodeAddresses provides a mock function with given fields:

type MisbehaviorReport added in v0.31.0 

type MisbehaviorReport struct {
	mock.Mock
}

MisbehaviorReport is an autogenerated mock type for the MisbehaviorReport type

func NewMisbehaviorReport added in v0.31.0 

func NewMisbehaviorReport(t interface {
	mock.TestingT
	Cleanup(func())
}) *MisbehaviorReport

NewMisbehaviorReport creates a new instance of MisbehaviorReport. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MisbehaviorReport) OriginId added in v0.31.0 

func (_m *MisbehaviorReport) OriginId() flow.Identifier

OriginId provides a mock function with given fields:

func (*MisbehaviorReport) Penalty added in v0.31.0 

func (_m *MisbehaviorReport) Penalty() float64

Penalty provides a mock function with given fields:

func (*MisbehaviorReport) Reason added in v0.31.0 

func (_m *MisbehaviorReport) Reason() network.Misbehavior

Reason provides a mock function with given fields:

type MisbehaviorReportConsumer added in v0.32.0 

type MisbehaviorReportConsumer struct {
	mock.Mock
}

MisbehaviorReportConsumer is an autogenerated mock type for the MisbehaviorReportConsumer type

func NewMisbehaviorReportConsumer added in v0.32.0 

func NewMisbehaviorReportConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MisbehaviorReportConsumer

NewMisbehaviorReportConsumer creates a new instance of MisbehaviorReportConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MisbehaviorReportConsumer) ReportMisbehaviorOnChannel added in v0.32.0 

func (_m *MisbehaviorReportConsumer) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)

ReportMisbehaviorOnChannel provides a mock function with given fields: channel, report

type MisbehaviorReportManager added in v0.31.0 

type MisbehaviorReportManager struct {
	mock.Mock
}

MisbehaviorReportManager is an autogenerated mock type for the MisbehaviorReportManager type

func NewMisbehaviorReportManager added in v0.31.0 

func NewMisbehaviorReportManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *MisbehaviorReportManager

NewMisbehaviorReportManager creates a new instance of MisbehaviorReportManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MisbehaviorReportManager) Done added in v0.31.0 

func (_m *MisbehaviorReportManager) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*MisbehaviorReportManager) HandleMisbehaviorReport added in v0.31.0 

func (_m *MisbehaviorReportManager) HandleMisbehaviorReport(_a0 channels.Channel, _a1 network.MisbehaviorReport)

HandleMisbehaviorReport provides a mock function with given fields: _a0, _a1

func (*MisbehaviorReportManager) Ready added in v0.31.0 

func (_m *MisbehaviorReportManager) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*MisbehaviorReportManager) Start added in v0.31.0 

func (_m *MisbehaviorReportManager) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

type MisbehaviorReporter added in v0.31.0 

type MisbehaviorReporter struct {
	mock.Mock
}

MisbehaviorReporter is an autogenerated mock type for the MisbehaviorReporter type

func NewMisbehaviorReporter added in v0.31.0 

func NewMisbehaviorReporter(t interface {
	mock.TestingT
	Cleanup(func())
}) *MisbehaviorReporter

NewMisbehaviorReporter creates a new instance of MisbehaviorReporter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MisbehaviorReporter) ReportMisbehavior added in v0.31.0 

func (_m *MisbehaviorReporter) ReportMisbehavior(_a0 network.MisbehaviorReport)

ReportMisbehavior provides a mock function with given fields: _a0

type MockEngineRegistry added in v0.32.0 

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

MockEngineRegistry is a mock of EngineRegistry interface.

func NewMockEngineRegistry added in v0.32.0 

func NewMockEngineRegistry(ctrl *gomock.Controller) *MockEngineRegistry

NewMockEngineRegistry creates a new mock instance.

func (*MockEngineRegistry) Done added in v0.32.0 

func (m *MockEngineRegistry) Done() <-chan struct{}

Done mocks base method.

func (*MockEngineRegistry) EXPECT added in v0.32.0 

func (m *MockEngineRegistry) EXPECT() *MockEngineRegistryMockRecorder

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

func (*MockEngineRegistry) Ready added in v0.32.0 

func (m *MockEngineRegistry) Ready() <-chan struct{}

Ready mocks base method.

func (*MockEngineRegistry) Register added in v0.32.0 

func (m *MockEngineRegistry) Register(arg0 channels.Channel, arg1 network.MessageProcessor) (network.Conduit, error)

Register mocks base method.

func (*MockEngineRegistry) RegisterBlobService added in v0.32.0 

func (m *MockEngineRegistry) RegisterBlobService(arg0 channels.Channel, arg1 datastore.Batching, arg2 ...network.BlobServiceOption) (network.BlobService, error)

RegisterBlobService mocks base method.

func (*MockEngineRegistry) RegisterPingService added in v0.32.0 

func (m *MockEngineRegistry) RegisterPingService(arg0 protocol.ID, arg1 network.PingInfoProvider) (network.PingService, error)

RegisterPingService mocks base method.

func (*MockEngineRegistry) Start added in v0.32.0 

func (m *MockEngineRegistry) Start(arg0 irrecoverable.SignalerContext)

Start mocks base method.

type MockEngineRegistryMockRecorder added in v0.32.0 

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

MockEngineRegistryMockRecorder is the mock recorder for MockEngineRegistry.

func (*MockEngineRegistryMockRecorder) Done added in v0.32.0 

func (mr *MockEngineRegistryMockRecorder) Done() *gomock.Call

Done indicates an expected call of Done.

func (*MockEngineRegistryMockRecorder) Ready added in v0.32.0 

func (mr *MockEngineRegistryMockRecorder) Ready() *gomock.Call

Ready indicates an expected call of Ready.

func (*MockEngineRegistryMockRecorder) Register added in v0.32.0 

func (mr *MockEngineRegistryMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call

Register indicates an expected call of Register.

func (*MockEngineRegistryMockRecorder) RegisterBlobService added in v0.32.0 

func (mr *MockEngineRegistryMockRecorder) RegisterBlobService(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RegisterBlobService indicates an expected call of RegisterBlobService.

func (*MockEngineRegistryMockRecorder) RegisterPingService added in v0.32.0 

func (mr *MockEngineRegistryMockRecorder) RegisterPingService(arg0, arg1 interface{}) *gomock.Call

RegisterPingService indicates an expected call of RegisterPingService.

func (*MockEngineRegistryMockRecorder) Start added in v0.32.0 

func (mr *MockEngineRegistryMockRecorder) Start(arg0 interface{}) *gomock.Call

Start indicates an expected call of Start.

type Network added in v0.23.0 

type Network struct {
	mock.Mock
}

Network is an autogenerated mock type for the Network type

func NewNetwork added in v0.26.1 

func NewNetwork(t mockConstructorTestingTNewNetwork) *Network

NewNetwork creates a new instance of Network. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Network) Done added in v0.23.0 

func (_m *Network) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*Network) Ready added in v0.23.0 

func (_m *Network) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*Network) Register added in v0.23.0 

func (_m *Network) Register(channel channels.Channel, messageProcessor network.MessageProcessor) (network.Conduit, error)

Register provides a mock function with given fields: channel, messageProcessor

func (*Network) RegisterBlobService added in v0.23.9 

func (_m *Network) RegisterBlobService(channel channels.Channel, store datastore.Batching, opts ...network.BlobServiceOption) (network.BlobService, error)

RegisterBlobService provides a mock function with given fields: channel, store, opts

func (*Network) RegisterPingService added in v0.23.9 

func (_m *Network) RegisterPingService(pingProtocolID protocol.ID, pingInfoProvider network.PingInfoProvider) (network.PingService, error)

RegisterPingService provides a mock function with given fields: pingProtocolID, pingInfoProvider

func (*Network) Start added in v0.23.0 

func (_m *Network) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

type OutgoingMessageScope added in v0.32.0 

type OutgoingMessageScope struct {
	mock.Mock
}

OutgoingMessageScope is an autogenerated mock type for the OutgoingMessageScope type

func NewOutgoingMessageScope added in v0.32.0 

func NewOutgoingMessageScope(t interface {
	mock.TestingT
	Cleanup(func())
}) *OutgoingMessageScope

NewOutgoingMessageScope creates a new instance of OutgoingMessageScope. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*OutgoingMessageScope) PayloadType added in v0.32.0 

func (_m *OutgoingMessageScope) PayloadType() string

PayloadType provides a mock function with given fields:

func (*OutgoingMessageScope) Proto added in v0.32.0 

func (_m *OutgoingMessageScope) Proto() *message.Message

Proto provides a mock function with given fields:

func (*OutgoingMessageScope) Size added in v0.32.0 

func (_m *OutgoingMessageScope) Size() int

Size provides a mock function with given fields:

func (*OutgoingMessageScope) TargetIds added in v0.32.0 

func (_m *OutgoingMessageScope) TargetIds() flow.IdentifierList

TargetIds provides a mock function with given fields:

func (*OutgoingMessageScope) Topic added in v0.32.0 

func (_m *OutgoingMessageScope) Topic() channels.Topic

Topic 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 NewOverlay added in v0.26.1 

func NewOverlay(t mockConstructorTestingTNewOverlay) *Overlay

NewOverlay creates a new instance of Overlay. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Overlay) Identities added in v0.21.1 

func (_m *Overlay) Identities() flow.IdentityList

Identities provides a mock function with given fields:

func (*Overlay) Identity 

func (_m *Overlay) Identity(_a0 peer.ID) (*flow.Identity, bool)

Identity provides a mock function with given fields: _a0

func (*Overlay) Receive 

func (_m *Overlay) Receive(_a0 network.IncomingMessageScope) error

Receive provides a mock function with given fields: _a0

func (*Overlay) Topology 

func (_m *Overlay) Topology() flow.IdentityList

Topology provides a mock function with given fields:

type PingInfoProvider added in v0.17.0 

type PingInfoProvider struct {
	mock.Mock
}

PingInfoProvider is an autogenerated mock type for the PingInfoProvider type

func NewPingInfoProvider added in v0.26.1 

func NewPingInfoProvider(t interface {
	mock.TestingT
	Cleanup(func())
}) *PingInfoProvider

NewPingInfoProvider creates a new instance of PingInfoProvider. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PingInfoProvider) HotstuffView added in v0.22.10 

func (_m *PingInfoProvider) HotstuffView() uint64

HotstuffView provides a mock function with given fields:

func (*PingInfoProvider) SealedBlockHeight added in v0.17.1 

func (_m *PingInfoProvider) SealedBlockHeight() uint64

SealedBlockHeight provides a mock function with given fields:

func (*PingInfoProvider) SoftwareVersion added in v0.17.0 

func (_m *PingInfoProvider) SoftwareVersion() string

SoftwareVersion provides a mock function with given fields:

type PingService added in v0.23.9 

type PingService struct {
	mock.Mock
}

PingService is an autogenerated mock type for the PingService type

func NewPingService added in v0.26.1 

func NewPingService(t interface {
	mock.TestingT
	Cleanup(func())
}) *PingService

NewPingService creates a new instance of PingService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PingService) Ping added in v0.23.9 

func (_m *PingService) Ping(ctx context.Context, peerID peer.ID) (message.PingResponse, time.Duration, error)

Ping provides a mock function with given fields: ctx, peerID

type SubscriptionManager 

type SubscriptionManager struct {
	mock.Mock
}

SubscriptionManager is an autogenerated mock type for the SubscriptionManager type

func NewSubscriptionManager added in v0.26.1 

func NewSubscriptionManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *SubscriptionManager

NewSubscriptionManager creates a new instance of SubscriptionManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SubscriptionManager) Channels added in v0.14.0 

func (_m *SubscriptionManager) Channels() channels.ChannelList

Channels provides a mock function with given fields:

func (*SubscriptionManager) GetEngine 

func (_m *SubscriptionManager) GetEngine(channel channels.Channel) (network.MessageProcessor, error)

GetEngine provides a mock function with given fields: channel

func (*SubscriptionManager) Register 

func (_m *SubscriptionManager) Register(channel channels.Channel, engine network.MessageProcessor) error

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

func (*SubscriptionManager) Unregister 

func (_m *SubscriptionManager) Unregister(channel channels.Channel) error

Unregister provides a mock function with given fields: channel

type Topology 

type Topology struct {
	mock.Mock
}

Topology is an autogenerated mock type for the Topology type

func NewTopology added in v0.26.1 

func NewTopology(t interface {
	mock.TestingT
	Cleanup(func())
}) *Topology

NewTopology creates a new instance of Topology. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Topology) Fanout added in v0.28.0 

func (_m *Topology) Fanout(ids flow.GenericIdentityList[flow.Identity]) flow.GenericIdentityList[flow.Identity]

Fanout provides a mock function with given fields: ids

type Underlay added in v0.32.0 

type Underlay struct {
	mock.Mock
}

Underlay is an autogenerated mock type for the Underlay type

func NewUnderlay added in v0.32.0 

func NewUnderlay(t interface {
	mock.TestingT
	Cleanup(func())
}) *Underlay

NewUnderlay creates a new instance of Underlay. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Underlay) Done added in v0.32.0 

func (_m *Underlay) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*Underlay) OnAllowListNotification added in v0.32.0 

func (_m *Underlay) OnAllowListNotification(_a0 *network.AllowListingUpdate)

OnAllowListNotification provides a mock function with given fields: _a0

func (*Underlay) OnDisallowListNotification added in v0.32.0 

func (_m *Underlay) OnDisallowListNotification(_a0 *network.DisallowListingUpdate)

OnDisallowListNotification provides a mock function with given fields: _a0

func (*Underlay) Ready added in v0.32.0 

func (_m *Underlay) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*Underlay) Subscribe added in v0.32.0 

func (_m *Underlay) Subscribe(channel channels.Channel) error

Subscribe provides a mock function with given fields: channel

func (*Underlay) Unsubscribe added in v0.32.0 

func (_m *Underlay) Unsubscribe(channel channels.Channel) error

Unsubscribe provides a mock function with given fields: channel

func (*Underlay) UpdateNodeAddresses added in v0.32.0 

func (_m *Underlay) UpdateNodeAddresses()

UpdateNodeAddresses provides a mock function with given fields:

type ViolationsConsumer added in v0.27.3 

type ViolationsConsumer struct {
	mock.Mock
}

ViolationsConsumer is an autogenerated mock type for the ViolationsConsumer type

func NewViolationsConsumer added in v0.27.3 

func NewViolationsConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *ViolationsConsumer

NewViolationsConsumer creates a new instance of ViolationsConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ViolationsConsumer) OnInvalidMsgError added in v0.27.3 

func (_m *ViolationsConsumer) OnInvalidMsgError(violation *network.Violation)

OnInvalidMsgError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnSenderEjectedError added in v0.27.3 

func (_m *ViolationsConsumer) OnSenderEjectedError(violation *network.Violation)

OnSenderEjectedError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnAuthorizedSenderError added in v0.27.3 

func (_m *ViolationsConsumer) OnUnAuthorizedSenderError(violation *network.Violation)

OnUnAuthorizedSenderError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnauthorizedPublishOnChannel added in v0.32.0 

func (_m *ViolationsConsumer) OnUnauthorizedPublishOnChannel(violation *network.Violation)

OnUnauthorizedPublishOnChannel provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnauthorizedUnicastOnChannel added in v0.29.0 

func (_m *ViolationsConsumer) OnUnauthorizedUnicastOnChannel(violation *network.Violation)

OnUnauthorizedUnicastOnChannel provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnexpectedError added in v0.28.0 

func (_m *ViolationsConsumer) OnUnexpectedError(violation *network.Violation)

OnUnexpectedError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnknownMsgTypeError added in v0.27.3 

func (_m *ViolationsConsumer) OnUnknownMsgTypeError(violation *network.Violation)

OnUnknownMsgTypeError provides a mock function with given fields: violation

type WriteCloseFlusher added in v0.23.1 

type WriteCloseFlusher struct {
	mock.Mock
}

WriteCloseFlusher is an autogenerated mock type for the WriteCloseFlusher type

func NewWriteCloseFlusher added in v0.26.1 

func NewWriteCloseFlusher(t interface {
	mock.TestingT
	Cleanup(func())
}) *WriteCloseFlusher

NewWriteCloseFlusher creates a new instance of WriteCloseFlusher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*WriteCloseFlusher) Close added in v0.23.1 

func (_m *WriteCloseFlusher) Close() error

Close provides a mock function with given fields:

func (*WriteCloseFlusher) Flush added in v0.23.1 

func (_m *WriteCloseFlusher) Flush() error

Flush provides a mock function with given fields:

func (*WriteCloseFlusher) Write added in v0.23.1 

func (_m *WriteCloseFlusher) Write(p []byte) (int, error)

Write provides a mock function with given fields: p

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.