mocks

package
v1.0.0-preupgrade Latest Latest
Warning

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

Go to latest
Published: Jul 14, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockServerStreamingClient

type MockServerStreamingClient[Res any] struct {
	mock.Mock
}

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 (*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

type MockServerStreamingClient_CloseSend_Call[Res any] struct {
	*mock.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 (*MockServerStreamingClient_CloseSend_Call[Res]) Run

func (*MockServerStreamingClient_CloseSend_Call[Res]) RunAndReturn

type MockServerStreamingClient_Context_Call

type MockServerStreamingClient_Context_Call[Res any] struct {
	*mock.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 (*MockServerStreamingClient_Context_Call[Res]) Run

func (*MockServerStreamingClient_Context_Call[Res]) RunAndReturn

type MockServerStreamingClient_Expecter

type MockServerStreamingClient_Expecter[Res any] struct {
	// contains filtered or unexported fields
}

func (*MockServerStreamingClient_Expecter[Res]) CloseSend

CloseSend is a helper method to define mock.On call

func (*MockServerStreamingClient_Expecter[Res]) Context

Context is a helper method to define mock.On call

func (*MockServerStreamingClient_Expecter[Res]) Header

Header is a helper method to define mock.On call

func (*MockServerStreamingClient_Expecter[Res]) Recv

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

Trailer is a helper method to define mock.On call

type MockServerStreamingClient_Header_Call

type MockServerStreamingClient_Header_Call[Res any] struct {
	*mock.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 (*MockServerStreamingClient_Header_Call[Res]) Run

func (*MockServerStreamingClient_Header_Call[Res]) RunAndReturn

type MockServerStreamingClient_RecvMsg_Call

type MockServerStreamingClient_RecvMsg_Call[Res any] struct {
	*mock.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 (*MockServerStreamingClient_RecvMsg_Call[Res]) Run

func (*MockServerStreamingClient_RecvMsg_Call[Res]) RunAndReturn

type MockServerStreamingClient_Recv_Call

type MockServerStreamingClient_Recv_Call[Res any] struct {
	*mock.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 (*MockServerStreamingClient_Recv_Call[Res]) Run

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

type MockServerStreamingClient_SendMsg_Call[Res any] struct {
	*mock.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 (*MockServerStreamingClient_SendMsg_Call[Res]) Run

func (*MockServerStreamingClient_SendMsg_Call[Res]) RunAndReturn

type MockServerStreamingClient_Trailer_Call

type MockServerStreamingClient_Trailer_Call[Res any] struct {
	*mock.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 (*MockServerStreamingClient_Trailer_Call[Res]) Run

func (*MockServerStreamingClient_Trailer_Call[Res]) RunAndReturn

type MockStateServiceClient

type MockStateServiceClient struct {
	mock.Mock
}

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 (*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

type MockStateServiceClient_GetActiveContracts_Call struct {
	*mock.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

type MockStateServiceClient_GetConnectedSynchronizers_Call struct {
	*mock.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 (*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

type MockStateServiceClient_GetLatestPrunedOffsets_Call struct {
	*mock.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 (*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

type MockStateServiceClient_GetLedgerEnd_Call struct {
	*mock.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

type MockUpdateServiceClient struct {
	mock.Mock
}

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 (*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

type MockUpdateServiceClient_GetUpdateById_Call struct {
	*mock.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

type MockUpdateServiceClient_GetUpdateByOffset_Call struct {
	*mock.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

type MockUpdateServiceClient_GetUpdates_Call struct {
	*mock.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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL