Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockDoer
- type MockDoerMockRecorder
- type MockGetter
- type MockGetterMockRecorder
- type MockPublisher
- type MockPublisherMockRecorder
- type MockReceiver
- type MockReceiverMockRecorder
- type MockSubscriberPipeline
- func (m *MockSubscriberPipeline) Batch(itemType reflect.Type, batchSize int, timeout time.Duration) pubsub0.SubscriberPipeline
- func (m *MockSubscriberPipeline) EXPECT() *MockSubscriberPipelineMockRecorder
- func (m *MockSubscriberPipeline) Errors() chan error
- func (m *MockSubscriberPipeline) Map(mapFn func(any) (any, error)) pubsub0.SubscriberPipeline
- func (m *MockSubscriberPipeline) Reduce(reduceFn func(interface{}, interface{}, int) (interface{}, error), ...) pubsub0.SubscriberPipeline
- func (m *MockSubscriberPipeline) Run(ctx context.Context) chan any
- type MockSubscriberPipelineMockRecorder
- func (mr *MockSubscriberPipelineMockRecorder) Batch(itemType, batchSize, timeout interface{}) *gomock.Call
- func (mr *MockSubscriberPipelineMockRecorder) Errors() *gomock.Call
- func (mr *MockSubscriberPipelineMockRecorder) Map(mapFn interface{}) *gomock.Call
- func (mr *MockSubscriberPipelineMockRecorder) Reduce(reduceFn, initialState interface{}) *gomock.Call
- func (mr *MockSubscriberPipelineMockRecorder) Run(ctx interface{}) *gomock.Call
- type MockToByteser
- type MockToByteserMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockDoer ¶ added in v1.1.0
type MockDoer struct {
// contains filtered or unexported fields
}
MockDoer is a mock of Doer interface.
func NewMockDoer ¶ added in v1.1.0
func NewMockDoer(ctrl *gomock.Controller) *MockDoer
NewMockDoer creates a new mock instance.
func (*MockDoer) EXPECT ¶ added in v1.1.0
func (m *MockDoer) EXPECT() *MockDoerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockDoerMockRecorder ¶ added in v1.1.0
type MockDoerMockRecorder struct {
// contains filtered or unexported fields
}
MockDoerMockRecorder is the mock recorder for MockDoer.
func (*MockDoerMockRecorder) Do ¶ added in v1.1.0
func (mr *MockDoerMockRecorder) Do(arg0, arg1, arg2 interface{}) *gomock.Call
Do indicates an expected call of Do.
type MockGetter ¶
type MockGetter struct {
// contains filtered or unexported fields
}
MockGetter is a mock of Getter interface.
func NewMockGetter ¶
func NewMockGetter(ctrl *gomock.Controller) *MockGetter
NewMockGetter creates a new mock instance.
func (*MockGetter) EXPECT ¶
func (m *MockGetter) EXPECT() *MockGetterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockGetterMockRecorder ¶
type MockGetterMockRecorder struct {
// contains filtered or unexported fields
}
MockGetterMockRecorder is the mock recorder for MockGetter.
func (*MockGetterMockRecorder) Get ¶
func (mr *MockGetterMockRecorder) Get(ctx interface{}) *gomock.Call
Get indicates an expected call of Get.
type MockPublisher ¶
type MockPublisher struct {
// contains filtered or unexported fields
}
MockPublisher is a mock of Publisher interface.
func NewMockPublisher ¶
func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher
NewMockPublisher creates a new mock instance.
func (*MockPublisher) EXPECT ¶
func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockPublisherMockRecorder ¶
type MockPublisherMockRecorder struct {
// contains filtered or unexported fields
}
MockPublisherMockRecorder is the mock recorder for MockPublisher.
func (*MockPublisherMockRecorder) Publish ¶
func (mr *MockPublisherMockRecorder) Publish(ctx, msg interface{}) *gomock.Call
Publish indicates an expected call of Publish.
type MockReceiver ¶ added in v1.1.0
type MockReceiver struct {
// contains filtered or unexported fields
}
MockReceiver is a mock of Receiver interface.
func NewMockReceiver ¶ added in v1.1.0
func NewMockReceiver(ctrl *gomock.Controller) *MockReceiver
NewMockReceiver creates a new mock instance.
func (*MockReceiver) EXPECT ¶ added in v1.1.0
func (m *MockReceiver) EXPECT() *MockReceiverMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockReceiverMockRecorder ¶ added in v1.1.0
type MockReceiverMockRecorder struct {
// contains filtered or unexported fields
}
MockReceiverMockRecorder is the mock recorder for MockReceiver.
func (*MockReceiverMockRecorder) Receive ¶ added in v1.1.0
func (mr *MockReceiverMockRecorder) Receive(ctx, f interface{}) *gomock.Call
Receive indicates an expected call of Receive.
type MockSubscriberPipeline ¶ added in v1.1.0
type MockSubscriberPipeline struct {
// contains filtered or unexported fields
}
MockSubscriberPipeline is a mock of SubscriberPipeline interface.
func NewMockSubscriberPipeline ¶ added in v1.1.0
func NewMockSubscriberPipeline(ctrl *gomock.Controller) *MockSubscriberPipeline
NewMockSubscriberPipeline creates a new mock instance.
func (*MockSubscriberPipeline) Batch ¶ added in v1.2.0
func (m *MockSubscriberPipeline) Batch(itemType reflect.Type, batchSize int, timeout time.Duration) pubsub0.SubscriberPipeline
Batch mocks base method.
func (*MockSubscriberPipeline) EXPECT ¶ added in v1.1.0
func (m *MockSubscriberPipeline) EXPECT() *MockSubscriberPipelineMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSubscriberPipeline) Errors ¶ added in v1.2.0
func (m *MockSubscriberPipeline) Errors() chan error
Errors mocks base method.
func (*MockSubscriberPipeline) Map ¶ added in v1.1.0
func (m *MockSubscriberPipeline) Map(mapFn func(any) (any, error)) pubsub0.SubscriberPipeline
Map mocks base method.
func (*MockSubscriberPipeline) Reduce ¶ added in v1.2.0
func (m *MockSubscriberPipeline) Reduce(reduceFn func(interface{}, interface{}, int) (interface{}, error), initialState func() interface{}) pubsub0.SubscriberPipeline
Reduce mocks base method.
type MockSubscriberPipelineMockRecorder ¶ added in v1.1.0
type MockSubscriberPipelineMockRecorder struct {
// contains filtered or unexported fields
}
MockSubscriberPipelineMockRecorder is the mock recorder for MockSubscriberPipeline.
func (*MockSubscriberPipelineMockRecorder) Batch ¶ added in v1.2.0
func (mr *MockSubscriberPipelineMockRecorder) Batch(itemType, batchSize, timeout interface{}) *gomock.Call
Batch indicates an expected call of Batch.
func (*MockSubscriberPipelineMockRecorder) Errors ¶ added in v1.2.0
func (mr *MockSubscriberPipelineMockRecorder) Errors() *gomock.Call
Errors indicates an expected call of Errors.
func (*MockSubscriberPipelineMockRecorder) Map ¶ added in v1.1.0
func (mr *MockSubscriberPipelineMockRecorder) Map(mapFn interface{}) *gomock.Call
Map indicates an expected call of Map.
func (*MockSubscriberPipelineMockRecorder) Reduce ¶ added in v1.2.0
func (mr *MockSubscriberPipelineMockRecorder) Reduce(reduceFn, initialState interface{}) *gomock.Call
Reduce indicates an expected call of Reduce.
func (*MockSubscriberPipelineMockRecorder) Run ¶ added in v1.1.0
func (mr *MockSubscriberPipelineMockRecorder) Run(ctx interface{}) *gomock.Call
Run indicates an expected call of Run.
type MockToByteser ¶ added in v1.0.1
type MockToByteser struct {
// contains filtered or unexported fields
}
MockToByteser is a mock of ToByteser interface.
func NewMockToByteser ¶ added in v1.0.1
func NewMockToByteser(ctrl *gomock.Controller) *MockToByteser
NewMockToByteser creates a new mock instance.
func (*MockToByteser) EXPECT ¶ added in v1.0.1
func (m *MockToByteser) EXPECT() *MockToByteserMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockToByteser) ToBytes ¶ added in v1.0.1
func (m *MockToByteser) ToBytes() ([]byte, error)
ToBytes mocks base method.
type MockToByteserMockRecorder ¶ added in v1.0.1
type MockToByteserMockRecorder struct {
// contains filtered or unexported fields
}
MockToByteserMockRecorder is the mock recorder for MockToByteser.
func (*MockToByteserMockRecorder) ToBytes ¶ added in v1.0.1
func (mr *MockToByteserMockRecorder) ToBytes() *gomock.Call
ToBytes indicates an expected call of ToBytes.