k8s

Documentation

Index

• Constants
• func IsNamespaced(resource dynamic.ResourceInterface) bool
• type ApplyOpts
• type ApplyResourcesOpts
• type Client
  • func NewClient(cfg *rest.Config) (*Client, error)
  • func NewClientFromKubeConfig(path string) (*Client, error)
  • func (client Client) ApplyResource(ctx context.Context, resource *unstructured.Unstructured, opts ApplyOpts) error
  • func (client Client) ApplyResources(ctx context.Context, resources []*unstructured.Unstructured, ...) error
  • func (client Client) DeleteRevisions(ctx context.Context, release string) error
  • func (client Client) GetAllRevisions(ctx context.Context) ([]internal.Revisions, error)
  • func (client Client) GetDynamicResourceInterface(resource *unstructured.Unstructured) (dynamic.ResourceInterface, error)
  • func (client Client) GetResourceReleaseMapping(ctx context.Context) (map[string]string, error)
  • func (client Client) GetRevisions(ctx context.Context, release string) (*internal.Revisions, error)
  • func (client *Client) LookupResourceMapping(resource *unstructured.Unstructured) (*meta.RESTMapping, error)
  • func (client Client) RemoveOrphans(ctx context.Context, previous, current []*unstructured.Unstructured) ([]*unstructured.Unstructured, error)
  • func (client Client) UpdateResourceReleaseMapping(ctx context.Context, release string, create, remove []string) error
  • func (client Client) UpsertRevisions(ctx context.Context, release string, revisions *internal.Revisions) error
  • func (client Client) ValidateOwnership(ctx context.Context, release string, resources []*unstructured.Unstructured) error

Constants

const (
	ResourceReleaseMapping = "yoke-resource-release-mapping"
	NSKubeSystem           = "kube-system"

	KeyRevisions = "revisions"
	KeyRelease   = "release"
)

Functions

func IsNamespaced

func IsNamespaced(resource dynamic.ResourceInterface) bool

Types

type ApplyOpts

type ApplyOpts struct {
	DryRun         bool
	ForceConflicts bool
}

type ApplyResourcesOpts

type ApplyResourcesOpts struct {
	SkipDryRun     bool
	ForceConflicts bool
}

type Client

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

func NewClient

func NewClient(cfg *rest.Config) (*Client, error)

func NewClientFromKubeConfig

func NewClientFromKubeConfig(path string) (*Client, error)

func (Client) ApplyResource

func (client Client) ApplyResource(ctx context.Context, resource *unstructured.Unstructured, opts ApplyOpts) error

func (Client) ApplyResources

func (client Client) ApplyResources(ctx context.Context, resources []*unstructured.Unstructured, opts ApplyResourcesOpts) error

func (Client) DeleteRevisions

func (client Client) DeleteRevisions(ctx context.Context, release string) error

func (Client) GetAllRevisions

func (client Client) GetAllRevisions(ctx context.Context) ([]internal.Revisions, error)

func (Client) GetDynamicResourceInterface

func (client Client) GetDynamicResourceInterface(resource *unstructured.Unstructured) (dynamic.ResourceInterface, error)

func (Client) GetResourceReleaseMapping

func (client Client) GetResourceReleaseMapping(ctx context.Context) (map[string]string, error)

func (Client) GetRevisions

func (client Client) GetRevisions(ctx context.Context, release string) (*internal.Revisions, error)

func (*Client) LookupResourceMapping

func (client *Client) LookupResourceMapping(resource *unstructured.Unstructured) (*meta.RESTMapping, error)

func (Client) RemoveOrphans

func (client Client) RemoveOrphans(ctx context.Context, previous, current []*unstructured.Unstructured) ([]*unstructured.Unstructured, error)

func (Client) UpdateResourceReleaseMapping

func (client Client) UpdateResourceReleaseMapping(ctx context.Context, release string, create, remove []string) error

func (Client) UpsertRevisions

func (client Client) UpsertRevisions(ctx context.Context, release string, revisions *internal.Revisions) error

func (Client) ValidateOwnership

func (client Client) ValidateOwnership(ctx context.Context, release string, resources []*unstructured.Unstructured) error