package testutils

import "go.etcd.io/etcd/tests/v3/framework/testutils"

Index ¶

• func ExecuteUntil(ctx context.Context, t *testing.T, f func())
• func ExecuteWithTimeout(t *testing.T, timeout time.Duration, f func())
• func KeysFromGetResponse(resp *clientv3.GetResponse) (kvs []string)
• func MustAbsPath(path string) string
• func MustClient(c intf.Client, err error) intf.Client
• type KV
• func KeyValuesFromGetResponse(resp *clientv3.GetResponse) (kvs []KV)
• func KeyValuesFromWatchChan(wch clientv3.WatchChan, wantedLen int, timeout time.Duration) (kvs []KV, err error)
• func KeyValuesFromWatchResponse(resp clientv3.WatchResponse) (kvs []KV)
• type LogObserver
• func NewLogObserver(level zapcore.LevelEnabler) (zapcore.Core, *LogObserver)
• func (logOb *LogObserver) Expect(ctx context.Context, s string, count int) ([]string, error)
• func (logOb *LogObserver) ExpectFunc(ctx context.Context, filter func(string) bool, count int) ([]string, error)

Functions ¶

func ExecuteUntil ¶

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

func ExecuteWithTimeout ¶

func ExecuteWithTimeout(t *testing.T, timeout time.Duration, f func())

func KeysFromGetResponse ¶

func KeysFromGetResponse(resp *clientv3.GetResponse) (kvs []string)

func MustAbsPath ¶

func MustAbsPath(path string) string

func MustClient ¶

func MustClient(c intf.Client, err error) intf.Client

Types ¶

type KV ¶

type KV struct {
	Key, Val string
}

func KeyValuesFromGetResponse ¶

func KeyValuesFromGetResponse(resp *clientv3.GetResponse) (kvs []KV)

func KeyValuesFromWatchChan ¶

func KeyValuesFromWatchChan(wch clientv3.WatchChan, wantedLen int, timeout time.Duration) (kvs []KV, err error)

func KeyValuesFromWatchResponse ¶

func KeyValuesFromWatchResponse(resp clientv3.WatchResponse) (kvs []KV)

type LogObserver ¶

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

func NewLogObserver ¶

func NewLogObserver(level zapcore.LevelEnabler) (zapcore.Core, *LogObserver)

func (*LogObserver) Expect ¶

func (logOb *LogObserver) Expect(ctx context.Context, s string, count int) ([]string, error)

Expect returns the first N lines containing the given string.

func (*LogObserver) ExpectFunc ¶

func (logOb *LogObserver) ExpectFunc(ctx context.Context, filter func(string) bool, count int) ([]string, error)

ExpectFunc returns the first N line satisfying the function f.

Source Files ¶

execute.go helpters.go log_observer.go path.go