Documentation
¶
Index ¶
- func ConfClusterAndCore(t testing.T, conf *vault.CoreConfig, opts *vault.TestClusterOptions) (*vault.TestCluster, *vault.TestClusterCore)
- func CreateRaftBackend(t testing.T, logger hclog.Logger, nodeID string) (physical.Backend, func(), error)
- 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)
- 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 EnsureStableActiveNode(t testing.T, cluster *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 PassthroughWithLocalPathsFactory(ctx context.Context, c *logical.BackendConfig) (logical.Backend, error)
- func RaftClusterJoinNodes(t testing.T, cluster *vault.TestCluster)
- func RandomWithPrefix(name string) string
- func RekeyCluster(t testing.T, cluster *vault.TestCluster)
- 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 WaitForActiveNodeAndPerfStandbys(t testing.T, cluster *vault.TestCluster)
- func WaitForMatchingMerkleRoots(t testing.T, endpoint string, primary, secondary *api.Client)
- func WaitForMatchingMerkleRootsCore(t testing.T, pri, sec *vault.TestClusterCore, dr bool)
- func WaitForNCoresSealed(t testing.T, cluster *vault.TestCluster, n int)
- func WaitForNCoresUnsealed(t testing.T, cluster *vault.TestCluster, n int)
- func WaitForPerfReplicationWorking(t testing.T, pri, sec *vault.TestCluster)
- func WaitForReplicationState(t testing.T, c *vault.Core, state consts.ReplicationState)
- func WaitForReplicationStatus(t testing.T, client *api.Client, dr bool, ...)
- func WaitForWAL(t testing.T, c *vault.TestClusterCore, wal uint64)
- type PassthroughWithLocalPaths
- type ReplicatedTestClusters
- func GetFourReplicatedClusters(t testing.T, handlerFunc func(*vault.HandlerProperties) http.Handler) *ReplicatedTestClusters
- func GetFourReplicatedClustersWithConf(t testing.T, conf *vault.CoreConfig, opts *vault.TestClusterOptions) *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
- type TestRaftServerAddressProvider
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 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 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 ¶
Generates a root token on the target cluster.
func GenerateRootWithError ¶
func PassthroughWithLocalPathsFactory ¶ added in v1.1.1
func RaftClusterJoinNodes ¶ added in v1.2.0
func RaftClusterJoinNodes(t testing.T, cluster *vault.TestCluster)
func RandomWithPrefix ¶ added in v0.11.0
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 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 WaitForReplicationStatus ¶ added in v1.2.0
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
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)
Click to show internal directories.
Click to hide internal directories.