util

Documentation

Index

• Constants
• 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) 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"
)

Types

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) 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)