schedulermocks

package
v0.8.2 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2024 License: Apache-2.0 Imports: 22 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.

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 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 *armadacontext.Context) ([]*schedulerobjects.Executor, error)

GetExecutors mocks base method.

func (*MockExecutorRepository) GetLastUpdateTimes 

func (m *MockExecutorRepository) GetLastUpdateTimes(arg0 *armadacontext.Context) (map[string]time.Time, error)

GetLastUpdateTimes mocks base method.

func (*MockExecutorRepository) StoreExecutor 

func (m *MockExecutorRepository) StoreExecutor(arg0 *armadacontext.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 *armadacontext.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 *armadacontext.Context, arg1 []uuid.UUID) (map[uuid.UUID]*armadaevents.Error, error)

FetchJobRunErrors mocks base method.

func (*MockJobRepository) FetchJobRunLeases 

func (m *MockJobRepository) FetchJobRunLeases(arg0 *armadacontext.Context, arg1 string, arg2 uint, arg3 []uuid.UUID) ([]*database.JobRunLease, error)

FetchJobRunLeases mocks base method.

func (*MockJobRepository) FetchJobUpdates 

func (m *MockJobRepository) FetchJobUpdates(arg0 *armadacontext.Context, arg1, arg2 int64) ([]database.Job, []database.Run, error)

FetchJobUpdates mocks base method.

func (*MockJobRepository) FindInactiveRuns 

func (m *MockJobRepository) FindInactiveRuns(arg0 *armadacontext.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 MockQueueCache added in v0.4.48 

type MockQueueCache struct {
	// contains filtered or unexported fields
}

MockQueueCache is a mock of QueueCache interface.

func NewMockQueueCache added in v0.4.48 

func NewMockQueueCache(ctrl *gomock.Controller) *MockQueueCache

NewMockQueueCache creates a new mock instance.

func (*MockQueueCache) EXPECT added in v0.4.48 

func (m *MockQueueCache) EXPECT() *MockQueueCacheMockRecorder

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

func (*MockQueueCache) GetAll added in v0.4.48 

func (m *MockQueueCache) GetAll(arg0 *armadacontext.Context) ([]*api.Queue, error)

GetAll mocks base method.

type MockQueueCacheMockRecorder added in v0.4.48 

type MockQueueCacheMockRecorder struct {
	// contains filtered or unexported fields
}

MockQueueCacheMockRecorder is the mock recorder for MockQueueCache.

func (*MockQueueCacheMockRecorder) GetAll added in v0.4.48 

func (mr *MockQueueCacheMockRecorder) GetAll(arg0 interface{}) *gomock.Call

GetAll indicates an expected call of GetAll.

type MockSubmitClient added in v0.4.48 

type MockSubmitClient struct {
	// contains filtered or unexported fields
}

MockSubmitClient is a mock of SubmitClient interface.

func NewMockSubmitClient added in v0.4.48 

func NewMockSubmitClient(ctrl *gomock.Controller) *MockSubmitClient

NewMockSubmitClient creates a new mock instance.

func (*MockSubmitClient) CancelJobSet added in v0.4.48 

func (m *MockSubmitClient) CancelJobSet(arg0 context.Context, arg1 *api.JobSetCancelRequest, arg2 ...grpc.CallOption) (*types.Empty, error)

CancelJobSet mocks base method.

func (*MockSubmitClient) CancelJobs added in v0.4.48 

func (m *MockSubmitClient) CancelJobs(arg0 context.Context, arg1 *api.JobCancelRequest, arg2 ...grpc.CallOption) (*api.CancellationResult, error)

CancelJobs mocks base method.

func (*MockSubmitClient) CreateQueue added in v0.4.48 

func (m *MockSubmitClient) CreateQueue(arg0 context.Context, arg1 *api.Queue, arg2 ...grpc.CallOption) (*types.Empty, error)

CreateQueue mocks base method.

func (*MockSubmitClient) CreateQueues added in v0.4.48 

func (m *MockSubmitClient) CreateQueues(arg0 context.Context, arg1 *api.QueueList, arg2 ...grpc.CallOption) (*api.BatchQueueCreateResponse, error)

CreateQueues mocks base method.

func (*MockSubmitClient) DeleteQueue added in v0.4.48 

func (m *MockSubmitClient) DeleteQueue(arg0 context.Context, arg1 *api.QueueDeleteRequest, arg2 ...grpc.CallOption) (*types.Empty, error)

DeleteQueue mocks base method.

func (*MockSubmitClient) EXPECT added in v0.4.48 

func (m *MockSubmitClient) EXPECT() *MockSubmitClientMockRecorder

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

func (*MockSubmitClient) GetQueue added in v0.4.48 

func (m *MockSubmitClient) GetQueue(arg0 context.Context, arg1 *api.QueueGetRequest, arg2 ...grpc.CallOption) (*api.Queue, error)

GetQueue mocks base method.

func (*MockSubmitClient) GetQueues added in v0.4.48 

func (m *MockSubmitClient) GetQueues(arg0 context.Context, arg1 *api.StreamingQueueGetRequest, arg2 ...grpc.CallOption) (api.Submit_GetQueuesClient, error)

GetQueues mocks base method.

func (*MockSubmitClient) Health added in v0.4.48 

func (m *MockSubmitClient) Health(arg0 context.Context, arg1 *types.Empty, arg2 ...grpc.CallOption) (*api.HealthCheckResponse, error)

Health mocks base method.

func (*MockSubmitClient) PreemptJobs added in v0.4.48 

func (m *MockSubmitClient) PreemptJobs(arg0 context.Context, arg1 *api.JobPreemptRequest, arg2 ...grpc.CallOption) (*types.Empty, error)

PreemptJobs mocks base method.

func (*MockSubmitClient) ReprioritizeJobs added in v0.4.48 

func (m *MockSubmitClient) ReprioritizeJobs(arg0 context.Context, arg1 *api.JobReprioritizeRequest, arg2 ...grpc.CallOption) (*api.JobReprioritizeResponse, error)

ReprioritizeJobs mocks base method.

func (*MockSubmitClient) SubmitJobs added in v0.4.48 

func (m *MockSubmitClient) SubmitJobs(arg0 context.Context, arg1 *api.JobSubmitRequest, arg2 ...grpc.CallOption) (*api.JobSubmitResponse, error)

SubmitJobs mocks base method.

func (*MockSubmitClient) UpdateQueue added in v0.4.48 

func (m *MockSubmitClient) UpdateQueue(arg0 context.Context, arg1 *api.Queue, arg2 ...grpc.CallOption) (*types.Empty, error)

UpdateQueue mocks base method.

func (*MockSubmitClient) UpdateQueues added in v0.4.48 

func (m *MockSubmitClient) UpdateQueues(arg0 context.Context, arg1 *api.QueueList, arg2 ...grpc.CallOption) (*api.BatchQueueUpdateResponse, error)

UpdateQueues mocks base method.

type MockSubmitClientMockRecorder added in v0.4.48 

type MockSubmitClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockSubmitClientMockRecorder is the mock recorder for MockSubmitClient.

func (*MockSubmitClientMockRecorder) CancelJobSet added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) CancelJobSet(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CancelJobSet indicates an expected call of CancelJobSet.

func (*MockSubmitClientMockRecorder) CancelJobs added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) CancelJobs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CancelJobs indicates an expected call of CancelJobs.

func (*MockSubmitClientMockRecorder) CreateQueue added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) CreateQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CreateQueue indicates an expected call of CreateQueue.

func (*MockSubmitClientMockRecorder) CreateQueues added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) CreateQueues(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CreateQueues indicates an expected call of CreateQueues.

func (*MockSubmitClientMockRecorder) DeleteQueue added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) DeleteQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DeleteQueue indicates an expected call of DeleteQueue.

func (*MockSubmitClientMockRecorder) GetQueue added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) GetQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetQueue indicates an expected call of GetQueue.

func (*MockSubmitClientMockRecorder) GetQueues added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) GetQueues(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetQueues indicates an expected call of GetQueues.

func (*MockSubmitClientMockRecorder) Health added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) Health(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Health indicates an expected call of Health.

func (*MockSubmitClientMockRecorder) PreemptJobs added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) PreemptJobs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PreemptJobs indicates an expected call of PreemptJobs.

func (*MockSubmitClientMockRecorder) ReprioritizeJobs added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) ReprioritizeJobs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ReprioritizeJobs indicates an expected call of ReprioritizeJobs.

func (*MockSubmitClientMockRecorder) SubmitJobs added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) SubmitJobs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SubmitJobs indicates an expected call of SubmitJobs.

func (*MockSubmitClientMockRecorder) UpdateQueue added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) UpdateQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateQueue indicates an expected call of UpdateQueue.

func (*MockSubmitClientMockRecorder) UpdateQueues added in v0.4.48 

func (mr *MockSubmitClientMockRecorder) UpdateQueues(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateQueues indicates an expected call of UpdateQueues.

type MockSubmit_GetQueuesClient added in v0.4.48 

type MockSubmit_GetQueuesClient struct {
	// contains filtered or unexported fields
}

MockSubmit_GetQueuesClient is a mock of Submit_GetQueuesClient interface.

func NewMockSubmit_GetQueuesClient added in v0.4.48 

func NewMockSubmit_GetQueuesClient(ctrl *gomock.Controller) *MockSubmit_GetQueuesClient

NewMockSubmit_GetQueuesClient creates a new mock instance.

func (*MockSubmit_GetQueuesClient) CloseSend added in v0.4.48 

func (m *MockSubmit_GetQueuesClient) CloseSend() error

CloseSend mocks base method.

func (*MockSubmit_GetQueuesClient) Context added in v0.4.48 

func (m *MockSubmit_GetQueuesClient) Context() context.Context

Context mocks base method.

func (*MockSubmit_GetQueuesClient) EXPECT added in v0.4.48 

func (m *MockSubmit_GetQueuesClient) EXPECT() *MockSubmit_GetQueuesClientMockRecorder

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

func (*MockSubmit_GetQueuesClient) Header added in v0.4.48 

func (m *MockSubmit_GetQueuesClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockSubmit_GetQueuesClient) Recv added in v0.4.48 

func (m *MockSubmit_GetQueuesClient) Recv() (*api.StreamingQueueMessage, error)

Recv mocks base method.

func (*MockSubmit_GetQueuesClient) RecvMsg added in v0.4.48 

func (m *MockSubmit_GetQueuesClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockSubmit_GetQueuesClient) SendMsg added in v0.4.48 

func (m *MockSubmit_GetQueuesClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockSubmit_GetQueuesClient) Trailer added in v0.4.48 

func (m *MockSubmit_GetQueuesClient) Trailer() metadata.MD

Trailer mocks base method.

type MockSubmit_GetQueuesClientMockRecorder added in v0.4.48 

type MockSubmit_GetQueuesClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockSubmit_GetQueuesClientMockRecorder is the mock recorder for MockSubmit_GetQueuesClient.

func (*MockSubmit_GetQueuesClientMockRecorder) CloseSend added in v0.4.48 

func (mr *MockSubmit_GetQueuesClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockSubmit_GetQueuesClientMockRecorder) Context added in v0.4.48 

func (mr *MockSubmit_GetQueuesClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockSubmit_GetQueuesClientMockRecorder) Header added in v0.4.48 

func (mr *MockSubmit_GetQueuesClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockSubmit_GetQueuesClientMockRecorder) Recv added in v0.4.48 

func (mr *MockSubmit_GetQueuesClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockSubmit_GetQueuesClientMockRecorder) RecvMsg added in v0.4.48 

func (mr *MockSubmit_GetQueuesClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockSubmit_GetQueuesClientMockRecorder) SendMsg added in v0.4.48 

func (mr *MockSubmit_GetQueuesClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockSubmit_GetQueuesClientMockRecorder) Trailer added in v0.4.48 

func (mr *MockSubmit_GetQueuesClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type SliceMatcher added in v0.3.49 

type SliceMatcher[T Stringer] struct {
	Expected []T
}

func (SliceMatcher[T]) Matches added in v0.3.49 

func (s SliceMatcher[T]) Matches(x interface{}) bool

Matches Matches input against provided expected input This matching ignores the input ordering, so args don't need to be passed in a known order

func (SliceMatcher[T]) String added in v0.3.49 

func (s SliceMatcher[T]) String() string

String describes what the matcher matches.

type Stringer added in v0.3.49 

type Stringer interface {
	String() string
}

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.