Documentation
¶
Index ¶
- func WaitClusterViewMaster(master string, e *etcdm.EtcdManager, timeout time.Duration) error
- type CheckFunc
- type Process
- type TestEtcd
- type TestKeeper
- 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
- type TestSentinel
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WaitClusterViewMaster ¶
Types ¶
type Process ¶
type Process struct {
// contains filtered or unexported fields
}
func (*Process) StartExpect ¶
type TestEtcd ¶
type TestEtcd struct {
Process
// contains filtered or unexported fields
}
func (*TestEtcd) GetEtcdNode ¶
type TestKeeper ¶
type TestKeeper struct {
Process
// contains filtered or unexported fields
}
func NewTestKeeper ¶
func NewTestKeeperWithID ¶
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) WaitDBDown ¶
func (tk *TestKeeper) WaitDBDown(timeout time.Duration) error
type TestProxy ¶
type TestProxy struct {
Process
// contains filtered or unexported fields
}
func NewTestProxy ¶
type TestSentinel ¶
type TestSentinel struct {
Process
// contains filtered or unexported fields
}
func NewTestSentinel ¶
func NewTestSentinel(dir string, clusterName string, etcdEndpoints string) (*TestSentinel, error)
Source Files
Click to show internal directories.
Click to hide internal directories.