e2e

package

Go to main page

Versions in this module

v3

v3.6.0-rc.2

Mar 5, 2025

v3.6.0-rc.1

Feb 25, 2025

v3.6.0-rc.0

Feb 13, 2025

v3.6.0-alpha.0

Feb 28, 2022

v3.5.19

Mar 5, 2025

v3.5.18

Jan 24, 2025

v3.5.17

Nov 12, 2024

v3.5.16

Sep 10, 2024

v3.5.15

Jul 19, 2024

v3.5.14

May 29, 2024

Changes in this version

+ var BinPathLastRelease string

+ func AssertProcessLogs(t *testing.T, ep EtcdProcess, expectLog string)

+ func GetVersionFromBinary(binaryPath string) (*semver.Version, error)

+ type ClusterContext struct

+ Version ClusterVersion

+ type ClusterVersion string

+ const CurrentVersion

+ const LastVersion

+ const MinorityLastVersion

+ const QuorumLastVersion

type EtcdProcessCluster

+ func (epc *EtcdProcessCluster) AddMember(cfg *EtcdProcessClusterConfig, tb testing.TB) (memberID uint64, serverCfg *EtcdServerProcessConfig, err error)

+ func (epc *EtcdProcessCluster) Etcdctl() *Etcdctl

+ func (epc *EtcdProcessCluster) StartNewProc(cfg *EtcdProcessClusterConfig, tb testing.TB) (memberID uint64, err error)

+ func (epc *EtcdProcessCluster) StartNewProcFromConfig(tb testing.TB, serverCfg *EtcdServerProcessConfig) error

type EtcdProcessClusterConfig

+ ExperimentalStopGRPCServiceOnDefrag bool

+ Logger *zap.Logger

+ NextClusterVersionCompatible bool

+ SnapshotCatchUpEntries int

+ Version ClusterVersion

+ func (cfg *EtcdProcessClusterConfig) EtcdServerProcessConfig(tb testing.TB, i int) *EtcdServerProcessConfig

+ func (cfg *EtcdProcessClusterConfig) SetInitialCluster(serverCfg *EtcdServerProcessConfig, initialCluster []string, ...)

type Etcdctl

+ func (ctl *Etcdctl) Defragment(timeout time.Duration) error

+ func (ctl *Etcdctl) GetWithPrefix(key string) (*clientv3.GetResponse, error)

+ func (ctl *Etcdctl) HashKV(rev int64) ([]*clientv3.HashKVResponse, error)

+ func (ctl *Etcdctl) MemberAddAsLearner(name string, peerURLs []string) (*clientv3.MemberAddResponse, error)

v3.5.13

Mar 29, 2024

Changes in this version

type EtcdProcess

+ Etcdctl func(connType ClientConnType, isAutoTLS bool, v2 bool) *Etcdctl

type EtcdProcessCluster

+ func (epc *EtcdProcessCluster) EndpointsGRPC() []string

+ func (epc *EtcdProcessCluster) EndpointsHTTP() []string

+ func (epc *EtcdProcessCluster) WaitLeader(t testing.TB) int

+ func (epc *EtcdProcessCluster) WaitMembersForLeader(ctx context.Context, t testing.TB, membs []EtcdProcess) int

type EtcdProcessClusterConfig

+ BaseClientScheme string

+ BasePeerScheme string

+ GoFailClientTimeout time.Duration

type EtcdServerProcess

+ func (ep *EtcdServerProcess) Etcdctl(connType ClientConnType, isAutoTLS, v2 bool) *Etcdctl

type EtcdServerProcessConfig

+ GoFailClientTimeout time.Duration

+ type Etcdctl struct

+ func NewEtcdctl(endpoints []string, connType ClientConnType, isAutoTLS bool, v2 bool) *Etcdctl

+ func (ctl *Etcdctl) AlarmList() (*clientv3.AlarmResponse, error)

+ func (ctl *Etcdctl) AuthEnable() error

+ func (ctl *Etcdctl) Compact(rev int64) (*clientv3.CompactResponse, error)

+ func (ctl *Etcdctl) Get(key string) (*clientv3.GetResponse, error)

+ func (ctl *Etcdctl) MemberAdd(name string, peerURLs []string) (*clientv3.MemberAddResponse, error)

+ func (ctl *Etcdctl) MemberList() (*clientv3.MemberListResponse, error)

+ func (ctl *Etcdctl) MemberRemove(id uint64) (*clientv3.MemberRemoveResponse, error)

+ func (ctl *Etcdctl) Put(key, value string) error

+ func (ctl *Etcdctl) PutWithAuth(key, value, username, password string) error

+ func (ctl *Etcdctl) Set(key, value string) error

+ func (ctl *Etcdctl) Status() ([]*clientv3.StatusResponse, error)

+ func (ctl *Etcdctl) UserAdd(name, password string) (*clientv3.AuthUserAddResponse, error)

+ func (ctl *Etcdctl) UserGrantRole(user string, role string) (*clientv3.AuthUserGrantRoleResponse, error)

v3.5.12

Jan 31, 2024

Changes in this version

+ const EtcdProcessBasePort

+ var BinDir string

+ var BinPath string

+ var CaPath string

+ var CertDir string

+ var CertPath string

+ var CertPath2 string

+ var CertPath3 string

+ var CrlPath string

+ var CtlBinPath string

+ var EtcdServerReadyLines = []string

+ var FixturesDir = integration.MustAbsPath("../fixtures")

+ var PrivateKeyPath string

+ var PrivateKeyPath2 string

+ var PrivateKeyPath3 string

+ var RevokedCertPath string

+ var RevokedPrivateKeyPath string

+ var UtlBinPath string

+ func AddV2Args(args []string) []string

+ func BeforeTest(t testing.TB)

+ func CURLGet(clus *EtcdProcessCluster, req CURLReq) error

+ func CURLPost(clus *EtcdProcessCluster, req CURLReq) error

+ func CURLPrefixArgs(clientURL string, connType ClientConnType, CN bool, method string, req CURLReq) []string

+ func CURLPrefixArgsCluster(clus *EtcdProcessCluster, method string, req CURLReq) []string

+ func CURLPut(clus *EtcdProcessCluster, req CURLReq) error

+ func CloseWithTimeout(p *expect.ExpectProcess, d time.Duration) error

+ func DataMarshal(data interface{}) (d string, e error)

+ func ExecuteUntil(ctx context.Context, t *testing.T, f func())

+ func InitFlags()

+ func RandomLeaseID() int64

+ func RunUtilCompletion(args []string, envVars map[string]string) ([]string, error)

+ func SkipInShortMode(t testing.TB)

+ func SpawnCmd(args []string, envVars map[string]string) (*expect.ExpectProcess, error)

+ func SpawnCmdWithLogger(lg *zap.Logger, args []string, envVars map[string]string) (*expect.ExpectProcess, error)

+ func SpawnWithExpect(args []string, expected string) error

+ func SpawnWithExpectLines(args []string, envVars map[string]string, xs ...string) ([]string, error)

+ func SpawnWithExpectWithEnv(args []string, envVars map[string]string, expected string) error

+ func SpawnWithExpects(args []string, envVars map[string]string, xs ...string) error

+ func ToTLS(s string) string

+ func WaitReadyExpectProc(exproc *expect.ExpectProcess, readyStrs []string) error

+ type BinaryFailpoints struct

+ func (f *BinaryFailpoints) Available(failpoint string) bool

+ func (f *BinaryFailpoints) DeactivateHTTP(ctx context.Context, failpoint string) error

+ func (f *BinaryFailpoints) Enabled() bool

+ func (f *BinaryFailpoints) SetupEnv(failpoint, payload string) error

+ func (f *BinaryFailpoints) SetupHTTP(ctx context.Context, failpoint, payload string) error

+ type CURLReq struct

+ Ciphers string

+ Endpoint string

+ Expected string

+ Header string

+ HttpVersion string

+ IsTLS bool

+ MetricsURLScheme string

+ OutputFile string

+ Password string

+ Timeout int

+ Username string

+ Value string

+ type ClientConnType int

+ const ClientNonTLS

+ const ClientTLS

+ const ClientTLSAndNonTLS

+ type EtcdProcess interface

+ Close func() error

+ Config func() *EtcdServerProcessConfig

+ EndpointsGRPC func() []string

+ EndpointsHTTP func() []string

+ EndpointsMetrics func() []string

+ EndpointsV2 func() []string

+ EndpointsV3 func() []string

+ Failpoints func() *BinaryFailpoints

+ IsRunning func() bool

+ Logs func() LogsExpect

+ PeerProxy func() proxy.Server

+ Restart func() error

+ Start func() error

+ Stop func() error

+ WithStopSignal func(sig os.Signal) os.Signal

+ func NewEtcdProcess(cfg *EtcdServerProcessConfig) (EtcdProcess, error)

+ type EtcdProcessCluster struct

+ Cfg *EtcdProcessClusterConfig

+ Procs []EtcdProcess

+ func InitEtcdProcessCluster(t testing.TB, cfg *EtcdProcessClusterConfig) (*EtcdProcessCluster, error)

+ func NewEtcdProcessCluster(t testing.TB, cfg *EtcdProcessClusterConfig) (*EtcdProcessCluster, error)

+ func StartEtcdProcessCluster(t testing.TB, epc *EtcdProcessCluster, cfg *EtcdProcessClusterConfig) (*EtcdProcessCluster, error)

+ func (epc *EtcdProcessCluster) Close() error

+ func (epc *EtcdProcessCluster) Endpoints(f func(ep EtcdProcess) []string) (ret []string)

+ func (epc *EtcdProcessCluster) EndpointsV2() []string

+ func (epc *EtcdProcessCluster) EndpointsV3() []string

+ func (epc *EtcdProcessCluster) Restart() error

+ func (epc *EtcdProcessCluster) RollingStart() error

+ func (epc *EtcdProcessCluster) Start() error

+ func (epc *EtcdProcessCluster) Stop() (err error)

+ func (epc *EtcdProcessCluster) WithStopSignal(sig os.Signal) (ret os.Signal)

+ type EtcdProcessClusterConfig struct

+ AuthTokenOpts string

+ BasePort int

+ BaseScheme string

+ CipherSuites []string

+ ClientCertAuthEnabled bool

+ ClientHttpSeparate bool

+ ClientTLS ClientConnType

+ ClusterSize int

+ CompactHashCheckEnabled bool

+ CompactHashCheckTime time.Duration

+ CompactionBatchLimit int

+ CorruptCheckTime time.Duration

+ DataDirPath string

+ EnableV2 bool

+ EnvVars map[string]string

+ ExecPath string

+ ForceNewCluster bool

+ GoFailEnabled bool

+ InitialCorruptCheck bool

+ InitialToken string

+ IsClientAutoTLS bool

+ IsClientCRL bool

+ IsPeerAutoTLS bool

+ IsPeerTLS bool

+ KeepDataDir bool

+ LogLevel string

+ MaxConcurrentStreams uint32

+ MetricsURLScheme string

+ NoCN bool

+ NoStrictReconfig bool

+ PeerProxy bool

+ QuotaBackendBytes int64

+ RollingStart bool

+ SnapshotCount int

+ V2deprecation string

+ WatchProcessNotifyInterval time.Duration

+ func ConfigStandalone(cfg EtcdProcessClusterConfig) *EtcdProcessClusterConfig

+ func NewConfigAutoTLS() *EtcdProcessClusterConfig

+ func NewConfigClientAutoTLS() *EtcdProcessClusterConfig

+ func NewConfigClientBoth() *EtcdProcessClusterConfig

+ func NewConfigClientTLS() *EtcdProcessClusterConfig

+ func NewConfigClientTLSCertAuth() *EtcdProcessClusterConfig

+ func NewConfigClientTLSCertAuthWithNoCN() *EtcdProcessClusterConfig

+ func NewConfigJWT() *EtcdProcessClusterConfig

+ func NewConfigNoTLS() *EtcdProcessClusterConfig

+ func NewConfigPeerTLS() *EtcdProcessClusterConfig

+ func NewConfigTLS() *EtcdProcessClusterConfig

+ func (cfg *EtcdProcessClusterConfig) ClientScheme() string

+ func (cfg *EtcdProcessClusterConfig) EtcdServerProcessConfigs(tb testing.TB) []*EtcdServerProcessConfig

+ func (cfg *EtcdProcessClusterConfig) PeerScheme() string

+ func (cfg *EtcdProcessClusterConfig) TlsArgs() (args []string)

+ type EtcdServerProcess struct

+ func NewEtcdServerProcess(cfg *EtcdServerProcessConfig) (*EtcdServerProcess, error)

+ func (ep *EtcdServerProcess) Close() error

+ func (ep *EtcdServerProcess) Config() *EtcdServerProcessConfig

+ func (ep *EtcdServerProcess) EndpointsGRPC() []string

+ func (ep *EtcdServerProcess) EndpointsHTTP() []string

+ func (ep *EtcdServerProcess) EndpointsMetrics() []string

+ func (ep *EtcdServerProcess) EndpointsV2() []string

+ func (ep *EtcdServerProcess) EndpointsV3() []string

+ func (ep *EtcdServerProcess) Failpoints() *BinaryFailpoints

+ func (ep *EtcdServerProcess) IsRunning() bool

+ func (ep *EtcdServerProcess) Logs() LogsExpect

+ func (ep *EtcdServerProcess) PeerProxy() proxy.Server

+ func (ep *EtcdServerProcess) Restart() error

+ func (ep *EtcdServerProcess) Start() error

+ func (ep *EtcdServerProcess) Stop() (err error)

+ func (ep *EtcdServerProcess) WithStopSignal(sig os.Signal) os.Signal

+ type EtcdServerProcessConfig struct

+ Acurl string

+ Args []string

+ ClientHttpUrl string

+ DataDirPath string

+ EnvVars map[string]string

+ ExecPath string

+ GoFailPort int

+ InitialCluster string

+ InitialToken string

+ KeepDataDir bool

+ Murl string

+ Name string

+ Proxy *proxy.ServerConfig

+ Purl url.URL

+ TlsArgs []string

+ type LogsExpect interface

+ Expect func(string) (string, error)

+ LineCount func() int

+ Lines func() []string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL