schedulermocks

package
v0.3.71-rc-9724e78 Latest Latest
Warning

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

Go to latest
Published: Jun 13, 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

Context mocks base method.

func (*MockExecutorApi_LeaseJobRunsServer) EXPECT

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

func (*MockExecutorApi_LeaseJobRunsServer) Recv

Recv mocks base method.

func (*MockExecutorApi_LeaseJobRunsServer) RecvMsg

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

RecvMsg mocks base method.

func (*MockExecutorApi_LeaseJobRunsServer) Send

Send mocks base method.

func (*MockExecutorApi_LeaseJobRunsServer) SendHeader

SendHeader mocks base method.

func (*MockExecutorApi_LeaseJobRunsServer) SendMsg

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

SendMsg mocks base method.

func (*MockExecutorApi_LeaseJobRunsServer) SetHeader

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

Context indicates an expected call of Context.

func (*MockExecutorApi_LeaseJobRunsServerMockRecorder) Recv

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

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

func (*MockExecutorRepository) GetExecutors

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

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

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

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

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

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

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

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL