pgbouncer

Documentation

Index

• Constants
• type Auth
• type Client
• type KubeDBClientBuilder
  • func NewKubeDBClientBuilder(kc client.Client, pb *dbapi.PgBouncer) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) GetPgBouncerXormClient() (*XormClient, error)
  • func (o *KubeDBClientBuilder) WithAuth(auth *Auth) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithContext(ctx context.Context) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithDatabaseName(dbName string) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithDatabaseRef(db *dbapi.Database) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithPbPort(listenPort int32) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithPod(podName string) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithURL(url string) *KubeDBClientBuilder
• type XormClient
• type XormClientList
  • func GetXormClientList(kc client.Client, pb *dbapi.PgBouncer, ctx context.Context, auth *Auth, ...) (*XormClientList, error)

Constants

const (
	DefaultBackendDBType = "postgres"
	TLSModeDisable       = "disable"
)

Types

type Auth

type Auth struct {
	UserName string
	Password string
}

type Client

type Client struct {
	*sql.DB
}

type KubeDBClientBuilder

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

func NewKubeDBClientBuilder

func NewKubeDBClientBuilder(kc client.Client, pb *dbapi.PgBouncer) *KubeDBClientBuilder

func (*KubeDBClientBuilder) GetPgBouncerXormClient

func (o *KubeDBClientBuilder) GetPgBouncerXormClient() (*XormClient, error)

func (*KubeDBClientBuilder) WithAuth

func (o *KubeDBClientBuilder) WithAuth(auth *Auth) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithContext

func (o *KubeDBClientBuilder) WithContext(ctx context.Context) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithDatabaseName

func (o *KubeDBClientBuilder) WithDatabaseName(dbName string) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithDatabaseRef

func (o *KubeDBClientBuilder) WithDatabaseRef(db *dbapi.Database) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithPbPort

func (o *KubeDBClientBuilder) WithPbPort(listenPort int32) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithPod

func (o *KubeDBClientBuilder) WithPod(podName string) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithURL

func (o *KubeDBClientBuilder) WithURL(url string) *KubeDBClientBuilder

type XormClient

type XormClient struct {
	*xorm.Engine
}

type XormClientList

type XormClientList struct {
	List  []*XormClient
	Mutex sync.Mutex
	WG    sync.WaitGroup
	// contains filtered or unexported fields
}

func GetXormClientList

func GetXormClientList(kc client.Client, pb *dbapi.PgBouncer, ctx context.Context, auth *Auth, dbName string, listenPort rune) (*XormClientList, error)