testhelpers

package
v1.2.4 Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2019 License: MPL-2.0 Imports: 31 Imported by: 11

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConfClusterAndCore added in v1.1.0 

func ConfClusterAndCore(t testing.T, conf *vault.CoreConfig, opts *vault.TestClusterOptions) (*vault.TestCluster, *vault.TestClusterCore)

func CreateRaftBackend added in v1.2.0 

func CreateRaftBackend(t testing.T, logger hclog.Logger, nodeID string) (physical.Backend, func(), error)

func DeriveActiveCore added in v0.11.2 

func DeriveActiveCore(t testing.T, cluster *vault.TestCluster) *vault.TestClusterCore

func DeriveStandbyCores added in v1.1.1 

func DeriveStandbyCores(t testing.T, cluster *vault.TestCluster) []*vault.TestClusterCore

func EnsureCoreIsPerfStandby added in v1.0.3 

func EnsureCoreIsPerfStandby(t testing.T, client *api.Client)

func EnsureCoreSealed added in v1.0.3 

func EnsureCoreSealed(t testing.T, core *vault.TestClusterCore)

func EnsureCoreUnsealed added in v1.0.3 

func EnsureCoreUnsealed(t testing.T, c *vault.TestCluster, core *vault.TestClusterCore)

func EnsureCoresSealed added in v1.0.3 

func EnsureCoresSealed(t testing.T, c *vault.TestCluster)

func EnsureCoresUnsealed added in v0.11.2 

func EnsureCoresUnsealed(t testing.T, c *vault.TestCluster)

func EnsureStableActiveNode added in v1.2.0 

func EnsureStableActiveNode(t testing.T, cluster *vault.TestCluster)

func GenerateRoot 

func GenerateRoot(t testing.T, cluster *vault.TestCluster, drToken bool) string

Generates a root token on the target cluster.

func GenerateRootWithError 

func GenerateRootWithError(t testing.T, cluster *vault.TestCluster, drToken bool) (string, error)

func PassthroughWithLocalPathsFactory added in v1.1.1 

func PassthroughWithLocalPathsFactory(ctx context.Context, c *logical.BackendConfig) (logical.Backend, error)

func RaftClusterJoinNodes added in v1.2.0 

func RaftClusterJoinNodes(t testing.T, cluster *vault.TestCluster)

func RandomWithPrefix added in v0.11.0 

func RandomWithPrefix(name string) string

RandomWithPrefix is used to generate a unique name with a prefix, for randomizing names in acceptance tests

func RekeyCluster added in v1.2.0 

func RekeyCluster(t testing.T, cluster *vault.TestCluster)

func SetupFourClusterReplication added in v0.11.2 

func SetupFourClusterReplication(t testing.T, pri, sec, pridr, secdr *vault.TestCluster)

func SetupTwoClusterPerfReplication added in v1.0.3 

func SetupTwoClusterPerfReplication(t testing.T, pri, sec *vault.TestCluster)

func WaitForActiveNode added in v1.1.0 

func WaitForActiveNode(t testing.T, cluster *vault.TestCluster) *vault.TestClusterCore

func WaitForActiveNodeAndPerfStandbys added in v1.2.0 

func WaitForActiveNodeAndPerfStandbys(t testing.T, cluster *vault.TestCluster)

func WaitForMatchingMerkleRoots added in v1.1.1 

func WaitForMatchingMerkleRoots(t testing.T, endpoint string, primary, secondary *api.Client)

func WaitForMatchingMerkleRootsCore added in v1.2.0 

func WaitForMatchingMerkleRootsCore(t testing.T, pri, sec *vault.TestClusterCore, dr bool)

func WaitForNCoresSealed added in v0.11.2 

func WaitForNCoresSealed(t testing.T, cluster *vault.TestCluster, n int)

func WaitForNCoresUnsealed added in v1.2.0 

func WaitForNCoresUnsealed(t testing.T, cluster *vault.TestCluster, n int)

func WaitForPerfReplicationWorking added in v1.2.0 

func WaitForPerfReplicationWorking(t testing.T, pri, sec *vault.TestCluster)

WaitForPerfReplicationWorking mounts a KV non-locally, writes to it on pri, and waits for the value to be readable on sec.

func WaitForReplicationState added in v0.11.2 

func WaitForReplicationState(t testing.T, c *vault.Core, state consts.ReplicationState)

func WaitForReplicationStatus added in v1.2.0 

func WaitForReplicationStatus(t testing.T, client *api.Client, dr bool, accept func(map[string]interface{}) bool)

func WaitForWAL added in v1.1.1 

func WaitForWAL(t testing.T, c *vault.TestClusterCore, wal uint64)

Types

type PassthroughWithLocalPaths added in v1.1.1 

type PassthroughWithLocalPaths struct {
	logical.Backend
}

func (*PassthroughWithLocalPaths) SpecialPaths added in v1.1.1 

func (p *PassthroughWithLocalPaths) SpecialPaths() *logical.Paths

type ReplicatedTestClusters added in v1.0.0 

type ReplicatedTestClusters struct {
	PerfPrimaryCluster     *vault.TestCluster
	PerfSecondaryCluster   *vault.TestCluster
	PerfPrimaryDRCluster   *vault.TestCluster
	PerfSecondaryDRCluster *vault.TestCluster
}

func GetFourReplicatedClusters added in v1.0.0 

func GetFourReplicatedClusters(t testing.T, handlerFunc func(*vault.HandlerProperties) http.Handler) *ReplicatedTestClusters

func GetFourReplicatedClustersWithConf added in v1.2.0 

func GetFourReplicatedClustersWithConf(t testing.T, conf *vault.CoreConfig, opts *vault.TestClusterOptions) *ReplicatedTestClusters

func GetPerfReplicatedClusters added in v1.0.3 

func GetPerfReplicatedClusters(t testing.T, conf *vault.CoreConfig, opts *vault.TestClusterOptions) *ReplicatedTestClusters

func (*ReplicatedTestClusters) Cleanup added in v1.0.0 

func (r *ReplicatedTestClusters) Cleanup()

func (*ReplicatedTestClusters) Primary added in v1.1.1 

func (r *ReplicatedTestClusters) Primary() (*vault.TestCluster, *vault.TestClusterCore, *api.Client)

func (*ReplicatedTestClusters) PrimaryDR added in v1.1.1 

func (r *ReplicatedTestClusters) PrimaryDR() (*vault.TestCluster, *vault.TestClusterCore, *api.Client)

func (*ReplicatedTestClusters) Secondary added in v1.1.1 

func (r *ReplicatedTestClusters) Secondary() (*vault.TestCluster, *vault.TestClusterCore, *api.Client)

func (*ReplicatedTestClusters) SecondaryDR added in v1.1.1 

func (r *ReplicatedTestClusters) SecondaryDR() (*vault.TestCluster, *vault.TestClusterCore, *api.Client)

type ReplicatedTestClustersBuilder added in v1.1.1 

type ReplicatedTestClustersBuilder struct {
	// contains filtered or unexported fields
}

type TestRaftServerAddressProvider added in v1.2.0 

type TestRaftServerAddressProvider struct {
	Cluster *vault.TestCluster
}

func (*TestRaftServerAddressProvider) ServerAddr added in v1.2.0 

func (p *TestRaftServerAddressProvider) ServerAddr(id raftlib.ServerID) (raftlib.ServerAddress, error)

Source Files

View all Source files

Directories

Path Synopsis

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.