schedulermocks

package
v0.3.47 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

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

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) Close 

func (m *MockClient) Close()

Close mocks base method.

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 uint, 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) Close 

func (m *MockProducer) Close()

Close mocks base method.

func (*MockProducer) EXPECT 

func (m *MockProducer) EXPECT() *MockProducerMockRecorder

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

func (*MockProducer) Flush 

func (m *MockProducer) Flush() error

Flush mocks base method.

func (*MockProducer) LastSequenceID 

func (m *MockProducer) LastSequenceID() int64

LastSequenceID mocks base method.

func (*MockProducer) Name 

func (m *MockProducer) Name() string

Name 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.

func (*MockProducer) Topic 

func (m *MockProducer) Topic() string

Topic 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.