integration

Sep 17, 2018

Changes in this version

+ type ReplQuerier interface

+ ReplQuery func(query string, args ...interface{}) (*sql.Rows, error)

Mar 21, 2018

Changes in this version

+ func WaitClusterDataEnabledProxiesNum(e *store.KVBackedStore, n int, timeout time.Duration) error

+ func WaitClusterDataUpdated(e *store.KVBackedStore, timeout time.Duration) error

Feb 1, 2018

Changes in this version

+ func GetSystemData(q Querier) (*pg.SystemData, error)

+ func GetXLogPos(q Querier) (uint64, error)

type Querier

+ ReplQuery func(query string, args ...interface{}) (*sql.Rows, error)

type TestKeeper

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

type TestProxy

+ func (tp *TestProxy) ReplQuery(query string, args ...interface{}) (*sql.Rows, error)

Jan 18, 2018

Changes in this version

type TestKeeper

+ func (tk *TestKeeper) CheckPoint() error

Aug 29, 2017

Changes in this version

+ func GetPGParameters(q Querier) (common.Parameters, error)

+ type Querier interface

+ Exec func(query string, args ...interface{}) (sql.Result, error)

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

type TestKeeper

+ func (tk *TestKeeper) SwitchWals(times int) error

type TestProxy

+ func (tp *TestProxy) CheckListening() bool

+ func (tp *TestProxy) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (tp *TestProxy) GetPGParameters() (common.Parameters, error)

+ func (tp *TestProxy) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (tp *TestProxy) WaitRightMaster(tk *TestKeeper, timeout time.Duration) error

May 30, 2017

Changes in this version

+ func WaitClusterDataKeepers(keepersUIDs []string, e *store.StoreManager, timeout time.Duration) error

+ func WaitClusterSyncedXLogPos(keepersUIDs []string, e *store.StoreManager, timeout time.Duration) error

type TestKeeper

+ func (tk *TestKeeper) GetPrimaryConninfo() (pg.ConnParams, error)

+ func (tk *TestKeeper) PGDataVersion() (int, int, error)

+ func (tk *TestKeeper) WaitDBRole(r common.Role, ptk *TestKeeper, timeout time.Duration) error

Dec 14, 2016

Changes in this version

+ const MaxPort

+ const MinPort

+ func StolonCtl(clusterName string, storeBackend store.Backend, storeEndpoints string, ...) error

+ func WaitClusterDataKeeperInitialized(keeperUID string, e *store.StoreManager, timeout time.Duration) error

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

+ func WaitClusterDataSynchronousStandbys(synchronousStandbys []string, e *store.StoreManager, timeout time.Duration) error

+ func WaitClusterDataWithMaster(e *store.StoreManager, timeout time.Duration) (string, error)

+ func WaitClusterPhase(e *store.StoreManager, phase cluster.ClusterPhase, timeout time.Duration) error

+ func WaitNumDBs(e *store.StoreManager, n int, timeout time.Duration) error

+ func WaitStandbyKeeper(e *store.StoreManager, keeperUID string, timeout time.Duration) error

type TestKeeper

+ func (tk *TestKeeper) GetPGParameters() (common.Parameters, error)

Sep 27, 2016

Changes in this version

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

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

+ type TestStore struct

+ func NewTestConsul(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

Nov 2, 2015

Changes in this version

+ func WaitClusterViewMaster(master string, e *etcdm.EtcdManager, timeout time.Duration) error

+ type CheckFunc func(time.Duration) error

+ type Process struct

+ 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 TestEtcd struct

+ func NewTestEtcd(dir string, a ...string) (*TestEtcd, error)

+ func (te *TestEtcd) GetEtcdNode(timeout time.Duration, path string) (*etcd.Node, error)

+ func (te *TestEtcd) WaitDown(timeout time.Duration) error

+ func (te *TestEtcd) WaitUp(timeout time.Duration) error

+ type TestKeeper struct

+ func NewTestKeeper(dir string, clusterName string, etcdEndpoints string, a ...string) (*TestKeeper, error)

+ func NewTestKeeperWithID(dir string, id string, clusterName string, etcdEndpoints string, a ...string) (*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 struct

+ func NewTestProxy(dir string, clusterName string, etcdEndpoints string, a ...string) (*TestProxy, error)

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

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

+ type TestSentinel struct

+ func NewTestSentinel(dir string, clusterName string, etcdEndpoints string) (*TestSentinel, error)