schedulermocks

package
v0.3.50 Latest Latest
Warning

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

 Go to latest Published: Feb 23, 2023 License: Apache-2.0 Imports: 18 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.

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 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.Error, 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 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.

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.