mock_workceptor

package
v1.5.2 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Overview

Package mock_workceptor is a generated GoMock package.

Package mock_workceptor is a generated GoMock package.

Package mock_workceptor is a generated GoMock package.

Package mock_workceptor is a generated GoMock package.

Package mock_workceptor is a generated GoMock package.

Package mock_workceptor is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBaseWorkUnitForWorkUnit added in v1.4.4 

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

MockBaseWorkUnitForWorkUnit is a mock of BaseWorkUnitForWorkUnit interface.

func NewMockBaseWorkUnitForWorkUnit added in v1.4.4 

func NewMockBaseWorkUnitForWorkUnit(ctrl *gomock.Controller) *MockBaseWorkUnitForWorkUnit

NewMockBaseWorkUnitForWorkUnit creates a new mock instance.

func (*MockBaseWorkUnitForWorkUnit) CancelContext added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) CancelContext()

CancelContext mocks base method.

func (*MockBaseWorkUnitForWorkUnit) EXPECT added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) EXPECT() *MockBaseWorkUnitForWorkUnitMockRecorder

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

func (*MockBaseWorkUnitForWorkUnit) GetCancel added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) GetCancel() context.CancelFunc

GetCancel mocks base method.

func (*MockBaseWorkUnitForWorkUnit) GetContext added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) GetContext() context.Context

GetContext mocks base method.

func (*MockBaseWorkUnitForWorkUnit) GetStatusCopy added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) GetStatusCopy() workceptor.StatusFileData

GetStatusCopy mocks base method.

func (*MockBaseWorkUnitForWorkUnit) GetStatusLock added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) GetStatusLock() *sync.RWMutex

GetStatusLock mocks base method.

func (*MockBaseWorkUnitForWorkUnit) GetStatusWithoutExtraData added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) GetStatusWithoutExtraData() *workceptor.StatusFileData

GetStatusWithoutExtraData mocks base method.

func (*MockBaseWorkUnitForWorkUnit) GetWorkceptor added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) GetWorkceptor() *workceptor.Workceptor

GetWorkceptor mocks base method.

func (*MockBaseWorkUnitForWorkUnit) ID added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) ID() string

ID mocks base method.

func (*MockBaseWorkUnitForWorkUnit) Init added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) Init(w *workceptor.Workceptor, unitID, workType string, fs workceptor.FileSystemer, watcher workceptor.WatcherWrapper)

Init mocks base method.

func (*MockBaseWorkUnitForWorkUnit) LastUpdateError added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) LastUpdateError() error

LastUpdateError mocks base method.

func (*MockBaseWorkUnitForWorkUnit) Load added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) Load() error

Load mocks base method.

func (*MockBaseWorkUnitForWorkUnit) MonitorLocalStatus added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) MonitorLocalStatus()

MonitorLocalStatus mocks base method.

func (*MockBaseWorkUnitForWorkUnit) Release added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) Release(force bool) error

Release mocks base method.

func (*MockBaseWorkUnitForWorkUnit) Save added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) Save() error

Save mocks base method.

func (*MockBaseWorkUnitForWorkUnit) SetFromParams added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) SetFromParams(arg0 map[string]string) error

SetFromParams mocks base method.

func (*MockBaseWorkUnitForWorkUnit) SetStatusExtraData added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) SetStatusExtraData(arg0 any)

SetStatusExtraData mocks base method.

func (*MockBaseWorkUnitForWorkUnit) SetWorkceptor added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) SetWorkceptor(arg0 *workceptor.Workceptor)

SetWorkceptor mocks base method.

func (*MockBaseWorkUnitForWorkUnit) Status added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) Status() *workceptor.StatusFileData

Status mocks base method.

func (*MockBaseWorkUnitForWorkUnit) StatusFileName added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) StatusFileName() string

StatusFileName mocks base method.

func (*MockBaseWorkUnitForWorkUnit) StdoutFileName added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) StdoutFileName() string

StdoutFileName mocks base method.

func (*MockBaseWorkUnitForWorkUnit) UnitDir added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) UnitDir() string

UnitDir mocks base method.

func (*MockBaseWorkUnitForWorkUnit) UnredactedStatus added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) UnredactedStatus() *workceptor.StatusFileData

UnredactedStatus mocks base method.

func (*MockBaseWorkUnitForWorkUnit) UpdateBasicStatus added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) UpdateBasicStatus(state int, detail string, stdoutSize int64)

UpdateBasicStatus mocks base method.

func (*MockBaseWorkUnitForWorkUnit) UpdateFullStatus added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) UpdateFullStatus(statusFunc func(*workceptor.StatusFileData))

UpdateFullStatus mocks base method.

type MockBaseWorkUnitForWorkUnitMockRecorder added in v1.4.4 

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

MockBaseWorkUnitForWorkUnitMockRecorder is the mock recorder for MockBaseWorkUnitForWorkUnit.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) CancelContext added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) CancelContext() *gomock.Call

CancelContext indicates an expected call of CancelContext.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) GetCancel added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) GetCancel() *gomock.Call

GetCancel indicates an expected call of GetCancel.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) GetContext added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) GetContext() *gomock.Call

GetContext indicates an expected call of GetContext.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) GetStatusCopy added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) GetStatusCopy() *gomock.Call

GetStatusCopy indicates an expected call of GetStatusCopy.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) GetStatusLock added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) GetStatusLock() *gomock.Call

GetStatusLock indicates an expected call of GetStatusLock.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) GetStatusWithoutExtraData added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) GetStatusWithoutExtraData() *gomock.Call

GetStatusWithoutExtraData indicates an expected call of GetStatusWithoutExtraData.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) GetWorkceptor added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) GetWorkceptor() *gomock.Call

GetWorkceptor indicates an expected call of GetWorkceptor.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) ID added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) Init added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) Init(w, unitID, workType, fs, watcher any) *gomock.Call

Init indicates an expected call of Init.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) LastUpdateError added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) LastUpdateError() *gomock.Call

LastUpdateError indicates an expected call of LastUpdateError.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) Load added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) Load() *gomock.Call

Load indicates an expected call of Load.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) MonitorLocalStatus added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) MonitorLocalStatus() *gomock.Call

MonitorLocalStatus indicates an expected call of MonitorLocalStatus.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) Release added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) Release(force any) *gomock.Call

Release indicates an expected call of Release.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) Save added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) Save() *gomock.Call

Save indicates an expected call of Save.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) SetFromParams added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) SetFromParams(arg0 any) *gomock.Call

SetFromParams indicates an expected call of SetFromParams.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) SetStatusExtraData added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) SetStatusExtraData(arg0 any) *gomock.Call

SetStatusExtraData indicates an expected call of SetStatusExtraData.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) SetWorkceptor added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) SetWorkceptor(arg0 any) *gomock.Call

SetWorkceptor indicates an expected call of SetWorkceptor.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) Status added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) Status() *gomock.Call

Status indicates an expected call of Status.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) StatusFileName added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) StatusFileName() *gomock.Call

StatusFileName indicates an expected call of StatusFileName.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) StdoutFileName added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) StdoutFileName() *gomock.Call

StdoutFileName indicates an expected call of StdoutFileName.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) UnitDir added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) UnitDir() *gomock.Call

UnitDir indicates an expected call of UnitDir.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) UnredactedStatus added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) UnredactedStatus() *gomock.Call

UnredactedStatus indicates an expected call of UnredactedStatus.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) UpdateBasicStatus added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) UpdateBasicStatus(state, detail, stdoutSize any) *gomock.Call

UpdateBasicStatus indicates an expected call of UpdateBasicStatus.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) UpdateFullStatus added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) UpdateFullStatus(statusFunc any) *gomock.Call

UpdateFullStatus indicates an expected call of UpdateFullStatus.

type MockFileReadCloser 

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

MockFileReadCloser is a mock of FileReadCloser interface.

func NewMockFileReadCloser 

func NewMockFileReadCloser(ctrl *gomock.Controller) *MockFileReadCloser

NewMockFileReadCloser creates a new mock instance.

func (*MockFileReadCloser) Close 

func (m *MockFileReadCloser) Close() error

Close mocks base method.

func (*MockFileReadCloser) EXPECT 

func (m *MockFileReadCloser) EXPECT() *MockFileReadCloserMockRecorder

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

func (*MockFileReadCloser) Read 

func (m *MockFileReadCloser) Read(p []byte) (int, error)

Read mocks base method.

type MockFileReadCloserMockRecorder 

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

MockFileReadCloserMockRecorder is the mock recorder for MockFileReadCloser.

func (*MockFileReadCloserMockRecorder) Close 

func (mr *MockFileReadCloserMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockFileReadCloserMockRecorder) Read 

func (mr *MockFileReadCloserMockRecorder) Read(p any) *gomock.Call

Read indicates an expected call of Read.

type MockFileSystemer 

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

MockFileSystemer is a mock of FileSystemer interface.

func NewMockFileSystemer 

func NewMockFileSystemer(ctrl *gomock.Controller) *MockFileSystemer

NewMockFileSystemer creates a new mock instance.

func (*MockFileSystemer) EXPECT 

func (m *MockFileSystemer) EXPECT() *MockFileSystemerMockRecorder

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

func (*MockFileSystemer) Open 

func (m *MockFileSystemer) Open(name string) (*os.File, error)

Open mocks base method.

func (*MockFileSystemer) OpenFile 

func (m *MockFileSystemer) OpenFile(name string, flag int, perm os.FileMode) (*os.File, error)

OpenFile mocks base method.

func (*MockFileSystemer) RemoveAll 

func (m *MockFileSystemer) RemoveAll(path string) error

RemoveAll mocks base method.

func (*MockFileSystemer) Stat 

func (m *MockFileSystemer) Stat(name string) (os.FileInfo, error)

Stat mocks base method.

type MockFileSystemerMockRecorder 

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

MockFileSystemerMockRecorder is the mock recorder for MockFileSystemer.

func (*MockFileSystemerMockRecorder) Open 

func (mr *MockFileSystemerMockRecorder) Open(name any) *gomock.Call

Open indicates an expected call of Open.

func (*MockFileSystemerMockRecorder) OpenFile 

func (mr *MockFileSystemerMockRecorder) OpenFile(name, flag, perm any) *gomock.Call

OpenFile indicates an expected call of OpenFile.

func (*MockFileSystemerMockRecorder) RemoveAll 

func (mr *MockFileSystemerMockRecorder) RemoveAll(path any) *gomock.Call

RemoveAll indicates an expected call of RemoveAll.

func (*MockFileSystemerMockRecorder) Stat 

func (mr *MockFileSystemerMockRecorder) Stat(name any) *gomock.Call

Stat indicates an expected call of Stat.

type MockFileWriteCloser 

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

MockFileWriteCloser is a mock of FileWriteCloser interface.

func NewMockFileWriteCloser 

func NewMockFileWriteCloser(ctrl *gomock.Controller) *MockFileWriteCloser

NewMockFileWriteCloser creates a new mock instance.

func (*MockFileWriteCloser) Close 

func (m *MockFileWriteCloser) Close() error

Close mocks base method.

func (*MockFileWriteCloser) EXPECT 

func (m *MockFileWriteCloser) EXPECT() *MockFileWriteCloserMockRecorder

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

func (*MockFileWriteCloser) Write 

func (m *MockFileWriteCloser) Write(p []byte) (int, error)

Write mocks base method.

type MockFileWriteCloserMockRecorder 

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

MockFileWriteCloserMockRecorder is the mock recorder for MockFileWriteCloser.

func (*MockFileWriteCloserMockRecorder) Close 

func (mr *MockFileWriteCloserMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockFileWriteCloserMockRecorder) Write 

func (mr *MockFileWriteCloserMockRecorder) Write(p any) *gomock.Call

Write indicates an expected call of Write.

type MockKubeAPIer added in v1.4.5 

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

MockKubeAPIer is a mock of KubeAPIer interface.

func NewMockKubeAPIer added in v1.4.5 

func NewMockKubeAPIer(ctrl *gomock.Controller) *MockKubeAPIer

NewMockKubeAPIer creates a new mock instance.

func (*MockKubeAPIer) BuildConfigFromFlags added in v1.4.5 

func (m *MockKubeAPIer) BuildConfigFromFlags(arg0, arg1 string) (*rest.Config, error)

BuildConfigFromFlags mocks base method.

func (*MockKubeAPIer) Create added in v1.4.5 

func (m *MockKubeAPIer) Create(arg0 context.Context, arg1 *kubernetes.Clientset, arg2 string, arg3 *v1.Pod, arg4 v10.CreateOptions) (*v1.Pod, error)

Create mocks base method.

func (*MockKubeAPIer) Delete added in v1.4.5 

func (m *MockKubeAPIer) Delete(arg0 context.Context, arg1 *kubernetes.Clientset, arg2, arg3 string, arg4 v10.DeleteOptions) error

Delete mocks base method.

func (*MockKubeAPIer) EXPECT added in v1.4.5 

func (m *MockKubeAPIer) EXPECT() *MockKubeAPIerMockRecorder

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

func (*MockKubeAPIer) Get added in v1.4.5 

func (m *MockKubeAPIer) Get(arg0 context.Context, arg1 *kubernetes.Clientset, arg2, arg3 string, arg4 v10.GetOptions) (*v1.Pod, error)

Get mocks base method.

func (*MockKubeAPIer) GetLogs added in v1.4.5 

func (m *MockKubeAPIer) GetLogs(arg0 *kubernetes.Clientset, arg1, arg2 string, arg3 *v1.PodLogOptions) *rest.Request

GetLogs mocks base method.

func (*MockKubeAPIer) InClusterConfig added in v1.4.5 

func (m *MockKubeAPIer) InClusterConfig() (*rest.Config, error)

InClusterConfig mocks base method.

func (*MockKubeAPIer) List added in v1.4.5 

func (m *MockKubeAPIer) List(arg0 context.Context, arg1 *kubernetes.Clientset, arg2 string, arg3 v10.ListOptions) (*v1.PodList, error)

List mocks base method.

func (*MockKubeAPIer) NewClientConfigFromBytes added in v1.4.5 

func (m *MockKubeAPIer) NewClientConfigFromBytes(arg0 []byte) (clientcmd.ClientConfig, error)

NewClientConfigFromBytes mocks base method.

func (*MockKubeAPIer) NewDefaultClientConfigLoadingRules added in v1.4.5 

func (m *MockKubeAPIer) NewDefaultClientConfigLoadingRules() *clientcmd.ClientConfigLoadingRules

NewDefaultClientConfigLoadingRules mocks base method.

func (*MockKubeAPIer) NewFakeAlwaysRateLimiter added in v1.4.5 

func (m *MockKubeAPIer) NewFakeAlwaysRateLimiter() flowcontrol.RateLimiter

NewFakeAlwaysRateLimiter mocks base method.

func (*MockKubeAPIer) NewFakeNeverRateLimiter added in v1.4.5 

func (m *MockKubeAPIer) NewFakeNeverRateLimiter() flowcontrol.RateLimiter

NewFakeNeverRateLimiter mocks base method.

func (*MockKubeAPIer) NewForConfig added in v1.4.5 

func (m *MockKubeAPIer) NewForConfig(arg0 *rest.Config) (*kubernetes.Clientset, error)

NewForConfig mocks base method.

func (*MockKubeAPIer) NewNotFound added in v1.4.5 

func (m *MockKubeAPIer) NewNotFound(arg0 schema.GroupResource, arg1 string) *errors.StatusError

NewNotFound mocks base method.

func (*MockKubeAPIer) NewSPDYExecutor added in v1.4.5 

func (m *MockKubeAPIer) NewSPDYExecutor(arg0 *rest.Config, arg1 string, arg2 *url.URL) (remotecommand.Executor, error)

NewSPDYExecutor mocks base method.

func (*MockKubeAPIer) OneTermEqualSelector added in v1.4.5 

func (m *MockKubeAPIer) OneTermEqualSelector(arg0, arg1 string) fields.Selector

OneTermEqualSelector mocks base method.

func (*MockKubeAPIer) StreamWithContext added in v1.4.5 

func (m *MockKubeAPIer) StreamWithContext(arg0 context.Context, arg1 remotecommand.Executor, arg2 remotecommand.StreamOptions) error

StreamWithContext mocks base method.

func (*MockKubeAPIer) SubResource added in v1.4.5 

func (m *MockKubeAPIer) SubResource(arg0 *kubernetes.Clientset, arg1, arg2 string) *rest.Request

SubResource mocks base method.

func (*MockKubeAPIer) UntilWithSync added in v1.4.5 

func (m *MockKubeAPIer) UntilWithSync(arg0 context.Context, arg1 cache.ListerWatcher, arg2 runtime.Object, arg3 watch0.PreconditionFunc, arg4 ...watch0.ConditionFunc) (*watch.Event, error)

UntilWithSync mocks base method.

func (*MockKubeAPIer) Watch added in v1.4.5 

func (m *MockKubeAPIer) Watch(arg0 context.Context, arg1 *kubernetes.Clientset, arg2 string, arg3 v10.ListOptions) (watch.Interface, error)

Watch mocks base method.

type MockKubeAPIerMockRecorder added in v1.4.5 

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

MockKubeAPIerMockRecorder is the mock recorder for MockKubeAPIer.

func (*MockKubeAPIerMockRecorder) BuildConfigFromFlags added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) BuildConfigFromFlags(arg0, arg1 any) *gomock.Call

BuildConfigFromFlags indicates an expected call of BuildConfigFromFlags.

func (*MockKubeAPIerMockRecorder) Create added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) Create(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call

Create indicates an expected call of Create.

func (*MockKubeAPIerMockRecorder) Delete added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) Delete(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockKubeAPIerMockRecorder) Get added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) Get(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call

Get indicates an expected call of Get.

func (*MockKubeAPIerMockRecorder) GetLogs added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) GetLogs(arg0, arg1, arg2, arg3 any) *gomock.Call

GetLogs indicates an expected call of GetLogs.

func (*MockKubeAPIerMockRecorder) InClusterConfig added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) InClusterConfig() *gomock.Call

InClusterConfig indicates an expected call of InClusterConfig.

func (*MockKubeAPIerMockRecorder) List added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) List(arg0, arg1, arg2, arg3 any) *gomock.Call

List indicates an expected call of List.

func (*MockKubeAPIerMockRecorder) NewClientConfigFromBytes added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) NewClientConfigFromBytes(arg0 any) *gomock.Call

NewClientConfigFromBytes indicates an expected call of NewClientConfigFromBytes.

func (*MockKubeAPIerMockRecorder) NewDefaultClientConfigLoadingRules added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) NewDefaultClientConfigLoadingRules() *gomock.Call

NewDefaultClientConfigLoadingRules indicates an expected call of NewDefaultClientConfigLoadingRules.

func (*MockKubeAPIerMockRecorder) NewFakeAlwaysRateLimiter added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) NewFakeAlwaysRateLimiter() *gomock.Call

NewFakeAlwaysRateLimiter indicates an expected call of NewFakeAlwaysRateLimiter.

func (*MockKubeAPIerMockRecorder) NewFakeNeverRateLimiter added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) NewFakeNeverRateLimiter() *gomock.Call

NewFakeNeverRateLimiter indicates an expected call of NewFakeNeverRateLimiter.

func (*MockKubeAPIerMockRecorder) NewForConfig added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) NewForConfig(arg0 any) *gomock.Call

NewForConfig indicates an expected call of NewForConfig.

func (*MockKubeAPIerMockRecorder) NewNotFound added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) NewNotFound(arg0, arg1 any) *gomock.Call

NewNotFound indicates an expected call of NewNotFound.

func (*MockKubeAPIerMockRecorder) NewSPDYExecutor added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) NewSPDYExecutor(arg0, arg1, arg2 any) *gomock.Call

NewSPDYExecutor indicates an expected call of NewSPDYExecutor.

func (*MockKubeAPIerMockRecorder) OneTermEqualSelector added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) OneTermEqualSelector(arg0, arg1 any) *gomock.Call

OneTermEqualSelector indicates an expected call of OneTermEqualSelector.

func (*MockKubeAPIerMockRecorder) StreamWithContext added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) StreamWithContext(arg0, arg1, arg2 any) *gomock.Call

StreamWithContext indicates an expected call of StreamWithContext.

func (*MockKubeAPIerMockRecorder) SubResource added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) SubResource(arg0, arg1, arg2 any) *gomock.Call

SubResource indicates an expected call of SubResource.

func (*MockKubeAPIerMockRecorder) UntilWithSync added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) UntilWithSync(arg0, arg1, arg2, arg3 any, arg4 ...any) *gomock.Call

UntilWithSync indicates an expected call of UntilWithSync.

func (*MockKubeAPIerMockRecorder) Watch added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) Watch(arg0, arg1, arg2, arg3 any) *gomock.Call

Watch indicates an expected call of Watch.

type MockNetceptorForWorkceptor 

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

MockNetceptorForWorkceptor is a mock of NetceptorForWorkceptor interface.

func NewMockNetceptorForWorkceptor 

func NewMockNetceptorForWorkceptor(ctrl *gomock.Controller) *MockNetceptorForWorkceptor

NewMockNetceptorForWorkceptor creates a new mock instance.

func (*MockNetceptorForWorkceptor) AddWorkCommand 

func (m *MockNetceptorForWorkceptor) AddWorkCommand(typeName string, verifySignature bool) error

AddWorkCommand mocks base method.

func (*MockNetceptorForWorkceptor) DialContext 

func (m *MockNetceptorForWorkceptor) DialContext(ctx context.Context, node, service string, tlscfg *tls.Config) (*netceptor.Conn, error)

DialContext mocks base method.

func (*MockNetceptorForWorkceptor) EXPECT 

func (m *MockNetceptorForWorkceptor) EXPECT() *MockNetceptorForWorkceptorMockRecorder

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

func (*MockNetceptorForWorkceptor) GetClientTLSConfig 

func (m *MockNetceptorForWorkceptor) GetClientTLSConfig(name, expectedHostName string, expectedHostNameType netceptor.ExpectedHostnameType) (*tls.Config, error)

GetClientTLSConfig mocks base method.

func (*MockNetceptorForWorkceptor) GetLogger 

func (m *MockNetceptorForWorkceptor) GetLogger() *logger.ReceptorLogger

GetLogger mocks base method.

func (*MockNetceptorForWorkceptor) NodeID 

func (m *MockNetceptorForWorkceptor) NodeID() string

NodeID mocks base method.

type MockNetceptorForWorkceptorMockRecorder 

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

MockNetceptorForWorkceptorMockRecorder is the mock recorder for MockNetceptorForWorkceptor.

func (*MockNetceptorForWorkceptorMockRecorder) AddWorkCommand 

func (mr *MockNetceptorForWorkceptorMockRecorder) AddWorkCommand(typeName, verifySignature any) *gomock.Call

AddWorkCommand indicates an expected call of AddWorkCommand.

func (*MockNetceptorForWorkceptorMockRecorder) DialContext 

func (mr *MockNetceptorForWorkceptorMockRecorder) DialContext(ctx, node, service, tlscfg any) *gomock.Call

DialContext indicates an expected call of DialContext.

func (*MockNetceptorForWorkceptorMockRecorder) GetClientTLSConfig 

func (mr *MockNetceptorForWorkceptorMockRecorder) GetClientTLSConfig(name, expectedHostName, expectedHostNameType any) *gomock.Call

GetClientTLSConfig indicates an expected call of GetClientTLSConfig.

func (*MockNetceptorForWorkceptorMockRecorder) GetLogger 

func (mr *MockNetceptorForWorkceptorMockRecorder) GetLogger() *gomock.Call

GetLogger indicates an expected call of GetLogger.

func (*MockNetceptorForWorkceptorMockRecorder) NodeID 

func (mr *MockNetceptorForWorkceptorMockRecorder) NodeID() *gomock.Call

NodeID indicates an expected call of NodeID.

type MockServerForWorkceptor added in v1.4.4 

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

MockServerForWorkceptor is a mock of ServerForWorkceptor interface.

func NewMockServerForWorkceptor added in v1.4.4 

func NewMockServerForWorkceptor(ctrl *gomock.Controller) *MockServerForWorkceptor

NewMockServerForWorkceptor creates a new mock instance.

func (*MockServerForWorkceptor) AddControlFunc added in v1.4.4 

func (m *MockServerForWorkceptor) AddControlFunc(name string, cType controlsvc.ControlCommandType) error

AddControlFunc mocks base method.

func (*MockServerForWorkceptor) ConnectionListener added in v1.4.4 

func (m *MockServerForWorkceptor) ConnectionListener(ctx context.Context, listener net.Listener)

ConnectionListener mocks base method.

func (*MockServerForWorkceptor) EXPECT added in v1.4.4 

func (m *MockServerForWorkceptor) EXPECT() *MockServerForWorkceptorMockRecorder

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

func (*MockServerForWorkceptor) RunControlSession added in v1.4.4 

func (m *MockServerForWorkceptor) RunControlSession(conn net.Conn)

RunControlSession mocks base method.

func (*MockServerForWorkceptor) RunControlSvc added in v1.4.4 

func (m *MockServerForWorkceptor) RunControlSvc(ctx context.Context, service string, tlscfg *tls.Config, unixSocket string, unixSocketPermissions fs.FileMode, tcpListen string, tcptls *tls.Config) error

RunControlSvc mocks base method.

func (*MockServerForWorkceptor) SetServerNet added in v1.4.4 

func (m *MockServerForWorkceptor) SetServerNet(n controlsvc.Neter)

SetServerNet mocks base method.

func (*MockServerForWorkceptor) SetServerTLS added in v1.4.4 

func (m *MockServerForWorkceptor) SetServerTLS(t controlsvc.Tlser)

SetServerTLS mocks base method.

func (*MockServerForWorkceptor) SetServerUtils added in v1.4.4 

func (m *MockServerForWorkceptor) SetServerUtils(u controlsvc.Utiler)

SetServerUtils mocks base method.

func (*MockServerForWorkceptor) SetupConnection added in v1.4.4 

func (m *MockServerForWorkceptor) SetupConnection(conn net.Conn)

SetupConnection mocks base method.

type MockServerForWorkceptorMockRecorder added in v1.4.4 

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

MockServerForWorkceptorMockRecorder is the mock recorder for MockServerForWorkceptor.

func (*MockServerForWorkceptorMockRecorder) AddControlFunc added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) AddControlFunc(name, cType any) *gomock.Call

AddControlFunc indicates an expected call of AddControlFunc.

func (*MockServerForWorkceptorMockRecorder) ConnectionListener added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) ConnectionListener(ctx, listener any) *gomock.Call

ConnectionListener indicates an expected call of ConnectionListener.

func (*MockServerForWorkceptorMockRecorder) RunControlSession added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) RunControlSession(conn any) *gomock.Call

RunControlSession indicates an expected call of RunControlSession.

func (*MockServerForWorkceptorMockRecorder) RunControlSvc added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) RunControlSvc(ctx, service, tlscfg, unixSocket, unixSocketPermissions, tcpListen, tcptls any) *gomock.Call

RunControlSvc indicates an expected call of RunControlSvc.

func (*MockServerForWorkceptorMockRecorder) SetServerNet added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) SetServerNet(n any) *gomock.Call

SetServerNet indicates an expected call of SetServerNet.

func (*MockServerForWorkceptorMockRecorder) SetServerTLS added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) SetServerTLS(t any) *gomock.Call

SetServerTLS indicates an expected call of SetServerTLS.

func (*MockServerForWorkceptorMockRecorder) SetServerUtils added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) SetServerUtils(u any) *gomock.Call

SetServerUtils indicates an expected call of SetServerUtils.

func (*MockServerForWorkceptorMockRecorder) SetupConnection added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) SetupConnection(conn any) *gomock.Call

SetupConnection indicates an expected call of SetupConnection.

type MockWatcherWrapper 

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

MockWatcherWrapper is a mock of WatcherWrapper interface.

func NewMockWatcherWrapper 

func NewMockWatcherWrapper(ctrl *gomock.Controller) *MockWatcherWrapper

NewMockWatcherWrapper creates a new mock instance.

func (*MockWatcherWrapper) Add 

func (m *MockWatcherWrapper) Add(name string) error

Add mocks base method.

func (*MockWatcherWrapper) Close 

func (m *MockWatcherWrapper) Close() error

Close mocks base method.

func (*MockWatcherWrapper) EXPECT 

func (m *MockWatcherWrapper) EXPECT() *MockWatcherWrapperMockRecorder

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

func (*MockWatcherWrapper) ErrorChannel added in v1.4.10 

func (m *MockWatcherWrapper) ErrorChannel() chan error

ErrorChannel mocks base method.

func (*MockWatcherWrapper) EventChannel 

func (m *MockWatcherWrapper) EventChannel() chan fsnotify.Event

EventChannel mocks base method.

type MockWatcherWrapperMockRecorder 

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

MockWatcherWrapperMockRecorder is the mock recorder for MockWatcherWrapper.

func (*MockWatcherWrapperMockRecorder) Add 

func (mr *MockWatcherWrapperMockRecorder) Add(name any) *gomock.Call

Add indicates an expected call of Add.

func (*MockWatcherWrapperMockRecorder) Close 

func (mr *MockWatcherWrapperMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockWatcherWrapperMockRecorder) ErrorChannel added in v1.4.10 

func (mr *MockWatcherWrapperMockRecorder) ErrorChannel() *gomock.Call

ErrorChannel indicates an expected call of ErrorChannel.

func (*MockWatcherWrapperMockRecorder) EventChannel 

func (mr *MockWatcherWrapperMockRecorder) EventChannel() *gomock.Call

EventChannel indicates an expected call of EventChannel.

type MockWorkUnit 

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

MockWorkUnit is a mock of WorkUnit interface.

func NewMockWorkUnit 

func NewMockWorkUnit(ctrl *gomock.Controller) *MockWorkUnit

NewMockWorkUnit creates a new mock instance.

func (*MockWorkUnit) Cancel 

func (m *MockWorkUnit) Cancel() error

Cancel mocks base method.

func (*MockWorkUnit) EXPECT 

func (m *MockWorkUnit) EXPECT() *MockWorkUnitMockRecorder

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

func (*MockWorkUnit) ID 

func (m *MockWorkUnit) ID() string

ID mocks base method.

func (*MockWorkUnit) LastUpdateError 

func (m *MockWorkUnit) LastUpdateError() error

LastUpdateError mocks base method.

func (*MockWorkUnit) Load 

func (m *MockWorkUnit) Load() error

Load mocks base method.

func (*MockWorkUnit) Release 

func (m *MockWorkUnit) Release(force bool) error

Release mocks base method.

func (*MockWorkUnit) Restart 

func (m *MockWorkUnit) Restart() error

Restart mocks base method.

func (*MockWorkUnit) Save 

func (m *MockWorkUnit) Save() error

Save mocks base method.

func (*MockWorkUnit) SetFromParams 

func (m *MockWorkUnit) SetFromParams(params map[string]string) error

SetFromParams mocks base method.

func (*MockWorkUnit) Start 

func (m *MockWorkUnit) Start() error

Start mocks base method.

func (*MockWorkUnit) Status 

func (m *MockWorkUnit) Status() *workceptor.StatusFileData

Status mocks base method.

func (*MockWorkUnit) StatusFileName 

func (m *MockWorkUnit) StatusFileName() string

StatusFileName mocks base method.

func (*MockWorkUnit) StdoutFileName 

func (m *MockWorkUnit) StdoutFileName() string

StdoutFileName mocks base method.

func (*MockWorkUnit) UnitDir 

func (m *MockWorkUnit) UnitDir() string

UnitDir mocks base method.

func (*MockWorkUnit) UnredactedStatus 

func (m *MockWorkUnit) UnredactedStatus() *workceptor.StatusFileData

UnredactedStatus mocks base method.

func (*MockWorkUnit) UpdateBasicStatus 

func (m *MockWorkUnit) UpdateBasicStatus(state int, detail string, stdoutSize int64)

UpdateBasicStatus mocks base method.

func (*MockWorkUnit) UpdateFullStatus 

func (m *MockWorkUnit) UpdateFullStatus(statusFunc func(*workceptor.StatusFileData))

UpdateFullStatus mocks base method.

type MockWorkUnitMockRecorder 

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

MockWorkUnitMockRecorder is the mock recorder for MockWorkUnit.

func (*MockWorkUnitMockRecorder) Cancel 

func (mr *MockWorkUnitMockRecorder) Cancel() *gomock.Call

Cancel indicates an expected call of Cancel.

func (*MockWorkUnitMockRecorder) ID 

func (mr *MockWorkUnitMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockWorkUnitMockRecorder) LastUpdateError 

func (mr *MockWorkUnitMockRecorder) LastUpdateError() *gomock.Call

LastUpdateError indicates an expected call of LastUpdateError.

func (*MockWorkUnitMockRecorder) Load 

func (mr *MockWorkUnitMockRecorder) Load() *gomock.Call

Load indicates an expected call of Load.

func (*MockWorkUnitMockRecorder) Release 

func (mr *MockWorkUnitMockRecorder) Release(force any) *gomock.Call

Release indicates an expected call of Release.

func (*MockWorkUnitMockRecorder) Restart 

func (mr *MockWorkUnitMockRecorder) Restart() *gomock.Call

Restart indicates an expected call of Restart.

func (*MockWorkUnitMockRecorder) Save 

func (mr *MockWorkUnitMockRecorder) Save() *gomock.Call

Save indicates an expected call of Save.

func (*MockWorkUnitMockRecorder) SetFromParams 

func (mr *MockWorkUnitMockRecorder) SetFromParams(params any) *gomock.Call

SetFromParams indicates an expected call of SetFromParams.

func (*MockWorkUnitMockRecorder) Start 

func (mr *MockWorkUnitMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockWorkUnitMockRecorder) Status 

func (mr *MockWorkUnitMockRecorder) Status() *gomock.Call

Status indicates an expected call of Status.

func (*MockWorkUnitMockRecorder) StatusFileName 

func (mr *MockWorkUnitMockRecorder) StatusFileName() *gomock.Call

StatusFileName indicates an expected call of StatusFileName.

func (*MockWorkUnitMockRecorder) StdoutFileName 

func (mr *MockWorkUnitMockRecorder) StdoutFileName() *gomock.Call

StdoutFileName indicates an expected call of StdoutFileName.

func (*MockWorkUnitMockRecorder) UnitDir 

func (mr *MockWorkUnitMockRecorder) UnitDir() *gomock.Call

UnitDir indicates an expected call of UnitDir.

func (*MockWorkUnitMockRecorder) UnredactedStatus 

func (mr *MockWorkUnitMockRecorder) UnredactedStatus() *gomock.Call

UnredactedStatus indicates an expected call of UnredactedStatus.

func (*MockWorkUnitMockRecorder) UpdateBasicStatus 

func (mr *MockWorkUnitMockRecorder) UpdateBasicStatus(state, detail, stdoutSize any) *gomock.Call

UpdateBasicStatus indicates an expected call of UpdateBasicStatus.

func (*MockWorkUnitMockRecorder) UpdateFullStatus 

func (mr *MockWorkUnitMockRecorder) UpdateFullStatus(statusFunc any) *gomock.Call

UpdateFullStatus indicates an expected call of UpdateFullStatus.

type MockWorkerConfig 

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

MockWorkerConfig is a mock of WorkerConfig interface.

func NewMockWorkerConfig 

func NewMockWorkerConfig(ctrl *gomock.Controller) *MockWorkerConfig

NewMockWorkerConfig creates a new mock instance.

func (*MockWorkerConfig) EXPECT 

func (m *MockWorkerConfig) EXPECT() *MockWorkerConfigMockRecorder

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

func (*MockWorkerConfig) GetVerifySignature 

func (m *MockWorkerConfig) GetVerifySignature() bool

GetVerifySignature mocks base method.

func (*MockWorkerConfig) GetWorkType 

func (m *MockWorkerConfig) GetWorkType() string

GetWorkType mocks base method.

func (*MockWorkerConfig) NewWorker 

func (m *MockWorkerConfig) NewWorker(bwu workceptor.BaseWorkUnitForWorkUnit, w *workceptor.Workceptor, unitID, workType string) workceptor.WorkUnit

NewWorker mocks base method.

type MockWorkerConfigMockRecorder 

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

MockWorkerConfigMockRecorder is the mock recorder for MockWorkerConfig.

func (*MockWorkerConfigMockRecorder) GetVerifySignature 

func (mr *MockWorkerConfigMockRecorder) GetVerifySignature() *gomock.Call

GetVerifySignature indicates an expected call of GetVerifySignature.

func (*MockWorkerConfigMockRecorder) GetWorkType 

func (mr *MockWorkerConfigMockRecorder) GetWorkType() *gomock.Call

GetWorkType indicates an expected call of GetWorkType.

func (*MockWorkerConfigMockRecorder) NewWorker 

func (mr *MockWorkerConfigMockRecorder) NewWorker(bwu, w, unitID, workType any) *gomock.Call

NewWorker indicates an expected call of NewWorker.

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.