Documentation ¶
Index ¶
- type AsyncPlugin
- func (_m *AsyncPlugin) Create(ctx context.Context, tCtx webapi.TaskExecutionContextReader) (interface{}, interface{}, error)
- func (_m *AsyncPlugin) Delete(ctx context.Context, tCtx webapi.DeleteContext) error
- func (_m *AsyncPlugin) Get(ctx context.Context, tCtx webapi.GetContext) (interface{}, error)
- func (_m *AsyncPlugin) GetConfig() webapi.PluginConfig
- func (_m *AsyncPlugin) OnCreate(ctx context.Context, tCtx webapi.TaskExecutionContextReader) *AsyncPlugin_Create
- func (_m *AsyncPlugin) OnCreateMatch(matchers ...interface{}) *AsyncPlugin_Create
- func (_m *AsyncPlugin) OnDelete(ctx context.Context, tCtx webapi.DeleteContext) *AsyncPlugin_Delete
- func (_m *AsyncPlugin) OnDeleteMatch(matchers ...interface{}) *AsyncPlugin_Delete
- func (_m *AsyncPlugin) OnGet(ctx context.Context, tCtx webapi.GetContext) *AsyncPlugin_Get
- func (_m *AsyncPlugin) OnGetConfig() *AsyncPlugin_GetConfig
- func (_m *AsyncPlugin) OnGetConfigMatch(matchers ...interface{}) *AsyncPlugin_GetConfig
- func (_m *AsyncPlugin) OnGetMatch(matchers ...interface{}) *AsyncPlugin_Get
- func (_m *AsyncPlugin) OnResourceRequirements(ctx context.Context, tCtx webapi.TaskExecutionContextReader) *AsyncPlugin_ResourceRequirements
- func (_m *AsyncPlugin) OnResourceRequirementsMatch(matchers ...interface{}) *AsyncPlugin_ResourceRequirements
- func (_m *AsyncPlugin) OnStatus(ctx context.Context, tCtx webapi.StatusContext) *AsyncPlugin_Status
- func (_m *AsyncPlugin) OnStatusMatch(matchers ...interface{}) *AsyncPlugin_Status
- func (_m *AsyncPlugin) ResourceRequirements(ctx context.Context, tCtx webapi.TaskExecutionContextReader) (core.ResourceNamespace, core.ResourceConstraintsSpec, error)
- func (_m *AsyncPlugin) Status(ctx context.Context, tCtx webapi.StatusContext) (core.PhaseInfo, error)
- type AsyncPlugin_Create
- type AsyncPlugin_Delete
- type AsyncPlugin_Get
- type AsyncPlugin_GetConfig
- type AsyncPlugin_ResourceRequirements
- type AsyncPlugin_Status
- type DeleteContext
- func (_m *DeleteContext) OnReason() *DeleteContext_Reason
- func (_m *DeleteContext) OnReasonMatch(matchers ...interface{}) *DeleteContext_Reason
- func (_m *DeleteContext) OnResourceMeta() *DeleteContext_ResourceMeta
- func (_m *DeleteContext) OnResourceMetaMatch(matchers ...interface{}) *DeleteContext_ResourceMeta
- func (_m *DeleteContext) Reason() string
- func (_m *DeleteContext) ResourceMeta() interface{}
- type DeleteContext_Reason
- type DeleteContext_ResourceMeta
- type GetContext
- type GetContext_ResourceMeta
- type PluginSetupContext
- type PluginSetupContext_MetricsScope
- type RemoteResource
- type Resource
- func (_m *Resource) ID() string
- func (_m *Resource) OnID() *Resource_ID
- func (_m *Resource) OnIDMatch(matchers ...interface{}) *Resource_ID
- func (_m *Resource) OnStatus() *Resource_Status
- func (_m *Resource) OnStatusMatch(matchers ...interface{}) *Resource_Status
- func (_m *Resource) Status() (core.PhaseInfo, error)
- type Resource_ID
- type Resource_Status
- type StatusContext
- func (_m *StatusContext) DataStore() *storage.DataStore
- func (_m *StatusContext) InputReader() io.InputReader
- func (_m *StatusContext) MaxDatasetSizeBytes() int64
- func (_m *StatusContext) OnDataStore() *StatusContext_DataStore
- func (_m *StatusContext) OnDataStoreMatch(matchers ...interface{}) *StatusContext_DataStore
- func (_m *StatusContext) OnInputReader() *StatusContext_InputReader
- func (_m *StatusContext) OnInputReaderMatch(matchers ...interface{}) *StatusContext_InputReader
- func (_m *StatusContext) OnMaxDatasetSizeBytes() *StatusContext_MaxDatasetSizeBytes
- func (_m *StatusContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *StatusContext_MaxDatasetSizeBytes
- func (_m *StatusContext) OnOutputWriter() *StatusContext_OutputWriter
- func (_m *StatusContext) OnOutputWriterMatch(matchers ...interface{}) *StatusContext_OutputWriter
- func (_m *StatusContext) OnResource() *StatusContext_Resource
- func (_m *StatusContext) OnResourceMatch(matchers ...interface{}) *StatusContext_Resource
- func (_m *StatusContext) OnResourceMeta() *StatusContext_ResourceMeta
- func (_m *StatusContext) OnResourceMetaMatch(matchers ...interface{}) *StatusContext_ResourceMeta
- func (_m *StatusContext) OnSecretManager() *StatusContext_SecretManager
- func (_m *StatusContext) OnSecretManagerMatch(matchers ...interface{}) *StatusContext_SecretManager
- func (_m *StatusContext) OnTaskExecutionMetadata() *StatusContext_TaskExecutionMetadata
- func (_m *StatusContext) OnTaskExecutionMetadataMatch(matchers ...interface{}) *StatusContext_TaskExecutionMetadata
- func (_m *StatusContext) OnTaskReader() *StatusContext_TaskReader
- func (_m *StatusContext) OnTaskReaderMatch(matchers ...interface{}) *StatusContext_TaskReader
- func (_m *StatusContext) OutputWriter() io.OutputWriter
- func (_m *StatusContext) Resource() interface{}
- func (_m *StatusContext) ResourceMeta() interface{}
- func (_m *StatusContext) SecretManager() core.SecretManager
- func (_m *StatusContext) TaskExecutionMetadata() core.TaskExecutionMetadata
- func (_m *StatusContext) TaskReader() core.TaskReader
- type StatusContext_DataStore
- type StatusContext_InputReader
- type StatusContext_MaxDatasetSizeBytes
- type StatusContext_OutputWriter
- type StatusContext_Resource
- type StatusContext_ResourceMeta
- type StatusContext_SecretManager
- type StatusContext_TaskExecutionMetadata
- type StatusContext_TaskReader
- type SyncPlugin
- func (_m *SyncPlugin) Do(ctx context.Context, tCtx webapi.TaskExecutionContext) (core.PhaseInfo, error)
- func (_m *SyncPlugin) GetConfig() webapi.PluginConfig
- func (_m *SyncPlugin) OnDo(ctx context.Context, tCtx webapi.TaskExecutionContext) *SyncPlugin_Do
- func (_m *SyncPlugin) OnDoMatch(matchers ...interface{}) *SyncPlugin_Do
- func (_m *SyncPlugin) OnGetConfig() *SyncPlugin_GetConfig
- func (_m *SyncPlugin) OnGetConfigMatch(matchers ...interface{}) *SyncPlugin_GetConfig
- type SyncPlugin_Do
- type SyncPlugin_GetConfig
- type TaskExecutionContext
- func (_m *TaskExecutionContext) DataStore() *storage.DataStore
- func (_m *TaskExecutionContext) InputReader() io.InputReader
- func (_m *TaskExecutionContext) MaxDatasetSizeBytes() int64
- func (_m *TaskExecutionContext) OnDataStore() *TaskExecutionContext_DataStore
- func (_m *TaskExecutionContext) OnDataStoreMatch(matchers ...interface{}) *TaskExecutionContext_DataStore
- func (_m *TaskExecutionContext) OnInputReader() *TaskExecutionContext_InputReader
- func (_m *TaskExecutionContext) OnInputReaderMatch(matchers ...interface{}) *TaskExecutionContext_InputReader
- func (_m *TaskExecutionContext) OnMaxDatasetSizeBytes() *TaskExecutionContext_MaxDatasetSizeBytes
- func (_m *TaskExecutionContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *TaskExecutionContext_MaxDatasetSizeBytes
- func (_m *TaskExecutionContext) OnOutputWriter() *TaskExecutionContext_OutputWriter
- func (_m *TaskExecutionContext) OnOutputWriterMatch(matchers ...interface{}) *TaskExecutionContext_OutputWriter
- func (_m *TaskExecutionContext) OnSecretManager() *TaskExecutionContext_SecretManager
- func (_m *TaskExecutionContext) OnSecretManagerMatch(matchers ...interface{}) *TaskExecutionContext_SecretManager
- func (_m *TaskExecutionContext) OnTaskExecutionMetadata() *TaskExecutionContext_TaskExecutionMetadata
- func (_m *TaskExecutionContext) OnTaskExecutionMetadataMatch(matchers ...interface{}) *TaskExecutionContext_TaskExecutionMetadata
- func (_m *TaskExecutionContext) OnTaskReader() *TaskExecutionContext_TaskReader
- func (_m *TaskExecutionContext) OnTaskReaderMatch(matchers ...interface{}) *TaskExecutionContext_TaskReader
- func (_m *TaskExecutionContext) OutputWriter() io.OutputWriter
- func (_m *TaskExecutionContext) SecretManager() core.SecretManager
- func (_m *TaskExecutionContext) TaskExecutionMetadata() core.TaskExecutionMetadata
- func (_m *TaskExecutionContext) TaskReader() core.TaskReader
- type TaskExecutionContextReader
- func (_m *TaskExecutionContextReader) InputReader() io.InputReader
- func (_m *TaskExecutionContextReader) OnInputReader() *TaskExecutionContextReader_InputReader
- func (_m *TaskExecutionContextReader) OnInputReaderMatch(matchers ...interface{}) *TaskExecutionContextReader_InputReader
- func (_m *TaskExecutionContextReader) OnOutputWriter() *TaskExecutionContextReader_OutputWriter
- func (_m *TaskExecutionContextReader) OnOutputWriterMatch(matchers ...interface{}) *TaskExecutionContextReader_OutputWriter
- func (_m *TaskExecutionContextReader) OnSecretManager() *TaskExecutionContextReader_SecretManager
- func (_m *TaskExecutionContextReader) OnSecretManagerMatch(matchers ...interface{}) *TaskExecutionContextReader_SecretManager
- func (_m *TaskExecutionContextReader) OnTaskExecutionMetadata() *TaskExecutionContextReader_TaskExecutionMetadata
- func (_m *TaskExecutionContextReader) OnTaskExecutionMetadataMatch(matchers ...interface{}) *TaskExecutionContextReader_TaskExecutionMetadata
- func (_m *TaskExecutionContextReader) OnTaskReader() *TaskExecutionContextReader_TaskReader
- func (_m *TaskExecutionContextReader) OnTaskReaderMatch(matchers ...interface{}) *TaskExecutionContextReader_TaskReader
- func (_m *TaskExecutionContextReader) OutputWriter() io.OutputWriter
- func (_m *TaskExecutionContextReader) SecretManager() core.SecretManager
- func (_m *TaskExecutionContextReader) TaskExecutionMetadata() core.TaskExecutionMetadata
- func (_m *TaskExecutionContextReader) TaskReader() core.TaskReader
- type TaskExecutionContextReader_InputReader
- type TaskExecutionContextReader_OutputWriter
- type TaskExecutionContextReader_SecretManager
- type TaskExecutionContextReader_TaskExecutionMetadata
- type TaskExecutionContextReader_TaskReader
- type TaskExecutionContext_DataStore
- type TaskExecutionContext_InputReader
- type TaskExecutionContext_MaxDatasetSizeBytes
- type TaskExecutionContext_OutputWriter
- type TaskExecutionContext_SecretManager
- type TaskExecutionContext_TaskExecutionMetadata
- type TaskExecutionContext_TaskReader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncPlugin ¶
AsyncPlugin is an autogenerated mock type for the AsyncPlugin type
func (*AsyncPlugin) Create ¶
func (_m *AsyncPlugin) Create(ctx context.Context, tCtx webapi.TaskExecutionContextReader) (interface{}, interface{}, error)
Create provides a mock function with given fields: ctx, tCtx
func (*AsyncPlugin) Delete ¶
func (_m *AsyncPlugin) Delete(ctx context.Context, tCtx webapi.DeleteContext) error
Delete provides a mock function with given fields: ctx, tCtx
func (*AsyncPlugin) Get ¶
func (_m *AsyncPlugin) Get(ctx context.Context, tCtx webapi.GetContext) (interface{}, error)
Get provides a mock function with given fields: ctx, tCtx
func (*AsyncPlugin) GetConfig ¶
func (_m *AsyncPlugin) GetConfig() webapi.PluginConfig
GetConfig provides a mock function with given fields:
func (*AsyncPlugin) OnCreate ¶
func (_m *AsyncPlugin) OnCreate(ctx context.Context, tCtx webapi.TaskExecutionContextReader) *AsyncPlugin_Create
func (*AsyncPlugin) OnCreateMatch ¶
func (_m *AsyncPlugin) OnCreateMatch(matchers ...interface{}) *AsyncPlugin_Create
func (*AsyncPlugin) OnDelete ¶
func (_m *AsyncPlugin) OnDelete(ctx context.Context, tCtx webapi.DeleteContext) *AsyncPlugin_Delete
func (*AsyncPlugin) OnDeleteMatch ¶
func (_m *AsyncPlugin) OnDeleteMatch(matchers ...interface{}) *AsyncPlugin_Delete
func (*AsyncPlugin) OnGet ¶
func (_m *AsyncPlugin) OnGet(ctx context.Context, tCtx webapi.GetContext) *AsyncPlugin_Get
func (*AsyncPlugin) OnGetConfig ¶
func (_m *AsyncPlugin) OnGetConfig() *AsyncPlugin_GetConfig
func (*AsyncPlugin) OnGetConfigMatch ¶
func (_m *AsyncPlugin) OnGetConfigMatch(matchers ...interface{}) *AsyncPlugin_GetConfig
func (*AsyncPlugin) OnGetMatch ¶
func (_m *AsyncPlugin) OnGetMatch(matchers ...interface{}) *AsyncPlugin_Get
func (*AsyncPlugin) OnResourceRequirements ¶
func (_m *AsyncPlugin) OnResourceRequirements(ctx context.Context, tCtx webapi.TaskExecutionContextReader) *AsyncPlugin_ResourceRequirements
func (*AsyncPlugin) OnResourceRequirementsMatch ¶
func (_m *AsyncPlugin) OnResourceRequirementsMatch(matchers ...interface{}) *AsyncPlugin_ResourceRequirements
func (*AsyncPlugin) OnStatus ¶
func (_m *AsyncPlugin) OnStatus(ctx context.Context, tCtx webapi.StatusContext) *AsyncPlugin_Status
func (*AsyncPlugin) OnStatusMatch ¶
func (_m *AsyncPlugin) OnStatusMatch(matchers ...interface{}) *AsyncPlugin_Status
func (*AsyncPlugin) ResourceRequirements ¶
func (_m *AsyncPlugin) ResourceRequirements(ctx context.Context, tCtx webapi.TaskExecutionContextReader) (core.ResourceNamespace, core.ResourceConstraintsSpec, error)
ResourceRequirements provides a mock function with given fields: ctx, tCtx
func (*AsyncPlugin) Status ¶
func (_m *AsyncPlugin) Status(ctx context.Context, tCtx webapi.StatusContext) (core.PhaseInfo, error)
Status provides a mock function with given fields: ctx, tCtx
type AsyncPlugin_Create ¶
func (AsyncPlugin_Create) Return ¶
func (_m AsyncPlugin_Create) Return(resourceMeta interface{}, optionalResource interface{}, err error) *AsyncPlugin_Create
type AsyncPlugin_Delete ¶
func (AsyncPlugin_Delete) Return ¶
func (_m AsyncPlugin_Delete) Return(_a0 error) *AsyncPlugin_Delete
type AsyncPlugin_Get ¶
func (AsyncPlugin_Get) Return ¶
func (_m AsyncPlugin_Get) Return(latest interface{}, err error) *AsyncPlugin_Get
type AsyncPlugin_GetConfig ¶
func (AsyncPlugin_GetConfig) Return ¶
func (_m AsyncPlugin_GetConfig) Return(_a0 webapi.PluginConfig) *AsyncPlugin_GetConfig
type AsyncPlugin_ResourceRequirements ¶
func (AsyncPlugin_ResourceRequirements) Return ¶
func (_m AsyncPlugin_ResourceRequirements) Return(namespace core.ResourceNamespace, constraints core.ResourceConstraintsSpec, err error) *AsyncPlugin_ResourceRequirements
type AsyncPlugin_Status ¶
func (AsyncPlugin_Status) Return ¶
func (_m AsyncPlugin_Status) Return(phase core.PhaseInfo, err error) *AsyncPlugin_Status
type DeleteContext ¶
DeleteContext is an autogenerated mock type for the DeleteContext type
func (*DeleteContext) OnReason ¶
func (_m *DeleteContext) OnReason() *DeleteContext_Reason
func (*DeleteContext) OnReasonMatch ¶
func (_m *DeleteContext) OnReasonMatch(matchers ...interface{}) *DeleteContext_Reason
func (*DeleteContext) OnResourceMeta ¶
func (_m *DeleteContext) OnResourceMeta() *DeleteContext_ResourceMeta
func (*DeleteContext) OnResourceMetaMatch ¶
func (_m *DeleteContext) OnResourceMetaMatch(matchers ...interface{}) *DeleteContext_ResourceMeta
func (*DeleteContext) Reason ¶
func (_m *DeleteContext) Reason() string
Reason provides a mock function with given fields:
func (*DeleteContext) ResourceMeta ¶
func (_m *DeleteContext) ResourceMeta() interface{}
ResourceMeta provides a mock function with given fields:
type DeleteContext_Reason ¶
func (DeleteContext_Reason) Return ¶
func (_m DeleteContext_Reason) Return(_a0 string) *DeleteContext_Reason
type DeleteContext_ResourceMeta ¶
func (DeleteContext_ResourceMeta) Return ¶
func (_m DeleteContext_ResourceMeta) Return(_a0 interface{}) *DeleteContext_ResourceMeta
type GetContext ¶
GetContext is an autogenerated mock type for the GetContext type
func (*GetContext) OnResourceMeta ¶
func (_m *GetContext) OnResourceMeta() *GetContext_ResourceMeta
func (*GetContext) OnResourceMetaMatch ¶
func (_m *GetContext) OnResourceMetaMatch(matchers ...interface{}) *GetContext_ResourceMeta
func (*GetContext) ResourceMeta ¶
func (_m *GetContext) ResourceMeta() interface{}
ResourceMeta provides a mock function with given fields:
type GetContext_ResourceMeta ¶
func (GetContext_ResourceMeta) Return ¶
func (_m GetContext_ResourceMeta) Return(_a0 interface{}) *GetContext_ResourceMeta
type PluginSetupContext ¶
PluginSetupContext is an autogenerated mock type for the PluginSetupContext type
func (*PluginSetupContext) MetricsScope ¶
func (_m *PluginSetupContext) MetricsScope() promutils.Scope
MetricsScope provides a mock function with given fields:
func (*PluginSetupContext) OnMetricsScope ¶
func (_m *PluginSetupContext) OnMetricsScope() *PluginSetupContext_MetricsScope
func (*PluginSetupContext) OnMetricsScopeMatch ¶
func (_m *PluginSetupContext) OnMetricsScopeMatch(matchers ...interface{}) *PluginSetupContext_MetricsScope
type PluginSetupContext_MetricsScope ¶
func (PluginSetupContext_MetricsScope) Return ¶
func (_m PluginSetupContext_MetricsScope) Return(_a0 promutils.Scope) *PluginSetupContext_MetricsScope
type RemoteResource ¶
RemoteResource is an autogenerated mock type for the RemoteResource type
type Resource ¶
Resource is an autogenerated mock type for the Resource type
func (*Resource) OnID ¶
func (_m *Resource) OnID() *Resource_ID
func (*Resource) OnIDMatch ¶
func (_m *Resource) OnIDMatch(matchers ...interface{}) *Resource_ID
func (*Resource) OnStatus ¶
func (_m *Resource) OnStatus() *Resource_Status
func (*Resource) OnStatusMatch ¶
func (_m *Resource) OnStatusMatch(matchers ...interface{}) *Resource_Status
type Resource_ID ¶
func (Resource_ID) Return ¶
func (_m Resource_ID) Return(_a0 string) *Resource_ID
type Resource_Status ¶
func (Resource_Status) Return ¶
func (_m Resource_Status) Return(phase core.PhaseInfo, err error) *Resource_Status
type StatusContext ¶
StatusContext is an autogenerated mock type for the StatusContext type
func (*StatusContext) DataStore ¶
func (_m *StatusContext) DataStore() *storage.DataStore
DataStore provides a mock function with given fields:
func (*StatusContext) InputReader ¶
func (_m *StatusContext) InputReader() io.InputReader
InputReader provides a mock function with given fields:
func (*StatusContext) MaxDatasetSizeBytes ¶
func (_m *StatusContext) MaxDatasetSizeBytes() int64
MaxDatasetSizeBytes provides a mock function with given fields:
func (*StatusContext) OnDataStore ¶
func (_m *StatusContext) OnDataStore() *StatusContext_DataStore
func (*StatusContext) OnDataStoreMatch ¶
func (_m *StatusContext) OnDataStoreMatch(matchers ...interface{}) *StatusContext_DataStore
func (*StatusContext) OnInputReader ¶
func (_m *StatusContext) OnInputReader() *StatusContext_InputReader
func (*StatusContext) OnInputReaderMatch ¶
func (_m *StatusContext) OnInputReaderMatch(matchers ...interface{}) *StatusContext_InputReader
func (*StatusContext) OnMaxDatasetSizeBytes ¶
func (_m *StatusContext) OnMaxDatasetSizeBytes() *StatusContext_MaxDatasetSizeBytes
func (*StatusContext) OnMaxDatasetSizeBytesMatch ¶
func (_m *StatusContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *StatusContext_MaxDatasetSizeBytes
func (*StatusContext) OnOutputWriter ¶
func (_m *StatusContext) OnOutputWriter() *StatusContext_OutputWriter
func (*StatusContext) OnOutputWriterMatch ¶
func (_m *StatusContext) OnOutputWriterMatch(matchers ...interface{}) *StatusContext_OutputWriter
func (*StatusContext) OnResource ¶
func (_m *StatusContext) OnResource() *StatusContext_Resource
func (*StatusContext) OnResourceMatch ¶
func (_m *StatusContext) OnResourceMatch(matchers ...interface{}) *StatusContext_Resource
func (*StatusContext) OnResourceMeta ¶
func (_m *StatusContext) OnResourceMeta() *StatusContext_ResourceMeta
func (*StatusContext) OnResourceMetaMatch ¶
func (_m *StatusContext) OnResourceMetaMatch(matchers ...interface{}) *StatusContext_ResourceMeta
func (*StatusContext) OnSecretManager ¶
func (_m *StatusContext) OnSecretManager() *StatusContext_SecretManager
func (*StatusContext) OnSecretManagerMatch ¶
func (_m *StatusContext) OnSecretManagerMatch(matchers ...interface{}) *StatusContext_SecretManager
func (*StatusContext) OnTaskExecutionMetadata ¶
func (_m *StatusContext) OnTaskExecutionMetadata() *StatusContext_TaskExecutionMetadata
func (*StatusContext) OnTaskExecutionMetadataMatch ¶
func (_m *StatusContext) OnTaskExecutionMetadataMatch(matchers ...interface{}) *StatusContext_TaskExecutionMetadata
func (*StatusContext) OnTaskReader ¶
func (_m *StatusContext) OnTaskReader() *StatusContext_TaskReader
func (*StatusContext) OnTaskReaderMatch ¶
func (_m *StatusContext) OnTaskReaderMatch(matchers ...interface{}) *StatusContext_TaskReader
func (*StatusContext) OutputWriter ¶
func (_m *StatusContext) OutputWriter() io.OutputWriter
OutputWriter provides a mock function with given fields:
func (*StatusContext) Resource ¶
func (_m *StatusContext) Resource() interface{}
Resource provides a mock function with given fields:
func (*StatusContext) ResourceMeta ¶
func (_m *StatusContext) ResourceMeta() interface{}
ResourceMeta provides a mock function with given fields:
func (*StatusContext) SecretManager ¶
func (_m *StatusContext) SecretManager() core.SecretManager
SecretManager provides a mock function with given fields:
func (*StatusContext) TaskExecutionMetadata ¶
func (_m *StatusContext) TaskExecutionMetadata() core.TaskExecutionMetadata
TaskExecutionMetadata provides a mock function with given fields:
func (*StatusContext) TaskReader ¶
func (_m *StatusContext) TaskReader() core.TaskReader
TaskReader provides a mock function with given fields:
type StatusContext_DataStore ¶
func (StatusContext_DataStore) Return ¶
func (_m StatusContext_DataStore) Return(_a0 *storage.DataStore) *StatusContext_DataStore
type StatusContext_InputReader ¶
func (StatusContext_InputReader) Return ¶
func (_m StatusContext_InputReader) Return(_a0 io.InputReader) *StatusContext_InputReader
type StatusContext_MaxDatasetSizeBytes ¶
func (StatusContext_MaxDatasetSizeBytes) Return ¶
func (_m StatusContext_MaxDatasetSizeBytes) Return(_a0 int64) *StatusContext_MaxDatasetSizeBytes
type StatusContext_OutputWriter ¶
func (StatusContext_OutputWriter) Return ¶
func (_m StatusContext_OutputWriter) Return(_a0 io.OutputWriter) *StatusContext_OutputWriter
type StatusContext_Resource ¶
func (StatusContext_Resource) Return ¶
func (_m StatusContext_Resource) Return(_a0 interface{}) *StatusContext_Resource
type StatusContext_ResourceMeta ¶
func (StatusContext_ResourceMeta) Return ¶
func (_m StatusContext_ResourceMeta) Return(_a0 interface{}) *StatusContext_ResourceMeta
type StatusContext_SecretManager ¶
func (StatusContext_SecretManager) Return ¶
func (_m StatusContext_SecretManager) Return(_a0 core.SecretManager) *StatusContext_SecretManager
type StatusContext_TaskExecutionMetadata ¶
func (StatusContext_TaskExecutionMetadata) Return ¶
func (_m StatusContext_TaskExecutionMetadata) Return(_a0 core.TaskExecutionMetadata) *StatusContext_TaskExecutionMetadata
type StatusContext_TaskReader ¶
func (StatusContext_TaskReader) Return ¶
func (_m StatusContext_TaskReader) Return(_a0 core.TaskReader) *StatusContext_TaskReader
type SyncPlugin ¶
SyncPlugin is an autogenerated mock type for the SyncPlugin type
func (*SyncPlugin) Do ¶
func (_m *SyncPlugin) Do(ctx context.Context, tCtx webapi.TaskExecutionContext) (core.PhaseInfo, error)
Do provides a mock function with given fields: ctx, tCtx
func (*SyncPlugin) GetConfig ¶
func (_m *SyncPlugin) GetConfig() webapi.PluginConfig
GetConfig provides a mock function with given fields:
func (*SyncPlugin) OnDo ¶
func (_m *SyncPlugin) OnDo(ctx context.Context, tCtx webapi.TaskExecutionContext) *SyncPlugin_Do
func (*SyncPlugin) OnDoMatch ¶
func (_m *SyncPlugin) OnDoMatch(matchers ...interface{}) *SyncPlugin_Do
func (*SyncPlugin) OnGetConfig ¶
func (_m *SyncPlugin) OnGetConfig() *SyncPlugin_GetConfig
func (*SyncPlugin) OnGetConfigMatch ¶
func (_m *SyncPlugin) OnGetConfigMatch(matchers ...interface{}) *SyncPlugin_GetConfig
type SyncPlugin_Do ¶
func (SyncPlugin_Do) Return ¶
func (_m SyncPlugin_Do) Return(phase core.PhaseInfo, err error) *SyncPlugin_Do
type SyncPlugin_GetConfig ¶
func (SyncPlugin_GetConfig) Return ¶
func (_m SyncPlugin_GetConfig) Return(_a0 webapi.PluginConfig) *SyncPlugin_GetConfig
type TaskExecutionContext ¶
TaskExecutionContext is an autogenerated mock type for the TaskExecutionContext type
func (*TaskExecutionContext) DataStore ¶
func (_m *TaskExecutionContext) DataStore() *storage.DataStore
DataStore provides a mock function with given fields:
func (*TaskExecutionContext) InputReader ¶
func (_m *TaskExecutionContext) InputReader() io.InputReader
InputReader provides a mock function with given fields:
func (*TaskExecutionContext) MaxDatasetSizeBytes ¶
func (_m *TaskExecutionContext) MaxDatasetSizeBytes() int64
MaxDatasetSizeBytes provides a mock function with given fields:
func (*TaskExecutionContext) OnDataStore ¶
func (_m *TaskExecutionContext) OnDataStore() *TaskExecutionContext_DataStore
func (*TaskExecutionContext) OnDataStoreMatch ¶
func (_m *TaskExecutionContext) OnDataStoreMatch(matchers ...interface{}) *TaskExecutionContext_DataStore
func (*TaskExecutionContext) OnInputReader ¶
func (_m *TaskExecutionContext) OnInputReader() *TaskExecutionContext_InputReader
func (*TaskExecutionContext) OnInputReaderMatch ¶
func (_m *TaskExecutionContext) OnInputReaderMatch(matchers ...interface{}) *TaskExecutionContext_InputReader
func (*TaskExecutionContext) OnMaxDatasetSizeBytes ¶
func (_m *TaskExecutionContext) OnMaxDatasetSizeBytes() *TaskExecutionContext_MaxDatasetSizeBytes
func (*TaskExecutionContext) OnMaxDatasetSizeBytesMatch ¶
func (_m *TaskExecutionContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *TaskExecutionContext_MaxDatasetSizeBytes
func (*TaskExecutionContext) OnOutputWriter ¶
func (_m *TaskExecutionContext) OnOutputWriter() *TaskExecutionContext_OutputWriter
func (*TaskExecutionContext) OnOutputWriterMatch ¶
func (_m *TaskExecutionContext) OnOutputWriterMatch(matchers ...interface{}) *TaskExecutionContext_OutputWriter
func (*TaskExecutionContext) OnSecretManager ¶
func (_m *TaskExecutionContext) OnSecretManager() *TaskExecutionContext_SecretManager
func (*TaskExecutionContext) OnSecretManagerMatch ¶
func (_m *TaskExecutionContext) OnSecretManagerMatch(matchers ...interface{}) *TaskExecutionContext_SecretManager
func (*TaskExecutionContext) OnTaskExecutionMetadata ¶
func (_m *TaskExecutionContext) OnTaskExecutionMetadata() *TaskExecutionContext_TaskExecutionMetadata
func (*TaskExecutionContext) OnTaskExecutionMetadataMatch ¶
func (_m *TaskExecutionContext) OnTaskExecutionMetadataMatch(matchers ...interface{}) *TaskExecutionContext_TaskExecutionMetadata
func (*TaskExecutionContext) OnTaskReader ¶
func (_m *TaskExecutionContext) OnTaskReader() *TaskExecutionContext_TaskReader
func (*TaskExecutionContext) OnTaskReaderMatch ¶
func (_m *TaskExecutionContext) OnTaskReaderMatch(matchers ...interface{}) *TaskExecutionContext_TaskReader
func (*TaskExecutionContext) OutputWriter ¶
func (_m *TaskExecutionContext) OutputWriter() io.OutputWriter
OutputWriter 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:
type TaskExecutionContextReader ¶
TaskExecutionContextReader is an autogenerated mock type for the TaskExecutionContextReader type
func (*TaskExecutionContextReader) InputReader ¶
func (_m *TaskExecutionContextReader) InputReader() io.InputReader
InputReader provides a mock function with given fields:
func (*TaskExecutionContextReader) OnInputReader ¶
func (_m *TaskExecutionContextReader) OnInputReader() *TaskExecutionContextReader_InputReader
func (*TaskExecutionContextReader) OnInputReaderMatch ¶
func (_m *TaskExecutionContextReader) OnInputReaderMatch(matchers ...interface{}) *TaskExecutionContextReader_InputReader
func (*TaskExecutionContextReader) OnOutputWriter ¶
func (_m *TaskExecutionContextReader) OnOutputWriter() *TaskExecutionContextReader_OutputWriter
func (*TaskExecutionContextReader) OnOutputWriterMatch ¶
func (_m *TaskExecutionContextReader) OnOutputWriterMatch(matchers ...interface{}) *TaskExecutionContextReader_OutputWriter
func (*TaskExecutionContextReader) OnSecretManager ¶
func (_m *TaskExecutionContextReader) OnSecretManager() *TaskExecutionContextReader_SecretManager
func (*TaskExecutionContextReader) OnSecretManagerMatch ¶
func (_m *TaskExecutionContextReader) OnSecretManagerMatch(matchers ...interface{}) *TaskExecutionContextReader_SecretManager
func (*TaskExecutionContextReader) OnTaskExecutionMetadata ¶
func (_m *TaskExecutionContextReader) OnTaskExecutionMetadata() *TaskExecutionContextReader_TaskExecutionMetadata
func (*TaskExecutionContextReader) OnTaskExecutionMetadataMatch ¶
func (_m *TaskExecutionContextReader) OnTaskExecutionMetadataMatch(matchers ...interface{}) *TaskExecutionContextReader_TaskExecutionMetadata
func (*TaskExecutionContextReader) OnTaskReader ¶
func (_m *TaskExecutionContextReader) OnTaskReader() *TaskExecutionContextReader_TaskReader
func (*TaskExecutionContextReader) OnTaskReaderMatch ¶
func (_m *TaskExecutionContextReader) OnTaskReaderMatch(matchers ...interface{}) *TaskExecutionContextReader_TaskReader
func (*TaskExecutionContextReader) OutputWriter ¶
func (_m *TaskExecutionContextReader) OutputWriter() io.OutputWriter
OutputWriter provides a mock function with given fields:
func (*TaskExecutionContextReader) SecretManager ¶
func (_m *TaskExecutionContextReader) SecretManager() core.SecretManager
SecretManager provides a mock function with given fields:
func (*TaskExecutionContextReader) TaskExecutionMetadata ¶
func (_m *TaskExecutionContextReader) TaskExecutionMetadata() core.TaskExecutionMetadata
TaskExecutionMetadata provides a mock function with given fields:
func (*TaskExecutionContextReader) TaskReader ¶
func (_m *TaskExecutionContextReader) TaskReader() core.TaskReader
TaskReader provides a mock function with given fields:
type TaskExecutionContextReader_InputReader ¶
func (TaskExecutionContextReader_InputReader) Return ¶
func (_m TaskExecutionContextReader_InputReader) Return(_a0 io.InputReader) *TaskExecutionContextReader_InputReader
type TaskExecutionContextReader_OutputWriter ¶
func (TaskExecutionContextReader_OutputWriter) Return ¶
func (_m TaskExecutionContextReader_OutputWriter) Return(_a0 io.OutputWriter) *TaskExecutionContextReader_OutputWriter
type TaskExecutionContextReader_SecretManager ¶
func (TaskExecutionContextReader_SecretManager) Return ¶
func (_m TaskExecutionContextReader_SecretManager) Return(_a0 core.SecretManager) *TaskExecutionContextReader_SecretManager
type TaskExecutionContextReader_TaskExecutionMetadata ¶
type TaskExecutionContextReader_TaskReader ¶
func (TaskExecutionContextReader_TaskReader) Return ¶
func (_m TaskExecutionContextReader_TaskReader) Return(_a0 core.TaskReader) *TaskExecutionContextReader_TaskReader
type TaskExecutionContext_DataStore ¶
func (TaskExecutionContext_DataStore) Return ¶
func (_m TaskExecutionContext_DataStore) Return(_a0 *storage.DataStore) *TaskExecutionContext_DataStore
type TaskExecutionContext_InputReader ¶
func (TaskExecutionContext_InputReader) Return ¶
func (_m TaskExecutionContext_InputReader) Return(_a0 io.InputReader) *TaskExecutionContext_InputReader
type TaskExecutionContext_MaxDatasetSizeBytes ¶
func (TaskExecutionContext_MaxDatasetSizeBytes) Return ¶
func (_m TaskExecutionContext_MaxDatasetSizeBytes) Return(_a0 int64) *TaskExecutionContext_MaxDatasetSizeBytes
type TaskExecutionContext_OutputWriter ¶
func (TaskExecutionContext_OutputWriter) Return ¶
func (_m TaskExecutionContext_OutputWriter) Return(_a0 io.OutputWriter) *TaskExecutionContext_OutputWriter
type TaskExecutionContext_SecretManager ¶
func (TaskExecutionContext_SecretManager) Return ¶
func (_m TaskExecutionContext_SecretManager) Return(_a0 core.SecretManager) *TaskExecutionContext_SecretManager
type TaskExecutionContext_TaskExecutionMetadata ¶
type TaskExecutionContext_TaskReader ¶
func (TaskExecutionContext_TaskReader) Return ¶
func (_m TaskExecutionContext_TaskReader) Return(_a0 core.TaskReader) *TaskExecutionContext_TaskReader