postgresql

Documentation

Index

• func ProcessToPostgressError(err error) string
• type Config
  • func NewConfig(host string, port int, user, pass, dbname string, ...) *Config
  • func (c *Config) Close() error
  • func (c *Config) ConnString() (string, error)
  • func (c *Config) Copy() *Config
  • func (c *Config) CreateCerts() bool
• type Postgresql
  • func NewPostgresql(c connection.Connection, config *Config, logger logr.Logger) *Postgresql
  • func (p *Postgresql) ApplyPrivileges(ctx context.Context, username string, privileges []v1alpha1.PrivilegeSpec) error
  • func (p *Postgresql) Close(ctx context.Context) error
  • func (p *Postgresql) Connect(ctx context.Context) error
  • func (p *Postgresql) CreateUser(ctx context.Context, username, password string) (map[string]string, error)
  • func (p *Postgresql) DeleteUser(ctx context.Context, username string) error
  • func (p *Postgresql) RevokePrivileges(ctx context.Context, username string, privileges []v1alpha1.PrivilegeSpec) error

Functions

func ProcessToPostgressError

func ProcessToPostgressError(err error) string

Types

type Config

type Config struct {
	Host                               string
	User                               string
	Password                           string
	DatabaseName                       string
	Port                               int
	SSLMode                            v1alpha1.PostgresSSLMode
	SSLCACert, SSLUserCert, SSLUserKey string
	SSLCAKey                           string
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(host string, port int, user, pass, dbname string, sslmode v1alpha1.PostgresSSLMode, sslCaCert, sslUserCert, sslUserKey, sslCAKey string) *Config

func (*Config) Close

func (c *Config) Close() error

func (*Config) ConnString

func (c *Config) ConnString() (string, error)

func (*Config) Copy

func (c *Config) Copy() *Config

func (*Config) CreateCerts

func (c *Config) CreateCerts() bool

type Postgresql

type Postgresql struct {
	// contains filtered or unexported fields
}

func NewPostgresql

func NewPostgresql(c connection.Connection, config *Config, logger logr.Logger) *Postgresql

func (*Postgresql) ApplyPrivileges

func (p *Postgresql) ApplyPrivileges(ctx context.Context, username string, privileges []v1alpha1.PrivilegeSpec) error

func (*Postgresql) Close

func (p *Postgresql) Close(ctx context.Context) error

func (*Postgresql) Connect

func (p *Postgresql) Connect(ctx context.Context) error

func (*Postgresql) CreateUser

func (p *Postgresql) CreateUser(ctx context.Context, username, password string) (map[string]string, error)

func (*Postgresql) DeleteUser

func (p *Postgresql) DeleteUser(ctx context.Context, username string) error

func (*Postgresql) RevokePrivileges

func (p *Postgresql) RevokePrivileges(ctx context.Context, username string, privileges []v1alpha1.PrivilegeSpec) error