wait

Apr 4, 2024

Changes in this version

type ResourceGetter

+ GetScheduledLambda func(ctx context.Context, workspace, scheduledLambdaRRN string) (openapi.ScheduledLambda, error)

type Waiter

+ func (w *Waiter) UntilScheduledLambdaAvailable(ctx context.Context, workspace, scheduledLambdaRRN string) error

+ func (w *Waiter) UntilScheduledLambdaGone(ctx context.Context, workspace, scheduledLambdaRRN string) error

Feb 7, 2024

Changes in this version

type ResourceGetter

+ GetCollectionCommit func(ctx context.Context, workspace string, name string, offsets []string) (openapi.GetCollectionCommitData, error)

type Waiter

+ func (w *Waiter) UntilQueryable(ctx context.Context, workspace, name string, offsets []string) error

Jan 16, 2024

Changes in this version

type Waiter

+ QueryLambdaTagPropagation time.Duration

Nov 9, 2023

Changes in this version

type Waiter

+ func (w *Waiter) UntilQueryLambdaTagPropagated(ctx context.Context, workspace, name, tag string) error

Nov 2, 2023

Changes in this version

type ResourceGetter

+ GetQueryLambdaVersion func(ctx context.Context, workspace, name, version string) (openapi.QueryLambdaVersion, error)

type Waiter

+ func (w *Waiter) UntilQueryLambdaVersionActive(ctx context.Context, workspace, name, version string) error

+ func (w *Waiter) UntilQueryLambdaVersionGone(ctx context.Context, workspace, name, version string) error

Oct 10, 2023

Changes in this version

type Waiter

+ func (w *Waiter) UntilMountGone(ctx context.Context, vID, workspace, collection string) error

+ func (w *Waiter) UntilVirtualInstanceGone(ctx context.Context, id string) error

Oct 5, 2023

Changes in this version

+ func ResourceHasState(ctx context.Context, states []T, fn func(ctx context.Context) (T, error)) retry.CheckFn

+ func ResourceIsAvailable(ctx context.Context, fn func(ctx context.Context) error) retry.CheckFn

+ func ResourceIsGone(ctx context.Context, fn func(ctx context.Context) error) retry.CheckFn

+ type ResourceGetter interface

+ GetAlias func(ctx context.Context, workspace string, name string) (openapi.Alias, error)

+ GetCollection func(ctx context.Context, workspace string, name string) (openapi.Collection, error)

+ GetCollectionMount func(ctx context.Context, id, collectionPath string) (openapi.CollectionMount, error)

+ GetIntegration func(ctx context.Context, name string) (openapi.Integration, error)

+ GetQueryInfo func(ctx context.Context, queryID string) (openapi.QueryInfo, error)

+ GetView func(ctx context.Context, workspace, name string) (openapi.View, error)

+ GetVirtualInstance func(ctx context.Context, id string) (openapi.VirtualInstance, error)

+ GetWorkspace func(ctx context.Context, name string) (openapi.Workspace, error)

+ type Waiter struct

+ func New(rs ResourceGetter) *Waiter

+ func (w *Waiter) UntilAliasAvailable(ctx context.Context, workspace, alias string) error

+ func (w *Waiter) UntilAliasGone(ctx context.Context, workspace, alias string) error

+ func (w *Waiter) UntilCollectionGone(ctx context.Context, workspace, name string) error

+ func (w *Waiter) UntilCollectionHasDocuments(ctx context.Context, workspace, name string, count int64) error

+ func (w *Waiter) UntilCollectionHasNewDocuments(ctx context.Context, workspace, name string, count int64) error

+ func (w *Waiter) UntilCollectionReady(ctx context.Context, workspace, name string) error

+ func (w *Waiter) UntilKafkaIntegrationActive(ctx context.Context, integration string) error

+ func (w *Waiter) UntilMountActive(ctx context.Context, vID, workspace, collection string) error

+ func (w *Waiter) UntilQueryDone(ctx context.Context, queryID string) error

+ func (w *Waiter) UntilViewGone(ctx context.Context, workspace, name string) error

+ func (w *Waiter) UntilVirtualInstanceActive(ctx context.Context, id string) error

+ func (w *Waiter) UntilVirtualInstanceSuspended(ctx context.Context, id string) error

+ func (w *Waiter) UntilWorkspaceAvailable(ctx context.Context, workspace string) error

+ func (w *Waiter) UntilWorkspaceGone(ctx context.Context, workspace string) error