Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + type AsyncPlugin struct + 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 struct + func (_m AsyncPlugin_Create) Return(resourceMeta interface{}, optionalResource interface{}, err error) *AsyncPlugin_Create + type AsyncPlugin_Delete struct + func (_m AsyncPlugin_Delete) Return(_a0 error) *AsyncPlugin_Delete + type AsyncPlugin_Get struct + func (_m AsyncPlugin_Get) Return(latest interface{}, err error) *AsyncPlugin_Get + type AsyncPlugin_GetConfig struct + func (_m AsyncPlugin_GetConfig) Return(_a0 webapi.PluginConfig) *AsyncPlugin_GetConfig + type AsyncPlugin_ResourceRequirements struct + func (_m AsyncPlugin_ResourceRequirements) Return(namespace core.ResourceNamespace, constraints core.ResourceConstraintsSpec, ...) *AsyncPlugin_ResourceRequirements + type AsyncPlugin_Status struct + func (_m AsyncPlugin_Status) Return(phase core.PhaseInfo, err error) *AsyncPlugin_Status + type DeleteContext struct + 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 struct + func (_m DeleteContext_Reason) Return(_a0 string) *DeleteContext_Reason + type DeleteContext_ResourceMeta struct + func (_m DeleteContext_ResourceMeta) Return(_a0 interface{}) *DeleteContext_ResourceMeta + type GetContext struct + func (_m *GetContext) OnResourceMeta() *GetContext_ResourceMeta + func (_m *GetContext) OnResourceMetaMatch(matchers ...interface{}) *GetContext_ResourceMeta + func (_m *GetContext) ResourceMeta() interface{} + type GetContext_ResourceMeta struct + func (_m GetContext_ResourceMeta) Return(_a0 interface{}) *GetContext_ResourceMeta + type Plugin struct + func (_m *Plugin) GetConfig() webapi.PluginConfig + func (_m *Plugin) OnGetConfig() *Plugin_GetConfig + func (_m *Plugin) OnGetConfigMatch(matchers ...interface{}) *Plugin_GetConfig + type PluginSetupContext struct + func (_m *PluginSetupContext) MetricsScope() promutils.Scope + func (_m *PluginSetupContext) OnMetricsScope() *PluginSetupContext_MetricsScope + func (_m *PluginSetupContext) OnMetricsScopeMatch(matchers ...interface{}) *PluginSetupContext_MetricsScope + type PluginSetupContext_MetricsScope struct + func (_m PluginSetupContext_MetricsScope) Return(_a0 promutils.Scope) *PluginSetupContext_MetricsScope + type Plugin_GetConfig struct + func (_m Plugin_GetConfig) Return(_a0 webapi.PluginConfig) *Plugin_GetConfig + type RemoteResource struct + type Resource struct + 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 struct + func (_m Resource_ID) Return(_a0 string) *Resource_ID + type Resource_Status struct + func (_m Resource_Status) Return(phase core.PhaseInfo, err error) *Resource_Status + type StatusContext struct + 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 struct + func (_m StatusContext_DataStore) Return(_a0 *storage.DataStore) *StatusContext_DataStore + type StatusContext_InputReader struct + func (_m StatusContext_InputReader) Return(_a0 io.InputReader) *StatusContext_InputReader + type StatusContext_MaxDatasetSizeBytes struct + func (_m StatusContext_MaxDatasetSizeBytes) Return(_a0 int64) *StatusContext_MaxDatasetSizeBytes + type StatusContext_OutputWriter struct + func (_m StatusContext_OutputWriter) Return(_a0 io.OutputWriter) *StatusContext_OutputWriter + type StatusContext_Resource struct + func (_m StatusContext_Resource) Return(_a0 interface{}) *StatusContext_Resource + type StatusContext_ResourceMeta struct + func (_m StatusContext_ResourceMeta) Return(_a0 interface{}) *StatusContext_ResourceMeta + type StatusContext_SecretManager struct + func (_m StatusContext_SecretManager) Return(_a0 core.SecretManager) *StatusContext_SecretManager + type StatusContext_TaskExecutionMetadata struct + func (_m StatusContext_TaskExecutionMetadata) Return(_a0 core.TaskExecutionMetadata) *StatusContext_TaskExecutionMetadata + type StatusContext_TaskReader struct + func (_m StatusContext_TaskReader) Return(_a0 core.TaskReader) *StatusContext_TaskReader + type SyncPlugin struct + 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 struct + func (_m SyncPlugin_Do) Return(phase core.PhaseInfo, err error) *SyncPlugin_Do + type SyncPlugin_GetConfig struct + func (_m SyncPlugin_GetConfig) Return(_a0 webapi.PluginConfig) *SyncPlugin_GetConfig + type TaskExecutionContext struct + 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 struct + 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 struct + func (_m TaskExecutionContextReader_InputReader) Return(_a0 io.InputReader) *TaskExecutionContextReader_InputReader + type TaskExecutionContextReader_OutputWriter struct + func (_m TaskExecutionContextReader_OutputWriter) Return(_a0 io.OutputWriter) *TaskExecutionContextReader_OutputWriter + type TaskExecutionContextReader_SecretManager struct + func (_m TaskExecutionContextReader_SecretManager) Return(_a0 core.SecretManager) *TaskExecutionContextReader_SecretManager + type TaskExecutionContextReader_TaskExecutionMetadata struct + func (_m TaskExecutionContextReader_TaskExecutionMetadata) Return(_a0 core.TaskExecutionMetadata) *TaskExecutionContextReader_TaskExecutionMetadata + type TaskExecutionContextReader_TaskReader struct + func (_m TaskExecutionContextReader_TaskReader) Return(_a0 core.TaskReader) *TaskExecutionContextReader_TaskReader + type TaskExecutionContext_DataStore struct + func (_m TaskExecutionContext_DataStore) Return(_a0 *storage.DataStore) *TaskExecutionContext_DataStore + type TaskExecutionContext_InputReader struct + func (_m TaskExecutionContext_InputReader) Return(_a0 io.InputReader) *TaskExecutionContext_InputReader + type TaskExecutionContext_MaxDatasetSizeBytes struct + func (_m TaskExecutionContext_MaxDatasetSizeBytes) Return(_a0 int64) *TaskExecutionContext_MaxDatasetSizeBytes + type TaskExecutionContext_OutputWriter struct + func (_m TaskExecutionContext_OutputWriter) Return(_a0 io.OutputWriter) *TaskExecutionContext_OutputWriter + type TaskExecutionContext_SecretManager struct + func (_m TaskExecutionContext_SecretManager) Return(_a0 core.SecretManager) *TaskExecutionContext_SecretManager + type TaskExecutionContext_TaskExecutionMetadata struct + func (_m TaskExecutionContext_TaskExecutionMetadata) Return(_a0 core.TaskExecutionMetadata) *TaskExecutionContext_TaskExecutionMetadata + type TaskExecutionContext_TaskReader struct + func (_m TaskExecutionContext_TaskReader) Return(_a0 core.TaskReader) *TaskExecutionContext_TaskReader
Go to main page