Versions in this module Expand all Collapse all v1 v1.0.0 Apr 28, 2020 Changes in this version + const DefaultResyncPeriod + const ObjectOperationDelete + const ObjectOperationUpdate + func NewNamespace(nsName string) *unstructured.Unstructured + type Environment interface + HydrateObject func(objData []byte) (*Object, error) + UniqueID func() string + func NewEnvironment() Environment + type Fixture struct + As string + type KubeClient struct + Client *kubernetes.Clientset + Config *rest.Config + Discovery discovery.CachedDiscoveryInterface + Dynamic dynamic.Interface + func NewKubeClient() (*KubeClient, error) + func (k *KubeClient) KindIsNamespaced(kind schema.GroupVersionKind) (bool, error) + func (k *KubeClient) NamespaceExists(nsName string) (bool, error) + func (k *KubeClient) ResourceForKind(kind schema.GroupVersionKind) (schema.GroupVersionResource, error) + func (k *KubeClient) ResourcesForName(name string) ([]schema.GroupVersionResource, error) + func (k *KubeClient) RunIDFor(u *unstructured.Unstructured) (string, error) + func (k *KubeClient) SelectObjects(kind schema.GroupVersionKind, selector labels.Selector) ([]*unstructured.Unstructured, error) + func (k *KubeClient) SelectObjectsByLabel(label string, value string) ([]*unstructured.Unstructured, error) + func (k *KubeClient) ServerResources() ([]metav1.APIResource, error) + func (k *KubeClient) SetUserAgent(ua string) + type LockingResourceEventHandler struct + Lock sync.Mutex + Next cache.ResourceEventHandler + func (l *LockingResourceEventHandler) OnAdd(newObj interface{}) + func (l *LockingResourceEventHandler) OnDelete(oldObj interface{}) + func (l *LockingResourceEventHandler) OnUpdate(oldObj, newObj interface{}) + type MuxingResourceEventHandler struct + Handlers map[int]cache.ResourceEventHandler + func (m *MuxingResourceEventHandler) Add(c cache.ResourceEventHandler) int + func (m *MuxingResourceEventHandler) Clear() + func (m *MuxingResourceEventHandler) OnAdd(newObj interface{}) + func (m *MuxingResourceEventHandler) OnDelete(oldObj interface{}) + func (m *MuxingResourceEventHandler) OnUpdate(oldObj, newObj interface{}) + func (m *MuxingResourceEventHandler) Remove(which int) + type Object struct + Check *ast.Module + Fixture *Fixture + Object *unstructured.Unstructured + Operation ObjectOperationType + type ObjectDriver interface + Adopt func(*unstructured.Unstructured) error + Apply func(*unstructured.Unstructured) (*OperationResult, error) + Delete func(*unstructured.Unstructured) (*OperationResult, error) + DeleteAll func() error + Done func() + InformOn func(gvr schema.GroupVersionResource) error + Watch func(cache.ResourceEventHandler) func() + func NewObjectDriver(client *KubeClient) ObjectDriver + type ObjectOperationType string + type ObjectReference struct + Meta struct{ ... } + Name string + Namespace string + func (o *ObjectReference) FromUnstructured(u *unstructured.Unstructured) *ObjectReference + type OperationResult struct + Error *metav1.Status + Latest *unstructured.Unstructured + Target ObjectReference + func (o *OperationResult) Succeeded() bool + type RegoDriver interface + Eval func(*ast.Module, ...RegoOpt) ([]result.Result, error) + RemovePath func(where string) error + StoreItem func(string, interface{}) error + StorePath func(where string) error + Trace func(RegoTracer) + func NewRegoDriver() RegoDriver + type RegoOpt = func(*rego.Rego) + type RegoTracer interface + Write func() + func NewRegoTracer(w io.Writer) RegoTracer + type WrappingResourceEventHandlerFuncs struct + AddFunc func(obj interface{}) + DeleteFunc func(obj interface{}) + Next cache.ResourceEventHandler + UpdateFunc func(oldObj, newObj interface{}) + func (r *WrappingResourceEventHandlerFuncs) OnAdd(newObj interface{}) + func (r *WrappingResourceEventHandlerFuncs) OnDelete(oldObj interface{}) + func (r *WrappingResourceEventHandlerFuncs) OnUpdate(oldObj, newObj interface{})