integration

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 30, 2017 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MinPort = 2048
	MaxPort = 16384
)

Variables

This section is empty.

Functions

func StolonCtl added in v0.5.0 

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

func WaitClusterDataKeeperInitialized added in v0.5.0 

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

func WaitClusterDataKeepers added in v0.6.0 

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

func WaitClusterDataMaster added in v0.5.0 

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

func WaitClusterDataSynchronousStandbys added in v0.5.0 

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

WaitClusterDataSynchronousStandbys waits for: * synchronous standby defined in masterdb spec * synchronous standby reported from masterdb status

func WaitClusterDataWithMaster added in v0.5.0 

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

func WaitClusterPhase added in v0.5.0 

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

func WaitClusterSyncedXLogPos added in v0.6.0 

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

WaitClusterSyncedXLogPos waits for all the specified keepers to have the same reported XLogPos

func WaitNumDBs added in v0.5.0 

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

func WaitStandbyKeeper added in v0.5.0 

func WaitStandbyKeeper(e *store.StoreManager, keeperUID string, 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, uid, 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) 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) SignalPG 

func (tk *TestKeeper) SignalPG(sig os.Signal) 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

func (*TestKeeper) WaitDBUp 

func (tk *TestKeeper) WaitDBUp(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 added in v0.3.0 

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

func NewTestConsul added in v0.3.0 

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 added in v0.3.0 

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

func (*TestStore) WaitDown added in v0.3.0 

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

func (*TestStore) WaitUp added in v0.3.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.