Documentation
¶
Index ¶
- type EnqueueOwner
- type EnqueueOwner_Execute_Call
- type EnqueueOwner_Expecter
- type EventsRecorder
- type EventsRecorder_Expecter
- type EventsRecorder_RecordRaw_Call
- func (_c *EventsRecorder_RecordRaw_Call) Return(_a0 error) *EventsRecorder_RecordRaw_Call
- func (_c *EventsRecorder_RecordRaw_Call) Run(run func(ctx context.Context, ev core.PhaseInfo)) *EventsRecorder_RecordRaw_Call
- func (_c *EventsRecorder_RecordRaw_Call) RunAndReturn(run func(context.Context, core.PhaseInfo) error) *EventsRecorder_RecordRaw_Call
- type FakeKubeCache
- func (m *FakeKubeCache) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) (err error)
- func (m *FakeKubeCache) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
- func (m *FakeKubeCache) Get(ctx context.Context, key client.ObjectKey, out client.Object, ...) error
- func (m *FakeKubeCache) GetInformer(ctx context.Context, obj client.Object, opts ...cache.InformerGetOption) (cache.Informer, error)
- func (m *FakeKubeCache) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind, ...) (cache.Informer, error)
- func (m *FakeKubeCache) IndexField(ctx context.Context, obj client.Object, field string, ...) error
- func (m *FakeKubeCache) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
- func (m *FakeKubeCache) Start(ctx context.Context) error
- func (m *FakeKubeCache) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
- func (m *FakeKubeCache) WaitForCacheSync(ctx context.Context) bool
- type FakeKubeClient
- func (m *FakeKubeClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) (err error)
- func (m *FakeKubeClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
- func (*FakeKubeClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
- func (m *FakeKubeClient) Get(ctx context.Context, key client.ObjectKey, out client.Object, ...) error
- func (m *FakeKubeClient) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)
- func (m *FakeKubeClient) IsObjectNamespaced(obj runtime.Object) (bool, error)
- func (m *FakeKubeClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
- func (*FakeKubeClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
- func (*FakeKubeClient) RESTMapper() meta.RESTMapper
- func (*FakeKubeClient) Scheme() *runtime.Scheme
- func (*FakeKubeClient) Status() client.StatusWriter
- func (m *FakeKubeClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
- type KubeClient
- type KubeClient_Expecter
- type KubeClient_GetCache_Call
- type KubeClient_GetClient_Call
- type Plugin
- func (_m *Plugin) Abort(ctx context.Context, tCtx core.TaskExecutionContext) error
- func (_m *Plugin) EXPECT() *Plugin_Expecter
- func (_m *Plugin) Finalize(ctx context.Context, tCtx core.TaskExecutionContext) error
- func (_m *Plugin) GetID() string
- func (_m *Plugin) GetProperties() core.PluginProperties
- func (_m *Plugin) Handle(ctx context.Context, tCtx core.TaskExecutionContext) (core.Transition, error)
- type PluginLoader
- type PluginLoader_Execute_Call
- func (_c *PluginLoader_Execute_Call) Return(_a0 core.Plugin, _a1 error) *PluginLoader_Execute_Call
- func (_c *PluginLoader_Execute_Call) Run(run func(ctx context.Context, iCtx core.SetupContext)) *PluginLoader_Execute_Call
- func (_c *PluginLoader_Execute_Call) RunAndReturn(run func(context.Context, core.SetupContext) (core.Plugin, error)) *PluginLoader_Execute_Call
- type PluginLoader_Expecter
- type PluginStateReader
- type PluginStateReader_Expecter
- type PluginStateReader_GetStateVersion_Call
- func (_c *PluginStateReader_GetStateVersion_Call) Return(_a0 uint8) *PluginStateReader_GetStateVersion_Call
- func (_c *PluginStateReader_GetStateVersion_Call) Run(run func()) *PluginStateReader_GetStateVersion_Call
- func (_c *PluginStateReader_GetStateVersion_Call) RunAndReturn(run func() uint8) *PluginStateReader_GetStateVersion_Call
- type PluginStateReader_Get_Call
- func (_c *PluginStateReader_Get_Call) Return(stateVersion uint8, err error) *PluginStateReader_Get_Call
- func (_c *PluginStateReader_Get_Call) Run(run func(t interface{})) *PluginStateReader_Get_Call
- func (_c *PluginStateReader_Get_Call) RunAndReturn(run func(interface{}) (uint8, error)) *PluginStateReader_Get_Call
- type PluginStateWriter
- type PluginStateWriter_Expecter
- type PluginStateWriter_Put_Call
- func (_c *PluginStateWriter_Put_Call) Return(_a0 error) *PluginStateWriter_Put_Call
- func (_c *PluginStateWriter_Put_Call) Run(run func(stateVersion uint8, v interface{})) *PluginStateWriter_Put_Call
- func (_c *PluginStateWriter_Put_Call) RunAndReturn(run func(uint8, interface{}) error) *PluginStateWriter_Put_Call
- type PluginStateWriter_Reset_Call
- type Plugin_Abort_Call
- func (_c *Plugin_Abort_Call) Return(_a0 error) *Plugin_Abort_Call
- func (_c *Plugin_Abort_Call) Run(run func(ctx context.Context, tCtx core.TaskExecutionContext)) *Plugin_Abort_Call
- func (_c *Plugin_Abort_Call) RunAndReturn(run func(context.Context, core.TaskExecutionContext) error) *Plugin_Abort_Call
- type Plugin_Expecter
- func (_e *Plugin_Expecter) Abort(ctx interface{}, tCtx interface{}) *Plugin_Abort_Call
- func (_e *Plugin_Expecter) Finalize(ctx interface{}, tCtx interface{}) *Plugin_Finalize_Call
- func (_e *Plugin_Expecter) GetID() *Plugin_GetID_Call
- func (_e *Plugin_Expecter) GetProperties() *Plugin_GetProperties_Call
- func (_e *Plugin_Expecter) Handle(ctx interface{}, tCtx interface{}) *Plugin_Handle_Call
- type Plugin_Finalize_Call
- func (_c *Plugin_Finalize_Call) Return(_a0 error) *Plugin_Finalize_Call
- func (_c *Plugin_Finalize_Call) Run(run func(ctx context.Context, tCtx core.TaskExecutionContext)) *Plugin_Finalize_Call
- func (_c *Plugin_Finalize_Call) RunAndReturn(run func(context.Context, core.TaskExecutionContext) error) *Plugin_Finalize_Call
- type Plugin_GetID_Call
- type Plugin_GetProperties_Call
- type Plugin_Handle_Call
- func (_c *Plugin_Handle_Call) Return(_a0 core.Transition, _a1 error) *Plugin_Handle_Call
- func (_c *Plugin_Handle_Call) Run(run func(ctx context.Context, tCtx core.TaskExecutionContext)) *Plugin_Handle_Call
- func (_c *Plugin_Handle_Call) RunAndReturn(run func(context.Context, core.TaskExecutionContext) (core.Transition, error)) *Plugin_Handle_Call
- type ResourceManager
- func (_m *ResourceManager) AllocateResource(ctx context.Context, namespace core.ResourceNamespace, allocationToken string, ...) (core.AllocationStatus, error)
- func (_m *ResourceManager) EXPECT() *ResourceManager_Expecter
- func (_m *ResourceManager) GetID() string
- func (_m *ResourceManager) ReleaseResource(ctx context.Context, namespace core.ResourceNamespace, allocationToken string) error
- type ResourceManager_AllocateResource_Call
- func (_c *ResourceManager_AllocateResource_Call) Return(_a0 core.AllocationStatus, _a1 error) *ResourceManager_AllocateResource_Call
- func (_c *ResourceManager_AllocateResource_Call) Run(...) *ResourceManager_AllocateResource_Call
- func (_c *ResourceManager_AllocateResource_Call) RunAndReturn(...) *ResourceManager_AllocateResource_Call
- type ResourceManager_Expecter
- func (_e *ResourceManager_Expecter) AllocateResource(ctx interface{}, namespace interface{}, allocationToken interface{}, ...) *ResourceManager_AllocateResource_Call
- func (_e *ResourceManager_Expecter) GetID() *ResourceManager_GetID_Call
- func (_e *ResourceManager_Expecter) ReleaseResource(ctx interface{}, namespace interface{}, allocationToken interface{}) *ResourceManager_ReleaseResource_Call
- type ResourceManager_GetID_Call
- type ResourceManager_ReleaseResource_Call
- func (_c *ResourceManager_ReleaseResource_Call) Return(_a0 error) *ResourceManager_ReleaseResource_Call
- func (_c *ResourceManager_ReleaseResource_Call) Run(...) *ResourceManager_ReleaseResource_Call
- func (_c *ResourceManager_ReleaseResource_Call) RunAndReturn(run func(context.Context, core.ResourceNamespace, string) error) *ResourceManager_ReleaseResource_Call
- type ResourceNegotiator
- func (_m *ResourceNegotiator) OnRegisterResourceQuota(ctx context.Context, namespace core.ResourceNamespace, quota int) *ResourceNegotiator_RegisterResourceQuota
- func (_m *ResourceNegotiator) OnRegisterResourceQuotaMatch(matchers ...interface{}) *ResourceNegotiator_RegisterResourceQuota
- func (_m *ResourceNegotiator) RegisterResourceQuota(ctx context.Context, namespace core.ResourceNamespace, quota int) error
- type ResourceNegotiator_RegisterResourceQuota
- type ResourceRegistrar
- type ResourceRegistrar_Expecter
- type ResourceRegistrar_RegisterResourceQuota_Call
- func (_c *ResourceRegistrar_RegisterResourceQuota_Call) Return(_a0 error) *ResourceRegistrar_RegisterResourceQuota_Call
- func (_c *ResourceRegistrar_RegisterResourceQuota_Call) Run(run func(ctx context.Context, namespace core.ResourceNamespace, quota int)) *ResourceRegistrar_RegisterResourceQuota_Call
- func (_c *ResourceRegistrar_RegisterResourceQuota_Call) RunAndReturn(run func(context.Context, core.ResourceNamespace, int) error) *ResourceRegistrar_RegisterResourceQuota_Call
- type SecretManager
- type SecretManager_Expecter
- type SecretManager_Get_Call
- func (_c *SecretManager_Get_Call) Return(_a0 string, _a1 error) *SecretManager_Get_Call
- func (_c *SecretManager_Get_Call) Run(run func(ctx context.Context, key string)) *SecretManager_Get_Call
- func (_c *SecretManager_Get_Call) RunAndReturn(run func(context.Context, string) (string, error)) *SecretManager_Get_Call
- type SetupContext
- func (_m *SetupContext) EXPECT() *SetupContext_Expecter
- func (_m *SetupContext) EnqueueOwner() core.EnqueueOwner
- func (_m *SetupContext) KubeClient() core.KubeClient
- func (_m *SetupContext) MetricsScope() promutils.Scope
- func (_m *SetupContext) OwnerKind() string
- func (_m *SetupContext) ResourceRegistrar() core.ResourceRegistrar
- func (_m *SetupContext) SecretManager() core.SecretManager
- type SetupContext_EnqueueOwner_Call
- func (_c *SetupContext_EnqueueOwner_Call) Return(_a0 core.EnqueueOwner) *SetupContext_EnqueueOwner_Call
- func (_c *SetupContext_EnqueueOwner_Call) Run(run func()) *SetupContext_EnqueueOwner_Call
- func (_c *SetupContext_EnqueueOwner_Call) RunAndReturn(run func() core.EnqueueOwner) *SetupContext_EnqueueOwner_Call
- type SetupContext_Expecter
- func (_e *SetupContext_Expecter) EnqueueOwner() *SetupContext_EnqueueOwner_Call
- func (_e *SetupContext_Expecter) KubeClient() *SetupContext_KubeClient_Call
- func (_e *SetupContext_Expecter) MetricsScope() *SetupContext_MetricsScope_Call
- func (_e *SetupContext_Expecter) OwnerKind() *SetupContext_OwnerKind_Call
- func (_e *SetupContext_Expecter) ResourceRegistrar() *SetupContext_ResourceRegistrar_Call
- func (_e *SetupContext_Expecter) SecretManager() *SetupContext_SecretManager_Call
- type SetupContext_KubeClient_Call
- type SetupContext_MetricsScope_Call
- func (_c *SetupContext_MetricsScope_Call) Return(_a0 promutils.Scope) *SetupContext_MetricsScope_Call
- func (_c *SetupContext_MetricsScope_Call) Run(run func()) *SetupContext_MetricsScope_Call
- func (_c *SetupContext_MetricsScope_Call) RunAndReturn(run func() promutils.Scope) *SetupContext_MetricsScope_Call
- type SetupContext_OwnerKind_Call
- type SetupContext_ResourceRegistrar_Call
- func (_c *SetupContext_ResourceRegistrar_Call) Return(_a0 core.ResourceRegistrar) *SetupContext_ResourceRegistrar_Call
- func (_c *SetupContext_ResourceRegistrar_Call) Run(run func()) *SetupContext_ResourceRegistrar_Call
- func (_c *SetupContext_ResourceRegistrar_Call) RunAndReturn(run func() core.ResourceRegistrar) *SetupContext_ResourceRegistrar_Call
- type SetupContext_SecretManager_Call
- func (_c *SetupContext_SecretManager_Call) Return(_a0 core.SecretManager) *SetupContext_SecretManager_Call
- func (_c *SetupContext_SecretManager_Call) Run(run func()) *SetupContext_SecretManager_Call
- func (_c *SetupContext_SecretManager_Call) RunAndReturn(run func() core.SecretManager) *SetupContext_SecretManager_Call
- type SignalAsync
- type SignalAsync_Execute_Call
- type SignalAsync_Expecter
- type TaskExecutionContext
- func (_m *TaskExecutionContext) Catalog() catalog.AsyncClient
- func (_m *TaskExecutionContext) DataStore() *storage.DataStore
- func (_m *TaskExecutionContext) EXPECT() *TaskExecutionContext_Expecter
- func (_m *TaskExecutionContext) EventsRecorder() core.EventsRecorder
- func (_m *TaskExecutionContext) InputReader() io.InputReader
- func (_m *TaskExecutionContext) OutputWriter() io.OutputWriter
- func (_m *TaskExecutionContext) PluginStateReader() core.PluginStateReader
- func (_m *TaskExecutionContext) PluginStateWriter() core.PluginStateWriter
- func (_m *TaskExecutionContext) ResourceManager() core.ResourceManager
- func (_m *TaskExecutionContext) SecretManager() core.SecretManager
- func (_m *TaskExecutionContext) TaskExecutionMetadata() core.TaskExecutionMetadata
- func (_m *TaskExecutionContext) TaskReader() core.TaskReader
- func (_m *TaskExecutionContext) TaskRefreshIndicator() core.SignalAsync
- type TaskExecutionContext_Catalog_Call
- func (_c *TaskExecutionContext_Catalog_Call) Return(_a0 catalog.AsyncClient) *TaskExecutionContext_Catalog_Call
- func (_c *TaskExecutionContext_Catalog_Call) Run(run func()) *TaskExecutionContext_Catalog_Call
- func (_c *TaskExecutionContext_Catalog_Call) RunAndReturn(run func() catalog.AsyncClient) *TaskExecutionContext_Catalog_Call
- type TaskExecutionContext_DataStore_Call
- func (_c *TaskExecutionContext_DataStore_Call) Return(_a0 *storage.DataStore) *TaskExecutionContext_DataStore_Call
- func (_c *TaskExecutionContext_DataStore_Call) Run(run func()) *TaskExecutionContext_DataStore_Call
- func (_c *TaskExecutionContext_DataStore_Call) RunAndReturn(run func() *storage.DataStore) *TaskExecutionContext_DataStore_Call
- type TaskExecutionContext_EventsRecorder_Call
- func (_c *TaskExecutionContext_EventsRecorder_Call) Return(_a0 core.EventsRecorder) *TaskExecutionContext_EventsRecorder_Call
- func (_c *TaskExecutionContext_EventsRecorder_Call) Run(run func()) *TaskExecutionContext_EventsRecorder_Call
- func (_c *TaskExecutionContext_EventsRecorder_Call) RunAndReturn(run func() core.EventsRecorder) *TaskExecutionContext_EventsRecorder_Call
- type TaskExecutionContext_Expecter
- func (_e *TaskExecutionContext_Expecter) Catalog() *TaskExecutionContext_Catalog_Call
- func (_e *TaskExecutionContext_Expecter) DataStore() *TaskExecutionContext_DataStore_Call
- func (_e *TaskExecutionContext_Expecter) EventsRecorder() *TaskExecutionContext_EventsRecorder_Call
- func (_e *TaskExecutionContext_Expecter) InputReader() *TaskExecutionContext_InputReader_Call
- func (_e *TaskExecutionContext_Expecter) OutputWriter() *TaskExecutionContext_OutputWriter_Call
- func (_e *TaskExecutionContext_Expecter) PluginStateReader() *TaskExecutionContext_PluginStateReader_Call
- func (_e *TaskExecutionContext_Expecter) PluginStateWriter() *TaskExecutionContext_PluginStateWriter_Call
- func (_e *TaskExecutionContext_Expecter) ResourceManager() *TaskExecutionContext_ResourceManager_Call
- func (_e *TaskExecutionContext_Expecter) SecretManager() *TaskExecutionContext_SecretManager_Call
- func (_e *TaskExecutionContext_Expecter) TaskExecutionMetadata() *TaskExecutionContext_TaskExecutionMetadata_Call
- func (_e *TaskExecutionContext_Expecter) TaskReader() *TaskExecutionContext_TaskReader_Call
- func (_e *TaskExecutionContext_Expecter) TaskRefreshIndicator() *TaskExecutionContext_TaskRefreshIndicator_Call
- type TaskExecutionContext_InputReader_Call
- func (_c *TaskExecutionContext_InputReader_Call) Return(_a0 io.InputReader) *TaskExecutionContext_InputReader_Call
- func (_c *TaskExecutionContext_InputReader_Call) Run(run func()) *TaskExecutionContext_InputReader_Call
- func (_c *TaskExecutionContext_InputReader_Call) RunAndReturn(run func() io.InputReader) *TaskExecutionContext_InputReader_Call
- type TaskExecutionContext_OutputWriter_Call
- func (_c *TaskExecutionContext_OutputWriter_Call) Return(_a0 io.OutputWriter) *TaskExecutionContext_OutputWriter_Call
- func (_c *TaskExecutionContext_OutputWriter_Call) Run(run func()) *TaskExecutionContext_OutputWriter_Call
- func (_c *TaskExecutionContext_OutputWriter_Call) RunAndReturn(run func() io.OutputWriter) *TaskExecutionContext_OutputWriter_Call
- type TaskExecutionContext_PluginStateReader_Call
- func (_c *TaskExecutionContext_PluginStateReader_Call) Return(_a0 core.PluginStateReader) *TaskExecutionContext_PluginStateReader_Call
- func (_c *TaskExecutionContext_PluginStateReader_Call) Run(run func()) *TaskExecutionContext_PluginStateReader_Call
- func (_c *TaskExecutionContext_PluginStateReader_Call) RunAndReturn(run func() core.PluginStateReader) *TaskExecutionContext_PluginStateReader_Call
- type TaskExecutionContext_PluginStateWriter_Call
- func (_c *TaskExecutionContext_PluginStateWriter_Call) Return(_a0 core.PluginStateWriter) *TaskExecutionContext_PluginStateWriter_Call
- func (_c *TaskExecutionContext_PluginStateWriter_Call) Run(run func()) *TaskExecutionContext_PluginStateWriter_Call
- func (_c *TaskExecutionContext_PluginStateWriter_Call) RunAndReturn(run func() core.PluginStateWriter) *TaskExecutionContext_PluginStateWriter_Call
- type TaskExecutionContext_ResourceManager_Call
- func (_c *TaskExecutionContext_ResourceManager_Call) Return(_a0 core.ResourceManager) *TaskExecutionContext_ResourceManager_Call
- func (_c *TaskExecutionContext_ResourceManager_Call) Run(run func()) *TaskExecutionContext_ResourceManager_Call
- func (_c *TaskExecutionContext_ResourceManager_Call) RunAndReturn(run func() core.ResourceManager) *TaskExecutionContext_ResourceManager_Call
- type TaskExecutionContext_SecretManager_Call
- func (_c *TaskExecutionContext_SecretManager_Call) Return(_a0 core.SecretManager) *TaskExecutionContext_SecretManager_Call
- func (_c *TaskExecutionContext_SecretManager_Call) Run(run func()) *TaskExecutionContext_SecretManager_Call
- func (_c *TaskExecutionContext_SecretManager_Call) RunAndReturn(run func() core.SecretManager) *TaskExecutionContext_SecretManager_Call
- type TaskExecutionContext_TaskExecutionMetadata_Call
- func (_c *TaskExecutionContext_TaskExecutionMetadata_Call) Return(_a0 core.TaskExecutionMetadata) *TaskExecutionContext_TaskExecutionMetadata_Call
- func (_c *TaskExecutionContext_TaskExecutionMetadata_Call) Run(run func()) *TaskExecutionContext_TaskExecutionMetadata_Call
- func (_c *TaskExecutionContext_TaskExecutionMetadata_Call) RunAndReturn(run func() core.TaskExecutionMetadata) *TaskExecutionContext_TaskExecutionMetadata_Call
- type TaskExecutionContext_TaskReader_Call
- func (_c *TaskExecutionContext_TaskReader_Call) Return(_a0 core.TaskReader) *TaskExecutionContext_TaskReader_Call
- func (_c *TaskExecutionContext_TaskReader_Call) Run(run func()) *TaskExecutionContext_TaskReader_Call
- func (_c *TaskExecutionContext_TaskReader_Call) RunAndReturn(run func() core.TaskReader) *TaskExecutionContext_TaskReader_Call
- type TaskExecutionContext_TaskRefreshIndicator_Call
- func (_c *TaskExecutionContext_TaskRefreshIndicator_Call) Return(_a0 core.SignalAsync) *TaskExecutionContext_TaskRefreshIndicator_Call
- func (_c *TaskExecutionContext_TaskRefreshIndicator_Call) Run(run func()) *TaskExecutionContext_TaskRefreshIndicator_Call
- func (_c *TaskExecutionContext_TaskRefreshIndicator_Call) RunAndReturn(run func() core.SignalAsync) *TaskExecutionContext_TaskRefreshIndicator_Call
- type TaskExecutionID
- func (_m *TaskExecutionID) EXPECT() *TaskExecutionID_Expecter
- func (_m *TaskExecutionID) GetGeneratedName() string
- func (_m *TaskExecutionID) GetGeneratedNameWith(minLength int, maxLength int) (string, error)
- func (_m *TaskExecutionID) GetID() flyteidlcore.TaskExecutionIdentifier
- func (_m *TaskExecutionID) GetUniqueNodeID() string
- type TaskExecutionID_Expecter
- func (_e *TaskExecutionID_Expecter) GetGeneratedName() *TaskExecutionID_GetGeneratedName_Call
- func (_e *TaskExecutionID_Expecter) GetGeneratedNameWith(minLength interface{}, maxLength interface{}) *TaskExecutionID_GetGeneratedNameWith_Call
- func (_e *TaskExecutionID_Expecter) GetID() *TaskExecutionID_GetID_Call
- func (_e *TaskExecutionID_Expecter) GetUniqueNodeID() *TaskExecutionID_GetUniqueNodeID_Call
- type TaskExecutionID_GetGeneratedNameWith_Call
- func (_c *TaskExecutionID_GetGeneratedNameWith_Call) Return(_a0 string, _a1 error) *TaskExecutionID_GetGeneratedNameWith_Call
- func (_c *TaskExecutionID_GetGeneratedNameWith_Call) Run(run func(minLength int, maxLength int)) *TaskExecutionID_GetGeneratedNameWith_Call
- func (_c *TaskExecutionID_GetGeneratedNameWith_Call) RunAndReturn(run func(int, int) (string, error)) *TaskExecutionID_GetGeneratedNameWith_Call
- type TaskExecutionID_GetGeneratedName_Call
- func (_c *TaskExecutionID_GetGeneratedName_Call) Return(_a0 string) *TaskExecutionID_GetGeneratedName_Call
- func (_c *TaskExecutionID_GetGeneratedName_Call) Run(run func()) *TaskExecutionID_GetGeneratedName_Call
- func (_c *TaskExecutionID_GetGeneratedName_Call) RunAndReturn(run func() string) *TaskExecutionID_GetGeneratedName_Call
- type TaskExecutionID_GetID_Call
- func (_c *TaskExecutionID_GetID_Call) Return(_a0 flyteidlcore.TaskExecutionIdentifier) *TaskExecutionID_GetID_Call
- func (_c *TaskExecutionID_GetID_Call) Run(run func()) *TaskExecutionID_GetID_Call
- func (_c *TaskExecutionID_GetID_Call) RunAndReturn(run func() flyteidlcore.TaskExecutionIdentifier) *TaskExecutionID_GetID_Call
- type TaskExecutionID_GetUniqueNodeID_Call
- func (_c *TaskExecutionID_GetUniqueNodeID_Call) Return(_a0 string) *TaskExecutionID_GetUniqueNodeID_Call
- func (_c *TaskExecutionID_GetUniqueNodeID_Call) Run(run func()) *TaskExecutionID_GetUniqueNodeID_Call
- func (_c *TaskExecutionID_GetUniqueNodeID_Call) RunAndReturn(run func() string) *TaskExecutionID_GetUniqueNodeID_Call
- type TaskExecutionMetadata
- func (_m *TaskExecutionMetadata) EXPECT() *TaskExecutionMetadata_Expecter
- func (_m *TaskExecutionMetadata) GetAnnotations() map[string]string
- func (_m *TaskExecutionMetadata) GetConsoleURL() string
- func (_m *TaskExecutionMetadata) GetEnvironmentVariables() map[string]string
- func (_m *TaskExecutionMetadata) GetInterruptibleFailureThreshold() int32
- func (_m *TaskExecutionMetadata) GetK8sServiceAccount() string
- func (_m *TaskExecutionMetadata) GetLabels() map[string]string
- func (_m *TaskExecutionMetadata) GetMaxAttempts() uint32
- func (_m *TaskExecutionMetadata) GetNamespace() string
- func (_m *TaskExecutionMetadata) GetOverrides() core.TaskOverrides
- func (_m *TaskExecutionMetadata) GetOwnerID() types.NamespacedName
- func (_m *TaskExecutionMetadata) GetOwnerReference() v1.OwnerReference
- func (_m *TaskExecutionMetadata) GetPlatformResources() *corev1.ResourceRequirements
- func (_m *TaskExecutionMetadata) GetSecurityContext() flyteidlcore.SecurityContext
- func (_m *TaskExecutionMetadata) GetTaskExecutionID() core.TaskExecutionID
- func (_m *TaskExecutionMetadata) IsInterruptible() bool
- type TaskExecutionMetadata_Expecter
- func (_e *TaskExecutionMetadata_Expecter) GetAnnotations() *TaskExecutionMetadata_GetAnnotations_Call
- func (_e *TaskExecutionMetadata_Expecter) GetConsoleURL() *TaskExecutionMetadata_GetConsoleURL_Call
- func (_e *TaskExecutionMetadata_Expecter) GetEnvironmentVariables() *TaskExecutionMetadata_GetEnvironmentVariables_Call
- func (_e *TaskExecutionMetadata_Expecter) GetInterruptibleFailureThreshold() *TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call
- func (_e *TaskExecutionMetadata_Expecter) GetK8sServiceAccount() *TaskExecutionMetadata_GetK8sServiceAccount_Call
- func (_e *TaskExecutionMetadata_Expecter) GetLabels() *TaskExecutionMetadata_GetLabels_Call
- func (_e *TaskExecutionMetadata_Expecter) GetMaxAttempts() *TaskExecutionMetadata_GetMaxAttempts_Call
- func (_e *TaskExecutionMetadata_Expecter) GetNamespace() *TaskExecutionMetadata_GetNamespace_Call
- func (_e *TaskExecutionMetadata_Expecter) GetOverrides() *TaskExecutionMetadata_GetOverrides_Call
- func (_e *TaskExecutionMetadata_Expecter) GetOwnerID() *TaskExecutionMetadata_GetOwnerID_Call
- func (_e *TaskExecutionMetadata_Expecter) GetOwnerReference() *TaskExecutionMetadata_GetOwnerReference_Call
- func (_e *TaskExecutionMetadata_Expecter) GetPlatformResources() *TaskExecutionMetadata_GetPlatformResources_Call
- func (_e *TaskExecutionMetadata_Expecter) GetSecurityContext() *TaskExecutionMetadata_GetSecurityContext_Call
- func (_e *TaskExecutionMetadata_Expecter) GetTaskExecutionID() *TaskExecutionMetadata_GetTaskExecutionID_Call
- func (_e *TaskExecutionMetadata_Expecter) IsInterruptible() *TaskExecutionMetadata_IsInterruptible_Call
- type TaskExecutionMetadata_GetAnnotations_Call
- func (_c *TaskExecutionMetadata_GetAnnotations_Call) Return(_a0 map[string]string) *TaskExecutionMetadata_GetAnnotations_Call
- func (_c *TaskExecutionMetadata_GetAnnotations_Call) Run(run func()) *TaskExecutionMetadata_GetAnnotations_Call
- func (_c *TaskExecutionMetadata_GetAnnotations_Call) RunAndReturn(run func() map[string]string) *TaskExecutionMetadata_GetAnnotations_Call
- type TaskExecutionMetadata_GetConsoleURL_Call
- func (_c *TaskExecutionMetadata_GetConsoleURL_Call) Return(_a0 string) *TaskExecutionMetadata_GetConsoleURL_Call
- func (_c *TaskExecutionMetadata_GetConsoleURL_Call) Run(run func()) *TaskExecutionMetadata_GetConsoleURL_Call
- func (_c *TaskExecutionMetadata_GetConsoleURL_Call) RunAndReturn(run func() string) *TaskExecutionMetadata_GetConsoleURL_Call
- type TaskExecutionMetadata_GetEnvironmentVariables_Call
- func (_c *TaskExecutionMetadata_GetEnvironmentVariables_Call) Return(_a0 map[string]string) *TaskExecutionMetadata_GetEnvironmentVariables_Call
- func (_c *TaskExecutionMetadata_GetEnvironmentVariables_Call) Run(run func()) *TaskExecutionMetadata_GetEnvironmentVariables_Call
- func (_c *TaskExecutionMetadata_GetEnvironmentVariables_Call) RunAndReturn(run func() map[string]string) *TaskExecutionMetadata_GetEnvironmentVariables_Call
- type TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call
- func (_c *TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call) Return(_a0 int32) *TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call
- func (_c *TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call) Run(run func()) *TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call
- func (_c *TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call) RunAndReturn(run func() int32) *TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call
- type TaskExecutionMetadata_GetK8sServiceAccount_Call
- func (_c *TaskExecutionMetadata_GetK8sServiceAccount_Call) Return(_a0 string) *TaskExecutionMetadata_GetK8sServiceAccount_Call
- func (_c *TaskExecutionMetadata_GetK8sServiceAccount_Call) Run(run func()) *TaskExecutionMetadata_GetK8sServiceAccount_Call
- func (_c *TaskExecutionMetadata_GetK8sServiceAccount_Call) RunAndReturn(run func() string) *TaskExecutionMetadata_GetK8sServiceAccount_Call
- type TaskExecutionMetadata_GetLabels_Call
- func (_c *TaskExecutionMetadata_GetLabels_Call) Return(_a0 map[string]string) *TaskExecutionMetadata_GetLabels_Call
- func (_c *TaskExecutionMetadata_GetLabels_Call) Run(run func()) *TaskExecutionMetadata_GetLabels_Call
- func (_c *TaskExecutionMetadata_GetLabels_Call) RunAndReturn(run func() map[string]string) *TaskExecutionMetadata_GetLabels_Call
- type TaskExecutionMetadata_GetMaxAttempts_Call
- func (_c *TaskExecutionMetadata_GetMaxAttempts_Call) Return(_a0 uint32) *TaskExecutionMetadata_GetMaxAttempts_Call
- func (_c *TaskExecutionMetadata_GetMaxAttempts_Call) Run(run func()) *TaskExecutionMetadata_GetMaxAttempts_Call
- func (_c *TaskExecutionMetadata_GetMaxAttempts_Call) RunAndReturn(run func() uint32) *TaskExecutionMetadata_GetMaxAttempts_Call
- type TaskExecutionMetadata_GetNamespace_Call
- func (_c *TaskExecutionMetadata_GetNamespace_Call) Return(_a0 string) *TaskExecutionMetadata_GetNamespace_Call
- func (_c *TaskExecutionMetadata_GetNamespace_Call) Run(run func()) *TaskExecutionMetadata_GetNamespace_Call
- func (_c *TaskExecutionMetadata_GetNamespace_Call) RunAndReturn(run func() string) *TaskExecutionMetadata_GetNamespace_Call
- type TaskExecutionMetadata_GetOverrides_Call
- func (_c *TaskExecutionMetadata_GetOverrides_Call) Return(_a0 core.TaskOverrides) *TaskExecutionMetadata_GetOverrides_Call
- func (_c *TaskExecutionMetadata_GetOverrides_Call) Run(run func()) *TaskExecutionMetadata_GetOverrides_Call
- func (_c *TaskExecutionMetadata_GetOverrides_Call) RunAndReturn(run func() core.TaskOverrides) *TaskExecutionMetadata_GetOverrides_Call
- type TaskExecutionMetadata_GetOwnerID_Call
- func (_c *TaskExecutionMetadata_GetOwnerID_Call) Return(_a0 types.NamespacedName) *TaskExecutionMetadata_GetOwnerID_Call
- func (_c *TaskExecutionMetadata_GetOwnerID_Call) Run(run func()) *TaskExecutionMetadata_GetOwnerID_Call
- func (_c *TaskExecutionMetadata_GetOwnerID_Call) RunAndReturn(run func() types.NamespacedName) *TaskExecutionMetadata_GetOwnerID_Call
- type TaskExecutionMetadata_GetOwnerReference_Call
- func (_c *TaskExecutionMetadata_GetOwnerReference_Call) Return(_a0 v1.OwnerReference) *TaskExecutionMetadata_GetOwnerReference_Call
- func (_c *TaskExecutionMetadata_GetOwnerReference_Call) Run(run func()) *TaskExecutionMetadata_GetOwnerReference_Call
- func (_c *TaskExecutionMetadata_GetOwnerReference_Call) RunAndReturn(run func() v1.OwnerReference) *TaskExecutionMetadata_GetOwnerReference_Call
- type TaskExecutionMetadata_GetPlatformResources_Call
- func (_c *TaskExecutionMetadata_GetPlatformResources_Call) Return(_a0 *corev1.ResourceRequirements) *TaskExecutionMetadata_GetPlatformResources_Call
- func (_c *TaskExecutionMetadata_GetPlatformResources_Call) Run(run func()) *TaskExecutionMetadata_GetPlatformResources_Call
- func (_c *TaskExecutionMetadata_GetPlatformResources_Call) RunAndReturn(run func() *corev1.ResourceRequirements) *TaskExecutionMetadata_GetPlatformResources_Call
- type TaskExecutionMetadata_GetSecurityContext_Call
- func (_c *TaskExecutionMetadata_GetSecurityContext_Call) Return(_a0 flyteidlcore.SecurityContext) *TaskExecutionMetadata_GetSecurityContext_Call
- func (_c *TaskExecutionMetadata_GetSecurityContext_Call) Run(run func()) *TaskExecutionMetadata_GetSecurityContext_Call
- func (_c *TaskExecutionMetadata_GetSecurityContext_Call) RunAndReturn(run func() flyteidlcore.SecurityContext) *TaskExecutionMetadata_GetSecurityContext_Call
- type TaskExecutionMetadata_GetTaskExecutionID_Call
- func (_c *TaskExecutionMetadata_GetTaskExecutionID_Call) Return(_a0 core.TaskExecutionID) *TaskExecutionMetadata_GetTaskExecutionID_Call
- func (_c *TaskExecutionMetadata_GetTaskExecutionID_Call) Run(run func()) *TaskExecutionMetadata_GetTaskExecutionID_Call
- func (_c *TaskExecutionMetadata_GetTaskExecutionID_Call) RunAndReturn(run func() core.TaskExecutionID) *TaskExecutionMetadata_GetTaskExecutionID_Call
- type TaskExecutionMetadata_IsInterruptible_Call
- func (_c *TaskExecutionMetadata_IsInterruptible_Call) Return(_a0 bool) *TaskExecutionMetadata_IsInterruptible_Call
- func (_c *TaskExecutionMetadata_IsInterruptible_Call) Run(run func()) *TaskExecutionMetadata_IsInterruptible_Call
- func (_c *TaskExecutionMetadata_IsInterruptible_Call) RunAndReturn(run func() bool) *TaskExecutionMetadata_IsInterruptible_Call
- type TaskOverrides
- func (_m *TaskOverrides) EXPECT() *TaskOverrides_Expecter
- func (_m *TaskOverrides) GetConfig() *v1.ConfigMap
- func (_m *TaskOverrides) GetContainerImage() string
- func (_m *TaskOverrides) GetExtendedResources() *flyteidlcore.ExtendedResources
- func (_m *TaskOverrides) GetPodTemplate() *flyteidlcore.K8SPod
- func (_m *TaskOverrides) GetResources() *v1.ResourceRequirements
- type TaskOverrides_Expecter
- func (_e *TaskOverrides_Expecter) GetConfig() *TaskOverrides_GetConfig_Call
- func (_e *TaskOverrides_Expecter) GetContainerImage() *TaskOverrides_GetContainerImage_Call
- func (_e *TaskOverrides_Expecter) GetExtendedResources() *TaskOverrides_GetExtendedResources_Call
- func (_e *TaskOverrides_Expecter) GetPodTemplate() *TaskOverrides_GetPodTemplate_Call
- func (_e *TaskOverrides_Expecter) GetResources() *TaskOverrides_GetResources_Call
- type TaskOverrides_GetConfig_Call
- type TaskOverrides_GetContainerImage_Call
- func (_c *TaskOverrides_GetContainerImage_Call) Return(_a0 string) *TaskOverrides_GetContainerImage_Call
- func (_c *TaskOverrides_GetContainerImage_Call) Run(run func()) *TaskOverrides_GetContainerImage_Call
- func (_c *TaskOverrides_GetContainerImage_Call) RunAndReturn(run func() string) *TaskOverrides_GetContainerImage_Call
- type TaskOverrides_GetExtendedResources_Call
- func (_c *TaskOverrides_GetExtendedResources_Call) Return(_a0 *flyteidlcore.ExtendedResources) *TaskOverrides_GetExtendedResources_Call
- func (_c *TaskOverrides_GetExtendedResources_Call) Run(run func()) *TaskOverrides_GetExtendedResources_Call
- func (_c *TaskOverrides_GetExtendedResources_Call) RunAndReturn(run func() *flyteidlcore.ExtendedResources) *TaskOverrides_GetExtendedResources_Call
- type TaskOverrides_GetPodTemplate_Call
- func (_c *TaskOverrides_GetPodTemplate_Call) Return(_a0 *flyteidlcore.K8SPod) *TaskOverrides_GetPodTemplate_Call
- func (_c *TaskOverrides_GetPodTemplate_Call) Run(run func()) *TaskOverrides_GetPodTemplate_Call
- func (_c *TaskOverrides_GetPodTemplate_Call) RunAndReturn(run func() *flyteidlcore.K8SPod) *TaskOverrides_GetPodTemplate_Call
- type TaskOverrides_GetResources_Call
- func (_c *TaskOverrides_GetResources_Call) Return(_a0 *v1.ResourceRequirements) *TaskOverrides_GetResources_Call
- func (_c *TaskOverrides_GetResources_Call) Run(run func()) *TaskOverrides_GetResources_Call
- func (_c *TaskOverrides_GetResources_Call) RunAndReturn(run func() *v1.ResourceRequirements) *TaskOverrides_GetResources_Call
- type TaskReader
- type TaskReader_Expecter
- type TaskReader_Path_Call
- func (_c *TaskReader_Path_Call) Return(_a0 storage.DataReference, _a1 error) *TaskReader_Path_Call
- func (_c *TaskReader_Path_Call) Run(run func(ctx context.Context)) *TaskReader_Path_Call
- func (_c *TaskReader_Path_Call) RunAndReturn(run func(context.Context) (storage.DataReference, error)) *TaskReader_Path_Call
- type TaskReader_Read_Call
- func (_c *TaskReader_Read_Call) Return(_a0 *flyteidlcore.TaskTemplate, _a1 error) *TaskReader_Read_Call
- func (_c *TaskReader_Read_Call) Run(run func(ctx context.Context)) *TaskReader_Read_Call
- func (_c *TaskReader_Read_Call) RunAndReturn(run func(context.Context) (*flyteidlcore.TaskTemplate, error)) *TaskReader_Read_Call
- type TaskTemplatePath
- type TaskTemplatePath_Expecter
- type TaskTemplatePath_Path_Call
- func (_c *TaskTemplatePath_Path_Call) Return(_a0 storage.DataReference, _a1 error) *TaskTemplatePath_Path_Call
- func (_c *TaskTemplatePath_Path_Call) Run(run func(ctx context.Context)) *TaskTemplatePath_Path_Call
- func (_c *TaskTemplatePath_Path_Call) RunAndReturn(run func(context.Context) (storage.DataReference, error)) *TaskTemplatePath_Path_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EnqueueOwner ¶ added in v1.15.1
EnqueueOwner is an autogenerated mock type for the EnqueueOwner type
func NewEnqueueOwner ¶ added in v1.15.1
func NewEnqueueOwner(t interface {
mock.TestingT
Cleanup(func())
}) *EnqueueOwner
NewEnqueueOwner creates a new instance of EnqueueOwner. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*EnqueueOwner) EXPECT ¶ added in v1.15.1
func (_m *EnqueueOwner) EXPECT() *EnqueueOwner_Expecter
func (*EnqueueOwner) Execute ¶ added in v1.15.1
func (_m *EnqueueOwner) Execute(id types.NamespacedName) error
Execute provides a mock function with given fields: id
type EnqueueOwner_Execute_Call ¶ added in v1.15.1
EnqueueOwner_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'
func (*EnqueueOwner_Execute_Call) Return ¶ added in v1.15.1
func (_c *EnqueueOwner_Execute_Call) Return(_a0 error) *EnqueueOwner_Execute_Call
func (*EnqueueOwner_Execute_Call) Run ¶ added in v1.15.1
func (_c *EnqueueOwner_Execute_Call) Run(run func(id types.NamespacedName)) *EnqueueOwner_Execute_Call
func (*EnqueueOwner_Execute_Call) RunAndReturn ¶ added in v1.15.1
func (_c *EnqueueOwner_Execute_Call) RunAndReturn(run func(types.NamespacedName) error) *EnqueueOwner_Execute_Call
type EnqueueOwner_Expecter ¶ added in v1.15.1
type EnqueueOwner_Expecter struct {
// contains filtered or unexported fields
}
func (*EnqueueOwner_Expecter) Execute ¶ added in v1.15.1
func (_e *EnqueueOwner_Expecter) Execute(id interface{}) *EnqueueOwner_Execute_Call
Execute is a helper method to define mock.On call
- id types.NamespacedName
type EventsRecorder ¶
EventsRecorder is an autogenerated mock type for the EventsRecorder type
func NewEventsRecorder ¶ added in v1.15.1
func NewEventsRecorder(t interface {
mock.TestingT
Cleanup(func())
}) *EventsRecorder
NewEventsRecorder creates a new instance of EventsRecorder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*EventsRecorder) EXPECT ¶ added in v1.15.1
func (_m *EventsRecorder) EXPECT() *EventsRecorder_Expecter
type EventsRecorder_Expecter ¶ added in v1.15.1
type EventsRecorder_Expecter struct {
// contains filtered or unexported fields
}
func (*EventsRecorder_Expecter) RecordRaw ¶ added in v1.15.1
func (_e *EventsRecorder_Expecter) RecordRaw(ctx interface{}, ev interface{}) *EventsRecorder_RecordRaw_Call
RecordRaw is a helper method to define mock.On call
- ctx context.Context
- ev core.PhaseInfo
type EventsRecorder_RecordRaw_Call ¶ added in v1.15.1
EventsRecorder_RecordRaw_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordRaw'
func (*EventsRecorder_RecordRaw_Call) Return ¶ added in v1.15.1
func (_c *EventsRecorder_RecordRaw_Call) Return(_a0 error) *EventsRecorder_RecordRaw_Call
func (*EventsRecorder_RecordRaw_Call) Run ¶ added in v1.15.1
func (_c *EventsRecorder_RecordRaw_Call) Run(run func(ctx context.Context, ev core.PhaseInfo)) *EventsRecorder_RecordRaw_Call
func (*EventsRecorder_RecordRaw_Call) RunAndReturn ¶ added in v1.15.1
func (_c *EventsRecorder_RecordRaw_Call) RunAndReturn(run func(context.Context, core.PhaseInfo) error) *EventsRecorder_RecordRaw_Call
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) 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) 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) GroupVersionKindFor ¶ added in v1.9.35
func (m *FakeKubeClient) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)
GroupVersionKindFor returns the GroupVersionKind for the given object.
func (*FakeKubeClient) IsObjectNamespaced ¶ added in v1.9.35
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 ¶
KubeClient is an autogenerated mock type for the KubeClient type
func NewKubeClient ¶ added in v1.15.1
func NewKubeClient(t interface {
mock.TestingT
Cleanup(func())
}) *KubeClient
NewKubeClient creates a new instance of KubeClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*KubeClient) EXPECT ¶ added in v1.15.1
func (_m *KubeClient) EXPECT() *KubeClient_Expecter
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:
type KubeClient_Expecter ¶ added in v1.15.1
type KubeClient_Expecter struct {
// contains filtered or unexported fields
}
func (*KubeClient_Expecter) GetCache ¶ added in v1.15.1
func (_e *KubeClient_Expecter) GetCache() *KubeClient_GetCache_Call
GetCache is a helper method to define mock.On call
func (*KubeClient_Expecter) GetClient ¶ added in v1.15.1
func (_e *KubeClient_Expecter) GetClient() *KubeClient_GetClient_Call
GetClient is a helper method to define mock.On call
type KubeClient_GetCache_Call ¶ added in v1.15.1
KubeClient_GetCache_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCache'
func (*KubeClient_GetCache_Call) Return ¶ added in v1.15.1
func (_c *KubeClient_GetCache_Call) Return(_a0 cache.Cache) *KubeClient_GetCache_Call
func (*KubeClient_GetCache_Call) Run ¶ added in v1.15.1
func (_c *KubeClient_GetCache_Call) Run(run func()) *KubeClient_GetCache_Call
func (*KubeClient_GetCache_Call) RunAndReturn ¶ added in v1.15.1
func (_c *KubeClient_GetCache_Call) RunAndReturn(run func() cache.Cache) *KubeClient_GetCache_Call
type KubeClient_GetClient_Call ¶ added in v1.15.1
KubeClient_GetClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetClient'
func (*KubeClient_GetClient_Call) Return ¶ added in v1.15.1
func (_c *KubeClient_GetClient_Call) Return(_a0 client.Client) *KubeClient_GetClient_Call
func (*KubeClient_GetClient_Call) Run ¶ added in v1.15.1
func (_c *KubeClient_GetClient_Call) Run(run func()) *KubeClient_GetClient_Call
func (*KubeClient_GetClient_Call) RunAndReturn ¶ added in v1.15.1
func (_c *KubeClient_GetClient_Call) RunAndReturn(run func() client.Client) *KubeClient_GetClient_Call
type Plugin ¶
Plugin is an autogenerated mock type for the Plugin type
func NewPlugin ¶ added in v1.15.1
NewPlugin creates a new instance of Plugin. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Plugin) EXPECT ¶ added in v1.15.1
func (_m *Plugin) EXPECT() *Plugin_Expecter
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
type PluginLoader ¶ added in v1.15.1
PluginLoader is an autogenerated mock type for the PluginLoader type
func NewPluginLoader ¶ added in v1.15.1
func NewPluginLoader(t interface {
mock.TestingT
Cleanup(func())
}) *PluginLoader
NewPluginLoader creates a new instance of PluginLoader. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*PluginLoader) EXPECT ¶ added in v1.15.1
func (_m *PluginLoader) EXPECT() *PluginLoader_Expecter
func (*PluginLoader) Execute ¶ added in v1.15.1
func (_m *PluginLoader) Execute(ctx context.Context, iCtx core.SetupContext) (core.Plugin, error)
Execute provides a mock function with given fields: ctx, iCtx
type PluginLoader_Execute_Call ¶ added in v1.15.1
PluginLoader_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'
func (*PluginLoader_Execute_Call) Return ¶ added in v1.15.1
func (_c *PluginLoader_Execute_Call) Return(_a0 core.Plugin, _a1 error) *PluginLoader_Execute_Call
func (*PluginLoader_Execute_Call) Run ¶ added in v1.15.1
func (_c *PluginLoader_Execute_Call) Run(run func(ctx context.Context, iCtx core.SetupContext)) *PluginLoader_Execute_Call
func (*PluginLoader_Execute_Call) RunAndReturn ¶ added in v1.15.1
func (_c *PluginLoader_Execute_Call) RunAndReturn(run func(context.Context, core.SetupContext) (core.Plugin, error)) *PluginLoader_Execute_Call
type PluginLoader_Expecter ¶ added in v1.15.1
type PluginLoader_Expecter struct {
// contains filtered or unexported fields
}
func (*PluginLoader_Expecter) Execute ¶ added in v1.15.1
func (_e *PluginLoader_Expecter) Execute(ctx interface{}, iCtx interface{}) *PluginLoader_Execute_Call
Execute is a helper method to define mock.On call
- ctx context.Context
- iCtx core.SetupContext
type PluginStateReader ¶
PluginStateReader is an autogenerated mock type for the PluginStateReader type
func NewPluginStateReader ¶ added in v1.15.1
func NewPluginStateReader(t interface {
mock.TestingT
Cleanup(func())
}) *PluginStateReader
NewPluginStateReader creates a new instance of PluginStateReader. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*PluginStateReader) EXPECT ¶ added in v1.15.1
func (_m *PluginStateReader) EXPECT() *PluginStateReader_Expecter
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:
type PluginStateReader_Expecter ¶ added in v1.15.1
type PluginStateReader_Expecter struct {
// contains filtered or unexported fields
}
func (*PluginStateReader_Expecter) Get ¶ added in v1.15.1
func (_e *PluginStateReader_Expecter) Get(t interface{}) *PluginStateReader_Get_Call
Get is a helper method to define mock.On call
- t interface{}
func (*PluginStateReader_Expecter) GetStateVersion ¶ added in v1.15.1
func (_e *PluginStateReader_Expecter) GetStateVersion() *PluginStateReader_GetStateVersion_Call
GetStateVersion is a helper method to define mock.On call
type PluginStateReader_GetStateVersion_Call ¶ added in v1.15.1
PluginStateReader_GetStateVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStateVersion'
func (*PluginStateReader_GetStateVersion_Call) Return ¶ added in v1.15.1
func (_c *PluginStateReader_GetStateVersion_Call) Return(_a0 uint8) *PluginStateReader_GetStateVersion_Call
func (*PluginStateReader_GetStateVersion_Call) Run ¶ added in v1.15.1
func (_c *PluginStateReader_GetStateVersion_Call) Run(run func()) *PluginStateReader_GetStateVersion_Call
func (*PluginStateReader_GetStateVersion_Call) RunAndReturn ¶ added in v1.15.1
func (_c *PluginStateReader_GetStateVersion_Call) RunAndReturn(run func() uint8) *PluginStateReader_GetStateVersion_Call
type PluginStateReader_Get_Call ¶ added in v1.15.1
PluginStateReader_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'
func (*PluginStateReader_Get_Call) Return ¶ added in v1.15.1
func (_c *PluginStateReader_Get_Call) Return(stateVersion uint8, err error) *PluginStateReader_Get_Call
func (*PluginStateReader_Get_Call) Run ¶ added in v1.15.1
func (_c *PluginStateReader_Get_Call) Run(run func(t interface{})) *PluginStateReader_Get_Call
func (*PluginStateReader_Get_Call) RunAndReturn ¶ added in v1.15.1
func (_c *PluginStateReader_Get_Call) RunAndReturn(run func(interface{}) (uint8, error)) *PluginStateReader_Get_Call
type PluginStateWriter ¶
PluginStateWriter is an autogenerated mock type for the PluginStateWriter type
func NewPluginStateWriter ¶ added in v1.15.1
func NewPluginStateWriter(t interface {
mock.TestingT
Cleanup(func())
}) *PluginStateWriter
NewPluginStateWriter creates a new instance of PluginStateWriter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*PluginStateWriter) EXPECT ¶ added in v1.15.1
func (_m *PluginStateWriter) EXPECT() *PluginStateWriter_Expecter
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_Expecter ¶ added in v1.15.1
type PluginStateWriter_Expecter struct {
// contains filtered or unexported fields
}
func (*PluginStateWriter_Expecter) Put ¶ added in v1.15.1
func (_e *PluginStateWriter_Expecter) Put(stateVersion interface{}, v interface{}) *PluginStateWriter_Put_Call
Put is a helper method to define mock.On call
- stateVersion uint8
- v interface{}
func (*PluginStateWriter_Expecter) Reset ¶ added in v1.15.1
func (_e *PluginStateWriter_Expecter) Reset() *PluginStateWriter_Reset_Call
Reset is a helper method to define mock.On call
type PluginStateWriter_Put_Call ¶ added in v1.15.1
PluginStateWriter_Put_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Put'
func (*PluginStateWriter_Put_Call) Return ¶ added in v1.15.1
func (_c *PluginStateWriter_Put_Call) Return(_a0 error) *PluginStateWriter_Put_Call
func (*PluginStateWriter_Put_Call) Run ¶ added in v1.15.1
func (_c *PluginStateWriter_Put_Call) Run(run func(stateVersion uint8, v interface{})) *PluginStateWriter_Put_Call
func (*PluginStateWriter_Put_Call) RunAndReturn ¶ added in v1.15.1
func (_c *PluginStateWriter_Put_Call) RunAndReturn(run func(uint8, interface{}) error) *PluginStateWriter_Put_Call
type PluginStateWriter_Reset_Call ¶ added in v1.15.1
PluginStateWriter_Reset_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Reset'
func (*PluginStateWriter_Reset_Call) Return ¶ added in v1.15.1
func (_c *PluginStateWriter_Reset_Call) Return(_a0 error) *PluginStateWriter_Reset_Call
func (*PluginStateWriter_Reset_Call) Run ¶ added in v1.15.1
func (_c *PluginStateWriter_Reset_Call) Run(run func()) *PluginStateWriter_Reset_Call
func (*PluginStateWriter_Reset_Call) RunAndReturn ¶ added in v1.15.1
func (_c *PluginStateWriter_Reset_Call) RunAndReturn(run func() error) *PluginStateWriter_Reset_Call
type Plugin_Abort_Call ¶ added in v1.15.1
Plugin_Abort_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Abort'
func (*Plugin_Abort_Call) Return ¶ added in v1.15.1
func (_c *Plugin_Abort_Call) Return(_a0 error) *Plugin_Abort_Call
func (*Plugin_Abort_Call) Run ¶ added in v1.15.1
func (_c *Plugin_Abort_Call) Run(run func(ctx context.Context, tCtx core.TaskExecutionContext)) *Plugin_Abort_Call
func (*Plugin_Abort_Call) RunAndReturn ¶ added in v1.15.1
func (_c *Plugin_Abort_Call) RunAndReturn(run func(context.Context, core.TaskExecutionContext) error) *Plugin_Abort_Call
type Plugin_Expecter ¶ added in v1.15.1
type Plugin_Expecter struct {
// contains filtered or unexported fields
}
func (*Plugin_Expecter) Abort ¶ added in v1.15.1
func (_e *Plugin_Expecter) Abort(ctx interface{}, tCtx interface{}) *Plugin_Abort_Call
Abort is a helper method to define mock.On call
- ctx context.Context
- tCtx core.TaskExecutionContext
func (*Plugin_Expecter) Finalize ¶ added in v1.15.1
func (_e *Plugin_Expecter) Finalize(ctx interface{}, tCtx interface{}) *Plugin_Finalize_Call
Finalize is a helper method to define mock.On call
- ctx context.Context
- tCtx core.TaskExecutionContext
func (*Plugin_Expecter) GetID ¶ added in v1.15.1
func (_e *Plugin_Expecter) GetID() *Plugin_GetID_Call
GetID is a helper method to define mock.On call
func (*Plugin_Expecter) GetProperties ¶ added in v1.15.1
func (_e *Plugin_Expecter) GetProperties() *Plugin_GetProperties_Call
GetProperties is a helper method to define mock.On call
func (*Plugin_Expecter) Handle ¶ added in v1.15.1
func (_e *Plugin_Expecter) Handle(ctx interface{}, tCtx interface{}) *Plugin_Handle_Call
Handle is a helper method to define mock.On call
- ctx context.Context
- tCtx core.TaskExecutionContext
type Plugin_Finalize_Call ¶ added in v1.15.1
Plugin_Finalize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Finalize'
func (*Plugin_Finalize_Call) Return ¶ added in v1.15.1
func (_c *Plugin_Finalize_Call) Return(_a0 error) *Plugin_Finalize_Call
func (*Plugin_Finalize_Call) Run ¶ added in v1.15.1
func (_c *Plugin_Finalize_Call) Run(run func(ctx context.Context, tCtx core.TaskExecutionContext)) *Plugin_Finalize_Call
func (*Plugin_Finalize_Call) RunAndReturn ¶ added in v1.15.1
func (_c *Plugin_Finalize_Call) RunAndReturn(run func(context.Context, core.TaskExecutionContext) error) *Plugin_Finalize_Call
type Plugin_GetID_Call ¶ added in v1.15.1
Plugin_GetID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetID'
func (*Plugin_GetID_Call) Return ¶ added in v1.15.1
func (_c *Plugin_GetID_Call) Return(_a0 string) *Plugin_GetID_Call
func (*Plugin_GetID_Call) Run ¶ added in v1.15.1
func (_c *Plugin_GetID_Call) Run(run func()) *Plugin_GetID_Call
func (*Plugin_GetID_Call) RunAndReturn ¶ added in v1.15.1
func (_c *Plugin_GetID_Call) RunAndReturn(run func() string) *Plugin_GetID_Call
type Plugin_GetProperties_Call ¶ added in v1.15.1
Plugin_GetProperties_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetProperties'
func (*Plugin_GetProperties_Call) Return ¶ added in v1.15.1
func (_c *Plugin_GetProperties_Call) Return(_a0 core.PluginProperties) *Plugin_GetProperties_Call
func (*Plugin_GetProperties_Call) Run ¶ added in v1.15.1
func (_c *Plugin_GetProperties_Call) Run(run func()) *Plugin_GetProperties_Call
func (*Plugin_GetProperties_Call) RunAndReturn ¶ added in v1.15.1
func (_c *Plugin_GetProperties_Call) RunAndReturn(run func() core.PluginProperties) *Plugin_GetProperties_Call
type Plugin_Handle_Call ¶ added in v1.15.1
Plugin_Handle_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Handle'
func (*Plugin_Handle_Call) Return ¶ added in v1.15.1
func (_c *Plugin_Handle_Call) Return(_a0 core.Transition, _a1 error) *Plugin_Handle_Call
func (*Plugin_Handle_Call) Run ¶ added in v1.15.1
func (_c *Plugin_Handle_Call) Run(run func(ctx context.Context, tCtx core.TaskExecutionContext)) *Plugin_Handle_Call
func (*Plugin_Handle_Call) RunAndReturn ¶ added in v1.15.1
func (_c *Plugin_Handle_Call) RunAndReturn(run func(context.Context, core.TaskExecutionContext) (core.Transition, error)) *Plugin_Handle_Call
type ResourceManager ¶
ResourceManager is an autogenerated mock type for the ResourceManager type
func NewResourceManager ¶ added in v1.15.1
func NewResourceManager(t interface {
mock.TestingT
Cleanup(func())
}) *ResourceManager
NewResourceManager creates a new instance of ResourceManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
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) EXPECT ¶ added in v1.15.1
func (_m *ResourceManager) EXPECT() *ResourceManager_Expecter
func (*ResourceManager) GetID ¶
func (_m *ResourceManager) GetID() string
GetID provides a mock function with given fields:
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_Call ¶ added in v1.15.1
ResourceManager_AllocateResource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AllocateResource'
func (*ResourceManager_AllocateResource_Call) Return ¶ added in v1.15.1
func (_c *ResourceManager_AllocateResource_Call) Return(_a0 core.AllocationStatus, _a1 error) *ResourceManager_AllocateResource_Call
func (*ResourceManager_AllocateResource_Call) Run ¶ added in v1.15.1
func (_c *ResourceManager_AllocateResource_Call) Run(run func(ctx context.Context, namespace core.ResourceNamespace, allocationToken string, constraintsSpec core.ResourceConstraintsSpec)) *ResourceManager_AllocateResource_Call
func (*ResourceManager_AllocateResource_Call) RunAndReturn ¶ added in v1.15.1
func (_c *ResourceManager_AllocateResource_Call) RunAndReturn(run func(context.Context, core.ResourceNamespace, string, core.ResourceConstraintsSpec) (core.AllocationStatus, error)) *ResourceManager_AllocateResource_Call
type ResourceManager_Expecter ¶ added in v1.15.1
type ResourceManager_Expecter struct {
// contains filtered or unexported fields
}
func (*ResourceManager_Expecter) AllocateResource ¶ added in v1.15.1
func (_e *ResourceManager_Expecter) AllocateResource(ctx interface{}, namespace interface{}, allocationToken interface{}, constraintsSpec interface{}) *ResourceManager_AllocateResource_Call
AllocateResource is a helper method to define mock.On call
- ctx context.Context
- namespace core.ResourceNamespace
- allocationToken string
- constraintsSpec core.ResourceConstraintsSpec
func (*ResourceManager_Expecter) GetID ¶ added in v1.15.1
func (_e *ResourceManager_Expecter) GetID() *ResourceManager_GetID_Call
GetID is a helper method to define mock.On call
func (*ResourceManager_Expecter) ReleaseResource ¶ added in v1.15.1
func (_e *ResourceManager_Expecter) ReleaseResource(ctx interface{}, namespace interface{}, allocationToken interface{}) *ResourceManager_ReleaseResource_Call
ReleaseResource is a helper method to define mock.On call
- ctx context.Context
- namespace core.ResourceNamespace
- allocationToken string
type ResourceManager_GetID_Call ¶ added in v1.15.1
ResourceManager_GetID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetID'
func (*ResourceManager_GetID_Call) Return ¶ added in v1.15.1
func (_c *ResourceManager_GetID_Call) Return(_a0 string) *ResourceManager_GetID_Call
func (*ResourceManager_GetID_Call) Run ¶ added in v1.15.1
func (_c *ResourceManager_GetID_Call) Run(run func()) *ResourceManager_GetID_Call
func (*ResourceManager_GetID_Call) RunAndReturn ¶ added in v1.15.1
func (_c *ResourceManager_GetID_Call) RunAndReturn(run func() string) *ResourceManager_GetID_Call
type ResourceManager_ReleaseResource_Call ¶ added in v1.15.1
ResourceManager_ReleaseResource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReleaseResource'
func (*ResourceManager_ReleaseResource_Call) Return ¶ added in v1.15.1
func (_c *ResourceManager_ReleaseResource_Call) Return(_a0 error) *ResourceManager_ReleaseResource_Call
func (*ResourceManager_ReleaseResource_Call) Run ¶ added in v1.15.1
func (_c *ResourceManager_ReleaseResource_Call) Run(run func(ctx context.Context, namespace core.ResourceNamespace, allocationToken string)) *ResourceManager_ReleaseResource_Call
func (*ResourceManager_ReleaseResource_Call) RunAndReturn ¶ added in v1.15.1
func (_c *ResourceManager_ReleaseResource_Call) RunAndReturn(run func(context.Context, core.ResourceNamespace, string) error) *ResourceManager_ReleaseResource_Call
type ResourceNegotiator ¶
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 ¶
func (ResourceNegotiator_RegisterResourceQuota) Return ¶
func (_m ResourceNegotiator_RegisterResourceQuota) Return(_a0 error) *ResourceNegotiator_RegisterResourceQuota
type ResourceRegistrar ¶
ResourceRegistrar is an autogenerated mock type for the ResourceRegistrar type
func NewResourceRegistrar ¶ added in v1.15.1
func NewResourceRegistrar(t interface {
mock.TestingT
Cleanup(func())
}) *ResourceRegistrar
NewResourceRegistrar creates a new instance of ResourceRegistrar. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ResourceRegistrar) EXPECT ¶ added in v1.15.1
func (_m *ResourceRegistrar) EXPECT() *ResourceRegistrar_Expecter
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_Expecter ¶ added in v1.15.1
type ResourceRegistrar_Expecter struct {
// contains filtered or unexported fields
}
func (*ResourceRegistrar_Expecter) RegisterResourceQuota ¶ added in v1.15.1
func (_e *ResourceRegistrar_Expecter) RegisterResourceQuota(ctx interface{}, namespace interface{}, quota interface{}) *ResourceRegistrar_RegisterResourceQuota_Call
RegisterResourceQuota is a helper method to define mock.On call
- ctx context.Context
- namespace core.ResourceNamespace
- quota int
type ResourceRegistrar_RegisterResourceQuota_Call ¶ added in v1.15.1
ResourceRegistrar_RegisterResourceQuota_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterResourceQuota'
func (*ResourceRegistrar_RegisterResourceQuota_Call) Return ¶ added in v1.15.1
func (_c *ResourceRegistrar_RegisterResourceQuota_Call) Return(_a0 error) *ResourceRegistrar_RegisterResourceQuota_Call
func (*ResourceRegistrar_RegisterResourceQuota_Call) Run ¶ added in v1.15.1
func (_c *ResourceRegistrar_RegisterResourceQuota_Call) Run(run func(ctx context.Context, namespace core.ResourceNamespace, quota int)) *ResourceRegistrar_RegisterResourceQuota_Call
func (*ResourceRegistrar_RegisterResourceQuota_Call) RunAndReturn ¶ added in v1.15.1
func (_c *ResourceRegistrar_RegisterResourceQuota_Call) RunAndReturn(run func(context.Context, core.ResourceNamespace, int) error) *ResourceRegistrar_RegisterResourceQuota_Call
type SecretManager ¶
SecretManager is an autogenerated mock type for the SecretManager type
func NewSecretManager ¶ added in v1.15.1
func NewSecretManager(t interface {
mock.TestingT
Cleanup(func())
}) *SecretManager
NewSecretManager creates a new instance of SecretManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SecretManager) EXPECT ¶ added in v1.15.1
func (_m *SecretManager) EXPECT() *SecretManager_Expecter
type SecretManager_Expecter ¶ added in v1.15.1
type SecretManager_Expecter struct {
// contains filtered or unexported fields
}
func (*SecretManager_Expecter) Get ¶ added in v1.15.1
func (_e *SecretManager_Expecter) Get(ctx interface{}, key interface{}) *SecretManager_Get_Call
Get is a helper method to define mock.On call
- ctx context.Context
- key string
type SecretManager_Get_Call ¶ added in v1.15.1
SecretManager_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'
func (*SecretManager_Get_Call) Return ¶ added in v1.15.1
func (_c *SecretManager_Get_Call) Return(_a0 string, _a1 error) *SecretManager_Get_Call
func (*SecretManager_Get_Call) Run ¶ added in v1.15.1
func (_c *SecretManager_Get_Call) Run(run func(ctx context.Context, key string)) *SecretManager_Get_Call
func (*SecretManager_Get_Call) RunAndReturn ¶ added in v1.15.1
func (_c *SecretManager_Get_Call) RunAndReturn(run func(context.Context, string) (string, error)) *SecretManager_Get_Call
type SetupContext ¶
SetupContext is an autogenerated mock type for the SetupContext type
func NewSetupContext ¶ added in v1.15.1
func NewSetupContext(t interface {
mock.TestingT
Cleanup(func())
}) *SetupContext
NewSetupContext creates a new instance of SetupContext. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SetupContext) EXPECT ¶ added in v1.15.1
func (_m *SetupContext) EXPECT() *SetupContext_Expecter
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) 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_Call ¶ added in v1.15.1
SetupContext_EnqueueOwner_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnqueueOwner'
func (*SetupContext_EnqueueOwner_Call) Return ¶ added in v1.15.1
func (_c *SetupContext_EnqueueOwner_Call) Return(_a0 core.EnqueueOwner) *SetupContext_EnqueueOwner_Call
func (*SetupContext_EnqueueOwner_Call) Run ¶ added in v1.15.1
func (_c *SetupContext_EnqueueOwner_Call) Run(run func()) *SetupContext_EnqueueOwner_Call
func (*SetupContext_EnqueueOwner_Call) RunAndReturn ¶ added in v1.15.1
func (_c *SetupContext_EnqueueOwner_Call) RunAndReturn(run func() core.EnqueueOwner) *SetupContext_EnqueueOwner_Call
type SetupContext_Expecter ¶ added in v1.15.1
type SetupContext_Expecter struct {
// contains filtered or unexported fields
}
func (*SetupContext_Expecter) EnqueueOwner ¶ added in v1.15.1
func (_e *SetupContext_Expecter) EnqueueOwner() *SetupContext_EnqueueOwner_Call
EnqueueOwner is a helper method to define mock.On call
func (*SetupContext_Expecter) KubeClient ¶ added in v1.15.1
func (_e *SetupContext_Expecter) KubeClient() *SetupContext_KubeClient_Call
KubeClient is a helper method to define mock.On call
func (*SetupContext_Expecter) MetricsScope ¶ added in v1.15.1
func (_e *SetupContext_Expecter) MetricsScope() *SetupContext_MetricsScope_Call
MetricsScope is a helper method to define mock.On call
func (*SetupContext_Expecter) OwnerKind ¶ added in v1.15.1
func (_e *SetupContext_Expecter) OwnerKind() *SetupContext_OwnerKind_Call
OwnerKind is a helper method to define mock.On call
func (*SetupContext_Expecter) ResourceRegistrar ¶ added in v1.15.1
func (_e *SetupContext_Expecter) ResourceRegistrar() *SetupContext_ResourceRegistrar_Call
ResourceRegistrar is a helper method to define mock.On call
func (*SetupContext_Expecter) SecretManager ¶ added in v1.15.1
func (_e *SetupContext_Expecter) SecretManager() *SetupContext_SecretManager_Call
SecretManager is a helper method to define mock.On call
type SetupContext_KubeClient_Call ¶ added in v1.15.1
SetupContext_KubeClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'KubeClient'
func (*SetupContext_KubeClient_Call) Return ¶ added in v1.15.1
func (_c *SetupContext_KubeClient_Call) Return(_a0 core.KubeClient) *SetupContext_KubeClient_Call
func (*SetupContext_KubeClient_Call) Run ¶ added in v1.15.1
func (_c *SetupContext_KubeClient_Call) Run(run func()) *SetupContext_KubeClient_Call
func (*SetupContext_KubeClient_Call) RunAndReturn ¶ added in v1.15.1
func (_c *SetupContext_KubeClient_Call) RunAndReturn(run func() core.KubeClient) *SetupContext_KubeClient_Call
type SetupContext_MetricsScope_Call ¶ added in v1.15.1
SetupContext_MetricsScope_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MetricsScope'
func (*SetupContext_MetricsScope_Call) Return ¶ added in v1.15.1
func (_c *SetupContext_MetricsScope_Call) Return(_a0 promutils.Scope) *SetupContext_MetricsScope_Call
func (*SetupContext_MetricsScope_Call) Run ¶ added in v1.15.1
func (_c *SetupContext_MetricsScope_Call) Run(run func()) *SetupContext_MetricsScope_Call
func (*SetupContext_MetricsScope_Call) RunAndReturn ¶ added in v1.15.1
func (_c *SetupContext_MetricsScope_Call) RunAndReturn(run func() promutils.Scope) *SetupContext_MetricsScope_Call
type SetupContext_OwnerKind_Call ¶ added in v1.15.1
SetupContext_OwnerKind_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OwnerKind'
func (*SetupContext_OwnerKind_Call) Return ¶ added in v1.15.1
func (_c *SetupContext_OwnerKind_Call) Return(_a0 string) *SetupContext_OwnerKind_Call
func (*SetupContext_OwnerKind_Call) Run ¶ added in v1.15.1
func (_c *SetupContext_OwnerKind_Call) Run(run func()) *SetupContext_OwnerKind_Call
func (*SetupContext_OwnerKind_Call) RunAndReturn ¶ added in v1.15.1
func (_c *SetupContext_OwnerKind_Call) RunAndReturn(run func() string) *SetupContext_OwnerKind_Call
type SetupContext_ResourceRegistrar_Call ¶ added in v1.15.1
SetupContext_ResourceRegistrar_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ResourceRegistrar'
func (*SetupContext_ResourceRegistrar_Call) Return ¶ added in v1.15.1
func (_c *SetupContext_ResourceRegistrar_Call) Return(_a0 core.ResourceRegistrar) *SetupContext_ResourceRegistrar_Call
func (*SetupContext_ResourceRegistrar_Call) Run ¶ added in v1.15.1
func (_c *SetupContext_ResourceRegistrar_Call) Run(run func()) *SetupContext_ResourceRegistrar_Call
func (*SetupContext_ResourceRegistrar_Call) RunAndReturn ¶ added in v1.15.1
func (_c *SetupContext_ResourceRegistrar_Call) RunAndReturn(run func() core.ResourceRegistrar) *SetupContext_ResourceRegistrar_Call
type SetupContext_SecretManager_Call ¶ added in v1.15.1
SetupContext_SecretManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SecretManager'
func (*SetupContext_SecretManager_Call) Return ¶ added in v1.15.1
func (_c *SetupContext_SecretManager_Call) Return(_a0 core.SecretManager) *SetupContext_SecretManager_Call
func (*SetupContext_SecretManager_Call) Run ¶ added in v1.15.1
func (_c *SetupContext_SecretManager_Call) Run(run func()) *SetupContext_SecretManager_Call
func (*SetupContext_SecretManager_Call) RunAndReturn ¶ added in v1.15.1
func (_c *SetupContext_SecretManager_Call) RunAndReturn(run func() core.SecretManager) *SetupContext_SecretManager_Call
type SignalAsync ¶ added in v1.15.1
SignalAsync is an autogenerated mock type for the SignalAsync type
func NewSignalAsync ¶ added in v1.15.1
func NewSignalAsync(t interface {
mock.TestingT
Cleanup(func())
}) *SignalAsync
NewSignalAsync creates a new instance of SignalAsync. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SignalAsync) EXPECT ¶ added in v1.15.1
func (_m *SignalAsync) EXPECT() *SignalAsync_Expecter
func (*SignalAsync) Execute ¶ added in v1.15.1
func (_m *SignalAsync) Execute(ctx context.Context)
Execute provides a mock function with given fields: ctx
type SignalAsync_Execute_Call ¶ added in v1.15.1
SignalAsync_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'
func (*SignalAsync_Execute_Call) Return ¶ added in v1.15.1
func (_c *SignalAsync_Execute_Call) Return() *SignalAsync_Execute_Call
func (*SignalAsync_Execute_Call) Run ¶ added in v1.15.1
func (_c *SignalAsync_Execute_Call) Run(run func(ctx context.Context)) *SignalAsync_Execute_Call
func (*SignalAsync_Execute_Call) RunAndReturn ¶ added in v1.15.1
func (_c *SignalAsync_Execute_Call) RunAndReturn(run func(context.Context)) *SignalAsync_Execute_Call
type SignalAsync_Expecter ¶ added in v1.15.1
type SignalAsync_Expecter struct {
// contains filtered or unexported fields
}
func (*SignalAsync_Expecter) Execute ¶ added in v1.15.1
func (_e *SignalAsync_Expecter) Execute(ctx interface{}) *SignalAsync_Execute_Call
Execute is a helper method to define mock.On call
- ctx context.Context
type TaskExecutionContext ¶
TaskExecutionContext is an autogenerated mock type for the TaskExecutionContext type
func NewTaskExecutionContext ¶ added in v1.15.1
func NewTaskExecutionContext(t interface {
mock.TestingT
Cleanup(func())
}) *TaskExecutionContext
NewTaskExecutionContext creates a new instance of TaskExecutionContext. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
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) EXPECT ¶ added in v1.15.1
func (_m *TaskExecutionContext) EXPECT() *TaskExecutionContext_Expecter
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) 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_Call ¶ added in v1.15.1
TaskExecutionContext_Catalog_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Catalog'
func (*TaskExecutionContext_Catalog_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_Catalog_Call) Return(_a0 catalog.AsyncClient) *TaskExecutionContext_Catalog_Call
func (*TaskExecutionContext_Catalog_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_Catalog_Call) Run(run func()) *TaskExecutionContext_Catalog_Call
func (*TaskExecutionContext_Catalog_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_Catalog_Call) RunAndReturn(run func() catalog.AsyncClient) *TaskExecutionContext_Catalog_Call
type TaskExecutionContext_DataStore_Call ¶ added in v1.15.1
TaskExecutionContext_DataStore_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DataStore'
func (*TaskExecutionContext_DataStore_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_DataStore_Call) Return(_a0 *storage.DataStore) *TaskExecutionContext_DataStore_Call
func (*TaskExecutionContext_DataStore_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_DataStore_Call) Run(run func()) *TaskExecutionContext_DataStore_Call
func (*TaskExecutionContext_DataStore_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_DataStore_Call) RunAndReturn(run func() *storage.DataStore) *TaskExecutionContext_DataStore_Call
type TaskExecutionContext_EventsRecorder_Call ¶ added in v1.15.1
TaskExecutionContext_EventsRecorder_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EventsRecorder'
func (*TaskExecutionContext_EventsRecorder_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_EventsRecorder_Call) Return(_a0 core.EventsRecorder) *TaskExecutionContext_EventsRecorder_Call
func (*TaskExecutionContext_EventsRecorder_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_EventsRecorder_Call) Run(run func()) *TaskExecutionContext_EventsRecorder_Call
func (*TaskExecutionContext_EventsRecorder_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_EventsRecorder_Call) RunAndReturn(run func() core.EventsRecorder) *TaskExecutionContext_EventsRecorder_Call
type TaskExecutionContext_Expecter ¶ added in v1.15.1
type TaskExecutionContext_Expecter struct {
// contains filtered or unexported fields
}
func (*TaskExecutionContext_Expecter) Catalog ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) Catalog() *TaskExecutionContext_Catalog_Call
Catalog is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) DataStore ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) DataStore() *TaskExecutionContext_DataStore_Call
DataStore is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) EventsRecorder ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) EventsRecorder() *TaskExecutionContext_EventsRecorder_Call
EventsRecorder is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) InputReader ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) InputReader() *TaskExecutionContext_InputReader_Call
InputReader is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) OutputWriter ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) OutputWriter() *TaskExecutionContext_OutputWriter_Call
OutputWriter is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) PluginStateReader ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) PluginStateReader() *TaskExecutionContext_PluginStateReader_Call
PluginStateReader is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) PluginStateWriter ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) PluginStateWriter() *TaskExecutionContext_PluginStateWriter_Call
PluginStateWriter is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) ResourceManager ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) ResourceManager() *TaskExecutionContext_ResourceManager_Call
ResourceManager is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) SecretManager ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) SecretManager() *TaskExecutionContext_SecretManager_Call
SecretManager is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) TaskExecutionMetadata ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) TaskExecutionMetadata() *TaskExecutionContext_TaskExecutionMetadata_Call
TaskExecutionMetadata is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) TaskReader ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) TaskReader() *TaskExecutionContext_TaskReader_Call
TaskReader is a helper method to define mock.On call
func (*TaskExecutionContext_Expecter) TaskRefreshIndicator ¶ added in v1.15.1
func (_e *TaskExecutionContext_Expecter) TaskRefreshIndicator() *TaskExecutionContext_TaskRefreshIndicator_Call
TaskRefreshIndicator is a helper method to define mock.On call
type TaskExecutionContext_InputReader_Call ¶ added in v1.15.1
TaskExecutionContext_InputReader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InputReader'
func (*TaskExecutionContext_InputReader_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_InputReader_Call) Return(_a0 io.InputReader) *TaskExecutionContext_InputReader_Call
func (*TaskExecutionContext_InputReader_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_InputReader_Call) Run(run func()) *TaskExecutionContext_InputReader_Call
func (*TaskExecutionContext_InputReader_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_InputReader_Call) RunAndReturn(run func() io.InputReader) *TaskExecutionContext_InputReader_Call
type TaskExecutionContext_OutputWriter_Call ¶ added in v1.15.1
TaskExecutionContext_OutputWriter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OutputWriter'
func (*TaskExecutionContext_OutputWriter_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_OutputWriter_Call) Return(_a0 io.OutputWriter) *TaskExecutionContext_OutputWriter_Call
func (*TaskExecutionContext_OutputWriter_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_OutputWriter_Call) Run(run func()) *TaskExecutionContext_OutputWriter_Call
func (*TaskExecutionContext_OutputWriter_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_OutputWriter_Call) RunAndReturn(run func() io.OutputWriter) *TaskExecutionContext_OutputWriter_Call
type TaskExecutionContext_PluginStateReader_Call ¶ added in v1.15.1
TaskExecutionContext_PluginStateReader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PluginStateReader'
func (*TaskExecutionContext_PluginStateReader_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_PluginStateReader_Call) Return(_a0 core.PluginStateReader) *TaskExecutionContext_PluginStateReader_Call
func (*TaskExecutionContext_PluginStateReader_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_PluginStateReader_Call) Run(run func()) *TaskExecutionContext_PluginStateReader_Call
func (*TaskExecutionContext_PluginStateReader_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_PluginStateReader_Call) RunAndReturn(run func() core.PluginStateReader) *TaskExecutionContext_PluginStateReader_Call
type TaskExecutionContext_PluginStateWriter_Call ¶ added in v1.15.1
TaskExecutionContext_PluginStateWriter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PluginStateWriter'
func (*TaskExecutionContext_PluginStateWriter_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_PluginStateWriter_Call) Return(_a0 core.PluginStateWriter) *TaskExecutionContext_PluginStateWriter_Call
func (*TaskExecutionContext_PluginStateWriter_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_PluginStateWriter_Call) Run(run func()) *TaskExecutionContext_PluginStateWriter_Call
func (*TaskExecutionContext_PluginStateWriter_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_PluginStateWriter_Call) RunAndReturn(run func() core.PluginStateWriter) *TaskExecutionContext_PluginStateWriter_Call
type TaskExecutionContext_ResourceManager_Call ¶ added in v1.15.1
TaskExecutionContext_ResourceManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ResourceManager'
func (*TaskExecutionContext_ResourceManager_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_ResourceManager_Call) Return(_a0 core.ResourceManager) *TaskExecutionContext_ResourceManager_Call
func (*TaskExecutionContext_ResourceManager_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_ResourceManager_Call) Run(run func()) *TaskExecutionContext_ResourceManager_Call
func (*TaskExecutionContext_ResourceManager_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_ResourceManager_Call) RunAndReturn(run func() core.ResourceManager) *TaskExecutionContext_ResourceManager_Call
type TaskExecutionContext_SecretManager_Call ¶ added in v1.15.1
TaskExecutionContext_SecretManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SecretManager'
func (*TaskExecutionContext_SecretManager_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_SecretManager_Call) Return(_a0 core.SecretManager) *TaskExecutionContext_SecretManager_Call
func (*TaskExecutionContext_SecretManager_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_SecretManager_Call) Run(run func()) *TaskExecutionContext_SecretManager_Call
func (*TaskExecutionContext_SecretManager_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_SecretManager_Call) RunAndReturn(run func() core.SecretManager) *TaskExecutionContext_SecretManager_Call
type TaskExecutionContext_TaskExecutionMetadata_Call ¶ added in v1.15.1
TaskExecutionContext_TaskExecutionMetadata_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TaskExecutionMetadata'
func (*TaskExecutionContext_TaskExecutionMetadata_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_TaskExecutionMetadata_Call) Run(run func()) *TaskExecutionContext_TaskExecutionMetadata_Call
func (*TaskExecutionContext_TaskExecutionMetadata_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_TaskExecutionMetadata_Call) RunAndReturn(run func() core.TaskExecutionMetadata) *TaskExecutionContext_TaskExecutionMetadata_Call
type TaskExecutionContext_TaskReader_Call ¶ added in v1.15.1
TaskExecutionContext_TaskReader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TaskReader'
func (*TaskExecutionContext_TaskReader_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_TaskReader_Call) Return(_a0 core.TaskReader) *TaskExecutionContext_TaskReader_Call
func (*TaskExecutionContext_TaskReader_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_TaskReader_Call) Run(run func()) *TaskExecutionContext_TaskReader_Call
func (*TaskExecutionContext_TaskReader_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_TaskReader_Call) RunAndReturn(run func() core.TaskReader) *TaskExecutionContext_TaskReader_Call
type TaskExecutionContext_TaskRefreshIndicator_Call ¶ added in v1.15.1
TaskExecutionContext_TaskRefreshIndicator_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TaskRefreshIndicator'
func (*TaskExecutionContext_TaskRefreshIndicator_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionContext_TaskRefreshIndicator_Call) Return(_a0 core.SignalAsync) *TaskExecutionContext_TaskRefreshIndicator_Call
func (*TaskExecutionContext_TaskRefreshIndicator_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionContext_TaskRefreshIndicator_Call) Run(run func()) *TaskExecutionContext_TaskRefreshIndicator_Call
func (*TaskExecutionContext_TaskRefreshIndicator_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionContext_TaskRefreshIndicator_Call) RunAndReturn(run func() core.SignalAsync) *TaskExecutionContext_TaskRefreshIndicator_Call
type TaskExecutionID ¶
TaskExecutionID is an autogenerated mock type for the TaskExecutionID type
func NewTaskExecutionID ¶ added in v1.15.1
func NewTaskExecutionID(t interface {
mock.TestingT
Cleanup(func())
}) *TaskExecutionID
NewTaskExecutionID creates a new instance of TaskExecutionID. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*TaskExecutionID) EXPECT ¶ added in v1.15.1
func (_m *TaskExecutionID) EXPECT() *TaskExecutionID_Expecter
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() flyteidlcore.TaskExecutionIdentifier
GetID provides a mock function with given fields:
func (*TaskExecutionID) GetUniqueNodeID ¶ added in v1.10.6
func (_m *TaskExecutionID) GetUniqueNodeID() string
GetUniqueNodeID provides a mock function with given fields:
type TaskExecutionID_Expecter ¶ added in v1.15.1
type TaskExecutionID_Expecter struct {
// contains filtered or unexported fields
}
func (*TaskExecutionID_Expecter) GetGeneratedName ¶ added in v1.15.1
func (_e *TaskExecutionID_Expecter) GetGeneratedName() *TaskExecutionID_GetGeneratedName_Call
GetGeneratedName is a helper method to define mock.On call
func (*TaskExecutionID_Expecter) GetGeneratedNameWith ¶ added in v1.15.1
func (_e *TaskExecutionID_Expecter) GetGeneratedNameWith(minLength interface{}, maxLength interface{}) *TaskExecutionID_GetGeneratedNameWith_Call
GetGeneratedNameWith is a helper method to define mock.On call
- minLength int
- maxLength int
func (*TaskExecutionID_Expecter) GetID ¶ added in v1.15.1
func (_e *TaskExecutionID_Expecter) GetID() *TaskExecutionID_GetID_Call
GetID is a helper method to define mock.On call
func (*TaskExecutionID_Expecter) GetUniqueNodeID ¶ added in v1.15.1
func (_e *TaskExecutionID_Expecter) GetUniqueNodeID() *TaskExecutionID_GetUniqueNodeID_Call
GetUniqueNodeID is a helper method to define mock.On call
type TaskExecutionID_GetGeneratedNameWith_Call ¶ added in v1.15.1
TaskExecutionID_GetGeneratedNameWith_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetGeneratedNameWith'
func (*TaskExecutionID_GetGeneratedNameWith_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionID_GetGeneratedNameWith_Call) Return(_a0 string, _a1 error) *TaskExecutionID_GetGeneratedNameWith_Call
func (*TaskExecutionID_GetGeneratedNameWith_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionID_GetGeneratedNameWith_Call) Run(run func(minLength int, maxLength int)) *TaskExecutionID_GetGeneratedNameWith_Call
func (*TaskExecutionID_GetGeneratedNameWith_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionID_GetGeneratedNameWith_Call) RunAndReturn(run func(int, int) (string, error)) *TaskExecutionID_GetGeneratedNameWith_Call
type TaskExecutionID_GetGeneratedName_Call ¶ added in v1.15.1
TaskExecutionID_GetGeneratedName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetGeneratedName'
func (*TaskExecutionID_GetGeneratedName_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionID_GetGeneratedName_Call) Return(_a0 string) *TaskExecutionID_GetGeneratedName_Call
func (*TaskExecutionID_GetGeneratedName_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionID_GetGeneratedName_Call) Run(run func()) *TaskExecutionID_GetGeneratedName_Call
func (*TaskExecutionID_GetGeneratedName_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionID_GetGeneratedName_Call) RunAndReturn(run func() string) *TaskExecutionID_GetGeneratedName_Call
type TaskExecutionID_GetID_Call ¶ added in v1.15.1
TaskExecutionID_GetID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetID'
func (*TaskExecutionID_GetID_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionID_GetID_Call) Return(_a0 flyteidlcore.TaskExecutionIdentifier) *TaskExecutionID_GetID_Call
func (*TaskExecutionID_GetID_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionID_GetID_Call) Run(run func()) *TaskExecutionID_GetID_Call
func (*TaskExecutionID_GetID_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionID_GetID_Call) RunAndReturn(run func() flyteidlcore.TaskExecutionIdentifier) *TaskExecutionID_GetID_Call
type TaskExecutionID_GetUniqueNodeID_Call ¶ added in v1.15.1
TaskExecutionID_GetUniqueNodeID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUniqueNodeID'
func (*TaskExecutionID_GetUniqueNodeID_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionID_GetUniqueNodeID_Call) Return(_a0 string) *TaskExecutionID_GetUniqueNodeID_Call
func (*TaskExecutionID_GetUniqueNodeID_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionID_GetUniqueNodeID_Call) Run(run func()) *TaskExecutionID_GetUniqueNodeID_Call
func (*TaskExecutionID_GetUniqueNodeID_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionID_GetUniqueNodeID_Call) RunAndReturn(run func() string) *TaskExecutionID_GetUniqueNodeID_Call
type TaskExecutionMetadata ¶
TaskExecutionMetadata is an autogenerated mock type for the TaskExecutionMetadata type
func NewTaskExecutionMetadata ¶ added in v1.15.1
func NewTaskExecutionMetadata(t interface {
mock.TestingT
Cleanup(func())
}) *TaskExecutionMetadata
NewTaskExecutionMetadata creates a new instance of TaskExecutionMetadata. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*TaskExecutionMetadata) EXPECT ¶ added in v1.15.1
func (_m *TaskExecutionMetadata) EXPECT() *TaskExecutionMetadata_Expecter
func (*TaskExecutionMetadata) GetAnnotations ¶
func (_m *TaskExecutionMetadata) GetAnnotations() map[string]string
GetAnnotations provides a mock function with given fields:
func (*TaskExecutionMetadata) GetConsoleURL ¶ added in v1.13.0
func (_m *TaskExecutionMetadata) GetConsoleURL() string
GetConsoleURL 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() flyteidlcore.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:
type TaskExecutionMetadata_Expecter ¶ added in v1.15.1
type TaskExecutionMetadata_Expecter struct {
// contains filtered or unexported fields
}
func (*TaskExecutionMetadata_Expecter) GetAnnotations ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetAnnotations() *TaskExecutionMetadata_GetAnnotations_Call
GetAnnotations is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetConsoleURL ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetConsoleURL() *TaskExecutionMetadata_GetConsoleURL_Call
GetConsoleURL is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetEnvironmentVariables ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetEnvironmentVariables() *TaskExecutionMetadata_GetEnvironmentVariables_Call
GetEnvironmentVariables is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetInterruptibleFailureThreshold ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetInterruptibleFailureThreshold() *TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call
GetInterruptibleFailureThreshold is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetK8sServiceAccount ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetK8sServiceAccount() *TaskExecutionMetadata_GetK8sServiceAccount_Call
GetK8sServiceAccount is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetLabels ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetLabels() *TaskExecutionMetadata_GetLabels_Call
GetLabels is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetMaxAttempts ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetMaxAttempts() *TaskExecutionMetadata_GetMaxAttempts_Call
GetMaxAttempts is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetNamespace ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetNamespace() *TaskExecutionMetadata_GetNamespace_Call
GetNamespace is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetOverrides ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetOverrides() *TaskExecutionMetadata_GetOverrides_Call
GetOverrides is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetOwnerID ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetOwnerID() *TaskExecutionMetadata_GetOwnerID_Call
GetOwnerID is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetOwnerReference ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetOwnerReference() *TaskExecutionMetadata_GetOwnerReference_Call
GetOwnerReference is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetPlatformResources ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetPlatformResources() *TaskExecutionMetadata_GetPlatformResources_Call
GetPlatformResources is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetSecurityContext ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetSecurityContext() *TaskExecutionMetadata_GetSecurityContext_Call
GetSecurityContext is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) GetTaskExecutionID ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) GetTaskExecutionID() *TaskExecutionMetadata_GetTaskExecutionID_Call
GetTaskExecutionID is a helper method to define mock.On call
func (*TaskExecutionMetadata_Expecter) IsInterruptible ¶ added in v1.15.1
func (_e *TaskExecutionMetadata_Expecter) IsInterruptible() *TaskExecutionMetadata_IsInterruptible_Call
IsInterruptible is a helper method to define mock.On call
type TaskExecutionMetadata_GetAnnotations_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetAnnotations_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAnnotations'
func (*TaskExecutionMetadata_GetAnnotations_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetAnnotations_Call) Return(_a0 map[string]string) *TaskExecutionMetadata_GetAnnotations_Call
func (*TaskExecutionMetadata_GetAnnotations_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetAnnotations_Call) Run(run func()) *TaskExecutionMetadata_GetAnnotations_Call
func (*TaskExecutionMetadata_GetAnnotations_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetAnnotations_Call) RunAndReturn(run func() map[string]string) *TaskExecutionMetadata_GetAnnotations_Call
type TaskExecutionMetadata_GetConsoleURL_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetConsoleURL_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConsoleURL'
func (*TaskExecutionMetadata_GetConsoleURL_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetConsoleURL_Call) Return(_a0 string) *TaskExecutionMetadata_GetConsoleURL_Call
func (*TaskExecutionMetadata_GetConsoleURL_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetConsoleURL_Call) Run(run func()) *TaskExecutionMetadata_GetConsoleURL_Call
func (*TaskExecutionMetadata_GetConsoleURL_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetConsoleURL_Call) RunAndReturn(run func() string) *TaskExecutionMetadata_GetConsoleURL_Call
type TaskExecutionMetadata_GetEnvironmentVariables_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetEnvironmentVariables_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetEnvironmentVariables'
func (*TaskExecutionMetadata_GetEnvironmentVariables_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetEnvironmentVariables_Call) Return(_a0 map[string]string) *TaskExecutionMetadata_GetEnvironmentVariables_Call
func (*TaskExecutionMetadata_GetEnvironmentVariables_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetEnvironmentVariables_Call) Run(run func()) *TaskExecutionMetadata_GetEnvironmentVariables_Call
func (*TaskExecutionMetadata_GetEnvironmentVariables_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetEnvironmentVariables_Call) RunAndReturn(run func() map[string]string) *TaskExecutionMetadata_GetEnvironmentVariables_Call
type TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetInterruptibleFailureThreshold'
func (*TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call) RunAndReturn(run func() int32) *TaskExecutionMetadata_GetInterruptibleFailureThreshold_Call
type TaskExecutionMetadata_GetK8sServiceAccount_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetK8sServiceAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetK8sServiceAccount'
func (*TaskExecutionMetadata_GetK8sServiceAccount_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetK8sServiceAccount_Call) Return(_a0 string) *TaskExecutionMetadata_GetK8sServiceAccount_Call
func (*TaskExecutionMetadata_GetK8sServiceAccount_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetK8sServiceAccount_Call) Run(run func()) *TaskExecutionMetadata_GetK8sServiceAccount_Call
func (*TaskExecutionMetadata_GetK8sServiceAccount_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetK8sServiceAccount_Call) RunAndReturn(run func() string) *TaskExecutionMetadata_GetK8sServiceAccount_Call
type TaskExecutionMetadata_GetLabels_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetLabels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLabels'
func (*TaskExecutionMetadata_GetLabels_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetLabels_Call) Return(_a0 map[string]string) *TaskExecutionMetadata_GetLabels_Call
func (*TaskExecutionMetadata_GetLabels_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetLabels_Call) Run(run func()) *TaskExecutionMetadata_GetLabels_Call
func (*TaskExecutionMetadata_GetLabels_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetLabels_Call) RunAndReturn(run func() map[string]string) *TaskExecutionMetadata_GetLabels_Call
type TaskExecutionMetadata_GetMaxAttempts_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetMaxAttempts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMaxAttempts'
func (*TaskExecutionMetadata_GetMaxAttempts_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetMaxAttempts_Call) Return(_a0 uint32) *TaskExecutionMetadata_GetMaxAttempts_Call
func (*TaskExecutionMetadata_GetMaxAttempts_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetMaxAttempts_Call) Run(run func()) *TaskExecutionMetadata_GetMaxAttempts_Call
func (*TaskExecutionMetadata_GetMaxAttempts_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetMaxAttempts_Call) RunAndReturn(run func() uint32) *TaskExecutionMetadata_GetMaxAttempts_Call
type TaskExecutionMetadata_GetNamespace_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetNamespace_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetNamespace'
func (*TaskExecutionMetadata_GetNamespace_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetNamespace_Call) Return(_a0 string) *TaskExecutionMetadata_GetNamespace_Call
func (*TaskExecutionMetadata_GetNamespace_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetNamespace_Call) Run(run func()) *TaskExecutionMetadata_GetNamespace_Call
func (*TaskExecutionMetadata_GetNamespace_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetNamespace_Call) RunAndReturn(run func() string) *TaskExecutionMetadata_GetNamespace_Call
type TaskExecutionMetadata_GetOverrides_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetOverrides_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOverrides'
func (*TaskExecutionMetadata_GetOverrides_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetOverrides_Call) Return(_a0 core.TaskOverrides) *TaskExecutionMetadata_GetOverrides_Call
func (*TaskExecutionMetadata_GetOverrides_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetOverrides_Call) Run(run func()) *TaskExecutionMetadata_GetOverrides_Call
func (*TaskExecutionMetadata_GetOverrides_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetOverrides_Call) RunAndReturn(run func() core.TaskOverrides) *TaskExecutionMetadata_GetOverrides_Call
type TaskExecutionMetadata_GetOwnerID_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetOwnerID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOwnerID'
func (*TaskExecutionMetadata_GetOwnerID_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetOwnerID_Call) Return(_a0 types.NamespacedName) *TaskExecutionMetadata_GetOwnerID_Call
func (*TaskExecutionMetadata_GetOwnerID_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetOwnerID_Call) Run(run func()) *TaskExecutionMetadata_GetOwnerID_Call
func (*TaskExecutionMetadata_GetOwnerID_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetOwnerID_Call) RunAndReturn(run func() types.NamespacedName) *TaskExecutionMetadata_GetOwnerID_Call
type TaskExecutionMetadata_GetOwnerReference_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetOwnerReference_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOwnerReference'
func (*TaskExecutionMetadata_GetOwnerReference_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetOwnerReference_Call) Return(_a0 v1.OwnerReference) *TaskExecutionMetadata_GetOwnerReference_Call
func (*TaskExecutionMetadata_GetOwnerReference_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetOwnerReference_Call) Run(run func()) *TaskExecutionMetadata_GetOwnerReference_Call
func (*TaskExecutionMetadata_GetOwnerReference_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetOwnerReference_Call) RunAndReturn(run func() v1.OwnerReference) *TaskExecutionMetadata_GetOwnerReference_Call
type TaskExecutionMetadata_GetPlatformResources_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetPlatformResources_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPlatformResources'
func (*TaskExecutionMetadata_GetPlatformResources_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetPlatformResources_Call) Run(run func()) *TaskExecutionMetadata_GetPlatformResources_Call
func (*TaskExecutionMetadata_GetPlatformResources_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetPlatformResources_Call) RunAndReturn(run func() *corev1.ResourceRequirements) *TaskExecutionMetadata_GetPlatformResources_Call
type TaskExecutionMetadata_GetSecurityContext_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetSecurityContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSecurityContext'
func (*TaskExecutionMetadata_GetSecurityContext_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetSecurityContext_Call) Run(run func()) *TaskExecutionMetadata_GetSecurityContext_Call
func (*TaskExecutionMetadata_GetSecurityContext_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetSecurityContext_Call) RunAndReturn(run func() flyteidlcore.SecurityContext) *TaskExecutionMetadata_GetSecurityContext_Call
type TaskExecutionMetadata_GetTaskExecutionID_Call ¶ added in v1.15.1
TaskExecutionMetadata_GetTaskExecutionID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskExecutionID'
func (*TaskExecutionMetadata_GetTaskExecutionID_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetTaskExecutionID_Call) Run(run func()) *TaskExecutionMetadata_GetTaskExecutionID_Call
func (*TaskExecutionMetadata_GetTaskExecutionID_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_GetTaskExecutionID_Call) RunAndReturn(run func() core.TaskExecutionID) *TaskExecutionMetadata_GetTaskExecutionID_Call
type TaskExecutionMetadata_IsInterruptible_Call ¶ added in v1.15.1
TaskExecutionMetadata_IsInterruptible_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsInterruptible'
func (*TaskExecutionMetadata_IsInterruptible_Call) Return ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_IsInterruptible_Call) Return(_a0 bool) *TaskExecutionMetadata_IsInterruptible_Call
func (*TaskExecutionMetadata_IsInterruptible_Call) Run ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_IsInterruptible_Call) Run(run func()) *TaskExecutionMetadata_IsInterruptible_Call
func (*TaskExecutionMetadata_IsInterruptible_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskExecutionMetadata_IsInterruptible_Call) RunAndReturn(run func() bool) *TaskExecutionMetadata_IsInterruptible_Call
type TaskOverrides ¶
TaskOverrides is an autogenerated mock type for the TaskOverrides type
func NewTaskOverrides ¶ added in v1.15.1
func NewTaskOverrides(t interface {
mock.TestingT
Cleanup(func())
}) *TaskOverrides
NewTaskOverrides creates a new instance of TaskOverrides. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*TaskOverrides) EXPECT ¶ added in v1.15.1
func (_m *TaskOverrides) EXPECT() *TaskOverrides_Expecter
func (*TaskOverrides) GetConfig ¶
func (_m *TaskOverrides) GetConfig() *v1.ConfigMap
GetConfig provides a mock function with given fields:
func (*TaskOverrides) GetContainerImage ¶ added in v1.11.0
func (_m *TaskOverrides) GetContainerImage() string
GetContainerImage provides a mock function with given fields:
func (*TaskOverrides) GetExtendedResources ¶ added in v1.9.20
func (_m *TaskOverrides) GetExtendedResources() *flyteidlcore.ExtendedResources
GetExtendedResources provides a mock function with given fields:
func (*TaskOverrides) GetPodTemplate ¶ added in v1.15.0
func (_m *TaskOverrides) GetPodTemplate() *flyteidlcore.K8SPod
GetPodTemplate provides a mock function with given fields:
func (*TaskOverrides) GetResources ¶
func (_m *TaskOverrides) GetResources() *v1.ResourceRequirements
GetResources provides a mock function with given fields:
type TaskOverrides_Expecter ¶ added in v1.15.1
type TaskOverrides_Expecter struct {
// contains filtered or unexported fields
}
func (*TaskOverrides_Expecter) GetConfig ¶ added in v1.15.1
func (_e *TaskOverrides_Expecter) GetConfig() *TaskOverrides_GetConfig_Call
GetConfig is a helper method to define mock.On call
func (*TaskOverrides_Expecter) GetContainerImage ¶ added in v1.15.1
func (_e *TaskOverrides_Expecter) GetContainerImage() *TaskOverrides_GetContainerImage_Call
GetContainerImage is a helper method to define mock.On call
func (*TaskOverrides_Expecter) GetExtendedResources ¶ added in v1.15.1
func (_e *TaskOverrides_Expecter) GetExtendedResources() *TaskOverrides_GetExtendedResources_Call
GetExtendedResources is a helper method to define mock.On call
func (*TaskOverrides_Expecter) GetPodTemplate ¶ added in v1.15.1
func (_e *TaskOverrides_Expecter) GetPodTemplate() *TaskOverrides_GetPodTemplate_Call
GetPodTemplate is a helper method to define mock.On call
func (*TaskOverrides_Expecter) GetResources ¶ added in v1.15.1
func (_e *TaskOverrides_Expecter) GetResources() *TaskOverrides_GetResources_Call
GetResources is a helper method to define mock.On call
type TaskOverrides_GetConfig_Call ¶ added in v1.15.1
TaskOverrides_GetConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConfig'
func (*TaskOverrides_GetConfig_Call) Return ¶ added in v1.15.1
func (_c *TaskOverrides_GetConfig_Call) Return(_a0 *v1.ConfigMap) *TaskOverrides_GetConfig_Call
func (*TaskOverrides_GetConfig_Call) Run ¶ added in v1.15.1
func (_c *TaskOverrides_GetConfig_Call) Run(run func()) *TaskOverrides_GetConfig_Call
func (*TaskOverrides_GetConfig_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskOverrides_GetConfig_Call) RunAndReturn(run func() *v1.ConfigMap) *TaskOverrides_GetConfig_Call
type TaskOverrides_GetContainerImage_Call ¶ added in v1.15.1
TaskOverrides_GetContainerImage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetContainerImage'
func (*TaskOverrides_GetContainerImage_Call) Return ¶ added in v1.15.1
func (_c *TaskOverrides_GetContainerImage_Call) Return(_a0 string) *TaskOverrides_GetContainerImage_Call
func (*TaskOverrides_GetContainerImage_Call) Run ¶ added in v1.15.1
func (_c *TaskOverrides_GetContainerImage_Call) Run(run func()) *TaskOverrides_GetContainerImage_Call
func (*TaskOverrides_GetContainerImage_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskOverrides_GetContainerImage_Call) RunAndReturn(run func() string) *TaskOverrides_GetContainerImage_Call
type TaskOverrides_GetExtendedResources_Call ¶ added in v1.15.1
TaskOverrides_GetExtendedResources_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetExtendedResources'
func (*TaskOverrides_GetExtendedResources_Call) Return ¶ added in v1.15.1
func (_c *TaskOverrides_GetExtendedResources_Call) Return(_a0 *flyteidlcore.ExtendedResources) *TaskOverrides_GetExtendedResources_Call
func (*TaskOverrides_GetExtendedResources_Call) Run ¶ added in v1.15.1
func (_c *TaskOverrides_GetExtendedResources_Call) Run(run func()) *TaskOverrides_GetExtendedResources_Call
func (*TaskOverrides_GetExtendedResources_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskOverrides_GetExtendedResources_Call) RunAndReturn(run func() *flyteidlcore.ExtendedResources) *TaskOverrides_GetExtendedResources_Call
type TaskOverrides_GetPodTemplate_Call ¶ added in v1.15.1
TaskOverrides_GetPodTemplate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPodTemplate'
func (*TaskOverrides_GetPodTemplate_Call) Return ¶ added in v1.15.1
func (_c *TaskOverrides_GetPodTemplate_Call) Return(_a0 *flyteidlcore.K8SPod) *TaskOverrides_GetPodTemplate_Call
func (*TaskOverrides_GetPodTemplate_Call) Run ¶ added in v1.15.1
func (_c *TaskOverrides_GetPodTemplate_Call) Run(run func()) *TaskOverrides_GetPodTemplate_Call
func (*TaskOverrides_GetPodTemplate_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskOverrides_GetPodTemplate_Call) RunAndReturn(run func() *flyteidlcore.K8SPod) *TaskOverrides_GetPodTemplate_Call
type TaskOverrides_GetResources_Call ¶ added in v1.15.1
TaskOverrides_GetResources_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetResources'
func (*TaskOverrides_GetResources_Call) Return ¶ added in v1.15.1
func (_c *TaskOverrides_GetResources_Call) Return(_a0 *v1.ResourceRequirements) *TaskOverrides_GetResources_Call
func (*TaskOverrides_GetResources_Call) Run ¶ added in v1.15.1
func (_c *TaskOverrides_GetResources_Call) Run(run func()) *TaskOverrides_GetResources_Call
func (*TaskOverrides_GetResources_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskOverrides_GetResources_Call) RunAndReturn(run func() *v1.ResourceRequirements) *TaskOverrides_GetResources_Call
type TaskReader ¶
TaskReader is an autogenerated mock type for the TaskReader type
func NewTaskReader ¶ added in v1.15.1
func NewTaskReader(t interface {
mock.TestingT
Cleanup(func())
}) *TaskReader
NewTaskReader creates a new instance of TaskReader. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*TaskReader) EXPECT ¶ added in v1.15.1
func (_m *TaskReader) EXPECT() *TaskReader_Expecter
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) (*flyteidlcore.TaskTemplate, error)
Read provides a mock function with given fields: ctx
type TaskReader_Expecter ¶ added in v1.15.1
type TaskReader_Expecter struct {
// contains filtered or unexported fields
}
func (*TaskReader_Expecter) Path ¶ added in v1.15.1
func (_e *TaskReader_Expecter) Path(ctx interface{}) *TaskReader_Path_Call
Path is a helper method to define mock.On call
- ctx context.Context
func (*TaskReader_Expecter) Read ¶ added in v1.15.1
func (_e *TaskReader_Expecter) Read(ctx interface{}) *TaskReader_Read_Call
Read is a helper method to define mock.On call
- ctx context.Context
type TaskReader_Path_Call ¶ added in v1.15.1
TaskReader_Path_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Path'
func (*TaskReader_Path_Call) Return ¶ added in v1.15.1
func (_c *TaskReader_Path_Call) Return(_a0 storage.DataReference, _a1 error) *TaskReader_Path_Call
func (*TaskReader_Path_Call) Run ¶ added in v1.15.1
func (_c *TaskReader_Path_Call) Run(run func(ctx context.Context)) *TaskReader_Path_Call
func (*TaskReader_Path_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskReader_Path_Call) RunAndReturn(run func(context.Context) (storage.DataReference, error)) *TaskReader_Path_Call
type TaskReader_Read_Call ¶ added in v1.15.1
TaskReader_Read_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Read'
func (*TaskReader_Read_Call) Return ¶ added in v1.15.1
func (_c *TaskReader_Read_Call) Return(_a0 *flyteidlcore.TaskTemplate, _a1 error) *TaskReader_Read_Call
func (*TaskReader_Read_Call) Run ¶ added in v1.15.1
func (_c *TaskReader_Read_Call) Run(run func(ctx context.Context)) *TaskReader_Read_Call
func (*TaskReader_Read_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskReader_Read_Call) RunAndReturn(run func(context.Context) (*flyteidlcore.TaskTemplate, error)) *TaskReader_Read_Call
type TaskTemplatePath ¶
TaskTemplatePath is an autogenerated mock type for the TaskTemplatePath type
func NewTaskTemplatePath ¶ added in v1.15.1
func NewTaskTemplatePath(t interface {
mock.TestingT
Cleanup(func())
}) *TaskTemplatePath
NewTaskTemplatePath creates a new instance of TaskTemplatePath. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*TaskTemplatePath) EXPECT ¶ added in v1.15.1
func (_m *TaskTemplatePath) EXPECT() *TaskTemplatePath_Expecter
func (*TaskTemplatePath) Path ¶
func (_m *TaskTemplatePath) Path(ctx context.Context) (storage.DataReference, error)
Path provides a mock function with given fields: ctx
type TaskTemplatePath_Expecter ¶ added in v1.15.1
type TaskTemplatePath_Expecter struct {
// contains filtered or unexported fields
}
func (*TaskTemplatePath_Expecter) Path ¶ added in v1.15.1
func (_e *TaskTemplatePath_Expecter) Path(ctx interface{}) *TaskTemplatePath_Path_Call
Path is a helper method to define mock.On call
- ctx context.Context
type TaskTemplatePath_Path_Call ¶ added in v1.15.1
TaskTemplatePath_Path_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Path'
func (*TaskTemplatePath_Path_Call) Return ¶ added in v1.15.1
func (_c *TaskTemplatePath_Path_Call) Return(_a0 storage.DataReference, _a1 error) *TaskTemplatePath_Path_Call
func (*TaskTemplatePath_Path_Call) Run ¶ added in v1.15.1
func (_c *TaskTemplatePath_Path_Call) Run(run func(ctx context.Context)) *TaskTemplatePath_Path_Call
func (*TaskTemplatePath_Path_Call) RunAndReturn ¶ added in v1.15.1
func (_c *TaskTemplatePath_Path_Call) RunAndReturn(run func(context.Context) (storage.DataReference, error)) *TaskTemplatePath_Path_Call
Source Files
¶
- enqueue_owner.go
- events_recorder.go
- fake_k8s_cache.go
- fake_k8s_client.go
- kube_client.go
- plugin.go
- plugin_loader.go
- plugin_state_reader.go
- plugin_state_writer.go
- resource_manager.go
- resource_negotiator.go
- resource_registrar.go
- secret_manager.go
- setup_context.go
- signal_async.go
- task_execution_context.go
- task_execution_id.go
- task_execution_metadata.go
- task_overrides.go
- task_reader.go
- task_template_path.go