mocks

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: github.com/NethermindEth/near-sffl/operator (interfaces: AggregatorRpcClienter)

Generated by this command:

mockgen -destination=./mocks/rpc_client.go -package=mocks github.com/NethermindEth/near-sffl/operator AggregatorRpcClienter

Package mocks is a generated GoMock package.

Index

• type MockAggregatorRpcClienter
  • func NewMockAggregatorRpcClienter(ctrl *gomock.Controller) *MockAggregatorRpcClienter
  • func (m *MockAggregatorRpcClienter) EXPECT() *MockAggregatorRpcClienterMockRecorder
  • func (m *MockAggregatorRpcClienter) EnableMetrics(arg0 *prometheus.Registry) error
  • func (m *MockAggregatorRpcClienter) GetAggregatedCheckpointMessages(arg0, arg1 uint64) (*messages.CheckpointMessages, error)
  • func (m *MockAggregatorRpcClienter) SendSignedCheckpointTaskResponseToAggregator(arg0 *messages.SignedCheckpointTaskResponse)
  • func (m *MockAggregatorRpcClienter) SendSignedOperatorSetUpdateToAggregator(arg0 *messages.SignedOperatorSetUpdateMessage)
  • func (m *MockAggregatorRpcClienter) SendSignedStateRootUpdateToAggregator(arg0 *messages.SignedStateRootUpdateMessage)
• type MockAggregatorRpcClienterMockRecorder
  • func (mr *MockAggregatorRpcClienterMockRecorder) EnableMetrics(arg0 any) *gomock.Call
  • func (mr *MockAggregatorRpcClienterMockRecorder) GetAggregatedCheckpointMessages(arg0, arg1 any) *gomock.Call
  • func (mr *MockAggregatorRpcClienterMockRecorder) SendSignedCheckpointTaskResponseToAggregator(arg0 any) *gomock.Call
  • func (mr *MockAggregatorRpcClienterMockRecorder) SendSignedOperatorSetUpdateToAggregator(arg0 any) *gomock.Call
  • func (mr *MockAggregatorRpcClienterMockRecorder) SendSignedStateRootUpdateToAggregator(arg0 any) *gomock.Call
• type MockAttestor
  • func NewMockAttestor(blsKeypair *bls.KeyPair, operatorId eigentypes.OperatorId) *MockAttestor
  • func (mockAttestor *MockAttestor) Close() error
  • func (mockAttestor *MockAttestor) EnableMetrics(_ *prometheus.Registry) error
  • func (mockAttestor *MockAttestor) GetSignedRootC() <-chan messages.SignedStateRootUpdateMessage
  • func (mockAttestor *MockAttestor) MockGetConsumer() *MockConsumer
  • func (mockAttestor *MockAttestor) Start(ctx context.Context) error
• type MockConsumer
  • func NewMockConsumer() *MockConsumer
  • func (c *MockConsumer) Close() error
  • func (c *MockConsumer) GetBlockStream() <-chan consumer.BlockData
  • func (c *MockConsumer) MockReceiveBlockData(data consumer.BlockData)
  • func (c *MockConsumer) Reconnect(addr string, ctx context.Context)
  • func (c *MockConsumer) ResetChannel(conn *rmq.Connection, ctx context.Context) bool

Types

type MockAggregatorRpcClienter

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

MockAggregatorRpcClienter is a mock of AggregatorRpcClienter interface.

func NewMockAggregatorRpcClienter

func NewMockAggregatorRpcClienter(ctrl *gomock.Controller) *MockAggregatorRpcClienter

NewMockAggregatorRpcClienter creates a new mock instance.

func (*MockAggregatorRpcClienter) EXPECT

func (m *MockAggregatorRpcClienter) EXPECT() *MockAggregatorRpcClienterMockRecorder

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

func (*MockAggregatorRpcClienter) EnableMetrics

func (m *MockAggregatorRpcClienter) EnableMetrics(arg0 *prometheus.Registry) error

EnableMetrics mocks base method.

func (*MockAggregatorRpcClienter) GetAggregatedCheckpointMessages

func (m *MockAggregatorRpcClienter) GetAggregatedCheckpointMessages(arg0, arg1 uint64) (*messages.CheckpointMessages, error)

GetAggregatedCheckpointMessages mocks base method.

func (*MockAggregatorRpcClienter) SendSignedCheckpointTaskResponseToAggregator

func (m *MockAggregatorRpcClienter) SendSignedCheckpointTaskResponseToAggregator(arg0 *messages.SignedCheckpointTaskResponse)

SendSignedCheckpointTaskResponseToAggregator mocks base method.

func (*MockAggregatorRpcClienter) SendSignedOperatorSetUpdateToAggregator

func (m *MockAggregatorRpcClienter) SendSignedOperatorSetUpdateToAggregator(arg0 *messages.SignedOperatorSetUpdateMessage)

SendSignedOperatorSetUpdateToAggregator mocks base method.

func (*MockAggregatorRpcClienter) SendSignedStateRootUpdateToAggregator

func (m *MockAggregatorRpcClienter) SendSignedStateRootUpdateToAggregator(arg0 *messages.SignedStateRootUpdateMessage)

SendSignedStateRootUpdateToAggregator mocks base method.

type MockAggregatorRpcClienterMockRecorder

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

MockAggregatorRpcClienterMockRecorder is the mock recorder for MockAggregatorRpcClienter.

func (*MockAggregatorRpcClienterMockRecorder) EnableMetrics

func (mr *MockAggregatorRpcClienterMockRecorder) EnableMetrics(arg0 any) *gomock.Call

EnableMetrics indicates an expected call of EnableMetrics.

func (*MockAggregatorRpcClienterMockRecorder) GetAggregatedCheckpointMessages

func (mr *MockAggregatorRpcClienterMockRecorder) GetAggregatedCheckpointMessages(arg0, arg1 any) *gomock.Call

GetAggregatedCheckpointMessages indicates an expected call of GetAggregatedCheckpointMessages.

func (*MockAggregatorRpcClienterMockRecorder) SendSignedCheckpointTaskResponseToAggregator

func (mr *MockAggregatorRpcClienterMockRecorder) SendSignedCheckpointTaskResponseToAggregator(arg0 any) *gomock.Call

SendSignedCheckpointTaskResponseToAggregator indicates an expected call of SendSignedCheckpointTaskResponseToAggregator.

func (*MockAggregatorRpcClienterMockRecorder) SendSignedOperatorSetUpdateToAggregator

func (mr *MockAggregatorRpcClienterMockRecorder) SendSignedOperatorSetUpdateToAggregator(arg0 any) *gomock.Call

SendSignedOperatorSetUpdateToAggregator indicates an expected call of SendSignedOperatorSetUpdateToAggregator.

func (*MockAggregatorRpcClienterMockRecorder) SendSignedStateRootUpdateToAggregator

func (mr *MockAggregatorRpcClienterMockRecorder) SendSignedStateRootUpdateToAggregator(arg0 any) *gomock.Call

SendSignedStateRootUpdateToAggregator indicates an expected call of SendSignedStateRootUpdateToAggregator.

type MockAttestor

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

func NewMockAttestor

func NewMockAttestor(blsKeypair *bls.KeyPair, operatorId eigentypes.OperatorId) *MockAttestor

func (*MockAttestor) Close

func (mockAttestor *MockAttestor) Close() error

func (*MockAttestor) EnableMetrics

func (mockAttestor *MockAttestor) EnableMetrics(_ *prometheus.Registry) error

func (*MockAttestor) GetSignedRootC

func (mockAttestor *MockAttestor) GetSignedRootC() <-chan messages.SignedStateRootUpdateMessage

func (*MockAttestor) MockGetConsumer

func (mockAttestor *MockAttestor) MockGetConsumer() *MockConsumer

func (*MockAttestor) Start

func (mockAttestor *MockAttestor) Start(ctx context.Context) error

type MockConsumer

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

func NewMockConsumer

func NewMockConsumer() *MockConsumer

func (*MockConsumer) Close

func (c *MockConsumer) Close() error

func (*MockConsumer) GetBlockStream

func (c *MockConsumer) GetBlockStream() <-chan consumer.BlockData

func (*MockConsumer) MockReceiveBlockData

func (c *MockConsumer) MockReceiveBlockData(data consumer.BlockData)

func (*MockConsumer) Reconnect

func (c *MockConsumer) Reconnect(addr string, ctx context.Context)

func (*MockConsumer) ResetChannel

func (c *MockConsumer) ResetChannel(conn *rmq.Connection, ctx context.Context) bool