Documentation
¶
Index ¶
- func UndoCreateDedicatedService(ctx context.Context, in CreateDedicatedServiceIn, ...) error
- func UndoCreateSharedService(ctx context.Context, in CreateSharedServiceIn, out CreateSharedServiceOut) error
- func UndoDecrementAssociationCount(ctx context.Context, in DecrementAssociationCountIn, ...) error
- func UndoDeleteDedicatedPool(ctx context.Context, in DeleteDedicatedPoolIn, out DeleteDedicatedPoolOut) error
- func UndoDeleteDedicatedService(ctx context.Context, in DeleteDedicatedServiceIn, ...) error
- func UndoIncrementAssociationCount(ctx context.Context, in IncrementAssociationCountIn, ...) error
- func UndoWaitForDedicatedPool(ctx context.Context, in WaitForDedicatedPoolIn, out WaitForDedicatedPoolOut) error
- func UndoWaitForDedicatedService(ctx context.Context, in WaitForDedicatedServiceIn, ...) error
- func UndoWaitForSharedPool(ctx context.Context, in WaitForSharedPoolIn, out WaitForSharedPoolOut) error
- func UndoWaitForSharedService(ctx context.Context, in WaitForSharedServiceIn, out WaitForSharedServiceOut) error
- type AddonConfig
- type BaseProvider
- type CreateDedicatedServiceIn
- type CreateDedicatedServiceOut
- type CreateSharedServiceIn
- type CreateSharedServiceOut
- type DecrementAssociationCountIn
- type DecrementAssociationCountOut
- type DeleteDedicatedPoolIn
- type DeleteDedicatedPoolOut
- type DeleteDedicatedServiceIn
- type DeleteDedicatedServiceOut
- type IncrementAssociationCountIn
- type IncrementAssociationCountOut
- type ServerCounter
- type WaitForDedicatedPoolIn
- type WaitForDedicatedPoolOut
- type WaitForDedicatedServiceIn
- type WaitForDedicatedServiceOut
- type WaitForSharedPoolIn
- type WaitForSharedPoolOut
- type WaitForSharedServiceIn
- type WaitForSharedServiceOut
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func UndoCreateDedicatedService ¶
func UndoCreateDedicatedService(ctx context.Context, in CreateDedicatedServiceIn, out CreateDedicatedServiceOut) error
func UndoCreateSharedService ¶
func UndoCreateSharedService(ctx context.Context, in CreateSharedServiceIn, out CreateSharedServiceOut) error
func UndoDecrementAssociationCount ¶
func UndoDecrementAssociationCount(ctx context.Context, in DecrementAssociationCountIn, out DecrementAssociationCountOut) error
func UndoDeleteDedicatedPool ¶
func UndoDeleteDedicatedPool(ctx context.Context, in DeleteDedicatedPoolIn, out DeleteDedicatedPoolOut) error
func UndoDeleteDedicatedService ¶
func UndoDeleteDedicatedService(ctx context.Context, in DeleteDedicatedServiceIn, out DeleteDedicatedServiceOut) error
func UndoIncrementAssociationCount ¶
func UndoIncrementAssociationCount(ctx context.Context, in IncrementAssociationCountIn, out IncrementAssociationCountOut) error
func UndoWaitForDedicatedPool ¶
func UndoWaitForDedicatedPool(ctx context.Context, in WaitForDedicatedPoolIn, out WaitForDedicatedPoolOut) error
func UndoWaitForDedicatedService ¶
func UndoWaitForDedicatedService(ctx context.Context, in WaitForDedicatedServiceIn, out WaitForDedicatedServiceOut) error
func UndoWaitForSharedPool ¶
func UndoWaitForSharedPool(ctx context.Context, in WaitForSharedPoolIn, out WaitForSharedPoolOut) error
func UndoWaitForSharedService ¶
func UndoWaitForSharedService(ctx context.Context, in WaitForSharedServiceIn, out WaitForSharedServiceOut) error
Types ¶
type AddonConfig ¶
AddonConfig holds database-agnostic configuration that shared saga actions use instead of referencing provider-specific package constants. Inject via saga.Using() and retrieve with saga.Get[*AddonConfig](ctx).
type BaseProvider ¶
type BaseProvider struct {
Fw *addon.ProviderFramework
Log *slog.Logger
}
BaseProvider holds fields and methods common to all on-cluster database addon providers. Embed it in provider structs to avoid duplicating LocalityMode and AdjustEnvVars.
func (*BaseProvider) AdjustEnvVars ¶
func (p *BaseProvider) AdjustEnvVars(_ context.Context, result *addon.ProvisionResult, _ addon.AddonAssociation, _ []string) ([]addon.Variable, error)
func (*BaseProvider) LocalityMode ¶
func (p *BaseProvider) LocalityMode() addon.LocalityMode
type CreateDedicatedServiceOut ¶
func CreateDedicatedService ¶
func CreateDedicatedService(ctx context.Context, in CreateDedicatedServiceIn) (CreateDedicatedServiceOut, error)
type CreateSharedServiceIn ¶
type CreateSharedServiceIn struct{}
type CreateSharedServiceOut ¶
type CreateSharedServiceOut struct {
}
func CreateSharedService ¶
func CreateSharedService(ctx context.Context, in CreateSharedServiceIn) (CreateSharedServiceOut, error)
type DecrementAssociationCountOut ¶
type DecrementAssociationCountOut struct {
RemainingCount int64
}
func DecrementAssociationCount ¶
func DecrementAssociationCount(ctx context.Context, in DecrementAssociationCountIn) (DecrementAssociationCountOut, error)
type DeleteDedicatedPoolIn ¶
type DeleteDedicatedPoolOut ¶
type DeleteDedicatedPoolOut struct {
PoolDeleted bool `saga:"dedicated_pool_deleted"`
}
func DeleteDedicatedPool ¶
func DeleteDedicatedPool(ctx context.Context, in DeleteDedicatedPoolIn) (DeleteDedicatedPoolOut, error)
type DeleteDedicatedServiceOut ¶
type DeleteDedicatedServiceOut struct {
ServiceDeleted bool `saga:"dedicated_service_deleted"`
}
func DeleteDedicatedService ¶
func DeleteDedicatedService(ctx context.Context, in DeleteDedicatedServiceIn) (DeleteDedicatedServiceOut, error)
type IncrementAssociationCountOut ¶
type IncrementAssociationCountOut struct {
Incremented bool
}
func IncrementAssociationCount ¶
func IncrementAssociationCount(ctx context.Context, in IncrementAssociationCountIn) (IncrementAssociationCountOut, error)
type ServerCounter ¶
type ServerCounter interface {
GetAssociationCount(ctx context.Context, serverID entity.Id) (count int64, revision int64, err error)
PatchAssociationCount(ctx context.Context, serverID entity.Id, revision int64, newCount int64) error
}
ServerCounter abstracts reading and patching the association count on a database server entity. Each provider implements this for its own entity type. Inject via saga.UsingAs[ServerCounter] and retrieve with saga.Get[ServerCounter](ctx).
type WaitForDedicatedPoolIn ¶
type WaitForDedicatedPoolOut ¶
type WaitForDedicatedPoolOut struct {
Ready bool
}
func WaitForDedicatedPool ¶
func WaitForDedicatedPool(ctx context.Context, in WaitForDedicatedPoolIn) (WaitForDedicatedPoolOut, error)
type WaitForDedicatedServiceOut ¶
type WaitForDedicatedServiceOut struct {
ServiceHost string
}
func WaitForDedicatedService ¶
func WaitForDedicatedService(ctx context.Context, in WaitForDedicatedServiceIn) (WaitForDedicatedServiceOut, error)
type WaitForSharedPoolIn ¶
type WaitForSharedPoolIn struct {
}
type WaitForSharedPoolOut ¶
type WaitForSharedPoolOut struct {
}
func WaitForSharedPool ¶
func WaitForSharedPool(ctx context.Context, in WaitForSharedPoolIn) (WaitForSharedPoolOut, error)
type WaitForSharedServiceIn ¶
type WaitForSharedServiceIn struct {
}
type WaitForSharedServiceOut ¶
type WaitForSharedServiceOut struct {
}
func WaitForSharedService ¶
func WaitForSharedService(ctx context.Context, in WaitForSharedServiceIn) (WaitForSharedServiceOut, error)
Click to show internal directories.
Click to hide internal directories.