mock

package
v0.43.4-access-ingesti... Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2025 License: AGPL-3.0 Imports: 16 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BasicResolver added in v0.43.3 

type BasicResolver struct {
	mock.Mock
}

BasicResolver is an autogenerated mock type for the BasicResolver type

func NewBasicResolver added in v0.43.3 

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.43.3 

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.43.3 

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.43.3 

type BlobGetter struct {
	mock.Mock
}

BlobGetter is an autogenerated mock type for the BlobGetter type

func NewBlobGetter added in v0.43.3 

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.43.3 

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

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

func (*BlobGetter) GetBlobs added in v0.43.3 

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

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

type BlobService added in v0.43.3 

type BlobService struct {
	mock.Mock
}

BlobService is an autogenerated mock type for the BlobService type

func NewBlobService added in v0.43.3 

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.43.3 

func (_m *BlobService) AddBlob(ctx context.Context, b blobs.Blob) error

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

func (*BlobService) AddBlobs added in v0.43.3 

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

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

func (*BlobService) DeleteBlob added in v0.43.3 

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.43.3 

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

Done provides a mock function with no fields

func (*BlobService) GetBlob added in v0.43.3 

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

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

func (*BlobService) GetBlobs added in v0.43.3 

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

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

func (*BlobService) GetSession added in v0.43.3 

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

GetSession provides a mock function with given fields: ctx

func (*BlobService) Ready added in v0.43.3 

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

Ready provides a mock function with no fields

func (*BlobService) Start added in v0.43.3 

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

Start provides a mock function with given fields: _a0

func (*BlobService) TriggerReprovide added in v0.43.3 

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

TriggerReprovide provides a mock function with given fields: ctx

type Codec 

type Codec struct {
	mock.Mock
}

Codec is an autogenerated mock type for the Codec type

func NewCodec added in v0.43.3 

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) (messages.UntrustedMessage, 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.43.3 

type Compressor struct {
	mock.Mock
}

Compressor is an autogenerated mock type for the Compressor type

func NewCompressor added in v0.43.3 

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.43.3 

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.43.3 

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.43.3 

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 no 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.43.3 

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.43.3 

type ConduitAdapter struct {
	mock.Mock
}

ConduitAdapter is an autogenerated mock type for the ConduitAdapter type

func NewConduitAdapter added in v0.43.3 

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.43.3 

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.43.3 

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.43.3 

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.43.3 

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

UnRegisterChannel provides a mock function with given fields: channel

func (*ConduitAdapter) UnicastOnChannel added in v0.43.3 

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.43.3 

type ConduitFactory struct {
	mock.Mock
}

ConduitFactory is an autogenerated mock type for the ConduitFactory type

func NewConduitFactory added in v0.43.3 

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.43.3 

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.43.3 

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

RegisterAdapter provides a mock function with given fields: _a0

type Connection added in v0.43.3 

type Connection struct {
	mock.Mock
}

Connection is an autogenerated mock type for the Connection type

func NewConnection added in v0.43.3 

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

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

Receive provides a mock function with no fields

func (*Connection) Send added in v0.43.3 

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

Send provides a mock function with given fields: msg

type Decoder 

type Decoder struct {
	mock.Mock
}

Decoder is an autogenerated mock type for the Decoder type

func NewDecoder added in v0.43.3 

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() (messages.UntrustedMessage, error)

Decode provides a mock function with no fields

type DisallowListNotificationConsumer added in v0.43.3 

type DisallowListNotificationConsumer struct {
	mock.Mock
}

DisallowListNotificationConsumer is an autogenerated mock type for the DisallowListNotificationConsumer type

func NewDisallowListNotificationConsumer added in v0.43.3 

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.43.3 

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

OnAllowListNotification provides a mock function with given fields: _a0

func (*DisallowListNotificationConsumer) OnDisallowListNotification added in v0.43.3 

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

OnDisallowListNotification 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.43.3 

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.43.3 

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.43.3 

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

Done provides a mock function with no 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.43.3 

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

Ready provides a mock function with no 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.43.3 

type EngineRegistry struct {
	mock.Mock
}

EngineRegistry is an autogenerated mock type for the EngineRegistry type

func NewEngineRegistry added in v0.43.3 

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.43.3 

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

Done provides a mock function with no fields

func (*EngineRegistry) Ready added in v0.43.3 

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

Ready provides a mock function with no fields

func (*EngineRegistry) Register added in v0.43.3 

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.43.3 

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.43.3 

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.43.3 

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

Start provides a mock function with given fields: _a0

type IncomingMessageScope added in v0.43.3 

type IncomingMessageScope struct {
	mock.Mock
}

IncomingMessageScope is an autogenerated mock type for the IncomingMessageScope type

func NewIncomingMessageScope added in v0.43.3 

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.43.3 

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

Channel provides a mock function with no fields

func (*IncomingMessageScope) DecodedPayload added in v0.43.3 

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

DecodedPayload provides a mock function with no fields

func (*IncomingMessageScope) EventID added in v0.43.3 

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

EventID provides a mock function with no fields

func (*IncomingMessageScope) OriginId added in v0.43.3 

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

OriginId provides a mock function with no fields

func (*IncomingMessageScope) PayloadType added in v0.43.3 

func (_m *IncomingMessageScope) PayloadType() string

PayloadType provides a mock function with no fields

func (*IncomingMessageScope) Proto added in v0.43.3 

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

Proto provides a mock function with no fields

func (*IncomingMessageScope) Protocol added in v0.43.3 

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

Protocol provides a mock function with no fields

func (*IncomingMessageScope) Size added in v0.43.3 

func (_m *IncomingMessageScope) Size() int

Size provides a mock function with no fields

func (*IncomingMessageScope) TargetIDs added in v0.43.3 

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

TargetIDs provides a mock function with no fields

type MessageProcessor added in v0.43.3 

type MessageProcessor struct {
	mock.Mock
}

MessageProcessor is an autogenerated mock type for the MessageProcessor type

func NewMessageProcessor added in v0.43.3 

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.43.3 

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

type MessageQueue struct {
	mock.Mock
}

MessageQueue is an autogenerated mock type for the MessageQueue type

func NewMessageQueue added in v0.43.3 

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

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

Insert provides a mock function with given fields: message

func (*MessageQueue) Len added in v0.43.3 

func (_m *MessageQueue) Len() int

Len provides a mock function with no fields

func (*MessageQueue) Remove added in v0.43.3 

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

Remove provides a mock function with no fields

type MessageValidator added in v0.43.3 

type MessageValidator struct {
	mock.Mock
}

MessageValidator is an autogenerated mock type for the MessageValidator type

func NewMessageValidator added in v0.43.3 

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

func (_m *MessageValidator) Validate(msg network.IncomingMessageScope) bool

Validate provides a mock function with given fields: msg

type MisbehaviorReport added in v0.43.3 

type MisbehaviorReport struct {
	mock.Mock
}

MisbehaviorReport is an autogenerated mock type for the MisbehaviorReport type

func NewMisbehaviorReport added in v0.43.3 

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.43.3 

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

OriginId provides a mock function with no fields

func (*MisbehaviorReport) Penalty added in v0.43.3 

func (_m *MisbehaviorReport) Penalty() float64

Penalty provides a mock function with no fields

func (*MisbehaviorReport) Reason added in v0.43.3 

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

Reason provides a mock function with no fields

type MisbehaviorReportConsumer added in v0.43.3 

type MisbehaviorReportConsumer struct {
	mock.Mock
}

MisbehaviorReportConsumer is an autogenerated mock type for the MisbehaviorReportConsumer type

func NewMisbehaviorReportConsumer added in v0.43.3 

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.43.3 

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.43.3 

type MisbehaviorReportManager struct {
	mock.Mock
}

MisbehaviorReportManager is an autogenerated mock type for the MisbehaviorReportManager type

func NewMisbehaviorReportManager added in v0.43.3 

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.43.3 

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

Done provides a mock function with no fields

func (*MisbehaviorReportManager) HandleMisbehaviorReport added in v0.43.3 

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.43.3 

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

Ready provides a mock function with no fields

func (*MisbehaviorReportManager) Start added in v0.43.3 

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

Start provides a mock function with given fields: _a0

type MisbehaviorReporter added in v0.43.3 

type MisbehaviorReporter struct {
	mock.Mock
}

MisbehaviorReporter is an autogenerated mock type for the MisbehaviorReporter type

func NewMisbehaviorReporter added in v0.43.3 

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.43.3 

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

ReportMisbehavior provides a mock function with given fields: _a0

type OutgoingMessageScope added in v0.43.3 

type OutgoingMessageScope struct {
	mock.Mock
}

OutgoingMessageScope is an autogenerated mock type for the OutgoingMessageScope type

func NewOutgoingMessageScope added in v0.43.3 

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.43.3 

func (_m *OutgoingMessageScope) PayloadType() string

PayloadType provides a mock function with no fields

func (*OutgoingMessageScope) Proto added in v0.43.3 

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

Proto provides a mock function with no fields

func (*OutgoingMessageScope) Size added in v0.43.3 

func (_m *OutgoingMessageScope) Size() int

Size provides a mock function with no fields

func (*OutgoingMessageScope) TargetIds added in v0.43.3 

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

TargetIds provides a mock function with no fields

func (*OutgoingMessageScope) Topic added in v0.43.3 

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

Topic provides a mock function with no fields

type PingInfoProvider added in v0.43.3 

type PingInfoProvider struct {
	mock.Mock
}

PingInfoProvider is an autogenerated mock type for the PingInfoProvider type

func NewPingInfoProvider added in v0.43.3 

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.43.3 

func (_m *PingInfoProvider) HotstuffView() uint64

HotstuffView provides a mock function with no fields

func (*PingInfoProvider) SealedBlockHeight added in v0.43.3 

func (_m *PingInfoProvider) SealedBlockHeight() uint64

SealedBlockHeight provides a mock function with no fields

func (*PingInfoProvider) SoftwareVersion added in v0.43.3 

func (_m *PingInfoProvider) SoftwareVersion() string

SoftwareVersion provides a mock function with no fields

type PingService added in v0.43.3 

type PingService struct {
	mock.Mock
}

PingService is an autogenerated mock type for the PingService type

func NewPingService added in v0.43.3 

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.43.3 

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

type SubscriptionManager struct {
	mock.Mock
}

SubscriptionManager is an autogenerated mock type for the SubscriptionManager type

func NewSubscriptionManager added in v0.43.3 

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.43.3 

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

Channels provides a mock function with no fields

func (*SubscriptionManager) GetEngine added in v0.43.3 

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

GetEngine provides a mock function with given fields: channel

func (*SubscriptionManager) Register added in v0.43.3 

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

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

func (*SubscriptionManager) Unregister added in v0.43.3 

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

Unregister provides a mock function with given fields: channel

type Topology added in v0.43.3 

type Topology struct {
	mock.Mock
}

Topology is an autogenerated mock type for the Topology type

func NewTopology added in v0.43.3 

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.43.3 

func (_m *Topology) Fanout(ids flow.IdentityList) flow.IdentityList

Fanout provides a mock function with given fields: ids

type Underlay added in v0.43.3 

type Underlay struct {
	mock.Mock
}

Underlay is an autogenerated mock type for the Underlay type

func NewUnderlay added in v0.43.3 

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.43.3 

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

Done provides a mock function with no fields

func (*Underlay) OnAllowListNotification added in v0.43.3 

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

OnAllowListNotification provides a mock function with given fields: _a0

func (*Underlay) OnDisallowListNotification added in v0.43.3 

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

OnDisallowListNotification provides a mock function with given fields: _a0

func (*Underlay) Ready added in v0.43.3 

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

Ready provides a mock function with no fields

func (*Underlay) Subscribe added in v0.43.3 

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

Subscribe provides a mock function with given fields: channel

func (*Underlay) Unsubscribe added in v0.43.3 

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

Unsubscribe provides a mock function with given fields: channel

func (*Underlay) UpdateNodeAddresses added in v0.43.3 

func (_m *Underlay) UpdateNodeAddresses()

UpdateNodeAddresses provides a mock function with no fields

type ViolationsConsumer added in v0.43.3 

type ViolationsConsumer struct {
	mock.Mock
}

ViolationsConsumer is an autogenerated mock type for the ViolationsConsumer type

func NewViolationsConsumer added in v0.43.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.43.3 

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

OnInvalidMsgError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnSenderEjectedError added in v0.43.3 

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

OnSenderEjectedError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnAuthorizedSenderError added in v0.43.3 

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

OnUnAuthorizedSenderError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnauthorizedPublishOnChannel added in v0.43.3 

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

OnUnauthorizedPublishOnChannel provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnauthorizedUnicastOnChannel added in v0.43.3 

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

OnUnauthorizedUnicastOnChannel provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnexpectedError added in v0.43.3 

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

OnUnexpectedError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnknownMsgTypeError added in v0.43.3 

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

OnUnknownMsgTypeError provides a mock function with given fields: violation

type WriteCloseFlusher added in v0.43.3 

type WriteCloseFlusher struct {
	mock.Mock
}

WriteCloseFlusher is an autogenerated mock type for the WriteCloseFlusher type

func NewWriteCloseFlusher added in v0.43.3 

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.43.3 

func (_m *WriteCloseFlusher) Close() error

Close provides a mock function with no fields

func (*WriteCloseFlusher) Flush added in v0.43.3 

func (_m *WriteCloseFlusher) Flush() error

Flush provides a mock function with no fields

func (*WriteCloseFlusher) Write added in v0.43.3 

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.