Documentation
¶
Index ¶
- type BasicResolver
- type BlobGetter
- type BlobService
- func (_m *BlobService) AddBlob(ctx context.Context, b blobs.Blob) error
- func (_m *BlobService) AddBlobs(ctx context.Context, bs []blobs.Blob) error
- func (_m *BlobService) DeleteBlob(ctx context.Context, c cid.Cid) error
- func (_m *BlobService) Done() <-chan struct{}
- func (_m *BlobService) GetBlob(ctx context.Context, c cid.Cid) (blobs.Blob, error)
- func (_m *BlobService) GetBlobs(ctx context.Context, ks []cid.Cid) <-chan blobs.Blob
- func (_m *BlobService) GetSession(ctx context.Context) network.BlobGetter
- func (_m *BlobService) Ready() <-chan struct{}
- func (_m *BlobService) Start(_a0 irrecoverable.SignalerContext)
- func (_m *BlobService) TriggerReprovide(ctx context.Context) error
- type Codec
- type Compressor
- 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) ReportMisbehavior(_a0 network.MisbehaviorReport)
- func (_m *Conduit) Unicast(event interface{}, targetID flow.Identifier) error
- type ConduitAdapter
- func (_m *ConduitAdapter) MulticastOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 uint, _a3 ...flow.Identifier) error
- func (_m *ConduitAdapter) PublishOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 ...flow.Identifier) error
- func (_m *ConduitAdapter) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)
- func (_m *ConduitAdapter) UnRegisterChannel(channel channels.Channel) error
- func (_m *ConduitAdapter) UnicastOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 flow.Identifier) error
- type ConduitFactory
- type Connection
- type Decoder
- type DisallowListNotificationConsumer
- type Encoder
- type Engine
- func (_m *Engine) Done() <-chan struct{}
- func (_m *Engine) Process(channel channels.Channel, originID flow.Identifier, event interface{}) error
- func (_m *Engine) ProcessLocal(event interface{}) error
- func (_m *Engine) Ready() <-chan struct{}
- func (_m *Engine) Submit(channel channels.Channel, originID flow.Identifier, event interface{})
- func (_m *Engine) SubmitLocal(event interface{})
- type EngineRegistry
- func (_m *EngineRegistry) Done() <-chan struct{}
- func (_m *EngineRegistry) Ready() <-chan struct{}
- func (_m *EngineRegistry) Register(channel channels.Channel, messageProcessor network.MessageProcessor) (network.Conduit, error)
- func (_m *EngineRegistry) RegisterBlobService(channel channels.Channel, store datastore.Batching, ...) (network.BlobService, error)
- func (_m *EngineRegistry) RegisterPingService(pingProtocolID protocol.ID, pingInfoProvider network.PingInfoProvider) (network.PingService, error)
- func (_m *EngineRegistry) Start(_a0 irrecoverable.SignalerContext)
- type IncomingMessageScope
- func (_m *IncomingMessageScope) Channel() channels.Channel
- func (_m *IncomingMessageScope) DecodedPayload() interface{}
- func (_m *IncomingMessageScope) EventID() []byte
- func (_m *IncomingMessageScope) OriginId() flow.Identifier
- func (_m *IncomingMessageScope) PayloadType() string
- func (_m *IncomingMessageScope) Proto() *message.Message
- func (_m *IncomingMessageScope) Protocol() message.ProtocolType
- func (_m *IncomingMessageScope) Size() int
- func (_m *IncomingMessageScope) TargetIDs() flow.IdentifierList
- type MessageProcessor
- type MessageQueue
- type MessageValidator
- type MisbehaviorReport
- type MisbehaviorReportConsumer
- type MisbehaviorReportManager
- func (_m *MisbehaviorReportManager) Done() <-chan struct{}
- func (_m *MisbehaviorReportManager) HandleMisbehaviorReport(_a0 channels.Channel, _a1 network.MisbehaviorReport)
- func (_m *MisbehaviorReportManager) Ready() <-chan struct{}
- func (_m *MisbehaviorReportManager) Start(_a0 irrecoverable.SignalerContext)
- type MisbehaviorReporter
- type OutgoingMessageScope
- type PingInfoProvider
- type PingService
- type SubscriptionManager
- func (_m *SubscriptionManager) Channels() channels.ChannelList
- func (_m *SubscriptionManager) GetEngine(channel channels.Channel) (network.MessageProcessor, error)
- func (_m *SubscriptionManager) Register(channel channels.Channel, engine network.MessageProcessor) error
- func (_m *SubscriptionManager) Unregister(channel channels.Channel) error
- type Topology
- type Underlay
- func (_m *Underlay) Done() <-chan struct{}
- func (_m *Underlay) OnAllowListNotification(_a0 *network.AllowListingUpdate)
- func (_m *Underlay) OnDisallowListNotification(_a0 *network.DisallowListingUpdate)
- func (_m *Underlay) Ready() <-chan struct{}
- func (_m *Underlay) Subscribe(channel channels.Channel) error
- func (_m *Underlay) Unsubscribe(channel channels.Channel) error
- func (_m *Underlay) UpdateNodeAddresses()
- type ViolationsConsumer
- func (_m *ViolationsConsumer) OnInvalidMsgError(violation *network.Violation)
- func (_m *ViolationsConsumer) OnSenderEjectedError(violation *network.Violation)
- func (_m *ViolationsConsumer) OnUnAuthorizedSenderError(violation *network.Violation)
- func (_m *ViolationsConsumer) OnUnauthorizedPublishOnChannel(violation *network.Violation)
- func (_m *ViolationsConsumer) OnUnauthorizedUnicastOnChannel(violation *network.Violation)
- func (_m *ViolationsConsumer) OnUnexpectedError(violation *network.Violation)
- func (_m *ViolationsConsumer) OnUnknownMsgTypeError(violation *network.Violation)
- type WriteCloseFlusher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasicResolver ¶
BasicResolver is an autogenerated mock type for the BasicResolver type
func NewBasicResolver ¶
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 ¶
LookupIPAddr provides a mock function with given fields: _a0, _a1
type BlobGetter ¶
BlobGetter is an autogenerated mock type for the BlobGetter type
func NewBlobGetter ¶
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.
type BlobService ¶
BlobService is an autogenerated mock type for the BlobService type
func NewBlobService ¶
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) DeleteBlob ¶
DeleteBlob provides a mock function with given fields: ctx, c
func (*BlobService) Done ¶
func (_m *BlobService) Done() <-chan struct{}
Done provides a mock function with no fields
func (*BlobService) GetSession ¶
func (_m *BlobService) GetSession(ctx context.Context) network.BlobGetter
GetSession provides a mock function with given fields: ctx
func (*BlobService) Ready ¶
func (_m *BlobService) Ready() <-chan struct{}
Ready provides a mock function with no fields
func (*BlobService) Start ¶
func (_m *BlobService) Start(_a0 irrecoverable.SignalerContext)
Start provides a mock function with given fields: _a0
func (*BlobService) TriggerReprovide ¶
func (_m *BlobService) TriggerReprovide(ctx context.Context) error
TriggerReprovide provides a mock function with given fields: ctx
type Codec ¶
Codec is an autogenerated mock type for the Codec type
func NewCodec ¶
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) NewDecoder ¶
NewDecoder provides a mock function with given fields: r
type Compressor ¶
Compressor is an autogenerated mock type for the Compressor type
func NewCompressor ¶
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 ¶
func (_m *Compressor) NewReader(_a0 io.Reader) (io.ReadCloser, error)
NewReader provides a mock function with given fields: _a0
func (*Compressor) NewWriter ¶
func (_m *Compressor) NewWriter(_a0 io.Writer) (network.WriteCloseFlusher, error)
NewWriter provides a mock function with given fields: _a0
type Conduit ¶
Conduit is an autogenerated mock type for the Conduit type
func NewConduit ¶
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) 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 ¶
func (_m *Conduit) ReportMisbehavior(_a0 network.MisbehaviorReport)
ReportMisbehavior provides a mock function with given fields: _a0
type ConduitAdapter ¶
ConduitAdapter is an autogenerated mock type for the ConduitAdapter type
func NewConduitAdapter ¶
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 ¶
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 ¶
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 ¶
func (_m *ConduitAdapter) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)
ReportMisbehaviorOnChannel provides a mock function with given fields: channel, report
func (*ConduitAdapter) UnRegisterChannel ¶
func (_m *ConduitAdapter) UnRegisterChannel(channel channels.Channel) error
UnRegisterChannel provides a mock function with given fields: channel
func (*ConduitAdapter) UnicastOnChannel ¶
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 ¶
ConduitFactory is an autogenerated mock type for the ConduitFactory type
func NewConduitFactory ¶
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 ¶
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 ¶
func (_m *ConduitFactory) RegisterAdapter(_a0 network.ConduitAdapter) error
RegisterAdapter provides a mock function with given fields: _a0
type Connection ¶
Connection is an autogenerated mock type for the Connection type
func NewConnection ¶
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 no fields
func (*Connection) Send ¶
func (_m *Connection) Send(msg interface{}) error
Send provides a mock function with given fields: msg
type Decoder ¶
Decoder is an autogenerated mock type for the Decoder type
func NewDecoder ¶
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.
type DisallowListNotificationConsumer ¶
DisallowListNotificationConsumer is an autogenerated mock type for the DisallowListNotificationConsumer type
func NewDisallowListNotificationConsumer ¶
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 ¶
func (_m *DisallowListNotificationConsumer) OnAllowListNotification(_a0 *network.AllowListingUpdate)
OnAllowListNotification provides a mock function with given fields: _a0
func (*DisallowListNotificationConsumer) OnDisallowListNotification ¶
func (_m *DisallowListNotificationConsumer) OnDisallowListNotification(_a0 *network.DisallowListingUpdate)
OnDisallowListNotification provides a mock function with given fields: _a0
type Encoder ¶
Encoder is an autogenerated mock type for the Encoder type
func NewEncoder ¶
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.
type Engine ¶
Engine is an autogenerated mock type for the Engine type
func NewEngine ¶
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 ¶
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 ¶
ProcessLocal provides a mock function with given fields: event
func (*Engine) Ready ¶
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 ¶
EngineRegistry is an autogenerated mock type for the EngineRegistry type
func NewEngineRegistry ¶
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 ¶
func (_m *EngineRegistry) Done() <-chan struct{}
Done provides a mock function with no fields
func (*EngineRegistry) Ready ¶
func (_m *EngineRegistry) Ready() <-chan struct{}
Ready provides a mock function with no fields
func (*EngineRegistry) Register ¶
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 ¶
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 ¶
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 ¶
func (_m *EngineRegistry) Start(_a0 irrecoverable.SignalerContext)
Start provides a mock function with given fields: _a0
type IncomingMessageScope ¶
IncomingMessageScope is an autogenerated mock type for the IncomingMessageScope type
func NewIncomingMessageScope ¶
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 ¶
func (_m *IncomingMessageScope) Channel() channels.Channel
Channel provides a mock function with no fields
func (*IncomingMessageScope) DecodedPayload ¶
func (_m *IncomingMessageScope) DecodedPayload() interface{}
DecodedPayload provides a mock function with no fields
func (*IncomingMessageScope) EventID ¶
func (_m *IncomingMessageScope) EventID() []byte
EventID provides a mock function with no fields
func (*IncomingMessageScope) OriginId ¶
func (_m *IncomingMessageScope) OriginId() flow.Identifier
OriginId provides a mock function with no fields
func (*IncomingMessageScope) PayloadType ¶
func (_m *IncomingMessageScope) PayloadType() string
PayloadType provides a mock function with no fields
func (*IncomingMessageScope) Proto ¶
func (_m *IncomingMessageScope) Proto() *message.Message
Proto provides a mock function with no fields
func (*IncomingMessageScope) Protocol ¶
func (_m *IncomingMessageScope) Protocol() message.ProtocolType
Protocol provides a mock function with no fields
func (*IncomingMessageScope) Size ¶
func (_m *IncomingMessageScope) Size() int
Size provides a mock function with no fields
func (*IncomingMessageScope) TargetIDs ¶
func (_m *IncomingMessageScope) TargetIDs() flow.IdentifierList
TargetIDs provides a mock function with no fields
type MessageProcessor ¶
MessageProcessor is an autogenerated mock type for the MessageProcessor type
func NewMessageProcessor ¶
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 ¶
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 ¶
MessageQueue is an autogenerated mock type for the MessageQueue type
func NewMessageQueue ¶
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 no fields
func (*MessageQueue) Remove ¶
func (_m *MessageQueue) Remove() interface{}
Remove provides a mock function with no fields
type MessageValidator ¶
MessageValidator is an autogenerated mock type for the MessageValidator type
func NewMessageValidator ¶
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 MisbehaviorReport ¶
MisbehaviorReport is an autogenerated mock type for the MisbehaviorReport type
func NewMisbehaviorReport ¶
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 ¶
func (_m *MisbehaviorReport) OriginId() flow.Identifier
OriginId provides a mock function with no fields
func (*MisbehaviorReport) Penalty ¶
func (_m *MisbehaviorReport) Penalty() float64
Penalty provides a mock function with no fields
func (*MisbehaviorReport) Reason ¶
func (_m *MisbehaviorReport) Reason() network.Misbehavior
Reason provides a mock function with no fields
type MisbehaviorReportConsumer ¶
MisbehaviorReportConsumer is an autogenerated mock type for the MisbehaviorReportConsumer type
func NewMisbehaviorReportConsumer ¶
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 ¶
func (_m *MisbehaviorReportConsumer) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)
ReportMisbehaviorOnChannel provides a mock function with given fields: channel, report
type MisbehaviorReportManager ¶
MisbehaviorReportManager is an autogenerated mock type for the MisbehaviorReportManager type
func NewMisbehaviorReportManager ¶
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 ¶
func (_m *MisbehaviorReportManager) Done() <-chan struct{}
Done provides a mock function with no fields
func (*MisbehaviorReportManager) HandleMisbehaviorReport ¶
func (_m *MisbehaviorReportManager) HandleMisbehaviorReport(_a0 channels.Channel, _a1 network.MisbehaviorReport)
HandleMisbehaviorReport provides a mock function with given fields: _a0, _a1
func (*MisbehaviorReportManager) Ready ¶
func (_m *MisbehaviorReportManager) Ready() <-chan struct{}
Ready provides a mock function with no fields
func (*MisbehaviorReportManager) Start ¶
func (_m *MisbehaviorReportManager) Start(_a0 irrecoverable.SignalerContext)
Start provides a mock function with given fields: _a0
type MisbehaviorReporter ¶
MisbehaviorReporter is an autogenerated mock type for the MisbehaviorReporter type
func NewMisbehaviorReporter ¶
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 ¶
func (_m *MisbehaviorReporter) ReportMisbehavior(_a0 network.MisbehaviorReport)
ReportMisbehavior provides a mock function with given fields: _a0
type OutgoingMessageScope ¶
OutgoingMessageScope is an autogenerated mock type for the OutgoingMessageScope type
func NewOutgoingMessageScope ¶
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 ¶
func (_m *OutgoingMessageScope) PayloadType() string
PayloadType provides a mock function with no fields
func (*OutgoingMessageScope) Proto ¶
func (_m *OutgoingMessageScope) Proto() *message.Message
Proto provides a mock function with no fields
func (*OutgoingMessageScope) Size ¶
func (_m *OutgoingMessageScope) Size() int
Size provides a mock function with no fields
func (*OutgoingMessageScope) TargetIds ¶
func (_m *OutgoingMessageScope) TargetIds() flow.IdentifierList
TargetIds provides a mock function with no fields
func (*OutgoingMessageScope) Topic ¶
func (_m *OutgoingMessageScope) Topic() channels.Topic
Topic provides a mock function with no fields
type PingInfoProvider ¶
PingInfoProvider is an autogenerated mock type for the PingInfoProvider type
func NewPingInfoProvider ¶
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 ¶
func (_m *PingInfoProvider) HotstuffView() uint64
HotstuffView provides a mock function with no fields
func (*PingInfoProvider) SealedBlockHeight ¶
func (_m *PingInfoProvider) SealedBlockHeight() uint64
SealedBlockHeight provides a mock function with no fields
func (*PingInfoProvider) SoftwareVersion ¶
func (_m *PingInfoProvider) SoftwareVersion() string
SoftwareVersion provides a mock function with no fields
type PingService ¶
PingService is an autogenerated mock type for the PingService type
func NewPingService ¶
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.
type SubscriptionManager ¶
SubscriptionManager is an autogenerated mock type for the SubscriptionManager type
func NewSubscriptionManager ¶
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 ¶
func (_m *SubscriptionManager) Channels() channels.ChannelList
Channels provides a mock function with no 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 ¶
Topology is an autogenerated mock type for the Topology type
func NewTopology ¶
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 ¶
func (_m *Topology) Fanout(ids flow.IdentityList) flow.IdentityList
Fanout provides a mock function with given fields: ids
type Underlay ¶
Underlay is an autogenerated mock type for the Underlay type
func NewUnderlay ¶
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 ¶
func (_m *Underlay) Done() <-chan struct{}
Done provides a mock function with no fields
func (*Underlay) OnAllowListNotification ¶
func (_m *Underlay) OnAllowListNotification(_a0 *network.AllowListingUpdate)
OnAllowListNotification provides a mock function with given fields: _a0
func (*Underlay) OnDisallowListNotification ¶
func (_m *Underlay) OnDisallowListNotification(_a0 *network.DisallowListingUpdate)
OnDisallowListNotification provides a mock function with given fields: _a0
func (*Underlay) Ready ¶
func (_m *Underlay) Ready() <-chan struct{}
Ready provides a mock function with no fields
func (*Underlay) Unsubscribe ¶
Unsubscribe provides a mock function with given fields: channel
func (*Underlay) UpdateNodeAddresses ¶
func (_m *Underlay) UpdateNodeAddresses()
UpdateNodeAddresses provides a mock function with no fields
type ViolationsConsumer ¶
ViolationsConsumer is an autogenerated mock type for the ViolationsConsumer type
func NewViolationsConsumer ¶
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 ¶
func (_m *ViolationsConsumer) OnInvalidMsgError(violation *network.Violation)
OnInvalidMsgError provides a mock function with given fields: violation
func (*ViolationsConsumer) OnSenderEjectedError ¶
func (_m *ViolationsConsumer) OnSenderEjectedError(violation *network.Violation)
OnSenderEjectedError provides a mock function with given fields: violation
func (*ViolationsConsumer) OnUnAuthorizedSenderError ¶
func (_m *ViolationsConsumer) OnUnAuthorizedSenderError(violation *network.Violation)
OnUnAuthorizedSenderError provides a mock function with given fields: violation
func (*ViolationsConsumer) OnUnauthorizedPublishOnChannel ¶
func (_m *ViolationsConsumer) OnUnauthorizedPublishOnChannel(violation *network.Violation)
OnUnauthorizedPublishOnChannel provides a mock function with given fields: violation
func (*ViolationsConsumer) OnUnauthorizedUnicastOnChannel ¶
func (_m *ViolationsConsumer) OnUnauthorizedUnicastOnChannel(violation *network.Violation)
OnUnauthorizedUnicastOnChannel provides a mock function with given fields: violation
func (*ViolationsConsumer) OnUnexpectedError ¶
func (_m *ViolationsConsumer) OnUnexpectedError(violation *network.Violation)
OnUnexpectedError provides a mock function with given fields: violation
func (*ViolationsConsumer) OnUnknownMsgTypeError ¶
func (_m *ViolationsConsumer) OnUnknownMsgTypeError(violation *network.Violation)
OnUnknownMsgTypeError provides a mock function with given fields: violation
type WriteCloseFlusher ¶
WriteCloseFlusher is an autogenerated mock type for the WriteCloseFlusher type
func NewWriteCloseFlusher ¶
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 ¶
func (_m *WriteCloseFlusher) Close() error
Close provides a mock function with no fields
func (*WriteCloseFlusher) Flush ¶
func (_m *WriteCloseFlusher) Flush() error
Flush provides a mock function with no fields
Source Files
¶
- basic_resolver.go
- blob_getter.go
- blob_service.go
- codec.go
- compressor.go
- conduit.go
- conduit_adapter.go
- conduit_factory.go
- connection.go
- decoder.go
- disallow_list_notification_consumer.go
- encoder.go
- engine.go
- engine_registry.go
- incoming_message_scope.go
- message_processor.go
- message_queue.go
- message_validator.go
- misbehavior_report.go
- misbehavior_report_consumer.go
- misbehavior_report_manager.go
- misbehavior_reporter.go
- outgoing_message_scope.go
- ping_info_provider.go
- ping_service.go
- subscription_manager.go
- topology.go
- underlay.go
- violations_consumer.go
- write_close_flusher.go