acceptance

Documentation

Index

• func BidirectionalPartitionNemesis(ctx context.Context, t *testing.T, c cluster.Cluster, stopper *stop.Stopper)
• func CheckGossip(ctx context.Context, t testing.TB, c cluster.Cluster, d time.Duration, ...)
• func MakeFarmer(t testing.TB, prefix string, stopper *stop.Stopper) *terrafarm.Farmer
• func RunTests(m *testing.M)
• func SkipUnlessLocal(t testing.TB)
• func SkipUnlessPrivileged(t testing.TB)
• func SkipUnlessRemote(t testing.TB)
• func StartCluster(ctx context.Context, t *testing.T, cfg cluster.TestConfig) (c cluster.Cluster)
• type CheckGossipFunc
  • func HasPeers(expected int) CheckGossipFunc
• type NemesisFn

Functions

func BidirectionalPartitionNemesis

func BidirectionalPartitionNemesis(
	ctx context.Context, t *testing.T, c cluster.Cluster, stopper *stop.Stopper,
)

BidirectionalPartitionNemesis is a nemesis which randomly severs the network symmetrically between two random groups of nodes. Partitioned and connected mode take alternating turns, with random durations of up to 15s.

func CheckGossip

func CheckGossip(
	ctx context.Context, t testing.TB, c cluster.Cluster, d time.Duration, f CheckGossipFunc,
)

CheckGossip fetches the gossip infoStore from each node and invokes the given function. The test passes if the function returns 0 for every node, retrying for up to the given duration.

func MakeFarmer

func MakeFarmer(t testing.TB, prefix string, stopper *stop.Stopper) *terrafarm.Farmer

MakeFarmer creates a terrafarm farmer for use in acceptance tests.

func RunTests

func RunTests(m *testing.M)

RunTests runs the tests in a package while gracefully handling interrupts.

func SkipUnlessLocal

func SkipUnlessLocal(t testing.TB)

SkipUnlessLocal calls t.Skip if not running against a local cluster.

func SkipUnlessPrivileged

func SkipUnlessPrivileged(t testing.TB)

SkipUnlessPrivileged calls t.Skip if not running with the privileged flag.

func SkipUnlessRemote

func SkipUnlessRemote(t testing.TB)

SkipUnlessRemote calls t.Skip if not running against a remote cluster.

func StartCluster

func StartCluster(ctx context.Context, t *testing.T, cfg cluster.TestConfig) (c cluster.Cluster)

StartCluster starts a cluster from the relevant flags. All test clusters should be created through this command since it sets up the logging in a unified way.

Types

type CheckGossipFunc

type CheckGossipFunc func(map[string]gossip.Info) error

CheckGossipFunc is the type of callback used in CheckGossip.

func HasPeers

func HasPeers(expected int) CheckGossipFunc

HasPeers returns a CheckGossipFunc that passes when the given number of peers are connected via gossip.

type NemesisFn

type NemesisFn func(ctx context.Context, t *testing.T, c cluster.Cluster, stopper *stop.Stopper)

A NemesisFn runs a nemesis on the given cluster, shutting down in a timely manner when the stop channel is closed.