cluster

Documentation

Index

• func CollectObjects(namespace string, clients Clients, components []string) ([]*unstructured.Unstructured, error)
• func RebuildObject(m map[string]interface{}) (map[string]interface{}, error)
• func RunApply(config ApplyConfig, opts ...ApplyOpts) error
• func RunDelete(config DeleteConfig, opts ...DeleteOpts) error
• func RunShow(config ShowConfig, opts ...ShowOpts) error
• func SetMetaDataAnnotation(obj metav1.Object, key, value string)
• func SetMetaDataLabel(obj metav1.Object, key, value string)
• func ShowYAML(out io.Writer, apiObjects []*unstructured.Unstructured) error
• type Apply
  • func (a *Apply) Apply() error
• type ApplyConfig
• type ApplyOpts
• type Clients
  • func GenClients(a app.App, clientConfig *client.Config, envName string) (Clients, error)
• type Delete
  • func (d *Delete) Delete() error
• type DeleteConfig
• type DeleteOpts
• type ObjectInfo
• type ResourceClient
• type ResourceInfo
• type Show
  • func (s *Show) Show() error
• type ShowConfig
• type ShowOpts
• type UnstructuredSlice
  • func (u UnstructuredSlice) Len() int
  • func (u UnstructuredSlice) Less(i, j int) bool
  • func (u UnstructuredSlice) Sort()
  • func (u UnstructuredSlice) Swap(i, j int)
• type Upserter

Functions

func CollectObjects

func CollectObjects(namespace string, clients Clients, components []string) ([]*unstructured.Unstructured, error)

CollectObjects collects objects in a cluster namespace.

func RebuildObject

func RebuildObject(m map[string]interface{}) (map[string]interface{}, error)

RebuildObject rebuilds the ksonnet generated object from an object on the cluster.

func RunApply

func RunApply(config ApplyConfig, opts ...ApplyOpts) error

RunApply runs apply against a cluster given a configuration.

func RunDelete

func RunDelete(config DeleteConfig, opts ...DeleteOpts) error

RunDelete runs delete against a cluster for a given configuration.

func RunShow

func RunShow(config ShowConfig, opts ...ShowOpts) error

RunShow shows objects for a given configuration.

func SetMetaDataAnnotation

func SetMetaDataAnnotation(obj metav1.Object, key, value string)

SetMetaDataAnnotation sets an annotation value

func SetMetaDataLabel

func SetMetaDataLabel(obj metav1.Object, key, value string)

SetMetaDataLabel sets a label value

func ShowYAML

func ShowYAML(out io.Writer, apiObjects []*unstructured.Unstructured) error

ShowYAML shows YAML objects.

Types

type Apply

type Apply struct {
	ApplyConfig
	// contains filtered or unexported fields
}

Apply applies objects to the cluster

func (*Apply) Apply

func (a *Apply) Apply() error

Apply applies against a cluster.

type ApplyConfig

type ApplyConfig struct {
	App            app.App
	ClientConfig   *client.Config
	ComponentNames []string
	Create         bool
	DryRun         bool
	EnvName        string
	GcTag          string
	SkipGc         bool
}

ApplyConfig is configuration for Apply.

type ApplyOpts

type ApplyOpts func(a *Apply)

ApplyOpts are options for configuring Apply.

type Clients

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

Clients is a tuple of Kubernetes clients: dynamic.ClientPool, discovery.DiscoveryInterface.

func GenClients

func GenClients(a app.App, clientConfig *client.Config, envName string) (Clients, error)

GenClients returns a cluster.Clients structure initialized to the provided environment cluster/namespace

type Delete

type Delete struct {
	DeleteConfig
	// contains filtered or unexported fields
}

Delete deletes objects from the cluster.

func (*Delete) Delete

func (d *Delete) Delete() error

Delete deletes objects from a cluster.

type DeleteConfig

type DeleteConfig struct {
	App            app.App
	ClientConfig   *client.Config
	ComponentNames []string
	EnvName        string
	GracePeriod    int64
}

DeleteConfig is configuration for Delete.

type DeleteOpts

type DeleteOpts func(*Delete)

DeleteOpts is an option for configuring Delete.

type ObjectInfo

type ObjectInfo interface {
	ResourceName(d discovery.ServerResourcesInterface, o runtime.Object) string
}

ObjectInfo can retrieve information about an object.

type ResourceClient

type ResourceClient interface {
	Create() (*unstructured.Unstructured, error)
	Delete(options *metav1.DeleteOptions) error
	Get(options metav1.GetOptions) (*unstructured.Unstructured, error)
	Patch(pt types.PatchType, data []byte) (*unstructured.Unstructured, error)
}

ResourceClient is a wrapper for a resource client.

type ResourceInfo

type ResourceInfo interface {
	Err() error
	Infos() ([]*resource.Info, error)
}

ResourceInfo holds information about cluster resources.

type Show

type Show struct {
	ShowConfig
	// contains filtered or unexported fields
}

Show shows objects.

func (*Show) Show

func (s *Show) Show() error

Show shows objects.

type ShowConfig

type ShowConfig struct {
	App            app.App
	ComponentNames []string
	EnvName        string
	Format         string
	Out            io.Writer
}

ShowConfig is configuration for Show.

type ShowOpts

type ShowOpts func(*Show)

ShowOpts is an option for configuring Show.

type UnstructuredSlice

type UnstructuredSlice []*unstructured.Unstructured

UnstructuredSlice is a sortable slice of k8s unstructured.Unstructured objects

func (UnstructuredSlice) Len

func (u UnstructuredSlice) Len() int

func (UnstructuredSlice) Less

func (u UnstructuredSlice) Less(i, j int) bool

func (UnstructuredSlice) Sort

func (u UnstructuredSlice) Sort()

Sort sorts an UnstructuredSlice

func (UnstructuredSlice) Swap

func (u UnstructuredSlice) Swap(i, j int)

type Upserter

type Upserter interface {
	// Upsert updates or creates an object.
	Upsert(*unstructured.Unstructured) (string, error)
}

Upserter updates or creates objects.