 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- type Client
- type K8sClient
- func (k *K8sClient) Apply(ctx context.Context, config string) <-chan error
- func (k *K8sClient) Decode(data io.Reader) ([]*unstructured.Unstructured, error)
- func (k *K8sClient) Delete(ctx context.Context, gvr schema.GroupVersionResource, namespace, name string) error
- func (k *K8sClient) Get(ctx context.Context, gvr schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error)
- func (k *K8sClient) UpdateOrCreate(ctx context.Context, gvr schema.GroupVersionResource, namespace string, ...) (*unstructured.Unstructured, error)
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface {
	Decode(reader io.Reader) ([]*unstructured.Unstructured, error)
	Get(ctx context.Context, gvr schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error)
	UpdateOrCreate(ctx context.Context, gvr schema.GroupVersionResource, namespace string, obj runtime.Object, force bool) (*unstructured.Unstructured, error)
	Delete(ctx context.Context, gvr schema.GroupVersionResource, namespace, name string) error
	Apply(ctx context.Context, config string) <-chan error
}
    type K8sClient ¶
type K8sClient struct {
	// contains filtered or unexported fields
}
    func (*K8sClient) Decode ¶
func (k *K8sClient) Decode(data io.Reader) ([]*unstructured.Unstructured, error)
func (*K8sClient) Get ¶
func (k *K8sClient) Get(ctx context.Context, gvr schema.GroupVersionResource, namespace, name string) (*unstructured.Unstructured, error)
func (*K8sClient) UpdateOrCreate ¶
func (k *K8sClient) UpdateOrCreate(ctx context.Context, gvr schema.GroupVersionResource, namespace string, obj runtime.Object, force bool) (*unstructured.Unstructured, error)
 Click to show internal directories. 
   Click to hide internal directories.