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 (_m *EventsRecorder) OnRecordRaw(ctx context.Context, ev core.PhaseInfo) *EventsRecorder_RecordRaw

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 

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

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 (m *FakeKubeCache) Get(ctx context.Context, key client.ObjectKey, out client.Object, opts ...client.GetOption) error

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 (m *FakeKubeClient) Get(ctx context.Context, key client.ObjectKey, out client.Object, opts ...client.GetOption) error

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) Status() client.StatusWriter

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 

func (_m KubeClient_GetCache) Return(_a0 cache.Cache) *KubeClient_GetCache

type KubeClient_GetClient 

type KubeClient_GetClient struct {
	*mock.Call
}

func (KubeClient_GetClient) Return 

func (_m KubeClient_GetClient) Return(_a0 client.Client) *KubeClient_GetClient

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 

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

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 

func (_m PluginStateReader_GetStateVersion) Return(_a0 uint8) *PluginStateReader_GetStateVersion

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 (_m *PluginStateWriter) OnReset() *PluginStateWriter_Reset

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 

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

type PluginStateWriter_Reset 

type PluginStateWriter_Reset struct {
	*mock.Call
}

func (PluginStateWriter_Reset) Return 

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

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 

func (_m Plugin_GetProperties) Return(_a0 core.PluginProperties) *Plugin_GetProperties

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 

func (_m ResourceManager_AllocateResource) Return(_a0 core.AllocationStatus, _a1 error) *ResourceManager_AllocateResource

type ResourceManager_GetID 

type ResourceManager_GetID struct {
	*mock.Call
}

func (ResourceManager_GetID) Return 

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

type ResourceManager_ReleaseResource 

type ResourceManager_ReleaseResource struct {
	*mock.Call
}

func (ResourceManager_ReleaseResource) Return 

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

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 

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

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 

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

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 

func (_m SetupContext_EnqueueOwner) Return(_a0 core.EnqueueOwner) *SetupContext_EnqueueOwner

type SetupContext_KubeClient 

type SetupContext_KubeClient struct {
	*mock.Call
}

func (SetupContext_KubeClient) Return 

func (_m SetupContext_KubeClient) Return(_a0 core.KubeClient) *SetupContext_KubeClient

type SetupContext_MetricsScope 

type SetupContext_MetricsScope struct {
	*mock.Call
}

func (SetupContext_MetricsScope) Return 

func (_m SetupContext_MetricsScope) Return(_a0 promutils.Scope) *SetupContext_MetricsScope

type SetupContext_OwnerKind 

type SetupContext_OwnerKind struct {
	*mock.Call
}

func (SetupContext_OwnerKind) Return 

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

type SetupContext_ResourceRegistrar 

type SetupContext_ResourceRegistrar struct {
	*mock.Call
}

func (SetupContext_ResourceRegistrar) Return 

func (_m SetupContext_ResourceRegistrar) Return(_a0 core.ResourceRegistrar) *SetupContext_ResourceRegistrar

type SetupContext_SecretManager 

type SetupContext_SecretManager struct {
	*mock.Call
}

func (SetupContext_SecretManager) Return 

func (_m SetupContext_SecretManager) Return(_a0 core.SecretManager) *SetupContext_SecretManager

type TaskExecutionContext 

type TaskExecutionContext struct {
	mock.Mock
}

TaskExecutionContext is an autogenerated mock type for the TaskExecutionContext type

func (*TaskExecutionContext) Catalog 

func (_m *TaskExecutionContext) Catalog() catalog.AsyncClient

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 (_m *TaskExecutionContext) OnCatalog() *TaskExecutionContext_Catalog

func (*TaskExecutionContext) OnCatalogMatch 

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

func (*TaskExecutionContext) OnDataStore 

func (_m *TaskExecutionContext) OnDataStore() *TaskExecutionContext_DataStore

func (*TaskExecutionContext) OnDataStoreMatch 

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

func (*TaskExecutionContext) OnEventsRecorder 

func (_m *TaskExecutionContext) OnEventsRecorder() *TaskExecutionContext_EventsRecorder

func (*TaskExecutionContext) OnEventsRecorderMatch 

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

func (*TaskExecutionContext) OnInputReader 

func (_m *TaskExecutionContext) OnInputReader() *TaskExecutionContext_InputReader

func (*TaskExecutionContext) OnInputReaderMatch 

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

func (*TaskExecutionContext) OnMaxDatasetSizeBytes 

func (_m *TaskExecutionContext) OnMaxDatasetSizeBytes() *TaskExecutionContext_MaxDatasetSizeBytes

func (*TaskExecutionContext) OnMaxDatasetSizeBytesMatch 

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

func (*TaskExecutionContext) OnOutputWriter 

func (_m *TaskExecutionContext) OnOutputWriter() *TaskExecutionContext_OutputWriter

func (*TaskExecutionContext) OnOutputWriterMatch 

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

func (*TaskExecutionContext) OnPluginStateReader 

func (_m *TaskExecutionContext) OnPluginStateReader() *TaskExecutionContext_PluginStateReader

func (*TaskExecutionContext) OnPluginStateReaderMatch 

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

func (*TaskExecutionContext) OnPluginStateWriter 

func (_m *TaskExecutionContext) OnPluginStateWriter() *TaskExecutionContext_PluginStateWriter

func (*TaskExecutionContext) OnPluginStateWriterMatch 

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

func (*TaskExecutionContext) OnResourceManager 

func (_m *TaskExecutionContext) OnResourceManager() *TaskExecutionContext_ResourceManager

func (*TaskExecutionContext) OnResourceManagerMatch 

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

func (*TaskExecutionContext) OnSecretManager 

func (_m *TaskExecutionContext) OnSecretManager() *TaskExecutionContext_SecretManager

func (*TaskExecutionContext) OnSecretManagerMatch 

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

func (*TaskExecutionContext) OnTaskExecutionMetadata 

func (_m *TaskExecutionContext) OnTaskExecutionMetadata() *TaskExecutionContext_TaskExecutionMetadata

func (*TaskExecutionContext) OnTaskExecutionMetadataMatch 

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

func (*TaskExecutionContext) OnTaskReader 

func (_m *TaskExecutionContext) OnTaskReader() *TaskExecutionContext_TaskReader

func (*TaskExecutionContext) OnTaskReaderMatch 

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

func (*TaskExecutionContext) OnTaskRefreshIndicator 

func (_m *TaskExecutionContext) OnTaskRefreshIndicator() *TaskExecutionContext_TaskRefreshIndicator

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 

func (_m TaskExecutionContext_Catalog) Return(_a0 catalog.AsyncClient) *TaskExecutionContext_Catalog

type TaskExecutionContext_DataStore 

type TaskExecutionContext_DataStore struct {
	*mock.Call
}

func (TaskExecutionContext_DataStore) Return 

func (_m TaskExecutionContext_DataStore) Return(_a0 *storage.DataStore) *TaskExecutionContext_DataStore

type TaskExecutionContext_EventsRecorder 

type TaskExecutionContext_EventsRecorder struct {
	*mock.Call
}

func (TaskExecutionContext_EventsRecorder) Return 

func (_m TaskExecutionContext_EventsRecorder) Return(_a0 core.EventsRecorder) *TaskExecutionContext_EventsRecorder

type TaskExecutionContext_InputReader 

type TaskExecutionContext_InputReader struct {
	*mock.Call
}

func (TaskExecutionContext_InputReader) Return 

func (_m TaskExecutionContext_InputReader) Return(_a0 io.InputReader) *TaskExecutionContext_InputReader

type TaskExecutionContext_MaxDatasetSizeBytes 

type TaskExecutionContext_MaxDatasetSizeBytes struct {
	*mock.Call
}

func (TaskExecutionContext_MaxDatasetSizeBytes) Return 

func (_m TaskExecutionContext_MaxDatasetSizeBytes) Return(_a0 int64) *TaskExecutionContext_MaxDatasetSizeBytes

type TaskExecutionContext_OutputWriter 

type TaskExecutionContext_OutputWriter struct {
	*mock.Call
}

func (TaskExecutionContext_OutputWriter) Return 

func (_m TaskExecutionContext_OutputWriter) Return(_a0 io.OutputWriter) *TaskExecutionContext_OutputWriter

type TaskExecutionContext_PluginStateReader 

type TaskExecutionContext_PluginStateReader struct {
	*mock.Call
}

func (TaskExecutionContext_PluginStateReader) Return 

func (_m TaskExecutionContext_PluginStateReader) Return(_a0 core.PluginStateReader) *TaskExecutionContext_PluginStateReader

type TaskExecutionContext_PluginStateWriter 

type TaskExecutionContext_PluginStateWriter struct {
	*mock.Call
}

func (TaskExecutionContext_PluginStateWriter) Return 

func (_m TaskExecutionContext_PluginStateWriter) Return(_a0 core.PluginStateWriter) *TaskExecutionContext_PluginStateWriter

type TaskExecutionContext_ResourceManager 

type TaskExecutionContext_ResourceManager struct {
	*mock.Call
}

func (TaskExecutionContext_ResourceManager) Return 

func (_m TaskExecutionContext_ResourceManager) Return(_a0 core.ResourceManager) *TaskExecutionContext_ResourceManager

type TaskExecutionContext_SecretManager 

type TaskExecutionContext_SecretManager struct {
	*mock.Call
}

func (TaskExecutionContext_SecretManager) Return 

func (_m TaskExecutionContext_SecretManager) Return(_a0 core.SecretManager) *TaskExecutionContext_SecretManager

type TaskExecutionContext_TaskExecutionMetadata 

type TaskExecutionContext_TaskExecutionMetadata struct {
	*mock.Call
}

func (TaskExecutionContext_TaskExecutionMetadata) Return 

func (_m TaskExecutionContext_TaskExecutionMetadata) Return(_a0 core.TaskExecutionMetadata) *TaskExecutionContext_TaskExecutionMetadata

type TaskExecutionContext_TaskReader 

type TaskExecutionContext_TaskReader struct {
	*mock.Call
}

func (TaskExecutionContext_TaskReader) Return 

func (_m TaskExecutionContext_TaskReader) Return(_a0 core.TaskReader) *TaskExecutionContext_TaskReader

type TaskExecutionContext_TaskRefreshIndicator 

type TaskExecutionContext_TaskRefreshIndicator struct {
	*mock.Call
}

func (TaskExecutionContext_TaskRefreshIndicator) Return 

func (_m TaskExecutionContext_TaskRefreshIndicator) Return(_a0 core.SignalAsync) *TaskExecutionContext_TaskRefreshIndicator

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 

func (_m *TaskExecutionID) GetID() kozmoidlcore.TaskExecutionIdentifier

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 

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

type TaskExecutionID_GetGeneratedNameWith 

type TaskExecutionID_GetGeneratedNameWith struct {
	*mock.Call
}

func (TaskExecutionID_GetGeneratedNameWith) Return 

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

type TaskExecutionID_GetID 

type TaskExecutionID_GetID struct {
	*mock.Call
}

func (TaskExecutionID_GetID) Return 

func (_m TaskExecutionID_GetID) Return(_a0 kozmoidlcore.TaskExecutionIdentifier) *TaskExecutionID_GetID

type TaskExecutionID_GetUniqueNodeID 

type TaskExecutionID_GetUniqueNodeID struct {
	*mock.Call
}

func (TaskExecutionID_GetUniqueNodeID) Return 

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

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 (_m *TaskExecutionMetadata) OnGetAnnotations() *TaskExecutionMetadata_GetAnnotations

func (*TaskExecutionMetadata) OnGetAnnotationsMatch 

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

func (*TaskExecutionMetadata) OnGetEnvironmentVariables 

func (_m *TaskExecutionMetadata) OnGetEnvironmentVariables() *TaskExecutionMetadata_GetEnvironmentVariables

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 (_m *TaskExecutionMetadata) OnGetK8sServiceAccount() *TaskExecutionMetadata_GetK8sServiceAccount

func (*TaskExecutionMetadata) OnGetK8sServiceAccountMatch 

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

func (*TaskExecutionMetadata) OnGetLabels 

func (_m *TaskExecutionMetadata) OnGetLabels() *TaskExecutionMetadata_GetLabels

func (*TaskExecutionMetadata) OnGetLabelsMatch 

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

func (*TaskExecutionMetadata) OnGetMaxAttempts 

func (_m *TaskExecutionMetadata) OnGetMaxAttempts() *TaskExecutionMetadata_GetMaxAttempts

func (*TaskExecutionMetadata) OnGetMaxAttemptsMatch 

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

func (*TaskExecutionMetadata) OnGetNamespace 

func (_m *TaskExecutionMetadata) OnGetNamespace() *TaskExecutionMetadata_GetNamespace

func (*TaskExecutionMetadata) OnGetNamespaceMatch 

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

func (*TaskExecutionMetadata) OnGetOverrides 

func (_m *TaskExecutionMetadata) OnGetOverrides() *TaskExecutionMetadata_GetOverrides

func (*TaskExecutionMetadata) OnGetOverridesMatch 

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

func (*TaskExecutionMetadata) OnGetOwnerID 

func (_m *TaskExecutionMetadata) OnGetOwnerID() *TaskExecutionMetadata_GetOwnerID

func (*TaskExecutionMetadata) OnGetOwnerIDMatch 

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

func (*TaskExecutionMetadata) OnGetOwnerReference 

func (_m *TaskExecutionMetadata) OnGetOwnerReference() *TaskExecutionMetadata_GetOwnerReference

func (*TaskExecutionMetadata) OnGetOwnerReferenceMatch 

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

func (*TaskExecutionMetadata) OnGetPlatformResources 

func (_m *TaskExecutionMetadata) OnGetPlatformResources() *TaskExecutionMetadata_GetPlatformResources

func (*TaskExecutionMetadata) OnGetPlatformResourcesMatch 

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

func (*TaskExecutionMetadata) OnGetSecurityContext 

func (_m *TaskExecutionMetadata) OnGetSecurityContext() *TaskExecutionMetadata_GetSecurityContext

func (*TaskExecutionMetadata) OnGetSecurityContextMatch 

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

func (*TaskExecutionMetadata) OnGetTaskExecutionID 

func (_m *TaskExecutionMetadata) OnGetTaskExecutionID() *TaskExecutionMetadata_GetTaskExecutionID

func (*TaskExecutionMetadata) OnGetTaskExecutionIDMatch 

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

func (*TaskExecutionMetadata) OnIsInterruptible 

func (_m *TaskExecutionMetadata) OnIsInterruptible() *TaskExecutionMetadata_IsInterruptible

func (*TaskExecutionMetadata) OnIsInterruptibleMatch 

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

type TaskExecutionMetadata_GetAnnotations 

type TaskExecutionMetadata_GetAnnotations struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetAnnotations) Return 

func (_m TaskExecutionMetadata_GetAnnotations) Return(_a0 map[string]string) *TaskExecutionMetadata_GetAnnotations

type TaskExecutionMetadata_GetEnvironmentVariables 

type TaskExecutionMetadata_GetEnvironmentVariables struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetEnvironmentVariables) Return 

func (_m TaskExecutionMetadata_GetEnvironmentVariables) Return(_a0 map[string]string) *TaskExecutionMetadata_GetEnvironmentVariables

type TaskExecutionMetadata_GetInterruptibleFailureThreshold 

type TaskExecutionMetadata_GetInterruptibleFailureThreshold struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetInterruptibleFailureThreshold) Return 

func (_m TaskExecutionMetadata_GetInterruptibleFailureThreshold) Return(_a0 int32) *TaskExecutionMetadata_GetInterruptibleFailureThreshold

type TaskExecutionMetadata_GetK8sServiceAccount 

type TaskExecutionMetadata_GetK8sServiceAccount struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetK8sServiceAccount) Return 

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

type TaskExecutionMetadata_GetLabels 

type TaskExecutionMetadata_GetLabels struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetLabels) Return 

func (_m TaskExecutionMetadata_GetLabels) Return(_a0 map[string]string) *TaskExecutionMetadata_GetLabels

type TaskExecutionMetadata_GetMaxAttempts 

type TaskExecutionMetadata_GetMaxAttempts struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetMaxAttempts) Return 

func (_m TaskExecutionMetadata_GetMaxAttempts) Return(_a0 uint32) *TaskExecutionMetadata_GetMaxAttempts

type TaskExecutionMetadata_GetNamespace 

type TaskExecutionMetadata_GetNamespace struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetNamespace) Return 

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

type TaskExecutionMetadata_GetOverrides 

type TaskExecutionMetadata_GetOverrides struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetOverrides) Return 

func (_m TaskExecutionMetadata_GetOverrides) Return(_a0 core.TaskOverrides) *TaskExecutionMetadata_GetOverrides

type TaskExecutionMetadata_GetOwnerID 

type TaskExecutionMetadata_GetOwnerID struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetOwnerID) Return 

func (_m TaskExecutionMetadata_GetOwnerID) Return(_a0 types.NamespacedName) *TaskExecutionMetadata_GetOwnerID

type TaskExecutionMetadata_GetOwnerReference 

type TaskExecutionMetadata_GetOwnerReference struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetOwnerReference) Return 

func (_m TaskExecutionMetadata_GetOwnerReference) Return(_a0 v1.OwnerReference) *TaskExecutionMetadata_GetOwnerReference

type TaskExecutionMetadata_GetPlatformResources 

type TaskExecutionMetadata_GetPlatformResources struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetPlatformResources) Return 

func (_m TaskExecutionMetadata_GetPlatformResources) Return(_a0 *corev1.ResourceRequirements) *TaskExecutionMetadata_GetPlatformResources

type TaskExecutionMetadata_GetSecurityContext 

type TaskExecutionMetadata_GetSecurityContext struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetSecurityContext) Return 

func (_m TaskExecutionMetadata_GetSecurityContext) Return(_a0 kozmoidlcore.SecurityContext) *TaskExecutionMetadata_GetSecurityContext

type TaskExecutionMetadata_GetTaskExecutionID 

type TaskExecutionMetadata_GetTaskExecutionID struct {
	*mock.Call
}

func (TaskExecutionMetadata_GetTaskExecutionID) Return 

func (_m TaskExecutionMetadata_GetTaskExecutionID) Return(_a0 core.TaskExecutionID) *TaskExecutionMetadata_GetTaskExecutionID

type TaskExecutionMetadata_IsInterruptible 

type TaskExecutionMetadata_IsInterruptible struct {
	*mock.Call
}

func (TaskExecutionMetadata_IsInterruptible) Return 

func (_m TaskExecutionMetadata_IsInterruptible) Return(_a0 bool) *TaskExecutionMetadata_IsInterruptible

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 

func (_m TaskOverrides_GetConfig) Return(_a0 *v1.ConfigMap) *TaskOverrides_GetConfig

type TaskOverrides_GetExtendedResources 

type TaskOverrides_GetExtendedResources struct {
	*mock.Call
}

func (TaskOverrides_GetExtendedResources) Return 

func (_m TaskOverrides_GetExtendedResources) Return(_a0 *kozmoidlcore.ExtendedResources) *TaskOverrides_GetExtendedResources

type TaskOverrides_GetResources 

type TaskOverrides_GetResources struct {
	*mock.Call
}

func (TaskOverrides_GetResources) Return 

func (_m TaskOverrides_GetResources) Return(_a0 *v1.ResourceRequirements) *TaskOverrides_GetResources

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 

func (_m *TaskReader) Path(ctx context.Context) (storage.DataReference, error)

Path provides a mock function with given fields: ctx

func (*TaskReader) Read 

func (_m *TaskReader) Read(ctx context.Context) (*kozmoidlcore.TaskTemplate, error)

Read provides a mock function with given fields: ctx

type TaskReader_Path 

type TaskReader_Path struct {
	*mock.Call
}

func (TaskReader_Path) Return 

func (_m TaskReader_Path) Return(_a0 storage.DataReference, _a1 error) *TaskReader_Path

type TaskReader_Read 

type TaskReader_Read struct {
	*mock.Call
}

func (TaskReader_Read) Return 

func (_m TaskReader_Read) Return(_a0 *kozmoidlcore.TaskTemplate, _a1 error) *TaskReader_Read

type TaskTemplatePath 

type TaskTemplatePath struct {
	mock.Mock
}

TaskTemplatePath is an autogenerated mock type for the TaskTemplatePath type

func (*TaskTemplatePath) OnPath 

func (_m *TaskTemplatePath) OnPath(ctx context.Context) *TaskTemplatePath_Path

func (*TaskTemplatePath) OnPathMatch 

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

func (*TaskTemplatePath) Path 

func (_m *TaskTemplatePath) Path(ctx context.Context) (storage.DataReference, error)

Path provides a mock function with given fields: ctx

type TaskTemplatePath_Path 

type TaskTemplatePath_Path struct {
	*mock.Call
}

func (TaskTemplatePath_Path) Return 

func (_m TaskTemplatePath_Path) Return(_a0 storage.DataReference, _a1 error) *TaskTemplatePath_Path

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.