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 (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 (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 (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 ¶
View Source
const (
E2ETestNameTag = "e2e.testName"
)
Variables ¶
This section is empty.
Functions ¶
func DecodeFile ¶ added in v0.23.0
func ObjectToJsonString ¶ added in v0.22.0
func ObjectToJsonString(obj interface{}) string
func ObjectToPrettyJsonString ¶ added in v0.22.0
func ObjectToPrettyJsonString(obj interface{}) string
func WithNamespace ¶ added in v0.23.0
func WithNamespace(namespace string) clientObjectOption
Types ¶
type DeterminedE2EClient ¶ added in v0.22.0
type DeterminedE2EClient struct {
*E2EKubeClient
}
DeterminedE2EClient wraps E2eClient calls in an Eventually assertion to keep trying or bail after some time if unsuccessful
func NewDeterminedClient ¶ added in v0.22.0
func NewDeterminedClient(e2eKubeClient *E2EKubeClient) *DeterminedE2EClient
func (*DeterminedE2EClient) Create ¶ added in v0.22.0
func (m *DeterminedE2EClient) Create(context context.Context, obj k8scontrollerclient.Object, options ...k8scontrollerclient.CreateOption) error
func (*DeterminedE2EClient) Delete ¶ added in v0.22.0
func (m *DeterminedE2EClient) Delete(context context.Context, obj k8scontrollerclient.Object, options ...k8scontrollerclient.DeleteOption) error
func (*DeterminedE2EClient) Patch ¶ added in v0.22.0
func (m *DeterminedE2EClient) Patch(context context.Context, obj k8scontrollerclient.Object, patch k8scontrollerclient.Patch, options ...k8scontrollerclient.PatchOption) error
func (*DeterminedE2EClient) Update ¶ added in v0.22.0
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 ¶ added in v0.22.0
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)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.