Versions in this module Expand all Collapse all v0 v0.1.0 Sep 30, 2024retracted Changes in this version + func AttemptUnsealCore(c *vault.TestCluster, core *vault.TestClusterCore) error + func AttemptUnsealCores(c *vault.TestCluster) error + func AwaitLeader(t testing.T, cluster *vault.TestCluster) (int, error) + func CreateEntityAndAlias(t testing.T, client *api.Client, mountAccessor, entityName, aliasName string) (*api.Client, string, string) + func DeriveActiveCore(t testing.T, cluster *vault.TestCluster) *vault.TestClusterCore + func DeriveStableActiveCore(t testing.T, cluster *vault.TestCluster) *vault.TestClusterCore + func DeriveStandbyCores(t testing.T, cluster *vault.TestCluster) []*vault.TestClusterCore + 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 GenerateDebugLogs(t testing.T, client *api.Client) chan struct + func GenerateRoot(t testing.T, cluster *vault.TestCluster, kind GenerateRootKind) string + func GenerateRootWithError(t testing.T, cluster *vault.TestCluster, kind GenerateRootKind) (string, error) + func GetTOTPCodeFromEngine(t testing.T, client *api.Client, enginePath string) string + func IsLocalOrRegressionTests() bool + func NewHardcodedServerAddressProvider(numCores, baseClusterPort int) raftlib.ServerAddressProvider + func RaftAppliedIndex(core *vault.TestClusterCore) uint64 + func RaftClusterJoinNodes(t testing.T, cluster *vault.TestCluster) + func RandomWithPrefix(name string) string + func RegisterEntityInTOTPEngine(t testing.T, client *api.Client, entityID, methodID string) string + func RekeyCluster(t testing.T, cluster *vault.TestCluster, recovery bool) [][]byte + func RetryUntil(t testing.T, timeout time.Duration, f func() error) + func RetryUntilAtCadence(t testing.T, timeout, sleepTime time.Duration, f func() error) + func SealCores(t testing.T, cluster *vault.TestCluster) + func SetNonRootToken(client *api.Client) error + func SetupLoginMFATOTP(t testing.T, client *api.Client, methodName string, waitPeriod int) (*api.Client, string, string) + func SetupMFALoginEnforcement(t testing.T, client *api.Client, config map[string]interface{}) + func SetupTOTPMethod(t testing.T, client *api.Client, config map[string]interface{}) string + func SetupTOTPMount(t testing.T, client *api.Client) + func SetupUserpassMountAccessor(t testing.T, client *api.Client) string + func SkipUnlessEnvVarsSet(t testing.T, envVars []string) + func TestMetricSinkProvider(gaugeInterval time.Duration) func(string) (*metricsutil.ClusterMetricSink, *metricsutil.MetricsHelper) + func VerifyRaftConfiguration(core *vault.TestClusterCore, numCores int) error + func VerifyRaftPeers(t testing.T, client *api.Client, expected map[string]bool) error + func WaitForActiveNode(t testing.T, cluster *vault.TestCluster) *vault.TestClusterCore + func WaitForActiveNodeAndStandbys(t testing.T, cluster *vault.TestCluster) + func WaitForNCoresSealed(t testing.T, cluster *vault.TestCluster, n int) + func WaitForNCoresUnsealed(t testing.T, cluster *vault.TestCluster, n int) + func WaitForNodesExcludingSelectedStandbys(t testing.T, cluster *vault.TestCluster, indexesToSkip ...int) + func WaitForRaftApply(t testing.T, core *vault.TestClusterCore, index uint64) + func WaitForStandbyNode(t testing.T, core *vault.TestClusterCore) + type GenerateRootKind int + const GenerateRecovery + const GenerateRootDR + const GenerateRootRegular + type HardcodedServerAddressProvider struct + Entries map[raftlib.ServerID]raftlib.ServerAddress + func (p *HardcodedServerAddressProvider) ServerAddr(id raftlib.ServerID) (raftlib.ServerAddress, error) + type SysMetricsJSON struct + Counters []counterJSON + Gauges []gaugeJSON + Summaries []summaryJSON + func SysMetricsReq(client *api.Client, cluster *vault.TestCluster, unauth bool) (*SysMetricsJSON, error) + type TestRaftServerAddressProvider struct + Cluster *vault.TestCluster + func (p *TestRaftServerAddressProvider) ServerAddr(id raftlib.ServerID) (raftlib.ServerAddress, error)
Go to main page