Documentation
¶
Index ¶
- Constants
- func GetPGParameters(q Querier) (common.Parameters, error)
- func GetSystemData(q ReplQuerier) (*pg.SystemData, error)
- func GetXLogPos(q ReplQuerier) (uint64, error)
- func StolonCtl(t *testing.T, clusterName string, storeBackend store.Backend, ...) error
- func WaitClusterDataEnabledProxiesNum(e *store.KVBackedStore, n int, timeout time.Duration) error
- func WaitClusterDataKeeperInitialized(keeperUID string, e *store.KVBackedStore, timeout time.Duration) error
- func WaitClusterDataKeepers(keepersUIDs []string, e *store.KVBackedStore, timeout time.Duration) error
- func WaitClusterDataMaster(master string, e *store.KVBackedStore, timeout time.Duration) error
- func WaitClusterDataSynchronousStandbys(synchronousStandbys []string, e *store.KVBackedStore, timeout time.Duration) error
- func WaitClusterDataUpdated(e *store.KVBackedStore, timeout time.Duration) error
- func WaitClusterDataWithMaster(e *store.KVBackedStore, timeout time.Duration) (string, error)
- func WaitClusterPhase(e *store.KVBackedStore, phase cluster.ClusterPhase, timeout time.Duration) error
- func WaitClusterSyncedXLogPos(keepers []*TestKeeper, xLogPos uint64, e *store.KVBackedStore, ...) error
- func WaitNumDBs(e *store.KVBackedStore, n int, timeout time.Duration) error
- func WaitStandbyKeeper(e *store.KVBackedStore, keeperUID string, timeout time.Duration) error
- type Process
- type Querier
- type ReplQuerier
- type TestKeeper
- func (tk *TestKeeper) CheckPoint() error
- func (tk *TestKeeper) Exec(query string, args ...interface{}) (sql.Result, error)
- func (tk *TestKeeper) GetPGParameters() (common.Parameters, error)
- func (tk *TestKeeper) GetPGProcess() (*os.Process, error)
- func (tk *TestKeeper) GetPrimaryConninfo() (pg.ConnParams, error)
- func (tk *TestKeeper) PGDataVersion() (int, int, error)
- func (tk *TestKeeper) Query(query string, args ...interface{}) (*sql.Rows, error)
- func (tk *TestKeeper) ReplQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (tk *TestKeeper) SignalPG(sig os.Signal) error
- func (tk *TestKeeper) SwitchWals(times int) error
- func (tk *TestKeeper) WaitDBDown(timeout time.Duration) error
- func (tk *TestKeeper) WaitDBRole(r common.Role, ptk *TestKeeper, timeout time.Duration) error
- func (tk *TestKeeper) WaitDBUp(timeout time.Duration) 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) ReplQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (tp *TestProxy) WaitListening(timeout time.Duration) error
- func (tp *TestProxy) WaitNotListening(timeout time.Duration) error
- func (tp *TestProxy) WaitRightMaster(tk *TestKeeper, timeout time.Duration) error
- type TestSentinel
- type TestStore
Constants ¶
View Source
const ( MinPort = 2048 MaxPort = 16384 )
Variables ¶
This section is empty.
Functions ¶
func GetPGParameters ¶ added in v0.7.0
func GetPGParameters(q Querier) (common.Parameters, error)
func GetSystemData ¶ added in v0.9.0
func GetSystemData(q ReplQuerier) (*pg.SystemData, error)
func GetXLogPos ¶ added in v0.9.0
func GetXLogPos(q ReplQuerier) (uint64, error)
func WaitClusterDataEnabledProxiesNum ¶ added in v0.10.0
func WaitClusterDataKeeperInitialized ¶ added in v0.5.0
func WaitClusterDataKeepers ¶ added in v0.6.0
func WaitClusterDataMaster ¶ added in v0.5.0
func WaitClusterDataSynchronousStandbys ¶ added in v0.5.0
func WaitClusterDataSynchronousStandbys(synchronousStandbys []string, e *store.KVBackedStore, timeout time.Duration) error
WaitClusterDataSynchronousStandbys waits for: * synchronous standby defined in masterdb spec * synchronous standby reported from masterdb status
func WaitClusterDataUpdated ¶ added in v0.10.0
func WaitClusterDataUpdated(e *store.KVBackedStore, timeout time.Duration) error
func WaitClusterDataWithMaster ¶ added in v0.5.0
func WaitClusterPhase ¶ added in v0.5.0
func WaitClusterPhase(e *store.KVBackedStore, phase cluster.ClusterPhase, timeout time.Duration) error
func WaitClusterSyncedXLogPos ¶ added in v0.6.0
func WaitClusterSyncedXLogPos(keepers []*TestKeeper, xLogPos uint64, e *store.KVBackedStore, timeout time.Duration) error
WaitClusterSyncedXLogPos waits for all the specified keepers to have the same reported XLogPos and that it's >= than master XLogPos
func WaitNumDBs ¶ added in v0.5.0
func WaitStandbyKeeper ¶ added in v0.5.0
Types ¶
type Process ¶
type Process struct {
// contains filtered or unexported fields
}
func (*Process) StartExpect ¶
type ReplQuerier ¶ added in v0.13.0
type TestKeeper ¶
type TestKeeper struct { Process // contains filtered or unexported fields }
func NewTestKeeper ¶
func NewTestKeeperWithID ¶
func (*TestKeeper) CheckPoint ¶ added in v0.8.0
func (tk *TestKeeper) CheckPoint() error
func (*TestKeeper) Exec ¶
func (tk *TestKeeper) Exec(query string, args ...interface{}) (sql.Result, error)
func (*TestKeeper) GetPGParameters ¶ added in v0.5.0
func (tk *TestKeeper) GetPGParameters() (common.Parameters, error)
func (*TestKeeper) GetPGProcess ¶
func (tk *TestKeeper) GetPGProcess() (*os.Process, error)
func (*TestKeeper) GetPrimaryConninfo ¶ added in v0.6.0
func (tk *TestKeeper) GetPrimaryConninfo() (pg.ConnParams, error)
func (*TestKeeper) PGDataVersion ¶ added in v0.6.0
func (tk *TestKeeper) PGDataVersion() (int, int, error)
func (*TestKeeper) Query ¶
func (tk *TestKeeper) Query(query string, args ...interface{}) (*sql.Rows, error)
func (*TestKeeper) ReplQuery ¶ added in v0.9.0
func (tk *TestKeeper) ReplQuery(query string, args ...interface{}) (*sql.Rows, error)
func (*TestKeeper) SwitchWals ¶ added in v0.7.0
func (tk *TestKeeper) SwitchWals(times int) error
func (*TestKeeper) WaitDBDown ¶
func (tk *TestKeeper) WaitDBDown(timeout time.Duration) error
func (*TestKeeper) WaitDBRole ¶ added in v0.6.0
func (tk *TestKeeper) WaitDBRole(r common.Role, ptk *TestKeeper, timeout time.Duration) error
type TestProxy ¶
type TestProxy struct { Process // contains filtered or unexported fields }
func NewTestProxy ¶
func (*TestProxy) CheckListening ¶ added in v0.7.0
func (*TestProxy) GetPGParameters ¶ added in v0.7.0
func (tp *TestProxy) GetPGParameters() (common.Parameters, error)
func (*TestProxy) WaitNotListening ¶
func (*TestProxy) WaitRightMaster ¶ added in v0.7.0
func (tp *TestProxy) WaitRightMaster(tk *TestKeeper, timeout time.Duration) error
type TestSentinel ¶
type TestSentinel struct { Process // contains filtered or unexported fields }
type TestStore ¶ added in v0.3.0
type TestStore struct { Process // contains filtered or unexported fields }
func NewTestConsul ¶ added in v0.3.0
func NewTestEtcd ¶
func NewTestStore ¶ added in v0.3.0
Click to show internal directories.
Click to hide internal directories.