mock_workceptor

package
v1.4.5 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 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.

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) Debug added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) Debug(arg0 string, arg1 ...interface{})

Debug 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) Error added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) Error(arg0 string, arg1 ...interface{})

Error mocks base method.

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) Info added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) Info(arg0 string, arg1 ...interface{})

Info mocks base method.

func (*MockBaseWorkUnitForWorkUnit) Init added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) Init(arg0 *workceptor.Workceptor, arg1, arg2 string, arg3 workceptor.FileSystemer, arg4 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(arg0 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 interface{})

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(arg0 int, arg1 string, arg2 int64)

UpdateBasicStatus mocks base method.

func (*MockBaseWorkUnitForWorkUnit) UpdateFullStatus added in v1.4.4 

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

UpdateFullStatus mocks base method.

func (*MockBaseWorkUnitForWorkUnit) Warning added in v1.4.4 

func (m *MockBaseWorkUnitForWorkUnit) Warning(arg0 string, arg1 ...interface{})

Warning 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) Debug added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) Debug(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Debug indicates an expected call of Debug.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) Error added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) Error(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Error indicates an expected call of Error.

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) Info added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) Info(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Info indicates an expected call of Info.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) Init added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) Init(arg0, arg1, arg2, arg3, arg4 interface{}) *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(arg0 interface{}) *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 interface{}) *gomock.Call

SetFromParams indicates an expected call of SetFromParams.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) SetStatusExtraData added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) SetStatusExtraData(arg0 interface{}) *gomock.Call

SetStatusExtraData indicates an expected call of SetStatusExtraData.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) SetWorkceptor added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) SetWorkceptor(arg0 interface{}) *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(arg0, arg1, arg2 interface{}) *gomock.Call

UpdateBasicStatus indicates an expected call of UpdateBasicStatus.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) UpdateFullStatus added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) UpdateFullStatus(arg0 interface{}) *gomock.Call

UpdateFullStatus indicates an expected call of UpdateFullStatus.

func (*MockBaseWorkUnitForWorkUnitMockRecorder) Warning added in v1.4.4 

func (mr *MockBaseWorkUnitForWorkUnitMockRecorder) Warning(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Warning indicates an expected call of Warning.

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 interface{}) *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 interface{}) *gomock.Call

Open indicates an expected call of Open

func (*MockFileSystemerMockRecorder) OpenFile 

func (mr *MockFileSystemerMockRecorder) OpenFile(name, flag, perm interface{}) *gomock.Call

OpenFile indicates an expected call of OpenFile

func (*MockFileSystemerMockRecorder) RemoveAll 

func (mr *MockFileSystemerMockRecorder) RemoveAll(path interface{}) *gomock.Call

RemoveAll indicates an expected call of RemoveAll

func (*MockFileSystemerMockRecorder) Stat 

func (mr *MockFileSystemerMockRecorder) Stat(name interface{}) *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 interface{}) *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 interface{}) *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 interface{}) *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 interface{}) *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 interface{}) *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 interface{}) *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 interface{}) *gomock.Call

List indicates an expected call of List

func (*MockKubeAPIerMockRecorder) NewClientConfigFromBytes added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) NewClientConfigFromBytes(arg0 interface{}) *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 interface{}) *gomock.Call

NewForConfig indicates an expected call of NewForConfig

func (*MockKubeAPIerMockRecorder) NewNotFound added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) NewNotFound(arg0, arg1 interface{}) *gomock.Call

NewNotFound indicates an expected call of NewNotFound

func (*MockKubeAPIerMockRecorder) NewSPDYExecutor added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) NewSPDYExecutor(arg0, arg1, arg2 interface{}) *gomock.Call

NewSPDYExecutor indicates an expected call of NewSPDYExecutor

func (*MockKubeAPIerMockRecorder) OneTermEqualSelector added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) OneTermEqualSelector(arg0, arg1 interface{}) *gomock.Call

OneTermEqualSelector indicates an expected call of OneTermEqualSelector

func (*MockKubeAPIerMockRecorder) StreamWithContext added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) StreamWithContext(arg0, arg1, arg2 interface{}) *gomock.Call

StreamWithContext indicates an expected call of StreamWithContext

func (*MockKubeAPIerMockRecorder) SubResource added in v1.4.5 

func (mr *MockKubeAPIerMockRecorder) SubResource(arg0, arg1, arg2 interface{}) *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 interface{}, arg4 ...interface{}) *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 interface{}) *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 interface{}) *gomock.Call

AddWorkCommand indicates an expected call of AddWorkCommand

func (*MockNetceptorForWorkceptorMockRecorder) DialContext 

func (mr *MockNetceptorForWorkceptorMockRecorder) DialContext(ctx, node, service, tlscfg interface{}) *gomock.Call

DialContext indicates an expected call of DialContext

func (*MockNetceptorForWorkceptorMockRecorder) GetClientTLSConfig 

func (mr *MockNetceptorForWorkceptorMockRecorder) GetClientTLSConfig(name, expectedHostName, expectedHostNameType interface{}) *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(arg0 string, arg1 controlsvc.ControlCommandType) error

AddControlFunc mocks base method.

func (*MockServerForWorkceptor) ConnectionListener added in v1.4.4 

func (m *MockServerForWorkceptor) ConnectionListener(arg0 context.Context, arg1 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(arg0 net.Conn)

RunControlSession mocks base method.

func (*MockServerForWorkceptor) RunControlSvc added in v1.4.4 

func (m *MockServerForWorkceptor) RunControlSvc(arg0 context.Context, arg1 string, arg2 *tls.Config, arg3 string, arg4 fs.FileMode, arg5 string, arg6 *tls.Config) error

RunControlSvc mocks base method.

func (*MockServerForWorkceptor) SetServerNet added in v1.4.4 

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

SetServerNet mocks base method.

func (*MockServerForWorkceptor) SetServerTLS added in v1.4.4 

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

SetServerTLS mocks base method.

func (*MockServerForWorkceptor) SetServerUtils added in v1.4.4 

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

SetServerUtils mocks base method.

func (*MockServerForWorkceptor) SetupConnection added in v1.4.4 

func (m *MockServerForWorkceptor) SetupConnection(arg0 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(arg0, arg1 interface{}) *gomock.Call

AddControlFunc indicates an expected call of AddControlFunc.

func (*MockServerForWorkceptorMockRecorder) ConnectionListener added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) ConnectionListener(arg0, arg1 interface{}) *gomock.Call

ConnectionListener indicates an expected call of ConnectionListener.

func (*MockServerForWorkceptorMockRecorder) RunControlSession added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) RunControlSession(arg0 interface{}) *gomock.Call

RunControlSession indicates an expected call of RunControlSession.

func (*MockServerForWorkceptorMockRecorder) RunControlSvc added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) RunControlSvc(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call

RunControlSvc indicates an expected call of RunControlSvc.

func (*MockServerForWorkceptorMockRecorder) SetServerNet added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) SetServerNet(arg0 interface{}) *gomock.Call

SetServerNet indicates an expected call of SetServerNet.

func (*MockServerForWorkceptorMockRecorder) SetServerTLS added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) SetServerTLS(arg0 interface{}) *gomock.Call

SetServerTLS indicates an expected call of SetServerTLS.

func (*MockServerForWorkceptorMockRecorder) SetServerUtils added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) SetServerUtils(arg0 interface{}) *gomock.Call

SetServerUtils indicates an expected call of SetServerUtils.

func (*MockServerForWorkceptorMockRecorder) SetupConnection added in v1.4.4 

func (mr *MockServerForWorkceptorMockRecorder) SetupConnection(arg0 interface{}) *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) 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 interface{}) *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) 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 interface{}) *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 interface{}) *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 interface{}) *gomock.Call

UpdateBasicStatus indicates an expected call of UpdateBasicStatus

func (*MockWorkUnitMockRecorder) UpdateFullStatus 

func (mr *MockWorkUnitMockRecorder) UpdateFullStatus(statusFunc interface{}) *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(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(w, unitID, workType interface{}) *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.