Documentation
¶
Index ¶
- type MockServerStreamingClient
- func (_mock *MockServerStreamingClient[Res]) CloseSend() error
- func (_mock *MockServerStreamingClient[Res]) Context() context.Context
- func (_m *MockServerStreamingClient[Res]) EXPECT() *MockServerStreamingClient_Expecter[Res]
- func (_mock *MockServerStreamingClient[Res]) Header() (metadata.MD, error)
- func (_mock *MockServerStreamingClient[Res]) Recv() (*Res, error)
- func (_mock *MockServerStreamingClient[Res]) RecvMsg(m any) error
- func (_mock *MockServerStreamingClient[Res]) SendMsg(m any) error
- func (_mock *MockServerStreamingClient[Res]) Trailer() metadata.MD
- type MockServerStreamingClient_CloseSend_Call
- func (_c *MockServerStreamingClient_CloseSend_Call[Res]) Return(err error) *MockServerStreamingClient_CloseSend_Call[Res]
- func (_c *MockServerStreamingClient_CloseSend_Call[Res]) Run(run func()) *MockServerStreamingClient_CloseSend_Call[Res]
- func (_c *MockServerStreamingClient_CloseSend_Call[Res]) RunAndReturn(run func() error) *MockServerStreamingClient_CloseSend_Call[Res]
- type MockServerStreamingClient_Context_Call
- func (_c *MockServerStreamingClient_Context_Call[Res]) Return(context1 context.Context) *MockServerStreamingClient_Context_Call[Res]
- func (_c *MockServerStreamingClient_Context_Call[Res]) Run(run func()) *MockServerStreamingClient_Context_Call[Res]
- func (_c *MockServerStreamingClient_Context_Call[Res]) RunAndReturn(run func() context.Context) *MockServerStreamingClient_Context_Call[Res]
- type MockServerStreamingClient_Expecter
- func (_e *MockServerStreamingClient_Expecter[Res]) CloseSend() *MockServerStreamingClient_CloseSend_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) Context() *MockServerStreamingClient_Context_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) Header() *MockServerStreamingClient_Header_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) Recv() *MockServerStreamingClient_Recv_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) RecvMsg(m interface{}) *MockServerStreamingClient_RecvMsg_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) SendMsg(m interface{}) *MockServerStreamingClient_SendMsg_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) Trailer() *MockServerStreamingClient_Trailer_Call[Res]
- type MockServerStreamingClient_Header_Call
- func (_c *MockServerStreamingClient_Header_Call[Res]) Return(mD metadata.MD, err error) *MockServerStreamingClient_Header_Call[Res]
- func (_c *MockServerStreamingClient_Header_Call[Res]) Run(run func()) *MockServerStreamingClient_Header_Call[Res]
- func (_c *MockServerStreamingClient_Header_Call[Res]) RunAndReturn(run func() (metadata.MD, error)) *MockServerStreamingClient_Header_Call[Res]
- type MockServerStreamingClient_RecvMsg_Call
- func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) Return(err error) *MockServerStreamingClient_RecvMsg_Call[Res]
- func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) Run(run func(m any)) *MockServerStreamingClient_RecvMsg_Call[Res]
- func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) RunAndReturn(run func(m any) error) *MockServerStreamingClient_RecvMsg_Call[Res]
- type MockServerStreamingClient_Recv_Call
- func (_c *MockServerStreamingClient_Recv_Call[Res]) Return(v *Res, err error) *MockServerStreamingClient_Recv_Call[Res]
- func (_c *MockServerStreamingClient_Recv_Call[Res]) Run(run func()) *MockServerStreamingClient_Recv_Call[Res]
- func (_c *MockServerStreamingClient_Recv_Call[Res]) RunAndReturn(run func() (*Res, error)) *MockServerStreamingClient_Recv_Call[Res]
- type MockServerStreamingClient_SendMsg_Call
- func (_c *MockServerStreamingClient_SendMsg_Call[Res]) Return(err error) *MockServerStreamingClient_SendMsg_Call[Res]
- func (_c *MockServerStreamingClient_SendMsg_Call[Res]) Run(run func(m any)) *MockServerStreamingClient_SendMsg_Call[Res]
- func (_c *MockServerStreamingClient_SendMsg_Call[Res]) RunAndReturn(run func(m any) error) *MockServerStreamingClient_SendMsg_Call[Res]
- type MockServerStreamingClient_Trailer_Call
- func (_c *MockServerStreamingClient_Trailer_Call[Res]) Return(mD metadata.MD) *MockServerStreamingClient_Trailer_Call[Res]
- func (_c *MockServerStreamingClient_Trailer_Call[Res]) Run(run func()) *MockServerStreamingClient_Trailer_Call[Res]
- func (_c *MockServerStreamingClient_Trailer_Call[Res]) RunAndReturn(run func() metadata.MD) *MockServerStreamingClient_Trailer_Call[Res]
- type MockStateServiceClient
- func (_m *MockStateServiceClient) EXPECT() *MockStateServiceClient_Expecter
- func (_mock *MockStateServiceClient) GetActiveContracts(ctx context.Context, in *v2.GetActiveContractsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[v2.GetActiveContractsResponse], error)
- func (_mock *MockStateServiceClient) GetConnectedSynchronizers(ctx context.Context, in *v2.GetConnectedSynchronizersRequest, ...) (*v2.GetConnectedSynchronizersResponse, error)
- func (_mock *MockStateServiceClient) GetLatestPrunedOffsets(ctx context.Context, in *v2.GetLatestPrunedOffsetsRequest, ...) (*v2.GetLatestPrunedOffsetsResponse, error)
- func (_mock *MockStateServiceClient) GetLedgerEnd(ctx context.Context, in *v2.GetLedgerEndRequest, opts ...grpc.CallOption) (*v2.GetLedgerEndResponse, error)
- type MockStateServiceClient_Expecter
- func (_e *MockStateServiceClient_Expecter) GetActiveContracts(ctx interface{}, in interface{}, opts ...interface{}) *MockStateServiceClient_GetActiveContracts_Call
- func (_e *MockStateServiceClient_Expecter) GetConnectedSynchronizers(ctx interface{}, in interface{}, opts ...interface{}) *MockStateServiceClient_GetConnectedSynchronizers_Call
- func (_e *MockStateServiceClient_Expecter) GetLatestPrunedOffsets(ctx interface{}, in interface{}, opts ...interface{}) *MockStateServiceClient_GetLatestPrunedOffsets_Call
- func (_e *MockStateServiceClient_Expecter) GetLedgerEnd(ctx interface{}, in interface{}, opts ...interface{}) *MockStateServiceClient_GetLedgerEnd_Call
- type MockStateServiceClient_GetActiveContracts_Call
- func (_c *MockStateServiceClient_GetActiveContracts_Call) Return(...) *MockStateServiceClient_GetActiveContracts_Call
- func (_c *MockStateServiceClient_GetActiveContracts_Call) Run(...) *MockStateServiceClient_GetActiveContracts_Call
- func (_c *MockStateServiceClient_GetActiveContracts_Call) RunAndReturn(...) *MockStateServiceClient_GetActiveContracts_Call
- type MockStateServiceClient_GetConnectedSynchronizers_Call
- func (_c *MockStateServiceClient_GetConnectedSynchronizers_Call) Return(getConnectedSynchronizersResponse *v2.GetConnectedSynchronizersResponse, ...) *MockStateServiceClient_GetConnectedSynchronizers_Call
- func (_c *MockStateServiceClient_GetConnectedSynchronizers_Call) Run(run func(ctx context.Context, in *v2.GetConnectedSynchronizersRequest, ...)) *MockStateServiceClient_GetConnectedSynchronizers_Call
- func (_c *MockStateServiceClient_GetConnectedSynchronizers_Call) RunAndReturn(...) *MockStateServiceClient_GetConnectedSynchronizers_Call
- type MockStateServiceClient_GetLatestPrunedOffsets_Call
- func (_c *MockStateServiceClient_GetLatestPrunedOffsets_Call) Return(getLatestPrunedOffsetsResponse *v2.GetLatestPrunedOffsetsResponse, err error) *MockStateServiceClient_GetLatestPrunedOffsets_Call
- func (_c *MockStateServiceClient_GetLatestPrunedOffsets_Call) Run(run func(ctx context.Context, in *v2.GetLatestPrunedOffsetsRequest, ...)) *MockStateServiceClient_GetLatestPrunedOffsets_Call
- func (_c *MockStateServiceClient_GetLatestPrunedOffsets_Call) RunAndReturn(...) *MockStateServiceClient_GetLatestPrunedOffsets_Call
- type MockStateServiceClient_GetLedgerEnd_Call
- func (_c *MockStateServiceClient_GetLedgerEnd_Call) Return(getLedgerEndResponse *v2.GetLedgerEndResponse, err error) *MockStateServiceClient_GetLedgerEnd_Call
- func (_c *MockStateServiceClient_GetLedgerEnd_Call) Run(...) *MockStateServiceClient_GetLedgerEnd_Call
- func (_c *MockStateServiceClient_GetLedgerEnd_Call) RunAndReturn(...) *MockStateServiceClient_GetLedgerEnd_Call
- type MockUpdateServiceClient
- func (_m *MockUpdateServiceClient) EXPECT() *MockUpdateServiceClient_Expecter
- func (_mock *MockUpdateServiceClient) GetUpdateById(ctx context.Context, in *v2.GetUpdateByIdRequest, opts ...grpc.CallOption) (*v2.GetUpdateResponse, error)
- func (_mock *MockUpdateServiceClient) GetUpdateByOffset(ctx context.Context, in *v2.GetUpdateByOffsetRequest, opts ...grpc.CallOption) (*v2.GetUpdateResponse, error)
- func (_mock *MockUpdateServiceClient) GetUpdates(ctx context.Context, in *v2.GetUpdatesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[v2.GetUpdatesResponse], error)
- type MockUpdateServiceClient_Expecter
- func (_e *MockUpdateServiceClient_Expecter) GetUpdateById(ctx interface{}, in interface{}, opts ...interface{}) *MockUpdateServiceClient_GetUpdateById_Call
- func (_e *MockUpdateServiceClient_Expecter) GetUpdateByOffset(ctx interface{}, in interface{}, opts ...interface{}) *MockUpdateServiceClient_GetUpdateByOffset_Call
- func (_e *MockUpdateServiceClient_Expecter) GetUpdates(ctx interface{}, in interface{}, opts ...interface{}) *MockUpdateServiceClient_GetUpdates_Call
- type MockUpdateServiceClient_GetUpdateById_Call
- func (_c *MockUpdateServiceClient_GetUpdateById_Call) Return(getUpdateResponse *v2.GetUpdateResponse, err error) *MockUpdateServiceClient_GetUpdateById_Call
- func (_c *MockUpdateServiceClient_GetUpdateById_Call) Run(...) *MockUpdateServiceClient_GetUpdateById_Call
- func (_c *MockUpdateServiceClient_GetUpdateById_Call) RunAndReturn(...) *MockUpdateServiceClient_GetUpdateById_Call
- type MockUpdateServiceClient_GetUpdateByOffset_Call
- func (_c *MockUpdateServiceClient_GetUpdateByOffset_Call) Return(getUpdateResponse *v2.GetUpdateResponse, err error) *MockUpdateServiceClient_GetUpdateByOffset_Call
- func (_c *MockUpdateServiceClient_GetUpdateByOffset_Call) Run(...) *MockUpdateServiceClient_GetUpdateByOffset_Call
- func (_c *MockUpdateServiceClient_GetUpdateByOffset_Call) RunAndReturn(...) *MockUpdateServiceClient_GetUpdateByOffset_Call
- type MockUpdateServiceClient_GetUpdates_Call
- func (_c *MockUpdateServiceClient_GetUpdates_Call) Return(serverStreamingClient grpc.ServerStreamingClient[v2.GetUpdatesResponse], ...) *MockUpdateServiceClient_GetUpdates_Call
- func (_c *MockUpdateServiceClient_GetUpdates_Call) Run(...) *MockUpdateServiceClient_GetUpdates_Call
- func (_c *MockUpdateServiceClient_GetUpdates_Call) RunAndReturn(...) *MockUpdateServiceClient_GetUpdates_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockServerStreamingClient ¶
MockServerStreamingClient is an autogenerated mock type for the ServerStreamingClient type
func NewMockServerStreamingClient ¶
func NewMockServerStreamingClient[Res any](t interface { mock.TestingT Cleanup(func()) }) *MockServerStreamingClient[Res]
NewMockServerStreamingClient creates a new instance of MockServerStreamingClient. 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 (*MockServerStreamingClient[Res]) CloseSend ¶
func (_mock *MockServerStreamingClient[Res]) CloseSend() error
CloseSend provides a mock function for the type MockServerStreamingClient
func (*MockServerStreamingClient[Res]) Context ¶
func (_mock *MockServerStreamingClient[Res]) Context() context.Context
Context provides a mock function for the type MockServerStreamingClient
func (*MockServerStreamingClient[Res]) EXPECT ¶
func (_m *MockServerStreamingClient[Res]) EXPECT() *MockServerStreamingClient_Expecter[Res]
func (*MockServerStreamingClient[Res]) Header ¶
func (_mock *MockServerStreamingClient[Res]) Header() (metadata.MD, error)
Header provides a mock function for the type MockServerStreamingClient
func (*MockServerStreamingClient[Res]) Recv ¶
func (_mock *MockServerStreamingClient[Res]) Recv() (*Res, error)
Recv provides a mock function for the type MockServerStreamingClient
func (*MockServerStreamingClient[Res]) RecvMsg ¶
func (_mock *MockServerStreamingClient[Res]) RecvMsg(m any) error
RecvMsg provides a mock function for the type MockServerStreamingClient
func (*MockServerStreamingClient[Res]) SendMsg ¶
func (_mock *MockServerStreamingClient[Res]) SendMsg(m any) error
SendMsg provides a mock function for the type MockServerStreamingClient
func (*MockServerStreamingClient[Res]) Trailer ¶
func (_mock *MockServerStreamingClient[Res]) Trailer() metadata.MD
Trailer provides a mock function for the type MockServerStreamingClient
type MockServerStreamingClient_CloseSend_Call ¶
MockServerStreamingClient_CloseSend_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseSend'
func (*MockServerStreamingClient_CloseSend_Call[Res]) Return ¶
func (_c *MockServerStreamingClient_CloseSend_Call[Res]) Return(err error) *MockServerStreamingClient_CloseSend_Call[Res]
func (*MockServerStreamingClient_CloseSend_Call[Res]) Run ¶
func (_c *MockServerStreamingClient_CloseSend_Call[Res]) Run(run func()) *MockServerStreamingClient_CloseSend_Call[Res]
func (*MockServerStreamingClient_CloseSend_Call[Res]) RunAndReturn ¶
func (_c *MockServerStreamingClient_CloseSend_Call[Res]) RunAndReturn(run func() error) *MockServerStreamingClient_CloseSend_Call[Res]
type MockServerStreamingClient_Context_Call ¶
MockServerStreamingClient_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'
func (*MockServerStreamingClient_Context_Call[Res]) Return ¶
func (_c *MockServerStreamingClient_Context_Call[Res]) Return(context1 context.Context) *MockServerStreamingClient_Context_Call[Res]
func (*MockServerStreamingClient_Context_Call[Res]) Run ¶
func (_c *MockServerStreamingClient_Context_Call[Res]) Run(run func()) *MockServerStreamingClient_Context_Call[Res]
func (*MockServerStreamingClient_Context_Call[Res]) RunAndReturn ¶
func (_c *MockServerStreamingClient_Context_Call[Res]) RunAndReturn(run func() context.Context) *MockServerStreamingClient_Context_Call[Res]
type MockServerStreamingClient_Expecter ¶
type MockServerStreamingClient_Expecter[Res any] struct { // contains filtered or unexported fields }
func (*MockServerStreamingClient_Expecter[Res]) CloseSend ¶
func (_e *MockServerStreamingClient_Expecter[Res]) CloseSend() *MockServerStreamingClient_CloseSend_Call[Res]
CloseSend is a helper method to define mock.On call
func (*MockServerStreamingClient_Expecter[Res]) Context ¶
func (_e *MockServerStreamingClient_Expecter[Res]) Context() *MockServerStreamingClient_Context_Call[Res]
Context is a helper method to define mock.On call
func (*MockServerStreamingClient_Expecter[Res]) Header ¶
func (_e *MockServerStreamingClient_Expecter[Res]) Header() *MockServerStreamingClient_Header_Call[Res]
Header is a helper method to define mock.On call
func (*MockServerStreamingClient_Expecter[Res]) Recv ¶
func (_e *MockServerStreamingClient_Expecter[Res]) Recv() *MockServerStreamingClient_Recv_Call[Res]
Recv is a helper method to define mock.On call
func (*MockServerStreamingClient_Expecter[Res]) RecvMsg ¶
func (_e *MockServerStreamingClient_Expecter[Res]) RecvMsg(m interface{}) *MockServerStreamingClient_RecvMsg_Call[Res]
RecvMsg is a helper method to define mock.On call
- m any
func (*MockServerStreamingClient_Expecter[Res]) SendMsg ¶
func (_e *MockServerStreamingClient_Expecter[Res]) SendMsg(m interface{}) *MockServerStreamingClient_SendMsg_Call[Res]
SendMsg is a helper method to define mock.On call
- m any
func (*MockServerStreamingClient_Expecter[Res]) Trailer ¶
func (_e *MockServerStreamingClient_Expecter[Res]) Trailer() *MockServerStreamingClient_Trailer_Call[Res]
Trailer is a helper method to define mock.On call
type MockServerStreamingClient_Header_Call ¶
MockServerStreamingClient_Header_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Header'
func (*MockServerStreamingClient_Header_Call[Res]) Return ¶
func (_c *MockServerStreamingClient_Header_Call[Res]) Return(mD metadata.MD, err error) *MockServerStreamingClient_Header_Call[Res]
func (*MockServerStreamingClient_Header_Call[Res]) Run ¶
func (_c *MockServerStreamingClient_Header_Call[Res]) Run(run func()) *MockServerStreamingClient_Header_Call[Res]
func (*MockServerStreamingClient_Header_Call[Res]) RunAndReturn ¶
func (_c *MockServerStreamingClient_Header_Call[Res]) RunAndReturn(run func() (metadata.MD, error)) *MockServerStreamingClient_Header_Call[Res]
type MockServerStreamingClient_RecvMsg_Call ¶
MockServerStreamingClient_RecvMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvMsg'
func (*MockServerStreamingClient_RecvMsg_Call[Res]) Return ¶
func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) Return(err error) *MockServerStreamingClient_RecvMsg_Call[Res]
func (*MockServerStreamingClient_RecvMsg_Call[Res]) Run ¶
func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) Run(run func(m any)) *MockServerStreamingClient_RecvMsg_Call[Res]
func (*MockServerStreamingClient_RecvMsg_Call[Res]) RunAndReturn ¶
func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) RunAndReturn(run func(m any) error) *MockServerStreamingClient_RecvMsg_Call[Res]
type MockServerStreamingClient_Recv_Call ¶
MockServerStreamingClient_Recv_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Recv'
func (*MockServerStreamingClient_Recv_Call[Res]) Return ¶
func (_c *MockServerStreamingClient_Recv_Call[Res]) Return(v *Res, err error) *MockServerStreamingClient_Recv_Call[Res]
func (*MockServerStreamingClient_Recv_Call[Res]) Run ¶
func (_c *MockServerStreamingClient_Recv_Call[Res]) Run(run func()) *MockServerStreamingClient_Recv_Call[Res]
func (*MockServerStreamingClient_Recv_Call[Res]) RunAndReturn ¶
func (_c *MockServerStreamingClient_Recv_Call[Res]) RunAndReturn(run func() (*Res, error)) *MockServerStreamingClient_Recv_Call[Res]
type MockServerStreamingClient_SendMsg_Call ¶
MockServerStreamingClient_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'
func (*MockServerStreamingClient_SendMsg_Call[Res]) Return ¶
func (_c *MockServerStreamingClient_SendMsg_Call[Res]) Return(err error) *MockServerStreamingClient_SendMsg_Call[Res]
func (*MockServerStreamingClient_SendMsg_Call[Res]) Run ¶
func (_c *MockServerStreamingClient_SendMsg_Call[Res]) Run(run func(m any)) *MockServerStreamingClient_SendMsg_Call[Res]
func (*MockServerStreamingClient_SendMsg_Call[Res]) RunAndReturn ¶
func (_c *MockServerStreamingClient_SendMsg_Call[Res]) RunAndReturn(run func(m any) error) *MockServerStreamingClient_SendMsg_Call[Res]
type MockServerStreamingClient_Trailer_Call ¶
MockServerStreamingClient_Trailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Trailer'
func (*MockServerStreamingClient_Trailer_Call[Res]) Return ¶
func (_c *MockServerStreamingClient_Trailer_Call[Res]) Return(mD metadata.MD) *MockServerStreamingClient_Trailer_Call[Res]
func (*MockServerStreamingClient_Trailer_Call[Res]) Run ¶
func (_c *MockServerStreamingClient_Trailer_Call[Res]) Run(run func()) *MockServerStreamingClient_Trailer_Call[Res]
func (*MockServerStreamingClient_Trailer_Call[Res]) RunAndReturn ¶
func (_c *MockServerStreamingClient_Trailer_Call[Res]) RunAndReturn(run func() metadata.MD) *MockServerStreamingClient_Trailer_Call[Res]
type MockStateServiceClient ¶
MockStateServiceClient is an autogenerated mock type for the StateServiceClient type
func NewMockStateServiceClient ¶
func NewMockStateServiceClient(t interface {
mock.TestingT
Cleanup(func())
}) *MockStateServiceClient
NewMockStateServiceClient creates a new instance of MockStateServiceClient. 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 (*MockStateServiceClient) EXPECT ¶
func (_m *MockStateServiceClient) EXPECT() *MockStateServiceClient_Expecter
func (*MockStateServiceClient) GetActiveContracts ¶
func (_mock *MockStateServiceClient) GetActiveContracts(ctx context.Context, in *v2.GetActiveContractsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[v2.GetActiveContractsResponse], error)
GetActiveContracts provides a mock function for the type MockStateServiceClient
func (*MockStateServiceClient) GetConnectedSynchronizers ¶
func (_mock *MockStateServiceClient) GetConnectedSynchronizers(ctx context.Context, in *v2.GetConnectedSynchronizersRequest, opts ...grpc.CallOption) (*v2.GetConnectedSynchronizersResponse, error)
GetConnectedSynchronizers provides a mock function for the type MockStateServiceClient
func (*MockStateServiceClient) GetLatestPrunedOffsets ¶
func (_mock *MockStateServiceClient) GetLatestPrunedOffsets(ctx context.Context, in *v2.GetLatestPrunedOffsetsRequest, opts ...grpc.CallOption) (*v2.GetLatestPrunedOffsetsResponse, error)
GetLatestPrunedOffsets provides a mock function for the type MockStateServiceClient
func (*MockStateServiceClient) GetLedgerEnd ¶
func (_mock *MockStateServiceClient) GetLedgerEnd(ctx context.Context, in *v2.GetLedgerEndRequest, opts ...grpc.CallOption) (*v2.GetLedgerEndResponse, error)
GetLedgerEnd provides a mock function for the type MockStateServiceClient
type MockStateServiceClient_Expecter ¶
type MockStateServiceClient_Expecter struct {
// contains filtered or unexported fields
}
func (*MockStateServiceClient_Expecter) GetActiveContracts ¶
func (_e *MockStateServiceClient_Expecter) GetActiveContracts(ctx interface{}, in interface{}, opts ...interface{}) *MockStateServiceClient_GetActiveContracts_Call
GetActiveContracts is a helper method to define mock.On call
- ctx context.Context
- in *v2.GetActiveContractsRequest
- opts ...grpc.CallOption
func (*MockStateServiceClient_Expecter) GetConnectedSynchronizers ¶
func (_e *MockStateServiceClient_Expecter) GetConnectedSynchronizers(ctx interface{}, in interface{}, opts ...interface{}) *MockStateServiceClient_GetConnectedSynchronizers_Call
GetConnectedSynchronizers is a helper method to define mock.On call
- ctx context.Context
- in *v2.GetConnectedSynchronizersRequest
- opts ...grpc.CallOption
func (*MockStateServiceClient_Expecter) GetLatestPrunedOffsets ¶
func (_e *MockStateServiceClient_Expecter) GetLatestPrunedOffsets(ctx interface{}, in interface{}, opts ...interface{}) *MockStateServiceClient_GetLatestPrunedOffsets_Call
GetLatestPrunedOffsets is a helper method to define mock.On call
- ctx context.Context
- in *v2.GetLatestPrunedOffsetsRequest
- opts ...grpc.CallOption
func (*MockStateServiceClient_Expecter) GetLedgerEnd ¶
func (_e *MockStateServiceClient_Expecter) GetLedgerEnd(ctx interface{}, in interface{}, opts ...interface{}) *MockStateServiceClient_GetLedgerEnd_Call
GetLedgerEnd is a helper method to define mock.On call
- ctx context.Context
- in *v2.GetLedgerEndRequest
- opts ...grpc.CallOption
type MockStateServiceClient_GetActiveContracts_Call ¶
MockStateServiceClient_GetActiveContracts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetActiveContracts'
func (*MockStateServiceClient_GetActiveContracts_Call) Return ¶
func (_c *MockStateServiceClient_GetActiveContracts_Call) Return(serverStreamingClient grpc.ServerStreamingClient[v2.GetActiveContractsResponse], err error) *MockStateServiceClient_GetActiveContracts_Call
func (*MockStateServiceClient_GetActiveContracts_Call) Run ¶
func (_c *MockStateServiceClient_GetActiveContracts_Call) Run(run func(ctx context.Context, in *v2.GetActiveContractsRequest, opts ...grpc.CallOption)) *MockStateServiceClient_GetActiveContracts_Call
func (*MockStateServiceClient_GetActiveContracts_Call) RunAndReturn ¶
func (_c *MockStateServiceClient_GetActiveContracts_Call) RunAndReturn(run func(ctx context.Context, in *v2.GetActiveContractsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[v2.GetActiveContractsResponse], error)) *MockStateServiceClient_GetActiveContracts_Call
type MockStateServiceClient_GetConnectedSynchronizers_Call ¶
MockStateServiceClient_GetConnectedSynchronizers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConnectedSynchronizers'
func (*MockStateServiceClient_GetConnectedSynchronizers_Call) Return ¶
func (_c *MockStateServiceClient_GetConnectedSynchronizers_Call) Return(getConnectedSynchronizersResponse *v2.GetConnectedSynchronizersResponse, err error) *MockStateServiceClient_GetConnectedSynchronizers_Call
func (*MockStateServiceClient_GetConnectedSynchronizers_Call) Run ¶
func (_c *MockStateServiceClient_GetConnectedSynchronizers_Call) Run(run func(ctx context.Context, in *v2.GetConnectedSynchronizersRequest, opts ...grpc.CallOption)) *MockStateServiceClient_GetConnectedSynchronizers_Call
func (*MockStateServiceClient_GetConnectedSynchronizers_Call) RunAndReturn ¶
func (_c *MockStateServiceClient_GetConnectedSynchronizers_Call) RunAndReturn(run func(ctx context.Context, in *v2.GetConnectedSynchronizersRequest, opts ...grpc.CallOption) (*v2.GetConnectedSynchronizersResponse, error)) *MockStateServiceClient_GetConnectedSynchronizers_Call
type MockStateServiceClient_GetLatestPrunedOffsets_Call ¶
MockStateServiceClient_GetLatestPrunedOffsets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestPrunedOffsets'
func (*MockStateServiceClient_GetLatestPrunedOffsets_Call) Return ¶
func (_c *MockStateServiceClient_GetLatestPrunedOffsets_Call) Return(getLatestPrunedOffsetsResponse *v2.GetLatestPrunedOffsetsResponse, err error) *MockStateServiceClient_GetLatestPrunedOffsets_Call
func (*MockStateServiceClient_GetLatestPrunedOffsets_Call) Run ¶
func (_c *MockStateServiceClient_GetLatestPrunedOffsets_Call) Run(run func(ctx context.Context, in *v2.GetLatestPrunedOffsetsRequest, opts ...grpc.CallOption)) *MockStateServiceClient_GetLatestPrunedOffsets_Call
func (*MockStateServiceClient_GetLatestPrunedOffsets_Call) RunAndReturn ¶
func (_c *MockStateServiceClient_GetLatestPrunedOffsets_Call) RunAndReturn(run func(ctx context.Context, in *v2.GetLatestPrunedOffsetsRequest, opts ...grpc.CallOption) (*v2.GetLatestPrunedOffsetsResponse, error)) *MockStateServiceClient_GetLatestPrunedOffsets_Call
type MockStateServiceClient_GetLedgerEnd_Call ¶
MockStateServiceClient_GetLedgerEnd_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLedgerEnd'
func (*MockStateServiceClient_GetLedgerEnd_Call) Return ¶
func (_c *MockStateServiceClient_GetLedgerEnd_Call) Return(getLedgerEndResponse *v2.GetLedgerEndResponse, err error) *MockStateServiceClient_GetLedgerEnd_Call
func (*MockStateServiceClient_GetLedgerEnd_Call) Run ¶
func (_c *MockStateServiceClient_GetLedgerEnd_Call) Run(run func(ctx context.Context, in *v2.GetLedgerEndRequest, opts ...grpc.CallOption)) *MockStateServiceClient_GetLedgerEnd_Call
func (*MockStateServiceClient_GetLedgerEnd_Call) RunAndReturn ¶
func (_c *MockStateServiceClient_GetLedgerEnd_Call) RunAndReturn(run func(ctx context.Context, in *v2.GetLedgerEndRequest, opts ...grpc.CallOption) (*v2.GetLedgerEndResponse, error)) *MockStateServiceClient_GetLedgerEnd_Call
type MockUpdateServiceClient ¶
MockUpdateServiceClient is an autogenerated mock type for the UpdateServiceClient type
func NewMockUpdateServiceClient ¶
func NewMockUpdateServiceClient(t interface {
mock.TestingT
Cleanup(func())
}) *MockUpdateServiceClient
NewMockUpdateServiceClient creates a new instance of MockUpdateServiceClient. 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 (*MockUpdateServiceClient) EXPECT ¶
func (_m *MockUpdateServiceClient) EXPECT() *MockUpdateServiceClient_Expecter
func (*MockUpdateServiceClient) GetUpdateById ¶
func (_mock *MockUpdateServiceClient) GetUpdateById(ctx context.Context, in *v2.GetUpdateByIdRequest, opts ...grpc.CallOption) (*v2.GetUpdateResponse, error)
GetUpdateById provides a mock function for the type MockUpdateServiceClient
func (*MockUpdateServiceClient) GetUpdateByOffset ¶
func (_mock *MockUpdateServiceClient) GetUpdateByOffset(ctx context.Context, in *v2.GetUpdateByOffsetRequest, opts ...grpc.CallOption) (*v2.GetUpdateResponse, error)
GetUpdateByOffset provides a mock function for the type MockUpdateServiceClient
func (*MockUpdateServiceClient) GetUpdates ¶
func (_mock *MockUpdateServiceClient) GetUpdates(ctx context.Context, in *v2.GetUpdatesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[v2.GetUpdatesResponse], error)
GetUpdates provides a mock function for the type MockUpdateServiceClient
type MockUpdateServiceClient_Expecter ¶
type MockUpdateServiceClient_Expecter struct {
// contains filtered or unexported fields
}
func (*MockUpdateServiceClient_Expecter) GetUpdateById ¶
func (_e *MockUpdateServiceClient_Expecter) GetUpdateById(ctx interface{}, in interface{}, opts ...interface{}) *MockUpdateServiceClient_GetUpdateById_Call
GetUpdateById is a helper method to define mock.On call
- ctx context.Context
- in *v2.GetUpdateByIdRequest
- opts ...grpc.CallOption
func (*MockUpdateServiceClient_Expecter) GetUpdateByOffset ¶
func (_e *MockUpdateServiceClient_Expecter) GetUpdateByOffset(ctx interface{}, in interface{}, opts ...interface{}) *MockUpdateServiceClient_GetUpdateByOffset_Call
GetUpdateByOffset is a helper method to define mock.On call
- ctx context.Context
- in *v2.GetUpdateByOffsetRequest
- opts ...grpc.CallOption
func (*MockUpdateServiceClient_Expecter) GetUpdates ¶
func (_e *MockUpdateServiceClient_Expecter) GetUpdates(ctx interface{}, in interface{}, opts ...interface{}) *MockUpdateServiceClient_GetUpdates_Call
GetUpdates is a helper method to define mock.On call
- ctx context.Context
- in *v2.GetUpdatesRequest
- opts ...grpc.CallOption
type MockUpdateServiceClient_GetUpdateById_Call ¶
MockUpdateServiceClient_GetUpdateById_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUpdateById'
func (*MockUpdateServiceClient_GetUpdateById_Call) Return ¶
func (_c *MockUpdateServiceClient_GetUpdateById_Call) Return(getUpdateResponse *v2.GetUpdateResponse, err error) *MockUpdateServiceClient_GetUpdateById_Call
func (*MockUpdateServiceClient_GetUpdateById_Call) Run ¶
func (_c *MockUpdateServiceClient_GetUpdateById_Call) Run(run func(ctx context.Context, in *v2.GetUpdateByIdRequest, opts ...grpc.CallOption)) *MockUpdateServiceClient_GetUpdateById_Call
func (*MockUpdateServiceClient_GetUpdateById_Call) RunAndReturn ¶
func (_c *MockUpdateServiceClient_GetUpdateById_Call) RunAndReturn(run func(ctx context.Context, in *v2.GetUpdateByIdRequest, opts ...grpc.CallOption) (*v2.GetUpdateResponse, error)) *MockUpdateServiceClient_GetUpdateById_Call
type MockUpdateServiceClient_GetUpdateByOffset_Call ¶
MockUpdateServiceClient_GetUpdateByOffset_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUpdateByOffset'
func (*MockUpdateServiceClient_GetUpdateByOffset_Call) Return ¶
func (_c *MockUpdateServiceClient_GetUpdateByOffset_Call) Return(getUpdateResponse *v2.GetUpdateResponse, err error) *MockUpdateServiceClient_GetUpdateByOffset_Call
func (*MockUpdateServiceClient_GetUpdateByOffset_Call) Run ¶
func (_c *MockUpdateServiceClient_GetUpdateByOffset_Call) Run(run func(ctx context.Context, in *v2.GetUpdateByOffsetRequest, opts ...grpc.CallOption)) *MockUpdateServiceClient_GetUpdateByOffset_Call
func (*MockUpdateServiceClient_GetUpdateByOffset_Call) RunAndReturn ¶
func (_c *MockUpdateServiceClient_GetUpdateByOffset_Call) RunAndReturn(run func(ctx context.Context, in *v2.GetUpdateByOffsetRequest, opts ...grpc.CallOption) (*v2.GetUpdateResponse, error)) *MockUpdateServiceClient_GetUpdateByOffset_Call
type MockUpdateServiceClient_GetUpdates_Call ¶
MockUpdateServiceClient_GetUpdates_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUpdates'
func (*MockUpdateServiceClient_GetUpdates_Call) Return ¶
func (_c *MockUpdateServiceClient_GetUpdates_Call) Return(serverStreamingClient grpc.ServerStreamingClient[v2.GetUpdatesResponse], err error) *MockUpdateServiceClient_GetUpdates_Call
func (*MockUpdateServiceClient_GetUpdates_Call) Run ¶
func (_c *MockUpdateServiceClient_GetUpdates_Call) Run(run func(ctx context.Context, in *v2.GetUpdatesRequest, opts ...grpc.CallOption)) *MockUpdateServiceClient_GetUpdates_Call
func (*MockUpdateServiceClient_GetUpdates_Call) RunAndReturn ¶
func (_c *MockUpdateServiceClient_GetUpdates_Call) RunAndReturn(run func(ctx context.Context, in *v2.GetUpdatesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[v2.GetUpdatesResponse], error)) *MockUpdateServiceClient_GetUpdates_Call