kubeclnt

Documentation

Index

• type ClientFactory
  • func NewClientFactory() (*ClientFactory, error)
  • func (f *ClientFactory) Discovery() discovery.CachedDiscoveryInterface
  • func (f *ClientFactory) Dynamic() dynamic.Interface
  • func (f *ClientFactory) KubeClient() KubeClienter
  • func (f *ClientFactory) Mapper() meta.ResettableRESTMapper
  • func (f *ClientFactory) Static() kubernetes.Interface
• type KubeClient
  • func NewKubeClient(staticClient kubernetes.Interface, dynamicClient dynamic.Interface, ...) *KubeClient
  • func (c *KubeClient) Apply(ctx context.Context, resource *resrcid.ResourceID, ...) (*unstructured.Unstructured, error)
  • func (c *KubeClient) Create(ctx context.Context, resource *resrcid.ResourceID, ...) (*unstructured.Unstructured, error)
  • func (c *KubeClient) Delete(ctx context.Context, resource *resrcid.ResourceID, ...) error
  • func (c *KubeClient) Get(ctx context.Context, resource *resrcid.ResourceID, opts KubeClientGetOptions) (*unstructured.Unstructured, error)
  • func (c *KubeClient) MergePatch(ctx context.Context, resource *resrcid.ResourceID, patch []byte) (*unstructured.Unstructured, error)
• type KubeClientApplyOptions
• type KubeClientCreateOptions
• type KubeClientDeleteOptions
• type KubeClientGetOptions
• type KubeClienter

Types

type ClientFactory

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

func NewClientFactory

func NewClientFactory() (*ClientFactory, error)

func (*ClientFactory) Discovery

func (f *ClientFactory) Discovery() discovery.CachedDiscoveryInterface

func (*ClientFactory) Dynamic

func (f *ClientFactory) Dynamic() dynamic.Interface

func (*ClientFactory) KubeClient

func (f *ClientFactory) KubeClient() KubeClienter

func (*ClientFactory) Mapper

func (f *ClientFactory) Mapper() meta.ResettableRESTMapper

func (*ClientFactory) Static

func (f *ClientFactory) Static() kubernetes.Interface

type KubeClient

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

func NewKubeClient

func NewKubeClient(staticClient kubernetes.Interface, dynamicClient dynamic.Interface, discoveryClient discovery.CachedDiscoveryInterface, mapper meta.ResettableRESTMapper) *KubeClient

func (*KubeClient) Apply

func (c *KubeClient) Apply(ctx context.Context, resource *resrcid.ResourceID, unstruct *unstructured.Unstructured, opts KubeClientApplyOptions) (*unstructured.Unstructured, error)

func (*KubeClient) Create

func (c *KubeClient) Create(ctx context.Context, resource *resrcid.ResourceID, unstruct *unstructured.Unstructured, opts KubeClientCreateOptions) (*unstructured.Unstructured, error)

func (*KubeClient) Delete

func (c *KubeClient) Delete(ctx context.Context, resource *resrcid.ResourceID, opts KubeClientDeleteOptions) error

func (*KubeClient) Get

func (c *KubeClient) Get(ctx context.Context, resource *resrcid.ResourceID, opts KubeClientGetOptions) (*unstructured.Unstructured, error)

func (*KubeClient) MergePatch

func (c *KubeClient) MergePatch(ctx context.Context, resource *resrcid.ResourceID, patch []byte) (*unstructured.Unstructured, error)

type KubeClientApplyOptions

type KubeClientApplyOptions struct {
	DryRun bool
}

type KubeClientCreateOptions

type KubeClientCreateOptions struct {
	ForceReplicas *int
}

type KubeClientDeleteOptions

type KubeClientDeleteOptions struct {
	PropagationPolicy *metav1.DeletionPropagation
}

type KubeClientGetOptions

type KubeClientGetOptions struct {
	TryCache bool
}

type KubeClienter

type KubeClienter interface {
	Get(ctx context.Context, resource *resrcid.ResourceID, opts KubeClientGetOptions) (*unstructured.Unstructured, error)
	Create(ctx context.Context, resource *resrcid.ResourceID, unstruct *unstructured.Unstructured, opts KubeClientCreateOptions) (*unstructured.Unstructured, error)
	Apply(ctx context.Context, resource *resrcid.ResourceID, unstruct *unstructured.Unstructured, opts KubeClientApplyOptions) (*unstructured.Unstructured, error)
	MergePatch(ctx context.Context, resource *resrcid.ResourceID, patch []byte) (*unstructured.Unstructured, error)
	Delete(ctx context.Context, resource *resrcid.ResourceID, opts KubeClientDeleteOptions) error
}