controller

Documentation

Index

• type Database
  • func (database *Database) HandleDatabaseHealthyState(instances map[string]*Instance, secrets map[string]*v1.Secret)
  • func (database *Database) HandleDatabasePendingState(instances map[string]*Instance, secrets map[string]*v1.Secret)
  • func (database *Database) HandleDatabaseUnhealthyState(instances map[string]*Instance, secrets map[string]*v1.Secret)
  • func (database *Database) HandleDatabaseUnknownState()
  • func (database *Database) HandleFinalizeDatabaseState(instances map[string]*Instance, secrets map[string]*v1.Secret)
• type Instance
  • func (instance *Instance) GetConnection(secret *v1.Secret) (*pgx.Conn, error)
  • func (instance *Instance) GetSecret(secrets map[string]*v1.Secret) (*v1.Secret, error)
  • func (instance *Instance) HandleFinalizeInstanceState(databases map[string]*Database, roles map[string]*Role)
  • func (instance *Instance) HandleInstanceHealthyState(secrets map[string]*v1.Secret)
  • func (instance *Instance) HandleInstancePendingState(secrets map[string]*v1.Secret)
  • func (instance *Instance) HandleInstanceUnhealthyState(secrets map[string]*v1.Secret)
  • func (instance *Instance) HandleUnknownState()
• type Postgres
  • func (p *Postgres) GetConnection() (*pgx.Conn, error)
• type Role
  • func (role *Role) HandleFinalizeRoleState(instances map[string]*Instance, secrets map[string]*v1.Secret)
  • func (role *Role) HandleRoleHealthyState(instances map[string]*Instance, secrets map[string]*v1.Secret)
  • func (role *Role) HandleRolePendingState(instances map[string]*Instance, secrets map[string]*v1.Secret)
  • func (role *Role) HandleRoleUnhealthyState(instances map[string]*Instance, secrets map[string]*v1.Secret)
  • func (role *Role) HandleRoleUnknownState()

Types

type Database

type Database v1alpha1.Database

func (*Database) HandleDatabaseHealthyState

func (database *Database) HandleDatabaseHealthyState(instances map[string]*Instance, secrets map[string]*v1.Secret)

func (*Database) HandleDatabasePendingState

func (database *Database) HandleDatabasePendingState(instances map[string]*Instance, secrets map[string]*v1.Secret)

func (*Database) HandleDatabaseUnhealthyState

func (database *Database) HandleDatabaseUnhealthyState(instances map[string]*Instance, secrets map[string]*v1.Secret)

func (*Database) HandleDatabaseUnknownState

func (database *Database) HandleDatabaseUnknownState()

func (*Database) HandleFinalizeDatabaseState

func (database *Database) HandleFinalizeDatabaseState(instances map[string]*Instance, secrets map[string]*v1.Secret)

type Instance

type Instance v1alpha1.Instance

func (*Instance) GetConnection

func (instance *Instance) GetConnection(secret *v1.Secret) (*pgx.Conn, error)

func (*Instance) GetSecret

func (instance *Instance) GetSecret(secrets map[string]*v1.Secret) (*v1.Secret, error)

func (*Instance) HandleFinalizeInstanceState

func (instance *Instance) HandleFinalizeInstanceState(databases map[string]*Database, roles map[string]*Role)

func (*Instance) HandleInstanceHealthyState

func (instance *Instance) HandleInstanceHealthyState(secrets map[string]*v1.Secret)

func (*Instance) HandleInstancePendingState

func (instance *Instance) HandleInstancePendingState(secrets map[string]*v1.Secret)

func (*Instance) HandleInstanceUnhealthyState

func (instance *Instance) HandleInstanceUnhealthyState(secrets map[string]*v1.Secret)

func (*Instance) HandleUnknownState

func (instance *Instance) HandleUnknownState()

type Postgres

type Postgres struct {
	Host     string
	Port     string
	Username string
	Password string
	Database string
	SSLMode  string
}

func (*Postgres) GetConnection

func (p *Postgres) GetConnection() (*pgx.Conn, error)

type Role

type Role v1alpha1.Role

func (*Role) HandleFinalizeRoleState

func (role *Role) HandleFinalizeRoleState(instances map[string]*Instance, secrets map[string]*v1.Secret)

func (*Role) HandleRoleHealthyState

func (role *Role) HandleRoleHealthyState(instances map[string]*Instance, secrets map[string]*v1.Secret)

func (*Role) HandleRolePendingState

func (role *Role) HandleRolePendingState(instances map[string]*Instance, secrets map[string]*v1.Secret)

func (*Role) HandleRoleUnhealthyState

func (role *Role) HandleRoleUnhealthyState(instances map[string]*Instance, secrets map[string]*v1.Secret)

func (*Role) HandleRoleUnknownState

func (role *Role) HandleRoleUnknownState()