integration

Documentation

Index

• func WaitClusterInitialized(e *store.StoreManager, timeout time.Duration) error
• func WaitClusterViewMaster(master string, e *store.StoreManager, timeout time.Duration) error
• func WaitClusterViewWithMaster(e *store.StoreManager, timeout time.Duration) error
• type CheckFunc
• type Process
  • func (p *Process) Kill()
  • func (p *Process) Signal(sig os.Signal) error
  • func (p *Process) Start() error
  • func (p *Process) StartExpect() error
  • func (p *Process) Stop()
  • func (p *Process) Wait(timeout time.Duration) error
• type TestKeeper
  • func NewTestKeeper(t *testing.T, ...) (*TestKeeper, error)
  • func NewTestKeeperWithID(t *testing.T, ...) (*TestKeeper, error)
  • func (tk *TestKeeper) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (tk *TestKeeper) GetKeeperInfo(timeout time.Duration) (*cluster.KeeperInfo, error)
  • func (tk *TestKeeper) GetPGProcess() (*os.Process, error)
  • func (tk *TestKeeper) IsMaster() (bool, error)
  • func (tk *TestKeeper) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (tk *TestKeeper) SignalPG(sig os.Signal) error
  • func (tk *TestKeeper) WaitDBDown(timeout time.Duration) error
  • func (tk *TestKeeper) WaitDBUp(timeout time.Duration) error
  • func (tk *TestKeeper) WaitDown(timeout time.Duration) error
  • func (tk *TestKeeper) WaitRole(r common.Role, timeout time.Duration) error
  • func (tk *TestKeeper) WaitUp(timeout time.Duration) error
• type TestProxy
  • func NewTestProxy(t *testing.T, dir string, clusterName string, storeBackend store.Backend, ...) (*TestProxy, error)
  • func (tp *TestProxy) WaitListening(timeout time.Duration) error
  • func (tp *TestProxy) WaitNotListening(timeout time.Duration) error
• type TestSentinel
  • func NewTestSentinel(t *testing.T, dir string, clusterName string, storeBackend store.Backend, ...) (*TestSentinel, error)
• type TestStore
  • func NewTestConsul(t *testing.T, dir string, a ...string) (*TestStore, error)
  • func NewTestEtcd(t *testing.T, dir string, a ...string) (*TestStore, error)
  • func NewTestStore(t *testing.T, dir string, a ...string) (*TestStore, error)
  • func (ts *TestStore) WaitDown(timeout time.Duration) error
  • func (ts *TestStore) WaitUp(timeout time.Duration) error

Functions

func WaitClusterInitialized

func WaitClusterInitialized(e *store.StoreManager, timeout time.Duration) error

func WaitClusterViewMaster

func WaitClusterViewMaster(master string, e *store.StoreManager, timeout time.Duration) error

func WaitClusterViewWithMaster

func WaitClusterViewWithMaster(e *store.StoreManager, timeout time.Duration) error

Types

type CheckFunc

type CheckFunc func(time.Duration) error

type Process

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

func (*Process) Kill

func (p *Process) Kill()

func (*Process) Signal

func (p *Process) Signal(sig os.Signal) error

func (*Process) Start

func (p *Process) Start() error

func (*Process) StartExpect

func (p *Process) StartExpect() error

func (*Process) Stop

func (p *Process) Stop()

func (*Process) Wait

func (p *Process) Wait(timeout time.Duration) error

type TestKeeper

type TestKeeper struct {
	Process
	// contains filtered or unexported fields
}

func NewTestKeeper

func NewTestKeeper(t *testing.T, dir, clusterName, pgSUUsername, pgSUPassword, pgReplUsername, pgReplPassword string, storeBackend store.Backend, storeEndpoints string, a ...string) (*TestKeeper, error)

func NewTestKeeperWithID

func NewTestKeeperWithID(t *testing.T, dir, id, clusterName, pgSUUsername, pgSUPassword, pgReplUsername, pgReplPassword string, storeBackend store.Backend, storeEndpoints string, a ...string) (*TestKeeper, error)

func (*TestKeeper) Exec

func (tk *TestKeeper) Exec(query string, args ...interface{}) (sql.Result, error)

func (*TestKeeper) GetKeeperInfo

func (tk *TestKeeper) GetKeeperInfo(timeout time.Duration) (*cluster.KeeperInfo, error)

func (*TestKeeper) GetPGProcess

func (tk *TestKeeper) GetPGProcess() (*os.Process, error)

func (*TestKeeper) IsMaster

func (tk *TestKeeper) IsMaster() (bool, error)

func (*TestKeeper) Query

func (tk *TestKeeper) Query(query string, args ...interface{}) (*sql.Rows, error)

func (*TestKeeper) SignalPG

func (tk *TestKeeper) SignalPG(sig os.Signal) error

func (*TestKeeper) WaitDBDown

func (tk *TestKeeper) WaitDBDown(timeout time.Duration) error

func (*TestKeeper) WaitDBUp

func (tk *TestKeeper) WaitDBUp(timeout time.Duration) error

func (*TestKeeper) WaitDown

func (tk *TestKeeper) WaitDown(timeout time.Duration) error

func (*TestKeeper) WaitRole

func (tk *TestKeeper) WaitRole(r common.Role, timeout time.Duration) error

func (*TestKeeper) WaitUp

func (tk *TestKeeper) WaitUp(timeout time.Duration) error

type TestProxy

type TestProxy struct {
	Process
	// contains filtered or unexported fields
}

func NewTestProxy

func NewTestProxy(t *testing.T, dir string, clusterName string, storeBackend store.Backend, storeEndpoints string, a ...string) (*TestProxy, error)

func (*TestProxy) WaitListening

func (tp *TestProxy) WaitListening(timeout time.Duration) error

func (*TestProxy) WaitNotListening

func (tp *TestProxy) WaitNotListening(timeout time.Duration) error

type TestSentinel

type TestSentinel struct {
	Process
	// contains filtered or unexported fields
}

func NewTestSentinel

func NewTestSentinel(t *testing.T, dir string, clusterName string, storeBackend store.Backend, storeEndpoints string, a ...string) (*TestSentinel, error)

type TestStore

type TestStore struct {
	Process
	// contains filtered or unexported fields
}

func NewTestConsul

func NewTestConsul(t *testing.T, dir string, a ...string) (*TestStore, error)

func NewTestEtcd

func NewTestEtcd(t *testing.T, dir string, a ...string) (*TestStore, error)

func NewTestStore

func NewTestStore(t *testing.T, dir string, a ...string) (*TestStore, error)

func (*TestStore) WaitDown

func (ts *TestStore) WaitDown(timeout time.Duration) error

func (*TestStore) WaitUp

func (ts *TestStore) WaitUp(timeout time.Duration) error