k8s

Documentation

Index

• type ApplyOpts
• type ApplyResourcesOpts
• type Client
  • func NewClient(cfg *rest.Config) (*Client, error)
  • func NewClientFromConfigFlags(cfgFlags *genericclioptions.ConfigFlags) (*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) CreateRevision(ctx context.Context, release, ns string, revision internal.Revision, ...) error
  • func (client Client) DeleteRevisions(ctx context.Context, revisions internal.Release) error
  • func (client Client) EnsureNamespace(ctx context.Context, namespace string) error
  • func (client Client) GetDynamicResourceInterface(resource *unstructured.Unstructured) (dynamic.ResourceInterface, error)
  • func (client Client) GetInClusterState(ctx context.Context, resource *unstructured.Unstructured) (*unstructured.Unstructured, error)
  • func (client Client) GetRelease(ctx context.Context, release, ns string) (*internal.Release, error)
  • func (client Client) GetReleases(ctx context.Context) ([]internal.Release, error)
  • func (client Client) GetReleasesByNS(ctx context.Context, ns string) ([]internal.Release, error)
  • func (client Client) GetRevisionResources(ctx context.Context, revision internal.Revision) (internal.Stages, error)
  • func (client Client) IsReady(ctx context.Context, resource *unstructured.Unstructured) (bool, error)
  • func (client *Client) LookupResourceMapping(resource *unstructured.Unstructured) (*meta.RESTMapping, error)
  • func (client Client) RemoveOrphans(ctx context.Context, previous, current internal.Stages) ([]*unstructured.Unstructured, error)
  • func (client Client) UpdateRevisionActiveState(ctx context.Context, revision internal.Revision) error
  • func (client Client) WaitForReady(ctx context.Context, resource *unstructured.Unstructured, opts WaitOptions) error
  • func (client Client) WaitForReadyMany(ctx context.Context, resources []*unstructured.Unstructured, opts WaitOptions) error
• type WaitOptions

Types

type ApplyOpts

type ApplyOpts struct {
	DryRun         bool
	ForceConflicts bool
}

type ApplyResourcesOpts

type ApplyResourcesOpts struct {
	DryRunOnly     bool
	SkipDryRun     bool
	ForceConflicts bool
}

type Client

type Client struct {
	Dynamic   *dynamic.DynamicClient
	Clientset *kubernetes.Clientset
	Meta      metadata.Interface
	Mapper    *restmapper.DeferredDiscoveryRESTMapper
}

func NewClient

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

func NewClientFromConfigFlags

func NewClientFromConfigFlags(cfgFlags *genericclioptions.ConfigFlags) (*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) CreateRevision

func (client Client) CreateRevision(ctx context.Context, release, ns string, revision internal.Revision, stages internal.Stages) error

func (Client) DeleteRevisions

func (client Client) DeleteRevisions(ctx context.Context, revisions internal.Release) error

func (Client) EnsureNamespace

func (client Client) EnsureNamespace(ctx context.Context, namespace string) error

func (Client) GetDynamicResourceInterface

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

func (Client) GetInClusterState

func (client Client) GetInClusterState(ctx context.Context, resource *unstructured.Unstructured) (*unstructured.Unstructured, error)

func (Client) GetRelease

func (client Client) GetRelease(ctx context.Context, release, ns string) (*internal.Release, error)

func (Client) GetReleases

func (client Client) GetReleases(ctx context.Context) ([]internal.Release, error)

func (Client) GetReleasesByNS

func (client Client) GetReleasesByNS(ctx context.Context, ns string) ([]internal.Release, error)

func (Client) GetRevisionResources

func (client Client) GetRevisionResources(ctx context.Context, revision internal.Revision) (internal.Stages, error)

func (Client) IsReady

func (client Client) IsReady(ctx context.Context, resource *unstructured.Unstructured) (bool, 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 internal.Stages) ([]*unstructured.Unstructured, error)

func (Client) UpdateRevisionActiveState

func (client Client) UpdateRevisionActiveState(ctx context.Context, revision internal.Revision) error

func (Client) WaitForReady

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

func (Client) WaitForReadyMany

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

type WaitOptions

type WaitOptions struct {
	Timeout  time.Duration
	Interval time.Duration
}