package pgbouncer

import "github.com/oslokommune/okctl/pkg/kube/manifests/pgbouncer"

Package pgbouncer knows how to deploy PgBouncer to the Kubernetes cluster: - https://www.pgbouncer.org

Index ¶

• func Pod( name, database, namespace, pgBouncerSecret, dbParamsConfigMap, dbParamsSecret string, labels map[string]string, listenPort int32, ) *v1.Pod
• func Secret(name, namespace, username, secret string) *v1.Secret
• type Config
• type PgBouncer
• func New(config *Config) *PgBouncer
• func (p *PgBouncer) Create() error
• func (p *PgBouncer) CreateSecret() error
• func (p *PgBouncer) Delete() error
• func (p *PgBouncer) DeleteSecret(s *v1.Secret) error
• func (p *PgBouncer) Forward(listenPort int32, pod *v1.Pod) error

Functions ¶

func Pod ¶

func Pod(
	name, database, namespace, pgBouncerSecret, dbParamsConfigMap, dbParamsSecret string,
	labels map[string]string,
	listenPort int32,
) *v1.Pod

Pod returns the Kubernetes Pod definition for PgBouncer - https://github.com/edoburu/docker-pgbouncer nolint: funlen

func Secret ¶

func Secret(name, namespace, username, secret string) *v1.Secret

Secret returns the Secret for setting up the `userlist.txt`

Types ¶

type Config ¶

type Config struct {
	Name                  string
	Database              string
	Namespace             string
	Username              string
	Password              string
	DBParamsSecretName    string
	DBParamsConfigmapName string
	Labels                map[string]string
	ListenPort            int32

	In  io.Reader
	Out io.Writer
	Err io.Writer

	ClientSet kubernetes.Interface
	Config    *restclient.Config

	Logger *logrus.Logger
}

Config contains all the required inputs

type PgBouncer ¶

type PgBouncer struct {
	ListenPort int32

	Pod    *v1.Pod
	Secret *v1.Secret

	In  io.Reader
	Out io.Writer
	Err io.Writer

	Client kubernetes.Interface
	Config *restclient.Config

	Ctx    context.Context
	Logger *logrus.Logger
}

PgBouncer contains the state we need to deploy onto Kubernetes

func New ¶

func New(config *Config) *PgBouncer

New returns an initialised PgBouncer client

func (*PgBouncer) Create ¶

func (p *PgBouncer) Create() error

Create all the PgBouncer resources

func (*PgBouncer) CreateSecret ¶

func (p *PgBouncer) CreateSecret() error

CreateSecret first removes any existing secret then creates a new one

func (*PgBouncer) Delete ¶

func (p *PgBouncer) Delete() error

Delete removes all PgBouncer Kubernetes resources

func (*PgBouncer) DeleteSecret ¶

func (p *PgBouncer) DeleteSecret(s *v1.Secret) error

DeleteSecret deletes the secret

func (*PgBouncer) Forward ¶

func (p *PgBouncer) Forward(listenPort int32, pod *v1.Pod) error

Forward start forwarding the connection

Source Files ¶

pgbouncer.go