integration

package

v0.5.0 Latest Latest Go to latest Published: Dec 14, 2016 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gocardless/stolon

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
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 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) GetPGParameters() (common.Parameters, 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) WaitRole(r common.Role, 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

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 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: * synchrnous standby defined in masterdb spec * synchrnous 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 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) 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) WaitRole ¶

func (tk *TestKeeper) WaitRole(r common.Role, 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

utils.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL