k8s

Documentation

Index

• Constants
• type GenericClient
  • func NewGenericClient(restMapper RESTMapper, dynamicClient dynamic.Interface, ...) *GenericClient
  • func (c GenericClient) ApplyConfigMaps(configMaps []*corev1.ConfigMap, namespace string) error
  • func (c GenericClient) ApplyResources(resources []K8sObject) ([]*unstructured.Unstructured, error)
  • func (c GenericClient) ApplySecrets(secrets []*corev1.Secret, namespace string) error
  • func (c GenericClient) CreateResources(resources []K8sObject) ([]*unstructured.Unstructured, error)
  • func (c GenericClient) WaitForPodByLabel(namespace, labelSelector string, desiredPhase corev1.PodPhase, ...) error
• type K8sObject
  • func ParseYamlToK8sObjects(decoder runtime.Decoder, yamlContent string) ([]K8sObject, error)
• type RESTMapper

Constants

const (
	OnConflictLabel   string = "conflict-strategy"
	ReplaceOnConflict string = "Replace"
	MergeOnConflict   string = "Merge"
)

Types

type GenericClient

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

func NewGenericClient

func NewGenericClient(restMapper RESTMapper, dynamicClient dynamic.Interface, k8sClientSet kubernetes.Interface) *GenericClient

func (GenericClient) ApplyConfigMaps

func (c GenericClient) ApplyConfigMaps(configMaps []*corev1.ConfigMap, namespace string) error

func (GenericClient) ApplyResources

func (c GenericClient) ApplyResources(resources []K8sObject) ([]*unstructured.Unstructured, error)

func (GenericClient) ApplySecrets

func (c GenericClient) ApplySecrets(secrets []*corev1.Secret, namespace string) error

func (GenericClient) CreateResources

func (c GenericClient) CreateResources(resources []K8sObject) ([]*unstructured.Unstructured, error)

func (GenericClient) WaitForPodByLabel

func (c GenericClient) WaitForPodByLabel(namespace, labelSelector string, desiredPhase corev1.PodPhase, timeout, checkInterval time.Duration) error

type K8sObject

type K8sObject struct {
	Object runtime.Object
	GVK    *schema.GroupVersionKind
}

func ParseYamlToK8sObjects

func ParseYamlToK8sObjects(decoder runtime.Decoder, yamlContent string) ([]K8sObject, error)

type RESTMapper

type RESTMapper interface {
	RESTMapping(gk schema.GroupKind, versions ...string) (*meta.RESTMapping, error)
}