Documentation
¶
Index ¶
- Constants
- func CheckDataGuardAssociationState(logger logr.Logger, dbClient database.DatabaseClient, associationId string, ...) (string, error)
- func CheckPatchState(ctx context.Context, logger logr.Logger, dbClient database.DatabaseClient, ...) error
- func CheckResourceState(logger logr.Logger, dbClient database.DatabaseClient, id string, ...) (string, error)
- func CloneAndGetDbcsId(compartmentId string, logger logr.Logger, kubeClient client.Client, ...) (string, error)
- func CloneFromBackupAndGetDbcsId(compartmentId string, logger logr.Logger, kubeClient client.Client, ...) (string, error)
- func CloneFromDatabaseAndGetDbcsId(compartmentId string, logger logr.Logger, kubeClient client.Client, ...) (string, error)
- func CreateAndGetDbcsId(compartmentId string, logger logr.Logger, kubeClient client.Client, ...) (string, error)
- func CreateDbcsBackup(compartmentId string, logger logr.Logger, dbClient database.DatabaseClient, ...) (string, error)
- func DeleteDbcsSystemSystem(dbClient database.DatabaseClient, Id string) error
- func GetAdminPassword(kubeClient client.Client, dbcs *databasev4.DbcsSystem) (string, error)
- func GetCloningAdminPassword(kubeClient client.Client, dbcs *databasev4.DbcsSystem) (string, error)
- func GetCloningTdePassword(kubeClient client.Client, dbcs *databasev4.DbcsSystem) (string, error)
- func GetDBDetails(kubeClient client.Client, dbcs *databasev4.DbcsSystem) (database.CreateDatabaseDetails, error)
- func GetDBEdition(dbcs *databasev4.DbcsSystem) database.LaunchDbSystemDetailsDatabaseEditionEnum
- func GetDBSystemopts(dbcs *databasev4.DbcsSystem) database.DbSystemOptions
- func GetDBbDiskRedundancy(dbcs *databasev4.DbcsSystem) database.LaunchDbSystemDetailsDiskRedundancyEnum
- func GetDataGuardAssociationState(logger logr.Logger, dbClient database.DatabaseClient, associationId string, ...) (string, error)
- func GetDbHomeDetails(kubeClient client.Client, dbClient database.DatabaseClient, ...) (database.CreateDbHomeDetails, error)
- func GetDbLatestVersion(dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, ...) (string, error)
- func GetDbSystemId(logger logr.Logger, dbClient database.DatabaseClient, ...) error
- func GetFmtStr(pstr string) string
- func GetInitialStorage(dbcs *databasev4.DbcsSystem) int
- func GetKeyValue(str1 string) string
- func GetListDatabaseRsp(logger logr.Logger, dbClient database.DatabaseClient, ...) (database.ListDatabasesResponse, error)
- func GetListDbHomeRsp(logger logr.Logger, dbClient database.DatabaseClient, ...) (database.ListDbHomesResponse, error)
- func GetNodeCount(dbcs *databasev4.DbcsSystem) int
- func GetResourceState(logger logr.Logger, dbClient database.DatabaseClient, id string) (string, error)
- func GetTdePassword(kubeClient client.Client, dbcs *databasev4.DbcsSystem) (string, error)
- func PatchDBSystem(ctx context.Context, compartmentId string, logger logr.Logger, ...) error
- func PopulateDBDetails(logger logr.Logger, dbClient database.DatabaseClient, ...) error
- func RestoreDbcsToPoint(compartmentId string, logger logr.Logger, dbClient database.DatabaseClient, ...) error
- func SetDBCSDatabaseLifecycleState(compartmentId string, logger logr.Logger, kubeClient client.Client, ...) error
- func SetDBCSStatus(state databasev4.LifecycleState, compartmentId string, ...) error
- func SetLifecycleState(compartmentId string, kubeClient client.Client, ...) error
- func UpdateDbcsSystemId(kubeClient client.Client, dbcs *databasev4.DbcsSystem) error
- func UpdateDbcsSystemIdInst(compartmentId string, log logr.Logger, dbClient database.DatabaseClient, ...) error
- func UpgradeDatabaseVersion(ctx context.Context, compartmentId string, logger logr.Logger, ...) error
- func ValidateSpex(logger logr.Logger, kubeClient client.Client, dbClient database.DatabaseClient, ...) error
- func WaitForDatabaseState(log logr.Logger, dbClient database.DatabaseClient, databaseId string, ...) error
Constants ¶
View Source
const ( PatchHistoryEntrySummaryLifecycleStateInProgress database.PatchHistoryEntrySummaryLifecycleStateEnum = "IN_PROGRESS" PatchHistoryEntrySummaryLifecycleStateSucceeded database.PatchHistoryEntrySummaryLifecycleStateEnum = "SUCCEEDED" )
Variables ¶
This section is empty.
Functions ¶
func CheckDataGuardAssociationState ¶
func CheckDataGuardAssociationState(logger logr.Logger, dbClient database.DatabaseClient, associationId string, currentState string, expectedState string, databaseId string) (string, error)
CheckDataGuardAssociationState will check the lifecycle state of the Data Guard Association and wait until it reaches the expected state (e.g., "AVAILABLE").
func CheckPatchState ¶
func CheckPatchState(ctx context.Context, logger logr.Logger, dbClient database.DatabaseClient, dbSystemId *string, patchId string) error
CheckPatchState waits for a specific patch to finish applying. It polls the patch history until the patch is SUCCEEDED or FAILED.
func CheckResourceState ¶
func CheckResourceState(logger logr.Logger, dbClient database.DatabaseClient, id string, transientState string, expectedState string) (string, error)
CheckResourceState waits until the resource moves from a transient state (e.g. PROVISIONING, UPDATING) to the expected state (e.g. AVAILABLE). It retries until success, timeout (120 minutes), or unexpected state occurs.
func CloneAndGetDbcsId ¶
func CloneAndGetDbcsId(compartmentId string, logger logr.Logger, kubeClient client.Client, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient) (string, error)
func CloneFromBackupAndGetDbcsId ¶
func CloneFromBackupAndGetDbcsId( compartmentId string, logger logr.Logger, kubeClient client.Client, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient) (string, error)
CloneFromBackupAndGetDbcsId clones a DB system from a backup and returns the new DB system's OCID.
func CloneFromDatabaseAndGetDbcsId ¶
func CloneFromDatabaseAndGetDbcsId(compartmentId string, logger logr.Logger, kubeClient client.Client, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient) (string, error)
Sync the DbcsSystem Database details
func CreateAndGetDbcsId ¶
func CreateAndGetDbcsId(compartmentId string, logger logr.Logger, kubeClient client.Client, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient, kmsDetails *databasev4.KMSDetailsStatus) (string, error)
func CreateDbcsBackup ¶
func CreateDbcsBackup( compartmentId string, logger logr.Logger, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, kubeClient client.Client, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient, ) (string, error)
func DeleteDbcsSystemSystem ¶
func DeleteDbcsSystemSystem(dbClient database.DatabaseClient, Id string) error
Delete DbcsSystem System
func GetAdminPassword ¶
func GetAdminPassword(kubeClient client.Client, dbcs *databasev4.DbcsSystem) (string, error)
Get admin password from Secret then OCI valut secret
func GetCloningAdminPassword ¶
func GetCloningAdminPassword(kubeClient client.Client, dbcs *databasev4.DbcsSystem) (string, error)
Get admin password from Secret then OCI valut secret
func GetCloningTdePassword ¶
func GetCloningTdePassword(kubeClient client.Client, dbcs *databasev4.DbcsSystem) (string, error)
Get admin password from Secret then OCI valut secret
func GetDBDetails ¶
func GetDBDetails(kubeClient client.Client, dbcs *databasev4.DbcsSystem) (database.CreateDatabaseDetails, error)
func GetDBEdition ¶
func GetDBEdition(dbcs *databasev4.DbcsSystem) database.LaunchDbSystemDetailsDatabaseEditionEnum
func GetDBSystemopts ¶
func GetDBSystemopts( dbcs *databasev4.DbcsSystem) database.DbSystemOptions
func GetDBbDiskRedundancy ¶
func GetDBbDiskRedundancy( dbcs *databasev4.DbcsSystem) database.LaunchDbSystemDetailsDiskRedundancyEnum
func GetDataGuardAssociationState ¶
func GetDataGuardAssociationState(logger logr.Logger, dbClient database.DatabaseClient, associationId string, databaseID string) (string, error)
GetDataGuardAssociationState retrieves the lifecycle state of the Data Guard Association.
func GetDbHomeDetails ¶
func GetDbHomeDetails(kubeClient client.Client, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, id string) (database.CreateDbHomeDetails, error)
func GetDbLatestVersion ¶
func GetDbLatestVersion(dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, dbSystemId string) (string, error)
func GetDbSystemId ¶
func GetDbSystemId(logger logr.Logger, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem) error
func GetInitialStorage ¶
func GetInitialStorage( dbcs *databasev4.DbcsSystem) int
func GetKeyValue ¶
func GetListDatabaseRsp ¶
func GetListDatabaseRsp(logger logr.Logger, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, dbHomeId string) (database.ListDatabasesResponse, error)
func GetListDbHomeRsp ¶
func GetListDbHomeRsp(logger logr.Logger, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem) (database.ListDbHomesResponse, error)
func GetNodeCount ¶
func GetNodeCount( dbcs *databasev4.DbcsSystem) int
func GetResourceState ¶
func GetResourceState(logger logr.Logger, dbClient database.DatabaseClient, id string) (string, error)
GetResourceState fetches the current lifecycle state of the DbSystem from OCI.
func GetTdePassword ¶
func GetTdePassword(kubeClient client.Client, dbcs *databasev4.DbcsSystem) (string, error)
Get admin password from Secret then OCI valut secret
func PatchDBSystem ¶
func PatchDBSystem( ctx context.Context, compartmentId string, logger logr.Logger, kubeClient client.Client, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient, dbHomeId, patchId string) error
func PopulateDBDetails ¶
func PopulateDBDetails(logger logr.Logger, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem) error
func RestoreDbcsToPoint ¶
func RestoreDbcsToPoint( compartmentId string, logger logr.Logger, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, restoreOpt databasev4.RestoreConfig, kubeClient client.Client, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient, ) error
func SetDBCSDatabaseLifecycleState ¶
func SetDBCSDatabaseLifecycleState(compartmentId string, logger logr.Logger, kubeClient client.Client, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient) error
func SetDBCSStatus ¶
func SetDBCSStatus(state databasev4.LifecycleState, compartmentId string, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient) error
func SetLifecycleState ¶
func SetLifecycleState(compartmentId string, kubeClient client.Client, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, state databasev4.LifecycleState, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient) error
SetLifecycleState set status.state of the reosurce.
func UpdateDbcsSystemId ¶
func UpdateDbcsSystemId(kubeClient client.Client, dbcs *databasev4.DbcsSystem) error
func UpdateDbcsSystemIdInst ¶
func UpdateDbcsSystemIdInst(compartmentId string, log logr.Logger, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, kubeClient client.Client, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient, databaseID string) error
func UpgradeDatabaseVersion ¶
func UpgradeDatabaseVersion( ctx context.Context, compartmentId string, logger logr.Logger, kubeClient client.Client, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, nwClient core.VirtualNetworkClient, wrClient workrequests.WorkRequestClient, databaseId, targetVersion string) error
func ValidateSpex ¶
func ValidateSpex(logger logr.Logger, kubeClient client.Client, dbClient database.DatabaseClient, dbcs *databasev4.DbcsSystem, nwClient core.VirtualNetworkClient, eRecord record.EventRecorder) error
=========== validate Specs ============
func WaitForDatabaseState ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.