kubernetes/vendor/github.com/onsi/gomega/internal/async_assertion.go

var errInterface …

var gomegaType …

var contextType …

type formattedGomegaError …

type asyncPolledActualError …

func (err *asyncPolledActualError) Error() string { … }

func (err *asyncPolledActualError) FormattedGomegaError() string { … }

type contextWithAttachProgressReporter …

type asyncGomegaHaltExecutionError …

func (a asyncGomegaHaltExecutionError) GinkgoRecoverShouldIgnoreThisPanic() { … }

func (a asyncGomegaHaltExecutionError) Error() string { … }

type AsyncAssertionType …

const AsyncAssertionTypeEventually …

const AsyncAssertionTypeConsistently …

func (at AsyncAssertionType) String() string { … }

type AsyncAssertion …

func NewAsyncAssertion(asyncType AsyncAssertionType, actualInput interface{ … }

func (assertion *AsyncAssertion) WithOffset(offset int) types.AsyncAssertion { … }

func (assertion *AsyncAssertion) WithTimeout(interval time.Duration) types.AsyncAssertion { … }

func (assertion *AsyncAssertion) WithPolling(interval time.Duration) types.AsyncAssertion { … }

func (assertion *AsyncAssertion) Within(timeout time.Duration) types.AsyncAssertion { … }

func (assertion *AsyncAssertion) ProbeEvery(interval time.Duration) types.AsyncAssertion { … }

func (assertion *AsyncAssertion) WithContext(ctx context.Context) types.AsyncAssertion { … }

func (assertion *AsyncAssertion) WithArguments(argsToForward ...interface{ … }

func (assertion *AsyncAssertion) MustPassRepeatedly(count int) types.AsyncAssertion { … }

func (assertion *AsyncAssertion) Should(matcher types.GomegaMatcher, optionalDescription ...interface{ … }

func (assertion *AsyncAssertion) ShouldNot(matcher types.GomegaMatcher, optionalDescription ...interface{ … }

func (assertion *AsyncAssertion) buildDescription(optionalDescription ...interface{ … }

func (assertion *AsyncAssertion) processReturnValues(values []reflect.Value) (interface{ … }

func (assertion *AsyncAssertion) invalidFunctionError(t reflect.Type) error { … }

func (assertion *AsyncAssertion) noConfiguredContextForFunctionError() error { … }

func (assertion *AsyncAssertion) argumentMismatchError(t reflect.Type, numProvided int) error { … }

func (assertion *AsyncAssertion) invalidMustPassRepeatedlyError(reason string) error { … }

func (assertion *AsyncAssertion) buildActualPoller() (func() (interface{ … }

func (assertion *AsyncAssertion) afterTimeout() <-chan time.Time { … }

func (assertion *AsyncAssertion) afterPolling() <-chan time.Time { … }

func (assertion *AsyncAssertion) matcherSaysStopTrying(matcher types.GomegaMatcher, value interface{ … }

func (assertion *AsyncAssertion) pollMatcher(matcher types.GomegaMatcher, value interface{ … }

func (assertion *AsyncAssertion) match(matcher types.GomegaMatcher, desiredMatch bool, optionalDescription ...interface{ … }