operation

package

Go to main page

Versions in this module

v1

v1.3.6

Jun 13, 2023

v1.3.5

Jun 13, 2023

Changes in this version

+ type ExecuteOperationCommand struct

+ OperationId uuid.UUID

type ExecutionContext

+ func (c *ExecutionContext) IsExecutable() ([]string, bool)

+ func (c *ExecutionContext) Pending() error

type Operation

+ func (o *Operation) Pending() error

+ func (o *Operation) Task(task OperationTask)

+ type OperationTask interface

+ Continue func(context ExecutionContext) error

+ Run func(context ExecutionContext) error

+ func NewOperationTask(options OperationTaskOptions) OperationTask

+ type OperationTaskOptions struct

+ Continue OperationFunc

+ Run OperationFunc

+ type Scheduler interface

+ Schedule func(ctx context.Context, operationId uuid.UUID) error

+ func NewScheduler(sender messaging.MessageSender) (Scheduler, error)

+ func NewSchedulerFromConfig(appConfig *config.AppConfig) (Scheduler, error)

v1.3.4

Jun 12, 2023

Changes in this version

+ type AzureDeploymentNameFinder struct

+ func NewAzureDeploymentNameFinder(operation *Operation) (*AzureDeploymentNameFinder, error)

+ func (finder *AzureDeploymentNameFinder) FindUntilDone(ctx context.Context) (string, error)

+ type DeployStageOperationFactory struct

+ func NewDeployStageOperationFactory(repository Repository) *DeployStageOperationFactory

+ func (f *DeployStageOperationFactory) Create(parent *Operation) (DeployStageOperationMap, error)

+ type DeployStageOperationMap map[uuid.UUID]*Operation

+ type FinderResponse struct

+ Name string

+ type OperationError struct

+ func NewError(operation *Operation) *OperationError

+ func (e *OperationError) Error() string

+ type OperationManager struct

+ func CloneManager(manager *OperationManager) *OperationManager

+ func NewManager(db *gorm.DB, sender messaging.MessageSender, notify hook.NotifyFunc) (*OperationManager, error)

+ func (service *OperationManager) Context() context.Context

+ type OperationWatcher interface

+ Watch func(id uuid.UUID, options OperationWatcherOptions) (threading.CancellationToken, error)

+ func NewWatcher(repository Repository) OperationWatcher

+ type OperationWatcherOptions struct

+ Condition func(operation model.InvokedOperation) bool

+ Frequency time.Duration

type Repository

+ Any func(id uuid.UUID) bool

+ type RepositoryFactory func() (Repository, error)

+ func NewRepositoryFactory(appConfig *config.AppConfig) RepositoryFactory

v1.3.3-preview

Jun 12, 2023

v1.3.2

Jun 9, 2023

v1.3.1

Jun 8, 2023

v1.3.0

Jun 6, 2023

Changes in this version

+ type Configure func(i *model.InvokedOperation) error

+ type DryRunFunc func(context.Context, *deployment.AzureDeployment) (*sdk.DryRunResult, error)

+ type ExecutionContext struct

+ func (c *ExecutionContext) Attribute(key model.AttributeKey, v any) error

+ func (c *ExecutionContext) Complete()

+ func (c *ExecutionContext) Context() context.Context

+ func (c *ExecutionContext) Error(err error)

+ func (c *ExecutionContext) Failed() error

+ func (c *ExecutionContext) Operation() *Operation

+ func (c *ExecutionContext) Retry() error

+ func (c *ExecutionContext) Running() error

+ func (c *ExecutionContext) SaveChanges() error

+ func (c *ExecutionContext) Success()

+ func (c *ExecutionContext) Value(v any) error

+ type Executor interface

+ Execute func(context *ExecutionContext) error

+ func NewExecutor(operation OperationFunc) Executor

+ type Operation struct

+ func (o *Operation) Attribute(key model.AttributeKey, v any) error

+ func (o *Operation) Complete() error

+ func (o *Operation) Context() context.Context

+ func (o *Operation) Deployment() *model.Deployment

+ func (o *Operation) Do(fn OperationFunc)

+ func (o *Operation) Execute() error

+ func (o *Operation) Failed() error

+ func (o *Operation) Retry() error

+ func (o *Operation) Running() error

+ func (o *Operation) SaveChanges() error

+ func (o *Operation) Schedule() error

+ func (o *Operation) Success() error

+ func (o *Operation) Value(v any) error

+ type OperationFunc func(context *ExecutionContext) error

+ func WithLogging(operation OperationFunc) OperationFunc

+ type OperationFuncProvider interface

+ Get func(operationType sdk.OperationType) (OperationFunc, error)

+ type OperationService struct

+ func NewService(db *gorm.DB, sender messaging.MessageSender, notify hook.NotifyFunc) (*OperationService, error)

+ func (service *OperationService) Context() context.Context

+ type Repository interface

+ First func(id uuid.UUID) (*Operation, error)

+ New func(operationType sdk.OperationType, configure Configure) (*Operation, error)

+ Provider func(provider OperationFuncProvider) error

+ WithContext func(ctx context.Context)

+ func NewRepository(service *OperationService, provider OperationFuncProvider) (Repository, error)

+ type RetriableError struct

+ Err error

+ RetryAfter time.Duration

+ func (e *RetriableError) Error() string

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