controller

May 23, 2025

Changes in this version

type BaseController

+ func (b *BaseController) UcpClient() *v20231001preview.ClientFactory

type Options

+ UcpClient *v20231001preview.ClientFactory

Jan 9, 2025

Changes in this version

type BaseController

+ func (b *BaseController) DatabaseClient() database.Client

type Controller

+ DatabaseClient func() database.Client

type Options

+ DatabaseClient database.Client

+ func (o Options) Validate() error

Sep 14, 2023

Changes in this version

+ var DefaultAsyncOperationTimeout = time.Duration(120) * time.Second

+ type BaseController struct

+ func NewBaseAsyncController(options Options) BaseController

+ func (b *BaseController) DataProvider() dataprovider.DataStorageProvider

+ func (b *BaseController) DeploymentProcessor() deployment.DeploymentProcessor

+ func (b *BaseController) KubeClient() runtimeclient.Client

+ func (b *BaseController) ResourceType() string

+ func (b *BaseController) StorageClient() store.StorageClient

+ type Controller interface

+ Run func(ctx context.Context, request *Request) (Result, error)

+ StorageClient func() store.StorageClient

+ type Options struct

+ DataProvider dataprovider.DataStorageProvider

+ GetDeploymentProcessor func() deployment.DeploymentProcessor

+ KubeClient runtimeclient.Client

+ ResourceType string

+ StorageClient store.StorageClient

+ type Request struct

+ APIVersion string

+ AcceptLanguage string

+ ClientObjectID string

+ CorrelationID string

+ HomeTenantID string

+ OperationID uuid.UUID

+ OperationTimeout *time.Duration

+ OperationType string

+ ResourceID string

+ TraceparentID string

+ func (r *Request) ARMRequestContext() (*v1.ARMRequestContext, error)

+ func (r *Request) Timeout() time.Duration

+ type Result struct

+ Error *v1.ErrorDetails

+ Requeue bool

+ func NewCanceledResult(message string) Result

+ func NewFailedResult(err v1.ErrorDetails) Result

+ func (r *Result) ProvisioningState() v1.ProvisioningState

+ func (r *Result) SetCanceled(message string)

+ func (r *Result) SetFailed(err v1.ErrorDetails, requeue bool)

+ func (r *Result) SetProvisioningState(s v1.ProvisioningState)