Documentation
¶
Overview ¶
Package schedulermocks is a generated GoMock package.
Package schedulermocks is a generated GoMock package.
Package schedulermocks is a generated GoMock package.
Package schedulermocks is a generated GoMock package.
Index ¶
- type MockClient
- func (m *MockClient) Close()
- func (m *MockClient) CreateProducer(arg0 pulsar.ProducerOptions) (pulsar.Producer, error)
- func (m *MockClient) CreateReader(arg0 pulsar.ReaderOptions) (pulsar.Reader, error)
- func (m *MockClient) CreateTableView(arg0 pulsar.TableViewOptions) (pulsar.TableView, error)
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) Subscribe(arg0 pulsar.ConsumerOptions) (pulsar.Consumer, error)
- func (m *MockClient) TopicPartitions(arg0 string) ([]string, error)
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) Close() *gomock.Call
- func (mr *MockClientMockRecorder) CreateProducer(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CreateReader(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CreateTableView(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Subscribe(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) TopicPartitions(arg0 interface{}) *gomock.Call
- type MockExecutorApi_LeaseJobRunsServer
- func (m *MockExecutorApi_LeaseJobRunsServer) Context() context.Context
- func (m *MockExecutorApi_LeaseJobRunsServer) EXPECT() *MockExecutorApi_LeaseJobRunsServerMockRecorder
- func (m *MockExecutorApi_LeaseJobRunsServer) Recv() (*executorapi.LeaseRequest, error)
- func (m *MockExecutorApi_LeaseJobRunsServer) RecvMsg(arg0 interface{}) error
- func (m *MockExecutorApi_LeaseJobRunsServer) Send(arg0 *executorapi.LeaseStreamMessage) error
- func (m *MockExecutorApi_LeaseJobRunsServer) SendHeader(arg0 metadata.MD) error
- func (m *MockExecutorApi_LeaseJobRunsServer) SendMsg(arg0 interface{}) error
- func (m *MockExecutorApi_LeaseJobRunsServer) SetHeader(arg0 metadata.MD) error
- func (m *MockExecutorApi_LeaseJobRunsServer) SetTrailer(arg0 metadata.MD)
- type MockExecutorApi_LeaseJobRunsServerMockRecorder
- func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) Context() *gomock.Call
- func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) Recv() *gomock.Call
- func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockExecutorRepository
- func (m *MockExecutorRepository) EXPECT() *MockExecutorRepositoryMockRecorder
- func (m *MockExecutorRepository) GetExecutors(arg0 context.Context) ([]*schedulerobjects.Executor, error)
- func (m *MockExecutorRepository) GetLastUpdateTimes(arg0 context.Context) (map[string]time.Time, error)
- func (m *MockExecutorRepository) StoreExecutor(arg0 context.Context, arg1 *schedulerobjects.Executor) error
- type MockExecutorRepositoryMockRecorder
- type MockJobRepository
- func (m *MockJobRepository) CountReceivedPartitions(arg0 context.Context, arg1 uuid.UUID) (uint32, error)
- func (m *MockJobRepository) EXPECT() *MockJobRepositoryMockRecorder
- func (m *MockJobRepository) FetchJobRunErrors(arg0 context.Context, arg1 []uuid.UUID) (map[uuid.UUID]*armadaevents.JobRunErrors, error)
- func (m *MockJobRepository) FetchJobRunLeases(arg0 context.Context, arg1 string, arg2 int, arg3 []uuid.UUID) ([]*database.JobRunLease, error)
- func (m *MockJobRepository) FetchJobUpdates(arg0 context.Context, arg1, arg2 int64) ([]database.Job, []database.Run, error)
- func (m *MockJobRepository) FindInactiveRuns(arg0 context.Context, arg1 []uuid.UUID) ([]uuid.UUID, error)
- type MockJobRepositoryMockRecorder
- func (mr *MockJobRepositoryMockRecorder) CountReceivedPartitions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockJobRepositoryMockRecorder) FetchJobRunErrors(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockJobRepositoryMockRecorder) FetchJobRunLeases(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockJobRepositoryMockRecorder) FetchJobUpdates(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockJobRepositoryMockRecorder) FindInactiveRuns(arg0, arg1 interface{}) *gomock.Call
- type MockLeaseInterface
- func (m *MockLeaseInterface) Apply(arg0 context.Context, arg1 *v11.LeaseApplyConfiguration, arg2 v10.ApplyOptions) (*v1.Lease, error)
- func (m *MockLeaseInterface) Create(arg0 context.Context, arg1 *v1.Lease, arg2 v10.CreateOptions) (*v1.Lease, error)
- func (m *MockLeaseInterface) Delete(arg0 context.Context, arg1 string, arg2 v10.DeleteOptions) error
- func (m *MockLeaseInterface) DeleteCollection(arg0 context.Context, arg1 v10.DeleteOptions, arg2 v10.ListOptions) error
- func (m *MockLeaseInterface) EXPECT() *MockLeaseInterfaceMockRecorder
- func (m *MockLeaseInterface) Get(arg0 context.Context, arg1 string, arg2 v10.GetOptions) (*v1.Lease, error)
- func (m *MockLeaseInterface) List(arg0 context.Context, arg1 v10.ListOptions) (*v1.LeaseList, error)
- func (m *MockLeaseInterface) Patch(arg0 context.Context, arg1 string, arg2 types.PatchType, arg3 []byte, ...) (*v1.Lease, error)
- func (m *MockLeaseInterface) Update(arg0 context.Context, arg1 *v1.Lease, arg2 v10.UpdateOptions) (*v1.Lease, error)
- func (m *MockLeaseInterface) Watch(arg0 context.Context, arg1 v10.ListOptions) (watch.Interface, error)
- type MockLeaseInterfaceMockRecorder
- func (mr *MockLeaseInterfaceMockRecorder) Apply(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockLeaseInterfaceMockRecorder) Create(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockLeaseInterfaceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockLeaseInterfaceMockRecorder) DeleteCollection(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockLeaseInterfaceMockRecorder) Get(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockLeaseInterfaceMockRecorder) List(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockLeaseInterfaceMockRecorder) Patch(arg0, arg1, arg2, arg3, arg4 interface{}, arg5 ...interface{}) *gomock.Call
- func (mr *MockLeaseInterfaceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockLeaseInterfaceMockRecorder) Watch(arg0, arg1 interface{}) *gomock.Call
- type MockLeasesGetter
- type MockLeasesGetterMockRecorder
- type MockProducer
- func (m *MockProducer) Close()
- func (m *MockProducer) EXPECT() *MockProducerMockRecorder
- func (m *MockProducer) Flush() error
- func (m *MockProducer) LastSequenceID() int64
- func (m *MockProducer) Name() string
- func (m *MockProducer) Send(arg0 context.Context, arg1 *pulsar.ProducerMessage) (pulsar.MessageID, error)
- func (m *MockProducer) SendAsync(arg0 context.Context, arg1 *pulsar.ProducerMessage, ...)
- func (m *MockProducer) Topic() string
- type MockProducerMockRecorder
- func (mr *MockProducerMockRecorder) Close() *gomock.Call
- func (mr *MockProducerMockRecorder) Flush() *gomock.Call
- func (mr *MockProducerMockRecorder) LastSequenceID() *gomock.Call
- func (mr *MockProducerMockRecorder) Name() *gomock.Call
- func (mr *MockProducerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockProducerMockRecorder) SendAsync(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockProducerMockRecorder) Topic() *gomock.Call
- type MockQueueRepository
- type MockQueueRepositoryMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockClient ¶
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface.
func NewMockClient ¶
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock instance.
func (*MockClient) CreateProducer ¶
func (m *MockClient) CreateProducer(arg0 pulsar.ProducerOptions) (pulsar.Producer, error)
CreateProducer mocks base method.
func (*MockClient) CreateReader ¶
func (m *MockClient) CreateReader(arg0 pulsar.ReaderOptions) (pulsar.Reader, error)
CreateReader mocks base method.
func (*MockClient) CreateTableView ¶
func (m *MockClient) CreateTableView(arg0 pulsar.TableViewOptions) (pulsar.TableView, error)
CreateTableView mocks base method.
func (*MockClient) EXPECT ¶
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClient) Subscribe ¶
func (m *MockClient) Subscribe(arg0 pulsar.ConsumerOptions) (pulsar.Consumer, error)
Subscribe mocks base method.
func (*MockClient) TopicPartitions ¶
func (m *MockClient) TopicPartitions(arg0 string) ([]string, error)
TopicPartitions mocks base method.
type MockClientMockRecorder ¶
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient.
func (*MockClientMockRecorder) Close ¶
func (mr *MockClientMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockClientMockRecorder) CreateProducer ¶
func (mr *MockClientMockRecorder) CreateProducer(arg0 interface{}) *gomock.Call
CreateProducer indicates an expected call of CreateProducer.
func (*MockClientMockRecorder) CreateReader ¶
func (mr *MockClientMockRecorder) CreateReader(arg0 interface{}) *gomock.Call
CreateReader indicates an expected call of CreateReader.
func (*MockClientMockRecorder) CreateTableView ¶
func (mr *MockClientMockRecorder) CreateTableView(arg0 interface{}) *gomock.Call
CreateTableView indicates an expected call of CreateTableView.
func (*MockClientMockRecorder) Subscribe ¶
func (mr *MockClientMockRecorder) Subscribe(arg0 interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe.
func (*MockClientMockRecorder) TopicPartitions ¶
func (mr *MockClientMockRecorder) TopicPartitions(arg0 interface{}) *gomock.Call
TopicPartitions indicates an expected call of TopicPartitions.
type MockExecutorApi_LeaseJobRunsServer ¶
type MockExecutorApi_LeaseJobRunsServer struct {
// contains filtered or unexported fields
}
MockExecutorApi_LeaseJobRunsServer is a mock of ExecutorApi_LeaseJobRunsServer interface.
func NewMockExecutorApi_LeaseJobRunsServer ¶
func NewMockExecutorApi_LeaseJobRunsServer(ctrl *gomock.Controller) *MockExecutorApi_LeaseJobRunsServer
NewMockExecutorApi_LeaseJobRunsServer creates a new mock instance.
func (*MockExecutorApi_LeaseJobRunsServer) Context ¶
func (m *MockExecutorApi_LeaseJobRunsServer) Context() context.Context
Context mocks base method.
func (*MockExecutorApi_LeaseJobRunsServer) EXPECT ¶
func (m *MockExecutorApi_LeaseJobRunsServer) EXPECT() *MockExecutorApi_LeaseJobRunsServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockExecutorApi_LeaseJobRunsServer) Recv ¶
func (m *MockExecutorApi_LeaseJobRunsServer) Recv() (*executorapi.LeaseRequest, error)
Recv mocks base method.
func (*MockExecutorApi_LeaseJobRunsServer) RecvMsg ¶
func (m *MockExecutorApi_LeaseJobRunsServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockExecutorApi_LeaseJobRunsServer) Send ¶
func (m *MockExecutorApi_LeaseJobRunsServer) Send(arg0 *executorapi.LeaseStreamMessage) error
Send mocks base method.
func (*MockExecutorApi_LeaseJobRunsServer) SendHeader ¶
func (m *MockExecutorApi_LeaseJobRunsServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockExecutorApi_LeaseJobRunsServer) SendMsg ¶
func (m *MockExecutorApi_LeaseJobRunsServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockExecutorApi_LeaseJobRunsServer) SetHeader ¶
func (m *MockExecutorApi_LeaseJobRunsServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockExecutorApi_LeaseJobRunsServer) SetTrailer ¶
func (m *MockExecutorApi_LeaseJobRunsServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockExecutorApi_LeaseJobRunsServerMockRecorder ¶
type MockExecutorApi_LeaseJobRunsServerMockRecorder struct {
// contains filtered or unexported fields
}
MockExecutorApi_LeaseJobRunsServerMockRecorder is the mock recorder for MockExecutorApi_LeaseJobRunsServer.
func (*MockExecutorApi_LeaseJobRunsServerMockRecorder) Context ¶
func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockExecutorApi_LeaseJobRunsServerMockRecorder) Recv ¶
func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockExecutorApi_LeaseJobRunsServerMockRecorder) RecvMsg ¶
func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockExecutorApi_LeaseJobRunsServerMockRecorder) Send ¶
func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockExecutorApi_LeaseJobRunsServerMockRecorder) SendHeader ¶
func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockExecutorApi_LeaseJobRunsServerMockRecorder) SendMsg ¶
func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockExecutorApi_LeaseJobRunsServerMockRecorder) SetHeader ¶
func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockExecutorApi_LeaseJobRunsServerMockRecorder) SetTrailer ¶
func (mr *MockExecutorApi_LeaseJobRunsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockExecutorRepository ¶
type MockExecutorRepository struct {
// contains filtered or unexported fields
}
MockExecutorRepository is a mock of ExecutorRepository interface.
func NewMockExecutorRepository ¶
func NewMockExecutorRepository(ctrl *gomock.Controller) *MockExecutorRepository
NewMockExecutorRepository creates a new mock instance.
func (*MockExecutorRepository) EXPECT ¶
func (m *MockExecutorRepository) EXPECT() *MockExecutorRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockExecutorRepository) GetExecutors ¶
func (m *MockExecutorRepository) GetExecutors(arg0 context.Context) ([]*schedulerobjects.Executor, error)
GetExecutors mocks base method.
func (*MockExecutorRepository) GetLastUpdateTimes ¶
func (m *MockExecutorRepository) GetLastUpdateTimes(arg0 context.Context) (map[string]time.Time, error)
GetLastUpdateTimes mocks base method.
func (*MockExecutorRepository) StoreExecutor ¶
func (m *MockExecutorRepository) StoreExecutor(arg0 context.Context, arg1 *schedulerobjects.Executor) error
StoreExecutor mocks base method.
type MockExecutorRepositoryMockRecorder ¶
type MockExecutorRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockExecutorRepositoryMockRecorder is the mock recorder for MockExecutorRepository.
func (*MockExecutorRepositoryMockRecorder) GetExecutors ¶
func (mr *MockExecutorRepositoryMockRecorder) GetExecutors(arg0 interface{}) *gomock.Call
GetExecutors indicates an expected call of GetExecutors.
func (*MockExecutorRepositoryMockRecorder) GetLastUpdateTimes ¶
func (mr *MockExecutorRepositoryMockRecorder) GetLastUpdateTimes(arg0 interface{}) *gomock.Call
GetLastUpdateTimes indicates an expected call of GetLastUpdateTimes.
func (*MockExecutorRepositoryMockRecorder) StoreExecutor ¶
func (mr *MockExecutorRepositoryMockRecorder) StoreExecutor(arg0, arg1 interface{}) *gomock.Call
StoreExecutor indicates an expected call of StoreExecutor.
type MockJobRepository ¶
type MockJobRepository struct {
// contains filtered or unexported fields
}
MockJobRepository is a mock of JobRepository interface.
func NewMockJobRepository ¶
func NewMockJobRepository(ctrl *gomock.Controller) *MockJobRepository
NewMockJobRepository creates a new mock instance.
func (*MockJobRepository) CountReceivedPartitions ¶
func (m *MockJobRepository) CountReceivedPartitions(arg0 context.Context, arg1 uuid.UUID) (uint32, error)
CountReceivedPartitions mocks base method.
func (*MockJobRepository) EXPECT ¶
func (m *MockJobRepository) EXPECT() *MockJobRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockJobRepository) FetchJobRunErrors ¶
func (m *MockJobRepository) FetchJobRunErrors(arg0 context.Context, arg1 []uuid.UUID) (map[uuid.UUID]*armadaevents.JobRunErrors, error)
FetchJobRunErrors mocks base method.
func (*MockJobRepository) FetchJobRunLeases ¶
func (m *MockJobRepository) FetchJobRunLeases(arg0 context.Context, arg1 string, arg2 int, arg3 []uuid.UUID) ([]*database.JobRunLease, error)
FetchJobRunLeases mocks base method.
func (*MockJobRepository) FetchJobUpdates ¶
func (m *MockJobRepository) FetchJobUpdates(arg0 context.Context, arg1, arg2 int64) ([]database.Job, []database.Run, error)
FetchJobUpdates mocks base method.
func (*MockJobRepository) FindInactiveRuns ¶
func (m *MockJobRepository) FindInactiveRuns(arg0 context.Context, arg1 []uuid.UUID) ([]uuid.UUID, error)
FindInactiveRuns mocks base method.
type MockJobRepositoryMockRecorder ¶
type MockJobRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockJobRepositoryMockRecorder is the mock recorder for MockJobRepository.
func (*MockJobRepositoryMockRecorder) CountReceivedPartitions ¶
func (mr *MockJobRepositoryMockRecorder) CountReceivedPartitions(arg0, arg1 interface{}) *gomock.Call
CountReceivedPartitions indicates an expected call of CountReceivedPartitions.
func (*MockJobRepositoryMockRecorder) FetchJobRunErrors ¶
func (mr *MockJobRepositoryMockRecorder) FetchJobRunErrors(arg0, arg1 interface{}) *gomock.Call
FetchJobRunErrors indicates an expected call of FetchJobRunErrors.
func (*MockJobRepositoryMockRecorder) FetchJobRunLeases ¶
func (mr *MockJobRepositoryMockRecorder) FetchJobRunLeases(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
FetchJobRunLeases indicates an expected call of FetchJobRunLeases.
func (*MockJobRepositoryMockRecorder) FetchJobUpdates ¶
func (mr *MockJobRepositoryMockRecorder) FetchJobUpdates(arg0, arg1, arg2 interface{}) *gomock.Call
FetchJobUpdates indicates an expected call of FetchJobUpdates.
func (*MockJobRepositoryMockRecorder) FindInactiveRuns ¶
func (mr *MockJobRepositoryMockRecorder) FindInactiveRuns(arg0, arg1 interface{}) *gomock.Call
FindInactiveRuns indicates an expected call of FindInactiveRuns.
type MockLeaseInterface ¶
type MockLeaseInterface struct {
// contains filtered or unexported fields
}
MockLeaseInterface is a mock of LeaseInterface interface.
func NewMockLeaseInterface ¶
func NewMockLeaseInterface(ctrl *gomock.Controller) *MockLeaseInterface
NewMockLeaseInterface creates a new mock instance.
func (*MockLeaseInterface) Apply ¶
func (m *MockLeaseInterface) Apply(arg0 context.Context, arg1 *v11.LeaseApplyConfiguration, arg2 v10.ApplyOptions) (*v1.Lease, error)
Apply mocks base method.
func (*MockLeaseInterface) Create ¶
func (m *MockLeaseInterface) Create(arg0 context.Context, arg1 *v1.Lease, arg2 v10.CreateOptions) (*v1.Lease, error)
Create mocks base method.
func (*MockLeaseInterface) Delete ¶
func (m *MockLeaseInterface) Delete(arg0 context.Context, arg1 string, arg2 v10.DeleteOptions) error
Delete mocks base method.
func (*MockLeaseInterface) DeleteCollection ¶
func (m *MockLeaseInterface) DeleteCollection(arg0 context.Context, arg1 v10.DeleteOptions, arg2 v10.ListOptions) error
DeleteCollection mocks base method.
func (*MockLeaseInterface) EXPECT ¶
func (m *MockLeaseInterface) EXPECT() *MockLeaseInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockLeaseInterface) Get ¶
func (m *MockLeaseInterface) Get(arg0 context.Context, arg1 string, arg2 v10.GetOptions) (*v1.Lease, error)
Get mocks base method.
func (*MockLeaseInterface) List ¶
func (m *MockLeaseInterface) List(arg0 context.Context, arg1 v10.ListOptions) (*v1.LeaseList, error)
List mocks base method.
func (*MockLeaseInterface) Patch ¶
func (m *MockLeaseInterface) Patch(arg0 context.Context, arg1 string, arg2 types.PatchType, arg3 []byte, arg4 v10.PatchOptions, arg5 ...string) (*v1.Lease, error)
Patch mocks base method.
func (*MockLeaseInterface) Update ¶
func (m *MockLeaseInterface) Update(arg0 context.Context, arg1 *v1.Lease, arg2 v10.UpdateOptions) (*v1.Lease, error)
Update mocks base method.
func (*MockLeaseInterface) Watch ¶
func (m *MockLeaseInterface) Watch(arg0 context.Context, arg1 v10.ListOptions) (watch.Interface, error)
Watch mocks base method.
type MockLeaseInterfaceMockRecorder ¶
type MockLeaseInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockLeaseInterfaceMockRecorder is the mock recorder for MockLeaseInterface.
func (*MockLeaseInterfaceMockRecorder) Apply ¶
func (mr *MockLeaseInterfaceMockRecorder) Apply(arg0, arg1, arg2 interface{}) *gomock.Call
Apply indicates an expected call of Apply.
func (*MockLeaseInterfaceMockRecorder) Create ¶
func (mr *MockLeaseInterfaceMockRecorder) Create(arg0, arg1, arg2 interface{}) *gomock.Call
Create indicates an expected call of Create.
func (*MockLeaseInterfaceMockRecorder) Delete ¶
func (mr *MockLeaseInterfaceMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockLeaseInterfaceMockRecorder) DeleteCollection ¶
func (mr *MockLeaseInterfaceMockRecorder) DeleteCollection(arg0, arg1, arg2 interface{}) *gomock.Call
DeleteCollection indicates an expected call of DeleteCollection.
func (*MockLeaseInterfaceMockRecorder) Get ¶
func (mr *MockLeaseInterfaceMockRecorder) Get(arg0, arg1, arg2 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockLeaseInterfaceMockRecorder) List ¶
func (mr *MockLeaseInterfaceMockRecorder) List(arg0, arg1 interface{}) *gomock.Call
List indicates an expected call of List.
func (*MockLeaseInterfaceMockRecorder) Patch ¶
func (mr *MockLeaseInterfaceMockRecorder) Patch(arg0, arg1, arg2, arg3, arg4 interface{}, arg5 ...interface{}) *gomock.Call
Patch indicates an expected call of Patch.
func (*MockLeaseInterfaceMockRecorder) Update ¶
func (mr *MockLeaseInterfaceMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call
Update indicates an expected call of Update.
func (*MockLeaseInterfaceMockRecorder) Watch ¶
func (mr *MockLeaseInterfaceMockRecorder) Watch(arg0, arg1 interface{}) *gomock.Call
Watch indicates an expected call of Watch.
type MockLeasesGetter ¶
type MockLeasesGetter struct {
// contains filtered or unexported fields
}
MockLeasesGetter is a mock of LeasesGetter interface.
func NewMockLeasesGetter ¶
func NewMockLeasesGetter(ctrl *gomock.Controller) *MockLeasesGetter
NewMockLeasesGetter creates a new mock instance.
func (*MockLeasesGetter) EXPECT ¶
func (m *MockLeasesGetter) EXPECT() *MockLeasesGetterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockLeasesGetter) Leases ¶
func (m *MockLeasesGetter) Leases(arg0 string) v12.LeaseInterface
Leases mocks base method.
type MockLeasesGetterMockRecorder ¶
type MockLeasesGetterMockRecorder struct {
// contains filtered or unexported fields
}
MockLeasesGetterMockRecorder is the mock recorder for MockLeasesGetter.
func (*MockLeasesGetterMockRecorder) Leases ¶
func (mr *MockLeasesGetterMockRecorder) Leases(arg0 interface{}) *gomock.Call
Leases indicates an expected call of Leases.
type MockProducer ¶
type MockProducer struct {
// contains filtered or unexported fields
}
MockProducer is a mock of Producer interface.
func NewMockProducer ¶
func NewMockProducer(ctrl *gomock.Controller) *MockProducer
NewMockProducer creates a new mock instance.
func (*MockProducer) EXPECT ¶
func (m *MockProducer) EXPECT() *MockProducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProducer) LastSequenceID ¶
func (m *MockProducer) LastSequenceID() int64
LastSequenceID mocks base method.
func (*MockProducer) Send ¶
func (m *MockProducer) Send(arg0 context.Context, arg1 *pulsar.ProducerMessage) (pulsar.MessageID, error)
Send mocks base method.
func (*MockProducer) SendAsync ¶
func (m *MockProducer) SendAsync(arg0 context.Context, arg1 *pulsar.ProducerMessage, arg2 func(pulsar.MessageID, *pulsar.ProducerMessage, error))
SendAsync mocks base method.
type MockProducerMockRecorder ¶
type MockProducerMockRecorder struct {
// contains filtered or unexported fields
}
MockProducerMockRecorder is the mock recorder for MockProducer.
func (*MockProducerMockRecorder) Close ¶
func (mr *MockProducerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockProducerMockRecorder) Flush ¶
func (mr *MockProducerMockRecorder) Flush() *gomock.Call
Flush indicates an expected call of Flush.
func (*MockProducerMockRecorder) LastSequenceID ¶
func (mr *MockProducerMockRecorder) LastSequenceID() *gomock.Call
LastSequenceID indicates an expected call of LastSequenceID.
func (*MockProducerMockRecorder) Name ¶
func (mr *MockProducerMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
func (*MockProducerMockRecorder) Send ¶
func (mr *MockProducerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockProducerMockRecorder) SendAsync ¶
func (mr *MockProducerMockRecorder) SendAsync(arg0, arg1, arg2 interface{}) *gomock.Call
SendAsync indicates an expected call of SendAsync.
func (*MockProducerMockRecorder) Topic ¶
func (mr *MockProducerMockRecorder) Topic() *gomock.Call
Topic indicates an expected call of Topic.
type MockQueueRepository ¶
type MockQueueRepository struct {
// contains filtered or unexported fields
}
MockQueueRepository is a mock of QueueRepository interface.
func NewMockQueueRepository ¶
func NewMockQueueRepository(ctrl *gomock.Controller) *MockQueueRepository
NewMockQueueRepository creates a new mock instance.
func (*MockQueueRepository) EXPECT ¶
func (m *MockQueueRepository) EXPECT() *MockQueueRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockQueueRepository) GetAllQueues ¶
func (m *MockQueueRepository) GetAllQueues() ([]*database.Queue, error)
GetAllQueues mocks base method.
type MockQueueRepositoryMockRecorder ¶
type MockQueueRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockQueueRepositoryMockRecorder is the mock recorder for MockQueueRepository.
func (*MockQueueRepositoryMockRecorder) GetAllQueues ¶
func (mr *MockQueueRepositoryMockRecorder) GetAllQueues() *gomock.Call
GetAllQueues indicates an expected call of GetAllQueues.