testhelpers

Documentation

Index

• func ConfClusterAndCore(t testing.T, conf *vault.CoreConfig, opts *vault.TestClusterOptions) (*vault.TestCluster, *vault.TestClusterCore)
• func DeriveActiveCore(t testing.T, cluster *vault.TestCluster) *vault.TestClusterCore
• func DeriveStandbyCores(t testing.T, cluster *vault.TestCluster) []*vault.TestClusterCore
• func EnsureCoreIsPerfStandby(t testing.T, client *api.Client)
• func EnsureCoreSealed(t testing.T, core *vault.TestClusterCore) error
• func EnsureCoreUnsealed(t testing.T, c *vault.TestCluster, core *vault.TestClusterCore)
• func EnsureCoresSealed(t testing.T, c *vault.TestCluster)
• func EnsureCoresUnsealed(t testing.T, c *vault.TestCluster)
• func GenerateRoot(t testing.T, cluster *vault.TestCluster, drToken bool) string
• func GenerateRootWithError(t testing.T, cluster *vault.TestCluster, drToken bool) (string, error)
• func GetClusterAndCore(t testing.T, logger log.Logger, ...) (*vault.TestCluster, *vault.TestClusterCore)
• func PassthroughWithLocalPathsFactory(ctx context.Context, c *logical.BackendConfig) (logical.Backend, error)
• func RandomWithPrefix(name string) string
• func SetupFourClusterReplication(t testing.T, pri, sec, pridr, secdr *vault.TestCluster)
• func SetupTwoClusterPerfReplication(t testing.T, pri, sec *vault.TestCluster)
• func WaitForActiveNode(t testing.T, cluster *vault.TestCluster) *vault.TestClusterCore
• func WaitForMatchingMerkleRoots(t testing.T, endpoint string, primary, secondary *api.Client)
• func WaitForNCoresSealed(t testing.T, cluster *vault.TestCluster, n int)
• func WaitForReplicationState(t testing.T, c *vault.Core, state consts.ReplicationState)
• func WaitForWAL(t testing.T, c *vault.TestClusterCore, wal uint64)
• type PassthroughWithLocalPaths
  • func (p *PassthroughWithLocalPaths) SpecialPaths() *logical.Paths
• type ReplicatedTestClusters
  • func GetFourReplicatedClusters(t testing.T, handlerFunc func(*vault.HandlerProperties) http.Handler) *ReplicatedTestClusters
  • func GetPerfReplicatedClusters(t testing.T, conf *vault.CoreConfig, opts *vault.TestClusterOptions) *ReplicatedTestClusters
  • func (r *ReplicatedTestClusters) Cleanup()
  • func (r *ReplicatedTestClusters) Primary() (*vault.TestCluster, *vault.TestClusterCore, *api.Client)
  • func (r *ReplicatedTestClusters) PrimaryDR() (*vault.TestCluster, *vault.TestClusterCore, *api.Client)
  • func (r *ReplicatedTestClusters) Secondary() (*vault.TestCluster, *vault.TestClusterCore, *api.Client)
  • func (r *ReplicatedTestClusters) SecondaryDR() (*vault.TestCluster, *vault.TestClusterCore, *api.Client)
• type ReplicatedTestClustersBuilder

Functions

func ConfClusterAndCore

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

func DeriveActiveCore

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

func DeriveStandbyCores

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

func EnsureCoreIsPerfStandby

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

func EnsureCoreSealed

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

func EnsureCoreUnsealed

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

func EnsureCoresSealed

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

func EnsureCoresUnsealed

func EnsureCoresUnsealed(t testing.T, c *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 GetClusterAndCore

func GetClusterAndCore(t testing.T, logger log.Logger, handlerFunc func(*vault.HandlerProperties) http.Handler) (*vault.TestCluster, *vault.TestClusterCore)

func PassthroughWithLocalPathsFactory

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

func RandomWithPrefix

func RandomWithPrefix(name string) string

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

func SetupFourClusterReplication

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

func SetupTwoClusterPerfReplication

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

func WaitForActiveNode

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

func WaitForMatchingMerkleRoots

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

func WaitForNCoresSealed

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

func WaitForReplicationState

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

func WaitForWAL

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

Types

type PassthroughWithLocalPaths

type PassthroughWithLocalPaths struct {
	logical.Backend
}

func (*PassthroughWithLocalPaths) SpecialPaths

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

type ReplicatedTestClusters

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

func GetFourReplicatedClusters

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

func GetPerfReplicatedClusters

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

func (*ReplicatedTestClusters) Cleanup

func (r *ReplicatedTestClusters) Cleanup()

func (*ReplicatedTestClusters) Primary

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

func (*ReplicatedTestClusters) PrimaryDR

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

func (*ReplicatedTestClusters) Secondary

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

func (*ReplicatedTestClusters) SecondaryDR

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

type ReplicatedTestClustersBuilder

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