Documentation ¶
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
- type LogObserver
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func KeysFromGetResponse ¶
func KeysFromGetResponse(resp *clientv3.GetResponse) (kvs []string)
func MustAbsPath ¶
Types ¶
type KV ¶
type KV struct {
Key, Val string
}
func KeyValuesFromGetResponse ¶
func KeyValuesFromGetResponse(resp *clientv3.GetResponse) (kvs []KV)
func KeyValuesFromWatchChan ¶
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) 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.
Click to show internal directories.
Click to hide internal directories.