util

Documentation

Index

• Constants
• func DecodeFile(file string, to client.Object, options ...clientObjectOption) (client.Object, error)
• func Logf(f string, v ...interface{})
• func ObjectToJsonString(obj interface{}) string
• func ObjectToPrettyJsonString(obj interface{}) string
• func WithNamespace(namespace string) clientObjectOption
• type DeterminedE2EClient
  • func NewDeterminedClient(e2eKubeClient *E2EKubeClient) *DeterminedE2EClient
  • func (m *DeterminedE2EClient) Create(context context.Context, obj k8scontrollerclient.Object, ...) error
  • func (m *DeterminedE2EClient) Delete(context context.Context, obj k8scontrollerclient.Object, ...) error
  • func (m *DeterminedE2EClient) Patch(context context.Context, obj k8scontrollerclient.Object, ...) error
  • func (m *DeterminedE2EClient) Update(context context.Context, obj k8scontrollerclient.Object, ...) error
• type E2EKubeClient
  • func NewK8sResourceManager(client k8scontrollerclient.Client) *E2EKubeClient
  • func (m *E2EKubeClient) Create(context context.Context, obj k8scontrollerclient.Object, ...) error
  • func (m *E2EKubeClient) Delete(context context.Context, obj k8scontrollerclient.Object, ...) error
  • func (m *E2EKubeClient) GarbageCollectCRDs() error
  • func (m *E2EKubeClient) Reset() error
  • func (m *E2EKubeClient) Update(context context.Context, obj k8scontrollerclient.Object, ...) error
• type ResourceQueue
  • func NewResourceQueue() *ResourceQueue
  • func (q *ResourceQueue) DequeueHead() (k8scontrollerclient.Object, bool)
  • func (q *ResourceQueue) DequeueTail() (k8scontrollerclient.Object, bool)
  • func (q *ResourceQueue) Enqueue(obj k8scontrollerclient.Object) error
  • func (q *ResourceQueue) EnqueueIgnoreExisting(obj k8scontrollerclient.Object)
  • func (q *ResourceQueue) Length() int
  • func (q *ResourceQueue) RemoveIgnoreNotFound(obj k8scontrollerclient.Object)

Constants

const (
	E2ETestNameTag = "e2e.testName"
)

Functions

func DecodeFile

func DecodeFile(file string, to client.Object, options ...clientObjectOption) (client.Object, error)

func Logf

func Logf(f string, v ...interface{})

func ObjectToJsonString

func ObjectToJsonString(obj interface{}) string

func ObjectToPrettyJsonString

func ObjectToPrettyJsonString(obj interface{}) string

func WithNamespace

func WithNamespace(namespace string) clientObjectOption

Types

type DeterminedE2EClient

type DeterminedE2EClient struct {
	*E2EKubeClient
}

DeterminedE2EClient wraps E2eClient calls in an Eventually assertion to keep trying or bail after some time if unsuccessful

func NewDeterminedClient

func NewDeterminedClient(e2eKubeClient *E2EKubeClient) *DeterminedE2EClient

func (*DeterminedE2EClient) Create

func (m *DeterminedE2EClient) Create(context context.Context, obj k8scontrollerclient.Object, options ...k8scontrollerclient.CreateOption) error

func (*DeterminedE2EClient) Delete

func (m *DeterminedE2EClient) Delete(context context.Context, obj k8scontrollerclient.Object, options ...k8scontrollerclient.DeleteOption) error

func (*DeterminedE2EClient) Patch

func (m *DeterminedE2EClient) Patch(context context.Context, obj k8scontrollerclient.Object, patch k8scontrollerclient.Patch, options ...k8scontrollerclient.PatchOption) error

func (*DeterminedE2EClient) Update

func (m *DeterminedE2EClient) Update(context context.Context, obj k8scontrollerclient.Object, options ...k8scontrollerclient.UpdateOption) error

type E2EKubeClient

type E2EKubeClient struct {
	k8scontrollerclient.Client
	// contains filtered or unexported fields
}

func NewK8sResourceManager

func NewK8sResourceManager(client k8scontrollerclient.Client) *E2EKubeClient

func (*E2EKubeClient) Create

func (m *E2EKubeClient) Create(context context.Context, obj k8scontrollerclient.Object, options ...k8scontrollerclient.CreateOption) error

func (*E2EKubeClient) Delete

func (m *E2EKubeClient) Delete(context context.Context, obj k8scontrollerclient.Object, options ...k8scontrollerclient.DeleteOption) error

func (*E2EKubeClient) GarbageCollectCRDs

func (m *E2EKubeClient) GarbageCollectCRDs() error

GarbageCollectCRDs deletes any CRD with a label like operatorframework.io/installed-alongside-* these are the result of operator installations by olm and tent to be left behind after an e2e test

func (*E2EKubeClient) Reset

func (m *E2EKubeClient) Reset() error

func (*E2EKubeClient) Update

func (m *E2EKubeClient) Update(context context.Context, obj k8scontrollerclient.Object, options ...k8scontrollerclient.UpdateOption) error

type ResourceQueue

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

func NewResourceQueue

func NewResourceQueue() *ResourceQueue

func (*ResourceQueue) DequeueHead

func (q *ResourceQueue) DequeueHead() (k8scontrollerclient.Object, bool)

func (*ResourceQueue) DequeueTail

func (q *ResourceQueue) DequeueTail() (k8scontrollerclient.Object, bool)

func (*ResourceQueue) Enqueue

func (q *ResourceQueue) Enqueue(obj k8scontrollerclient.Object) error

func (*ResourceQueue) EnqueueIgnoreExisting

func (q *ResourceQueue) EnqueueIgnoreExisting(obj k8scontrollerclient.Object)

func (*ResourceQueue) Length

func (q *ResourceQueue) Length() int

func (*ResourceQueue) RemoveIgnoreNotFound

func (q *ResourceQueue) RemoveIgnoreNotFound(obj k8scontrollerclient.Object)