integration

Documentation

Index

• func StartEtcd(t *testing.T, ctx context.Context) *clientv3.Client
• type Cluster
  • func StartCluster(t *testing.T, ctx context.Context) *Cluster
  • func (c *Cluster) EtcdClient(t *testing.T) *clientv3.Client
  • func (c *Cluster) Executor() dockerExecutor
  • func (c *Cluster) Hostname(t *testing.T) string
  • func (c *Cluster) Roles(ctx context.Context) (*docker.Container, *docker.Container, *docker.Container)
  • func (c *Cluster) Shutdown()
• type PGBouncerProcess
  • func StartPGBouncer(t *testing.T, ctx context.Context) *PGBouncerProcess

Functions

func StartEtcd

func StartEtcd(t *testing.T, ctx context.Context) *clientv3.Client

Types

type Cluster

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

Cluster wraps three postgres cluster members, providing the Roles method to inspect the roles of each node.

func StartCluster

func StartCluster(t *testing.T, ctx context.Context) *Cluster

func (*Cluster) EtcdClient

func (c *Cluster) EtcdClient(t *testing.T) *clientv3.Client

EtcdClient returns a client connection to the etcd cluster running on the cluster members.

func (*Cluster) Executor

func (c *Cluster) Executor() dockerExecutor

Executor returns a handle to execute commands against a cluster member. It's assumed this will be to issue pacemaker commands, and so the caller does not care which member the command executes against.

func (*Cluster) Hostname

func (c *Cluster) Hostname(t *testing.T) string

Hostname returns the IP of the docker host

func (*Cluster) Roles

func (c *Cluster) Roles(ctx context.Context) (*docker.Container, *docker.Container, *docker.Container)

Roles returns a triple of master, sync, async docker containers. When a role doesn't exist, the container will be nil.

func (*Cluster) Shutdown

func (c *Cluster) Shutdown()

Shutdown forcibly removes all containers

type PGBouncerProcess

type PGBouncerProcess struct {
	*pgbouncer.PGBouncer
	ConfigFile, ConfigFileTemplate string
}

func StartPGBouncer

func StartPGBouncer(t *testing.T, ctx context.Context) *PGBouncerProcess