postgresflexalpha

package

v0.2.7 Latest Latest Go to latest Published: Mar 25, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation ¶

Index ¶

Constants
func CreateInstanceWaitHandler(ctx context.Context, a APIClientInstanceInterface, ...) *wait.AsyncActionHandler[v3alpha1api.GetInstanceResponse]
func DeleteInstanceWaitHandler(ctx context.Context, a APIClientInstanceInterface, ...) error
func GetDatabaseByIdWaitHandler(ctx context.Context, a APIClientDatabaseInterface, ...) *wait.AsyncActionHandler[v3alpha1api.GetDatabaseResponse]
func GetUserByIdWaitHandler(ctx context.Context, a APIClientUserInterface, ...) *wait.AsyncActionHandler[v3alpha1api.GetUserResponse]
func PartialUpdateInstanceWaitHandler(ctx context.Context, a APIClientInstanceInterface, ...) *wait.AsyncActionHandler[v3alpha1api.GetInstanceResponse]
type APIClientDatabaseInterface
type APIClientInstanceInterface
type APIClientUserInterface

Constants ¶

const (
	InstanceStateEmpty       = ""
	InstanceStateProgressing = "PROGRESSING"
	InstanceStateSuccess     = "READY"
	InstanceStateFailed      = "FAILURE"
	InstanceStateTerminating = "TERMINATING"
	InstanceStateUnknown     = "UNKNOWN"
	InstanceStatePending     = "PENDING"
	InstanceStateDeleted     = "DELETED"
)

"READY" "PENDING" "PROGRESSING" "FAILURE" "UNKNOWN" "TERMINATING"

Variables ¶

This section is empty.

Functions ¶

func CreateInstanceWaitHandler ¶

func CreateInstanceWaitHandler(
	ctx context.Context, a APIClientInstanceInterface, projectID, region,
	instanceID string,
) *wait.AsyncActionHandler[v3alpha1api.GetInstanceResponse]

CreateInstanceWaitHandler will wait for instance creation

func DeleteInstanceWaitHandler ¶

func DeleteInstanceWaitHandler(
	ctx context.Context,
	a APIClientInstanceInterface,
	projectID,
	region,
	instanceID string,
	timeout, sleepBeforeWait time.Duration,
) error

func GetDatabaseByIdWaitHandler ¶

func GetDatabaseByIdWaitHandler(
	ctx context.Context,
	a APIClientDatabaseInterface,
	projectID, instanceID, region string,
	databaseID int64,
) *wait.AsyncActionHandler[v3alpha1api.GetDatabaseResponse]

GetDatabaseByIdWaitHandler will wait for instance creation

func GetUserByIdWaitHandler ¶

func GetUserByIdWaitHandler(
	ctx context.Context,
	a APIClientUserInterface,
	projectID, instanceID, region string,
	userID int64,
) *wait.AsyncActionHandler[v3alpha1api.GetUserResponse]

GetUserByIdWaitHandler will wait for instance creation

func PartialUpdateInstanceWaitHandler ¶

func PartialUpdateInstanceWaitHandler(
	ctx context.Context, a APIClientInstanceInterface, projectID, region,
	instanceID string,
) *wait.AsyncActionHandler[v3alpha1api.GetInstanceResponse]

PartialUpdateInstanceWaitHandler will wait for instance update

Types ¶

type APIClientDatabaseInterface ¶

type APIClientDatabaseInterface interface {
	GetDatabaseRequest(ctx context.Context, projectID string, region string, instanceID string, databaseID int32) v3alpha1api.ApiGetDatabaseRequestRequest
}

APIClientDatabaseInterface Interface needed for tests

type APIClientInstanceInterface ¶

type APIClientInstanceInterface interface {
	GetInstanceRequest(ctx context.Context, projectID, region, instanceID string) v3alpha1api.ApiGetInstanceRequestRequest

	ListUsersRequest(
		ctx context.Context,
		projectID string,
		region string,
		instanceID string,
	) v3alpha1api.ApiListUsersRequestRequest
}

APIClientInstanceInterface Interface needed for tests

type APIClientUserInterface ¶

type APIClientUserInterface interface {
	GetUserRequest(ctx context.Context, projectID, region, instanceID string, userID int32) v3alpha1api.ApiGetUserRequestRequest
}

APIClientUserInterface Interface needed for tests

Source Files ¶

View all Source files

wait.go

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