mocks

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Feb 21, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventsRecorder

type EventsRecorder struct {
	mock.Mock
}

EventsRecorder is an autogenerated mock type for the EventsRecorder type

func (*EventsRecorder) OnRecordRaw

func (*EventsRecorder) OnRecordRawMatch

func (_m *EventsRecorder) OnRecordRawMatch(matchers ...interface{}) *EventsRecorder_RecordRaw

func (*EventsRecorder) RecordRaw

func (_m *EventsRecorder) RecordRaw(ctx context.Context, ev core.PhaseInfo) error

RecordRaw provides a mock function with given fields: ctx, ev

type EventsRecorder_RecordRaw

type EventsRecorder_RecordRaw struct {
	*mock.Call
}

func (EventsRecorder_RecordRaw) Return

type FakeKubeCache

type FakeKubeCache struct {
	// Reader acts as a client to objects stored in the cache.
	client.Reader

	// Informers loads informers and adds field indices.
	cache.Informers

	Cache map[string]runtime.Object
	// contains filtered or unexported fields
}

func NewFakeKubeCache

func NewFakeKubeCache() *FakeKubeCache

func (*FakeKubeCache) Create

func (m *FakeKubeCache) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) (err error)

func (*FakeKubeCache) Delete

func (m *FakeKubeCache) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*FakeKubeCache) Get

func (*FakeKubeCache) GetInformer

func (m *FakeKubeCache) GetInformer(ctx context.Context, obj client.Object, opts ...cache.InformerGetOption) (cache.Informer, error)

func (*FakeKubeCache) GetInformerForKind

func (m *FakeKubeCache) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind, opts ...cache.InformerGetOption) (cache.Informer, error)

func (*FakeKubeCache) IndexField

func (m *FakeKubeCache) IndexField(ctx context.Context, obj client.Object, field string, extractValue client.IndexerFunc) error

func (*FakeKubeCache) List

func (m *FakeKubeCache) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*FakeKubeCache) Start

func (m *FakeKubeCache) Start(ctx context.Context) error

func (*FakeKubeCache) Update

func (m *FakeKubeCache) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

func (*FakeKubeCache) WaitForCacheSync

func (m *FakeKubeCache) WaitForCacheSync(ctx context.Context) bool

type FakeKubeClient

type FakeKubeClient struct {
	client.Reader
	client.Writer
	client.StatusClient
	client.SubResourceClientConstructor

	Cache map[string]runtime.Object
	// contains filtered or unexported fields
}

func NewFakeKubeClient

func NewFakeKubeClient() *FakeKubeClient

func (*FakeKubeClient) Create

func (m *FakeKubeClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) (err error)

func (*FakeKubeClient) Delete

func (m *FakeKubeClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*FakeKubeClient) DeleteAllOf

func (*FakeKubeClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

DeleteAllOf deletes all objects of the given type matching the given options.

func (*FakeKubeClient) Get

func (*FakeKubeClient) GroupVersionKindFor

func (m *FakeKubeClient) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)

GroupVersionKindFor returns the GroupVersionKind for the given object.

func (*FakeKubeClient) IsObjectNamespaced

func (m *FakeKubeClient) IsObjectNamespaced(obj runtime.Object) (bool, error)

IsObjectNamespaced returns true if the GroupVersionKind of the object is namespaced.

func (*FakeKubeClient) List

func (m *FakeKubeClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*FakeKubeClient) Patch

func (*FakeKubeClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

Patch patches the given obj in the Kubernetes cluster. obj must be a struct pointer so that obj can be updated with the content returned by the Server.

func (*FakeKubeClient) RESTMapper

func (*FakeKubeClient) RESTMapper() meta.RESTMapper

func (*FakeKubeClient) Scheme

func (*FakeKubeClient) Scheme() *runtime.Scheme

func (*FakeKubeClient) Status

func (*FakeKubeClient) Update

func (m *FakeKubeClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type KubeClient

type KubeClient struct {
	mock.Mock
}

KubeClient is an autogenerated mock type for the KubeClient type

func (*KubeClient) GetCache

func (_m *KubeClient) GetCache() cache.Cache

GetCache provides a mock function with given fields:

func (*KubeClient) GetClient

func (_m *KubeClient) GetClient() client.Client

GetClient provides a mock function with given fields:

func (*KubeClient) OnGetCache

func (_m *KubeClient) OnGetCache() *KubeClient_GetCache

func (*KubeClient) OnGetCacheMatch

func (_m *KubeClient) OnGetCacheMatch(matchers ...interface{}) *KubeClient_GetCache

func (*KubeClient) OnGetClient

func (_m *KubeClient) OnGetClient() *KubeClient_GetClient

func (*KubeClient) OnGetClientMatch

func (_m *KubeClient) OnGetClientMatch(matchers ...interface{}) *KubeClient_GetClient

type KubeClient_GetCache

type KubeClient_GetCache struct {
	*mock.Call
}

func (KubeClient_GetCache) Return

type KubeClient_GetClient

type KubeClient_GetClient struct {
	*mock.Call
}

func (KubeClient_GetClient) Return

type Plugin

type Plugin struct {
	mock.Mock
}

Plugin is an autogenerated mock type for the Plugin type

func (*Plugin) Abort

func (_m *Plugin) Abort(ctx context.Context, tCtx core.TaskExecutionContext) error

Abort provides a mock function with given fields: ctx, tCtx

func (*Plugin) Finalize

func (_m *Plugin) Finalize(ctx context.Context, tCtx core.TaskExecutionContext) error

Finalize provides a mock function with given fields: ctx, tCtx

func (*Plugin) GetID

func (_m *Plugin) GetID() string

GetID provides a mock function with given fields:

func (*Plugin) GetProperties

func (_m *Plugin) GetProperties() core.PluginProperties

GetProperties provides a mock function with given fields:

func (*Plugin) Handle

Handle provides a mock function with given fields: ctx, tCtx

func (*Plugin) OnAbort

func (_m *Plugin) OnAbort(ctx context.Context, tCtx core.TaskExecutionContext) *Plugin_Abort

func (*Plugin) OnAbortMatch

func (_m *Plugin) OnAbortMatch(matchers ...interface{}) *Plugin_Abort

func (*Plugin) OnFinalize

func (_m *Plugin) OnFinalize(ctx context.Context, tCtx core.TaskExecutionContext) *Plugin_Finalize

func (*Plugin) OnFinalizeMatch

func (_m *Plugin) OnFinalizeMatch(matchers ...interface{}) *Plugin_Finalize

func (*Plugin) OnGetID

func (_m *Plugin) OnGetID() *Plugin_GetID

func (*Plugin) OnGetIDMatch

func (_m *Plugin) OnGetIDMatch(matchers ...interface{}) *Plugin_GetID

func (*Plugin) OnGetProperties

func (_m *Plugin) OnGetProperties() *Plugin_GetProperties

func (*Plugin) OnGetPropertiesMatch

func (_m *Plugin) OnGetPropertiesMatch(matchers ...interface{}) *Plugin_GetProperties

func (*Plugin) OnHandle

func (_m *Plugin) OnHandle(ctx context.Context, tCtx core.TaskExecutionContext) *Plugin_Handle

func (*Plugin) OnHandleMatch

func (_m *Plugin) OnHandleMatch(matchers ...interface{}) *Plugin_Handle

type PluginStateReader

type PluginStateReader struct {
	mock.Mock
}

PluginStateReader is an autogenerated mock type for the PluginStateReader type

func (*PluginStateReader) Get

func (_m *PluginStateReader) Get(t interface{}) (uint8, error)

Get provides a mock function with given fields: t

func (*PluginStateReader) GetStateVersion

func (_m *PluginStateReader) GetStateVersion() uint8

GetStateVersion provides a mock function with given fields:

func (*PluginStateReader) OnGet

func (_m *PluginStateReader) OnGet(t interface{}) *PluginStateReader_Get

func (*PluginStateReader) OnGetMatch

func (_m *PluginStateReader) OnGetMatch(matchers ...interface{}) *PluginStateReader_Get

func (*PluginStateReader) OnGetStateVersion

func (_m *PluginStateReader) OnGetStateVersion() *PluginStateReader_GetStateVersion

func (*PluginStateReader) OnGetStateVersionMatch

func (_m *PluginStateReader) OnGetStateVersionMatch(matchers ...interface{}) *PluginStateReader_GetStateVersion

type PluginStateReader_Get

type PluginStateReader_Get struct {
	*mock.Call
}

func (PluginStateReader_Get) Return

func (_m PluginStateReader_Get) Return(stateVersion uint8, err error) *PluginStateReader_Get

type PluginStateReader_GetStateVersion

type PluginStateReader_GetStateVersion struct {
	*mock.Call
}

func (PluginStateReader_GetStateVersion) Return

type PluginStateWriter

type PluginStateWriter struct {
	mock.Mock
}

PluginStateWriter is an autogenerated mock type for the PluginStateWriter type

func (*PluginStateWriter) OnPut

func (_m *PluginStateWriter) OnPut(stateVersion uint8, v interface{}) *PluginStateWriter_Put

func (*PluginStateWriter) OnPutMatch

func (_m *PluginStateWriter) OnPutMatch(matchers ...interface{}) *PluginStateWriter_Put

func (*PluginStateWriter) OnReset

func (*PluginStateWriter) OnResetMatch

func (_m *PluginStateWriter) OnResetMatch(matchers ...interface{}) *PluginStateWriter_Reset

func (*PluginStateWriter) Put

func (_m *PluginStateWriter) Put(stateVersion uint8, v interface{}) error

Put provides a mock function with given fields: stateVersion, v

func (*PluginStateWriter) Reset

func (_m *PluginStateWriter) Reset() error

Reset provides a mock function with given fields:

type PluginStateWriter_Put

type PluginStateWriter_Put struct {
	*mock.Call
}

func (PluginStateWriter_Put) Return

type PluginStateWriter_Reset

type PluginStateWriter_Reset struct {
	*mock.Call
}

func (PluginStateWriter_Reset) Return

type Plugin_Abort

type Plugin_Abort struct {
	*mock.Call
}

func (Plugin_Abort) Return

func (_m Plugin_Abort) Return(_a0 error) *Plugin_Abort

type Plugin_Finalize

type Plugin_Finalize struct {
	*mock.Call
}

func (Plugin_Finalize) Return

func (_m Plugin_Finalize) Return(_a0 error) *Plugin_Finalize

type Plugin_GetID

type Plugin_GetID struct {
	*mock.Call
}

func (Plugin_GetID) Return

func (_m Plugin_GetID) Return(_a0 string) *Plugin_GetID

type Plugin_GetProperties

type Plugin_GetProperties struct {
	*mock.Call
}

func (Plugin_GetProperties) Return

type Plugin_Handle

type Plugin_Handle struct {
	*mock.Call
}

func (Plugin_Handle) Return

func (_m Plugin_Handle) Return(_a0 core.Transition, _a1 error) *Plugin_Handle

type ResourceManager

type ResourceManager struct {
	mock.Mock
}

ResourceManager is an autogenerated mock type for the ResourceManager type

func (*ResourceManager) AllocateResource

func (_m *ResourceManager) AllocateResource(ctx context.Context, namespace core.ResourceNamespace, allocationToken string, constraintsSpec core.ResourceConstraintsSpec) (core.AllocationStatus, error)

AllocateResource provides a mock function with given fields: ctx, namespace, allocationToken, constraintsSpec

func (*ResourceManager) GetID

func (_m *ResourceManager) GetID() string

GetID provides a mock function with given fields:

func (*ResourceManager) OnAllocateResource

func (_m *ResourceManager) OnAllocateResource(ctx context.Context, namespace core.ResourceNamespace, allocationToken string, constraintsSpec core.ResourceConstraintsSpec) *ResourceManager_AllocateResource

func (*ResourceManager) OnAllocateResourceMatch

func (_m *ResourceManager) OnAllocateResourceMatch(matchers ...interface{}) *ResourceManager_AllocateResource

func (*ResourceManager) OnGetID

func (_m *ResourceManager) OnGetID() *ResourceManager_GetID

func (*ResourceManager) OnGetIDMatch

func (_m *ResourceManager) OnGetIDMatch(matchers ...interface{}) *ResourceManager_GetID

func (*ResourceManager) OnReleaseResource

func (_m *ResourceManager) OnReleaseResource(ctx context.Context, namespace core.ResourceNamespace, allocationToken string) *ResourceManager_ReleaseResource

func (*ResourceManager) OnReleaseResourceMatch

func (_m *ResourceManager) OnReleaseResourceMatch(matchers ...interface{}) *ResourceManager_ReleaseResource

func (*ResourceManager) ReleaseResource

func (_m *ResourceManager) ReleaseResource(ctx context.Context, namespace core.ResourceNamespace, allocationToken string) error

ReleaseResource provides a mock function with given fields: ctx, namespace, allocationToken

type ResourceManager_AllocateResource

type ResourceManager_AllocateResource struct {
	*mock.Call
}

func (ResourceManager_AllocateResource) Return

type ResourceManager_GetID

type ResourceManager_GetID struct {
	*mock.Call
}

func (ResourceManager_GetID) Return

type ResourceManager_ReleaseResource

type ResourceManager_ReleaseResource struct {
	*mock.Call
}

func (ResourceManager_ReleaseResource) Return

type ResourceNegotiator

type ResourceNegotiator struct {
	mock.Mock
}

ResourceRegistrar is an autogenerated mock type for the ResourceRegistrar type

func (*ResourceNegotiator) OnRegisterResourceQuota

func (_m *ResourceNegotiator) OnRegisterResourceQuota(ctx context.Context, namespace core.ResourceNamespace, quota int) *ResourceNegotiator_RegisterResourceQuota

func (*ResourceNegotiator) OnRegisterResourceQuotaMatch

func (_m *ResourceNegotiator) OnRegisterResourceQuotaMatch(matchers ...interface{}) *ResourceNegotiator_RegisterResourceQuota

func (*ResourceNegotiator) RegisterResourceQuota

func (_m *ResourceNegotiator) RegisterResourceQuota(ctx context.Context, namespace core.ResourceNamespace, quota int) error

RegisterResourceQuota provides a mock function with given fields: ctx, namespace, quota

type ResourceNegotiator_RegisterResourceQuota

type ResourceNegotiator_RegisterResourceQuota struct {
	*mock.Call
}

func (ResourceNegotiator_RegisterResourceQuota) Return

type ResourceRegistrar

type ResourceRegistrar struct {
	mock.Mock
}

ResourceRegistrar is an autogenerated mock type for the ResourceRegistrar type

func (*ResourceRegistrar) OnRegisterResourceQuota

func (_m *ResourceRegistrar) OnRegisterResourceQuota(ctx context.Context, namespace core.ResourceNamespace, quota int) *ResourceRegistrar_RegisterResourceQuota

func (*ResourceRegistrar) OnRegisterResourceQuotaMatch

func (_m *ResourceRegistrar) OnRegisterResourceQuotaMatch(matchers ...interface{}) *ResourceRegistrar_RegisterResourceQuota

func (*ResourceRegistrar) RegisterResourceQuota

func (_m *ResourceRegistrar) RegisterResourceQuota(ctx context.Context, namespace core.ResourceNamespace, quota int) error

RegisterResourceQuota provides a mock function with given fields: ctx, namespace, quota

type ResourceRegistrar_RegisterResourceQuota

type ResourceRegistrar_RegisterResourceQuota struct {
	*mock.Call
}

func (ResourceRegistrar_RegisterResourceQuota) Return

type SecretManager

type SecretManager struct {
	mock.Mock
}

SecretManager is an autogenerated mock type for the SecretManager type

func (*SecretManager) Get

func (_m *SecretManager) Get(ctx context.Context, key string) (string, error)

Get provides a mock function with given fields: ctx, key

func (*SecretManager) OnGet

func (_m *SecretManager) OnGet(ctx context.Context, key string) *SecretManager_Get

func (*SecretManager) OnGetMatch

func (_m *SecretManager) OnGetMatch(matchers ...interface{}) *SecretManager_Get

type SecretManager_Get

type SecretManager_Get struct {
	*mock.Call
}

func (SecretManager_Get) Return

func (_m SecretManager_Get) Return(_a0 string, _a1 error) *SecretManager_Get

type SetupContext

type SetupContext struct {
	mock.Mock
}

SetupContext is an autogenerated mock type for the SetupContext type

func (*SetupContext) EnqueueOwner

func (_m *SetupContext) EnqueueOwner() core.EnqueueOwner

EnqueueOwner provides a mock function with given fields:

func (*SetupContext) KubeClient

func (_m *SetupContext) KubeClient() core.KubeClient

KubeClient provides a mock function with given fields:

func (*SetupContext) MetricsScope

func (_m *SetupContext) MetricsScope() promutils.Scope

MetricsScope provides a mock function with given fields:

func (*SetupContext) OnEnqueueOwner

func (_m *SetupContext) OnEnqueueOwner() *SetupContext_EnqueueOwner

func (*SetupContext) OnEnqueueOwnerMatch

func (_m *SetupContext) OnEnqueueOwnerMatch(matchers ...interface{}) *SetupContext_EnqueueOwner

func (*SetupContext) OnKubeClient

func (_m *SetupContext) OnKubeClient() *SetupContext_KubeClient

func (*SetupContext) OnKubeClientMatch

func (_m *SetupContext) OnKubeClientMatch(matchers ...interface{}) *SetupContext_KubeClient

func (*SetupContext) OnMetricsScope

func (_m *SetupContext) OnMetricsScope() *SetupContext_MetricsScope

func (*SetupContext) OnMetricsScopeMatch

func (_m *SetupContext) OnMetricsScopeMatch(matchers ...interface{}) *SetupContext_MetricsScope

func (*SetupContext) OnOwnerKind

func (_m *SetupContext) OnOwnerKind() *SetupContext_OwnerKind

func (*SetupContext) OnOwnerKindMatch

func (_m *SetupContext) OnOwnerKindMatch(matchers ...interface{}) *SetupContext_OwnerKind

func (*SetupContext) OnResourceRegistrar

func (_m *SetupContext) OnResourceRegistrar() *SetupContext_ResourceRegistrar

func (*SetupContext) OnResourceRegistrarMatch

func (_m *SetupContext) OnResourceRegistrarMatch(matchers ...interface{}) *SetupContext_ResourceRegistrar

func (*SetupContext) OnSecretManager

func (_m *SetupContext) OnSecretManager() *SetupContext_SecretManager

func (*SetupContext) OnSecretManagerMatch

func (_m *SetupContext) OnSecretManagerMatch(matchers ...interface{}) *SetupContext_SecretManager

func (*SetupContext) OwnerKind

func (_m *SetupContext) OwnerKind() string

OwnerKind provides a mock function with given fields:

func (*SetupContext) ResourceRegistrar

func (_m *SetupContext) ResourceRegistrar() core.ResourceRegistrar

ResourceRegistrar provides a mock function with given fields:

func (*SetupContext) SecretManager

func (_m *SetupContext) SecretManager() core.SecretManager

SecretManager provides a mock function with given fields:

type SetupContext_EnqueueOwner

type SetupContext_EnqueueOwner struct {
	*mock.Call
}

func (SetupContext_EnqueueOwner) Return

type SetupContext_KubeClient

type SetupContext_KubeClient struct {
	*mock.Call
}

func (SetupContext_KubeClient) Return

type SetupContext_MetricsScope

type SetupContext_MetricsScope struct {
	*mock.Call
}

func (SetupContext_MetricsScope) Return

type SetupContext_OwnerKind

type SetupContext_OwnerKind struct {
	*mock.Call
}

func (SetupContext_OwnerKind) Return

type SetupContext_ResourceRegistrar

type SetupContext_ResourceRegistrar struct {
	*mock.Call
}

func (SetupContext_ResourceRegistrar) Return

type SetupContext_SecretManager

type SetupContext_SecretManager struct {
	*mock.Call
}

func (SetupContext_SecretManager) Return

type TaskExecutionContext

type TaskExecutionContext struct {
	mock.Mock
}

TaskExecutionContext is an autogenerated mock type for the TaskExecutionContext type

func (*TaskExecutionContext) Catalog

Catalog provides a mock function with given fields:

func (*TaskExecutionContext) DataStore

func (_m *TaskExecutionContext) DataStore() *storage.DataStore

DataStore provides a mock function with given fields:

func (*TaskExecutionContext) EventsRecorder

func (_m *TaskExecutionContext) EventsRecorder() core.EventsRecorder

EventsRecorder provides a mock function with given fields:

func (*TaskExecutionContext) InputReader

func (_m *TaskExecutionContext) InputReader() io.InputReader

InputReader provides a mock function with given fields:

func (*TaskExecutionContext) MaxDatasetSizeBytes

func (_m *TaskExecutionContext) MaxDatasetSizeBytes() int64

MaxDatasetSizeBytes provides a mock function with given fields:

func (*TaskExecutionContext) OnCatalog

func (*TaskExecutionContext) OnCatalogMatch

func (_m *TaskExecutionContext) OnCatalogMatch(matchers ...interface{}) *TaskExecutionContext_Catalog

func (*TaskExecutionContext) OnDataStore

func (*TaskExecutionContext) OnDataStoreMatch

func (_m *TaskExecutionContext) OnDataStoreMatch(matchers ...interface{}) *TaskExecutionContext_DataStore

func (*TaskExecutionContext) OnEventsRecorder

func (*TaskExecutionContext) OnEventsRecorderMatch

func (_m *TaskExecutionContext) OnEventsRecorderMatch(matchers ...interface{}) *TaskExecutionContext_EventsRecorder

func (*TaskExecutionContext) OnInputReader

func (*TaskExecutionContext) OnInputReaderMatch

func (_m *TaskExecutionContext) OnInputReaderMatch(matchers ...interface{}) *TaskExecutionContext_InputReader

func (*TaskExecutionContext) OnMaxDatasetSizeBytes

func (*TaskExecutionContext) OnMaxDatasetSizeBytesMatch

func (_m *TaskExecutionContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *TaskExecutionContext_MaxDatasetSizeBytes

func (*TaskExecutionContext) OnOutputWriter

func (*TaskExecutionContext) OnOutputWriterMatch

func (_m *TaskExecutionContext) OnOutputWriterMatch(matchers ...interface{}) *TaskExecutionContext_OutputWriter

func (*TaskExecutionContext) OnPluginStateReader

func (*TaskExecutionContext) OnPluginStateReaderMatch

func (_m *TaskExecutionContext) OnPluginStateReaderMatch(matchers ...interface{}) *TaskExecutionContext_PluginStateReader

func (*TaskExecutionContext) OnPluginStateWriter

func (*TaskExecutionContext) OnPluginStateWriterMatch

func (_m *TaskExecutionContext) OnPluginStateWriterMatch(matchers ...interface{}) *TaskExecutionContext_PluginStateWriter

func (*TaskExecutionContext) OnResourceManager

func (*TaskExecutionContext) OnResourceManagerMatch

func (_m *TaskExecutionContext) OnResourceManagerMatch(matchers ...interface{}) *TaskExecutionContext_ResourceManager

func (*TaskExecutionContext) OnSecretManager

func (*TaskExecutionContext) OnSecretManagerMatch

func (_m *TaskExecutionContext) OnSecretManagerMatch(matchers ...interface{}) *TaskExecutionContext_SecretManager

func (*TaskExecutionContext) OnTaskExecutionMetadata

func (*TaskExecutionContext) OnTaskExecutionMetadataMatch

func (_m *TaskExecutionContext) OnTaskExecutionMetadataMatch(matchers ...interface{}) *TaskExecutionContext_TaskExecutionMetadata

func (*TaskExecutionContext) OnTaskReader

func (*TaskExecutionContext) OnTaskReaderMatch

func (_m *TaskExecutionContext) OnTaskReaderMatch(matchers ...interface{}) *TaskExecutionContext_TaskReader

func (*TaskExecutionContext) OnTaskRefreshIndicator

func (*TaskExecutionContext) OnTaskRefreshIndicatorMatch

func (_m *TaskExecutionContext) OnTaskRefreshIndicatorMatch(matchers ...interface{}) *TaskExecutionContext_TaskRefreshIndicator

func (*TaskExecutionContext) OutputWriter

func (_m *TaskExecutionContext) OutputWriter() io.OutputWriter

OutputWriter provides a mock function with given fields:

func (*TaskExecutionContext) PluginStateReader

func (_m *TaskExecutionContext) PluginStateReader() core.PluginStateReader

PluginStateReader provides a mock function with given fields:

func (*TaskExecutionContext) PluginStateWriter

func (_m *TaskExecutionContext) PluginStateWriter() core.PluginStateWriter

PluginStateWriter provides a mock function with given fields:

func (*TaskExecutionContext) ResourceManager

func (_m *TaskExecutionContext) ResourceManager() core.ResourceManager

ResourceManager provides a mock function with given fields:

func (*TaskExecutionContext) SecretManager

func (_m *TaskExecutionContext) SecretManager() core.SecretManager

SecretManager provides a mock function with given fields:

func (*TaskExecutionContext) TaskExecutionMetadata

func (_m *TaskExecutionContext) TaskExecutionMetadata() core.TaskExecutionMetadata

TaskExecutionMetadata provides a mock function with given fields:

func (*TaskExecutionContext) TaskReader

func (_m *TaskExecutionContext) TaskReader() core.TaskReader

TaskReader provides a mock function with given fields:

func (*TaskExecutionContext) TaskRefreshIndicator

func (_m *TaskExecutionContext) TaskRefreshIndicator() core.SignalAsync

TaskRefreshIndicator provides a mock function with given fields:

type TaskExecutionContext_Catalog

type TaskExecutionContext_Catalog struct {
	*mock.Call
}

func (TaskExecutionContext_Catalog) Return

type TaskExecutionContext_DataStore

type TaskExecutionContext_DataStore struct {
	*mock.Call
}

func (TaskExecutionContext_DataStore) Return

type TaskExecutionContext_EventsRecorder

type TaskExecutionContext_EventsRecorder struct {
	*mock.Call
}

func (TaskExecutionContext_EventsRecorder) Return

type TaskExecutionContext_InputReader

type TaskExecutionContext_InputReader struct {
	*mock.Call
}

func (TaskExecutionContext_InputReader) Return

type TaskExecutionContext_MaxDatasetSizeBytes

type TaskExecutionContext_MaxDatasetSizeBytes struct {
	*mock.Call
}

func (TaskExecutionContext_MaxDatasetSizeBytes) Return

type TaskExecutionContext_OutputWriter

type TaskExecutionContext_OutputWriter struct {
	*mock.Call
}

func (TaskExecutionContext_OutputWriter) Return

type TaskExecutionContext_PluginStateReader

type TaskExecutionContext_PluginStateReader struct {
	*mock.Call
}

func (TaskExecutionContext_PluginStateReader) Return

type TaskExecutionContext_PluginStateWriter

type TaskExecutionContext_PluginStateWriter struct {
	*mock.Call
}

func (TaskExecutionContext_PluginStateWriter) Return

type TaskExecutionContext_ResourceManager

type TaskExecutionContext_ResourceManager struct {
	*mock.Call
}

func (TaskExecutionContext_ResourceManager) Return

type TaskExecutionContext_SecretManager

type TaskExecutionContext_SecretManager struct {
	*mock.Call
}

func (TaskExecutionContext_SecretManager) Return

type TaskExecutionContext_TaskExecutionMetadata

type TaskExecutionContext_TaskExecutionMetadata struct {
	*mock.Call
}

func (TaskExecutionContext_TaskExecutionMetadata) Return

type TaskExecutionContext_TaskReader

type TaskExecutionContext_TaskReader struct {
	*mock.Call
}

func (TaskExecutionContext_TaskReader) Return

type TaskExecutionContext_TaskRefreshIndicator

type TaskExecutionContext_TaskRefreshIndicator struct {
	*mock.Call
}

func (TaskExecutionContext_TaskRefreshIndicator) Return

type TaskExecutionID

type TaskExecutionID struct {
	mock.Mock
}

TaskExecutionID is an autogenerated mock type for the TaskExecutionID type

func (*TaskExecutionID) GetGeneratedName

func (_m *TaskExecutionID) GetGeneratedName() string

GetGeneratedName provides a mock function with given fields:

func (*TaskExecutionID) GetGeneratedNameWith

func (_m *TaskExecutionID) GetGeneratedNameWith(minLength int, maxLength int) (string, error)

GetGeneratedNameWith provides a mock function with given fields: minLength, maxLength

func (*TaskExecutionID) GetID

GetID provides a mock function with given fields:

func (*TaskExecutionID) GetUniqueNodeID

func (_m *TaskExecutionID) GetUniqueNodeID() string

GetUniqueNodeID provides a mock function with given fields:

func (*TaskExecutionID) OnGetGeneratedName

func (_m *TaskExecutionID) OnGetGeneratedName() *TaskExecutionID_GetGeneratedName

func (*TaskExecutionID) OnGetGeneratedNameMatch

func (_m *TaskExecutionID) OnGetGeneratedNameMatch(matchers ...interface{}) *TaskExecutionID_GetGeneratedName

func (*TaskExecutionID) OnGetGeneratedNameWith

func (_m *TaskExecutionID) OnGetGeneratedNameWith(minLength int, maxLength int) *TaskExecutionID_GetGeneratedNameWith

func (*TaskExecutionID) OnGetGeneratedNameWithMatch

func (_m *TaskExecutionID) OnGetGeneratedNameWithMatch(matchers ...interface{}) *TaskExecutionID_GetGeneratedNameWith

func (*TaskExecutionID) OnGetID

func (_m *TaskExecutionID) OnGetID() *TaskExecutionID_GetID

func (*TaskExecutionID) OnGetIDMatch

func (_m *TaskExecutionID) OnGetIDMatch(matchers ...interface{}) *TaskExecutionID_GetID

func (*TaskExecutionID) OnGetUniqueNodeID

func (_m *TaskExecutionID) OnGetUniqueNodeID() *TaskExecutionID_GetUniqueNodeID

func (*TaskExecutionID) OnGetUniqueNodeIDMatch

func (_m *TaskExecutionID) OnGetUniqueNodeIDMatch(matchers ...interface{}) *TaskExecutionID_GetUniqueNodeID

type TaskExecutionID_GetGeneratedName

type TaskExecutionID_GetGeneratedName struct {
	*mock.Call
}

func (TaskExecutionID_GetGeneratedName) Return

type TaskExecutionID_GetGeneratedNameWith

type TaskExecutionID_GetGeneratedNameWith struct {
	*mock.Call
}

func (TaskExecutionID_GetGeneratedNameWith) Return

type TaskExecutionID_GetID

type TaskExecutionID_GetID struct {
	*mock.Call
}

func (TaskExecutionID_GetID) Return

type TaskExecutionID_GetUniqueNodeID

type TaskExecutionID_GetUniqueNodeID struct {
	*mock.Call
}

func (TaskExecutionID_GetUniqueNodeID) Return

type TaskExecutionMetadata

type TaskExecutionMetadata struct {
	mock.Mock
}

TaskExecutionMetadata is an autogenerated mock type for the TaskExecutionMetadata type

func (*TaskExecutionMetadata) GetAnnotations

func (_m *TaskExecutionMetadata) GetAnnotations() map[string]string

GetAnnotations provides a mock function with given fields:

func (*TaskExecutionMetadata) GetEnvironmentVariables

func (_m *TaskExecutionMetadata) GetEnvironmentVariables() map[string]string

GetEnvironmentVariables provides a mock function with given fields:

func (*TaskExecutionMetadata) GetInterruptibleFailureThreshold

func (_m *TaskExecutionMetadata) GetInterruptibleFailureThreshold() int32

GetInterruptibleFailureThreshold provides a mock function with given fields:

func (*TaskExecutionMetadata) GetK8sServiceAccount

func (_m *TaskExecutionMetadata) GetK8sServiceAccount() string

GetK8sServiceAccount provides a mock function with given fields:

func (*TaskExecutionMetadata) GetLabels

func (_m *TaskExecutionMetadata) GetLabels() map[string]string

GetLabels provides a mock function with given fields:

func (*TaskExecutionMetadata) GetMaxAttempts

func (_m *TaskExecutionMetadata) GetMaxAttempts() uint32

GetMaxAttempts provides a mock function with given fields:

func (*TaskExecutionMetadata) GetNamespace

func (_m *TaskExecutionMetadata) GetNamespace() string

GetNamespace provides a mock function with given fields:

func (*TaskExecutionMetadata) GetOverrides

func (_m *TaskExecutionMetadata) GetOverrides() core.TaskOverrides

GetOverrides provides a mock function with given fields:

func (*TaskExecutionMetadata) GetOwnerID

func (_m *TaskExecutionMetadata) GetOwnerID() types.NamespacedName

GetOwnerID provides a mock function with given fields:

func (*TaskExecutionMetadata) GetOwnerReference

func (_m *TaskExecutionMetadata) GetOwnerReference() v1.OwnerReference

GetOwnerReference provides a mock function with given fields:

func (*TaskExecutionMetadata) GetPlatformResources

func (_m *TaskExecutionMetadata) GetPlatformResources() *corev1.ResourceRequirements

GetPlatformResources provides a mock function with given fields:

func (*TaskExecutionMetadata) GetSecurityContext

func (_m *TaskExecutionMetadata) GetSecurityContext() kozmoidlcore.SecurityContext

GetSecurityContext provides a mock function with given fields:

func (*TaskExecutionMetadata) GetTaskExecutionID

func (_m *TaskExecutionMetadata) GetTaskExecutionID() core.TaskExecutionID

GetTaskExecutionID provides a mock function with given fields:

func (*TaskExecutionMetadata) IsInterruptible

func (_m *TaskExecutionMetadata) IsInterruptible() bool

IsInterruptible provides a mock function with given fields:

func (*TaskExecutionMetadata) OnGetAnnotations

func (*TaskExecutionMetadata) OnGetAnnotationsMatch

func (_m *TaskExecutionMetadata) OnGetAnnotationsMatch(matchers ...interface{}) *TaskExecutionMetadata_GetAnnotations

func (*TaskExecutionMetadata) OnGetEnvironmentVariables

func (*TaskExecutionMetadata) OnGetEnvironmentVariablesMatch

func (_m *TaskExecutionMetadata) OnGetEnvironmentVariablesMatch(matchers ...interface{}) *TaskExecutionMetadata_GetEnvironmentVariables

func (*TaskExecutionMetadata) OnGetInterruptibleFailureThreshold

func (_m *TaskExecutionMetadata) OnGetInterruptibleFailureThreshold() *TaskExecutionMetadata_GetInterruptibleFailureThreshold

func (*TaskExecutionMetadata) OnGetInterruptibleFailureThresholdMatch

func (_m *TaskExecutionMetadata) OnGetInterruptibleFailureThresholdMatch(matchers ...interface{}) *TaskExecutionMetadata_GetInterruptibleFailureThreshold

func (*TaskExecutionMetadata) OnGetK8sServiceAccount

func (*TaskExecutionMetadata) OnGetK8sServiceAccountMatch

func (_m *TaskExecutionMetadata) OnGetK8sServiceAccountMatch(matchers ...interface{}) *TaskExecutionMetadata_GetK8sServiceAccount

func (*TaskExecutionMetadata) OnGetLabels

func (*TaskExecutionMetadata) OnGetLabelsMatch

func (_m *TaskExecutionMetadata) OnGetLabelsMatch(matchers ...interface{}) *TaskExecutionMetadata_GetLabels

func (*TaskExecutionMetadata) OnGetMaxAttempts

func (*TaskExecutionMetadata) OnGetMaxAttemptsMatch

func (_m *TaskExecutionMetadata) OnGetMaxAttemptsMatch(matchers ...interface{}) *TaskExecutionMetadata_GetMaxAttempts

func (*TaskExecutionMetadata) OnGetNamespace

func (*TaskExecutionMetadata) OnGetNamespaceMatch

func (_m *TaskExecutionMetadata) OnGetNamespaceMatch(matchers ...interface{}) *TaskExecutionMetadata_GetNamespace

func (*TaskExecutionMetadata) OnGetOverrides

func (*TaskExecutionMetadata) OnGetOverridesMatch

func (_m *TaskExecutionMetadata) OnGetOverridesMatch(matchers ...interface{}) *TaskExecutionMetadata_GetOverrides

func (*TaskExecutionMetadata) OnGetOwnerID

func (*TaskExecutionMetadata) OnGetOwnerIDMatch

func (_m *TaskExecutionMetadata) OnGetOwnerIDMatch(matchers ...interface{}) *TaskExecutionMetadata_GetOwnerID

func (*TaskExecutionMetadata) OnGetOwnerReference

func (*TaskExecutionMetadata) OnGetOwnerReferenceMatch

func (_m *TaskExecutionMetadata) OnGetOwnerReferenceMatch(matchers ...interface{}) *TaskExecutionMetadata_GetOwnerReference

func (*TaskExecutionMetadata) OnGetPlatformResources

func (*TaskExecutionMetadata) OnGetPlatformResourcesMatch

func (_m *TaskExecutionMetadata) OnGetPlatformResourcesMatch(matchers ...interface{}) *TaskExecutionMetadata_GetPlatformResources

func (*TaskExecutionMetadata) OnGetSecurityContext

func (*TaskExecutionMetadata) OnGetSecurityContextMatch

func (_m *TaskExecutionMetadata) OnGetSecurityContextMatch(matchers ...interface{}) *TaskExecutionMetadata_GetSecurityContext

func (*TaskExecutionMetadata) OnGetTaskExecutionID

func (*TaskExecutionMetadata) OnGetTaskExecutionIDMatch

func (_m *TaskExecutionMetadata) OnGetTaskExecutionIDMatch(matchers ...interface{}) *TaskExecutionMetadata_GetTaskExecutionID

func (*TaskExecutionMetadata) OnIsInterruptible

func (*TaskExecutionMetadata) OnIsInterruptibleMatch

func (_m *TaskExecutionMetadata) OnIsInterruptibleMatch(matchers ...interface{}) *TaskExecutionMetadata_IsInterruptible

type TaskExecutionMetadata_GetAnnotations

type TaskExecutionMetadata_GetAnnotations struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetAnnotations) Return

type TaskExecutionMetadata_GetEnvironmentVariables

type TaskExecutionMetadata_GetEnvironmentVariables struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetEnvironmentVariables) Return

type TaskExecutionMetadata_GetInterruptibleFailureThreshold

type TaskExecutionMetadata_GetInterruptibleFailureThreshold struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetInterruptibleFailureThreshold) Return

type TaskExecutionMetadata_GetK8sServiceAccount

type TaskExecutionMetadata_GetK8sServiceAccount struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetK8sServiceAccount) Return

type TaskExecutionMetadata_GetLabels

type TaskExecutionMetadata_GetLabels struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetLabels) Return

type TaskExecutionMetadata_GetMaxAttempts

type TaskExecutionMetadata_GetMaxAttempts struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetMaxAttempts) Return

type TaskExecutionMetadata_GetNamespace

type TaskExecutionMetadata_GetNamespace struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetNamespace) Return

type TaskExecutionMetadata_GetOverrides

type TaskExecutionMetadata_GetOverrides struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetOverrides) Return

type TaskExecutionMetadata_GetOwnerID

type TaskExecutionMetadata_GetOwnerID struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetOwnerID) Return

type TaskExecutionMetadata_GetOwnerReference

type TaskExecutionMetadata_GetOwnerReference struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetOwnerReference) Return

type TaskExecutionMetadata_GetPlatformResources

type TaskExecutionMetadata_GetPlatformResources struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetPlatformResources) Return

type TaskExecutionMetadata_GetSecurityContext

type TaskExecutionMetadata_GetSecurityContext struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetSecurityContext) Return

type TaskExecutionMetadata_GetTaskExecutionID

type TaskExecutionMetadata_GetTaskExecutionID struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetTaskExecutionID) Return

type TaskExecutionMetadata_IsInterruptible

type TaskExecutionMetadata_IsInterruptible struct {
	*mock.Call
}

func (TaskExecutionMetadata_IsInterruptible) Return

type TaskOverrides

type TaskOverrides struct {
	mock.Mock
}

TaskOverrides is an autogenerated mock type for the TaskOverrides type

func (*TaskOverrides) GetConfig

func (_m *TaskOverrides) GetConfig() *v1.ConfigMap

GetConfig provides a mock function with given fields:

func (*TaskOverrides) GetExtendedResources

func (_m *TaskOverrides) GetExtendedResources() *kozmoidlcore.ExtendedResources

GetExtendedResources provides a mock function with given fields:

func (*TaskOverrides) GetResources

func (_m *TaskOverrides) GetResources() *v1.ResourceRequirements

GetResources provides a mock function with given fields:

func (*TaskOverrides) OnGetConfig

func (_m *TaskOverrides) OnGetConfig() *TaskOverrides_GetConfig

func (*TaskOverrides) OnGetConfigMatch

func (_m *TaskOverrides) OnGetConfigMatch(matchers ...interface{}) *TaskOverrides_GetConfig

func (*TaskOverrides) OnGetExtendedResources

func (_m *TaskOverrides) OnGetExtendedResources() *TaskOverrides_GetExtendedResources

func (*TaskOverrides) OnGetExtendedResourcesMatch

func (_m *TaskOverrides) OnGetExtendedResourcesMatch(matchers ...interface{}) *TaskOverrides_GetExtendedResources

func (*TaskOverrides) OnGetResources

func (_m *TaskOverrides) OnGetResources() *TaskOverrides_GetResources

func (*TaskOverrides) OnGetResourcesMatch

func (_m *TaskOverrides) OnGetResourcesMatch(matchers ...interface{}) *TaskOverrides_GetResources

type TaskOverrides_GetConfig

type TaskOverrides_GetConfig struct {
	*mock.Call
}

func (TaskOverrides_GetConfig) Return

type TaskOverrides_GetExtendedResources

type TaskOverrides_GetExtendedResources struct {
	*mock.Call
}

func (TaskOverrides_GetExtendedResources) Return

type TaskOverrides_GetResources

type TaskOverrides_GetResources struct {
	*mock.Call
}

func (TaskOverrides_GetResources) Return

type TaskReader

type TaskReader struct {
	mock.Mock
}

TaskReader is an autogenerated mock type for the TaskReader type

func (*TaskReader) OnPath

func (_m *TaskReader) OnPath(ctx context.Context) *TaskReader_Path

func (*TaskReader) OnPathMatch

func (_m *TaskReader) OnPathMatch(matchers ...interface{}) *TaskReader_Path

func (*TaskReader) OnRead

func (_m *TaskReader) OnRead(ctx context.Context) *TaskReader_Read

func (*TaskReader) OnReadMatch

func (_m *TaskReader) OnReadMatch(matchers ...interface{}) *TaskReader_Read

func (*TaskReader) Path

Path provides a mock function with given fields: ctx

func (*TaskReader) Read

Read provides a mock function with given fields: ctx

type TaskReader_Path

type TaskReader_Path struct {
	*mock.Call
}

func (TaskReader_Path) Return

type TaskReader_Read

type TaskReader_Read struct {
	*mock.Call
}

func (TaskReader_Read) Return

type TaskTemplatePath

type TaskTemplatePath struct {
	mock.Mock
}

TaskTemplatePath is an autogenerated mock type for the TaskTemplatePath type

func (*TaskTemplatePath) OnPath

func (*TaskTemplatePath) OnPathMatch

func (_m *TaskTemplatePath) OnPathMatch(matchers ...interface{}) *TaskTemplatePath_Path

func (*TaskTemplatePath) Path

Path provides a mock function with given fields: ctx

type TaskTemplatePath_Path

type TaskTemplatePath_Path struct {
	*mock.Call
}

func (TaskTemplatePath_Path) Return

Jump to

Keyboard shortcuts

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