k8s

Oct 1, 2021

Changes in this version

+ type ConvertSchemaFn func(schema.GroupVersionKind, extv1.CustomResourceDefinitionVersion) (*spec.Schema, error)

+ type FetchCRDFn func(context.Context) ([]extv1.CustomResourceDefinition, error)

type SchemaCache

+ func (sc *SchemaCache) CachedConvertSchema(gvk schema.GroupVersionKind, crd extv1.CustomResourceDefinitionVersion) (*spec.Schema, error)

+ func (sc *SchemaCache) FetchCRD() ([]extv1.CustomResourceDefinition, error)

Aug 16, 2021

Changes in this version

+ type RESTManager struct

+ Client *kommons.Client

+ FuncMap template.FuncMap

+ Log logr.Logger

+ func NewRESTManager(c *kommons.Client, log logr.Logger) (*RESTManager, error)

+ func (r *RESTManager) Delete(ctx context.Context, rest *templatev1.REST) error

+ func (r *RESTManager) Update(ctx context.Context, rest *templatev1.REST) error

Jun 18, 2021

Changes in this version

+ type CallbackFunc func(unstructured.Unstructured) error

+ type NullWatcher struct

+ func (w *NullWatcher) Watch(exampleObject *unstructured.Unstructured, template *templatev1.Template, ...) error

type TemplateManager

+ SchemaCache *SchemaCache

+ Watcher WatcherInterface

+ func (tm *TemplateManager) GetSourceNamespaces(ctx context.Context, template *templatev1.Template) ([]string, error)

+ func (tm *TemplateManager) HandleSource(ctx context.Context, template *templatev1.Template, ...) (result ctrl.Result, err error)

+ type Watcher struct

+ func (w *Watcher) Watch(exampleObject *unstructured.Unstructured, template *templatev1.Template, ...) error

+ type WatcherInterface interface

+ Watch func(exampleObject *unstructured.Unstructured, template *templatev1.Template, ...) error

+ func NewWatcher(client *kommons.Client, log logr.Logger) (WatcherInterface, error)

Jun 1, 2021

Changes in this version

type SchemaCache

+ func (sc *SchemaCache) ExpireResources() error

+ func (sc *SchemaCache) ExpireSchema() error

+ func (sc *SchemaCache) ResourceHasExpired() bool

+ func (sc *SchemaCache) SchemaHasExpired() bool

Feb 28, 2021

Changes in this version

+ type Conditionals struct

+ When string

type TemplateManager

+ Events record.EventRecorder

+ func (tm *TemplateManager) GetBool(object interface{}, jsonpath string) (bool, error)

Jan 18, 2021

Changes in this version

+ type ForEach struct

+ Array []interface{}

+ IsArray bool

+ IsMap bool

+ Map map[string]interface{}

+ type ForEachResource struct

+ ForEach string

type TemplateManager

+ FuncMap template.FuncMap

+ func (tm *TemplateManager) JSONPath(object interface{}, jsonpath string) (*ForEach, error)

Jan 13, 2021

Changes in this version

+ type SchemaCache struct

+ func NewSchemaCache(clientset *kubernetes.Clientset, expire time.Duration, log logr.Logger) *SchemaCache

+ func (sc *SchemaCache) FetchResources() ([]*metav1.APIResourceList, error)

+ func (sc *SchemaCache) FetchSchema() (*spec.Swagger, error)

type SchemaManager

+ func NewSchemaManagerWithCache(clientset *kubernetes.Clientset, ...) (*SchemaManager, error)

Dec 7, 2020

Changes in this version

+ type MapInterface map[string]interface

type PatchApplier

+ SchemaManager *SchemaManager

+ type SchemaManager struct

+ func NewSchemaManager(clientset *kubernetes.Clientset, ...) (*SchemaManager, error)

+ func (m *SchemaManager) DuckType(gvk schema.GroupVersionKind, object *unstructured.Unstructured) error

+ func (m *SchemaManager) FindSchemaForKind(gvk schema.GroupVersionKind) (*spec.Schema, bool, error)

+ func (m *SchemaManager) FindTypeForKey(gvk schema.GroupVersionKind, key string) (*TypedField, error)

+ func (m *SchemaManager) FindTypeForKeyFromSchema(schema *spec.Schema, key string) (*TypedField, error)

type TemplateManager

+ SchemaManager *SchemaManager

+ type TypedField struct

+ Format string

+ Types []string

Oct 23, 2020

Changes in this version

type TemplateManager

+ func (tm *TemplateManager) Template(data []byte, vars interface{}) ([]byte, error)

Oct 7, 2020

Changes in this version

+ type Builder struct

+ Annotations map[string]string

+ Labels map[string]string

+ Namespace string

+ Objects []runtime.Object

+ func (b *Builder) AddAnnotations(annotations map[string]string) *Builder

+ func (b *Builder) AddLabels(labels map[string]string) *Builder

+ func (b *Builder) Append(objects ...runtime.Object) *Builder

+ func (b *Builder) ConfigMap(name string, data map[string]string) *Builder

+ func (b *Builder) Deployment(name, image string) *DeploymentBuilder

+ func (b *Builder) ObjectMeta(name string) metav1.ObjectMeta

+ func (b *Builder) Secret(name string, data map[string][]byte) *Builder

+ func (b *Builder) ServiceAccount(name string) *ServiceAccountBuilder

+ func (b *Builder) SetNamespace(namespace string) *Builder

+ type CRD struct

+ APIVersion string

+ Kind string

+ Metadata Metadata

+ Spec map[string]interface{}

+ type DeploymentBuilder struct

+ Builder *Builder

+ Image string

+ Name string

+ func Deployment(name, image string) *DeploymentBuilder

+ func (d *DeploymentBuilder) Annotations(annotations map[string]string) *DeploymentBuilder

+ func (d *DeploymentBuilder) Args(args ...string) *DeploymentBuilder

+ func (d *DeploymentBuilder) AsCronJob(schedule string) *batchv1beta1.CronJob

+ func (d *DeploymentBuilder) AsOneShotJob() *v1.Pod

+ func (d *DeploymentBuilder) Build() *Builder

+ func (d *DeploymentBuilder) Command(cmd ...string) *DeploymentBuilder

+ func (d *DeploymentBuilder) EnvVarFromConfigMap(env, configmap, key string) *DeploymentBuilder

+ func (d *DeploymentBuilder) EnvVarFromField(env, field string) *DeploymentBuilder

+ func (d *DeploymentBuilder) EnvVarFromSecret(env, secret, key string) *DeploymentBuilder

+ func (d *DeploymentBuilder) EnvVars(env map[string]string) *DeploymentBuilder

+ func (d *DeploymentBuilder) Expose(ports ...int32) *DeploymentBuilder

+ func (d *DeploymentBuilder) GetLabels() map[string]string

+ func (d *DeploymentBuilder) Labels(labels map[string]string) *DeploymentBuilder

+ func (d *DeploymentBuilder) MountConfigMap(cm, path string) *DeploymentBuilder

+ func (d *DeploymentBuilder) MountSecret(secret, path string, mode int32) *DeploymentBuilder

+ func (d *DeploymentBuilder) NodeAffinity(nodeReadinessLabel map[string]string) *DeploymentBuilder

+ func (d *DeploymentBuilder) ObjectMeta() metav1.ObjectMeta

+ func (d *DeploymentBuilder) PodAffinity(labels map[string]string, topologyKey string) *DeploymentBuilder

+ func (d *DeploymentBuilder) PodSpec() v1.PodSpec

+ func (d *DeploymentBuilder) PodTemplate() v1.PodTemplateSpec

+ func (d *DeploymentBuilder) Ports(ports ...int32) *DeploymentBuilder

+ func (d *DeploymentBuilder) Replicas(replicas int) *DeploymentBuilder

+ func (d *DeploymentBuilder) Resources(resources v1.ResourceRequirements) *DeploymentBuilder

+ func (d *DeploymentBuilder) ServiceAccount(name string) *DeploymentBuilder

+ type DynamicKind struct

+ APIVersion string

+ Kind string

+ func (dk DynamicKind) GroupVersionKind() schema.GroupVersionKind

+ func (dk DynamicKind) SetGroupVersionKind(gvk schema.GroupVersionKind)

+ type Metadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ Name string

+ Namespace string

+ type ServiceAccountBuilder struct

+ Name string

+ func (s *ServiceAccountBuilder) AddClusterRole(role string) *ServiceAccountBuilder

+ func (s *ServiceAccountBuilder) AddRole(role string) *ServiceAccountBuilder

+ type Spec struct

+ Items []unstructured.Unstructured

+ Path string

+ type Specs []Spec

+ func Walk(path string) (Specs, error)

+ func (specs Specs) FilterBy(kind string) []unstructured.Unstructured

Oct 6, 2020

Changes in this version

+ func CreateKubeConfig(clusterName string, ca certs.CertificateAuthority, endpoint string, ...) ([]byte, error)

+ func CreateMultiKubeConfig(ca certs.CertificateAuthority, clusters map[string]string, group string, ...) ([]byte, error)

+ func CreateOIDCKubeConfig(clusterName string, ca certs.CertificateAuthority, ...) ([]byte, error)

+ func GetContainerStatus(pod v1.Pod) string

+ func GetCurrentClusterNameFrom(kubeConfigPath string) string

+ func GetLastRestartTime(pod v1.Pod) *time.Time

+ func GetNodeStatus(node v1.Node) string

+ func GetPodStatus(pod v1.Pod) string

+ func GetUnstructuredObjects(data []byte) ([]unstructured.Unstructured, error)

+ func GetValidName(name string) string

+ func HasTaint(node v1.Node, name string) bool

+ func IsDeleted(object metav1.Object) bool

+ func IsMasterNode(node v1.Node) bool

+ func IsPodCrashLoopBackoff(pod v1.Pod) bool

+ func IsPodDaemonSet(pod v1.Pod) bool

+ func IsPodFinished(pod v1.Pod) bool

+ func IsPodHealthy(pod v1.Pod) bool

+ func IsPodPending(pod v1.Pod) bool

+ func IsPodReady(pod v1.Pod) bool

+ func IsStaticPod(pod v1.Pod) bool

+ func LowResourceRequirements() v1.ResourceRequirements

+ func NewCommandJob(node, command string) v1.PodSpec

+ func NewDeployment(ns, name, image string, labels map[string]string, port int32, args ...string) *apps.Deployment

+ func NewObjectMeta(ns, name string) metav1.ObjectMeta

+ func RemoveTaint(taints []v1.Taint, name string) []v1.Taint

+ func WaitForNamespace(client kubernetes.Interface, ns string, timeout time.Duration)

+ type ApplyHook func(namespace string, obj unstructured.Unstructured)

+ type Client struct

+ ApplyDryRun bool

+ ApplyHook ApplyHook

+ GetKubeConfigBytes func() ([]byte, error)

+ GetKustomizePatches func() ([]string, error)

+ Trace bool

+ func NewClient(config *rest.Config, logger logger.Logger) *Client

+ func (c *Client) Annotate(obj runtime.Object, annotations map[string]string) error

+ func (c *Client) Apply(namespace string, objects ...runtime.Object) error

+ func (c *Client) ApplyUnstructured(namespace string, objects ...*unstructured.Unstructured) error

+ func (c *Client) Cordon(nodeName string) error

+ func (c *Client) CreateOrUpdateConfigMap(name, ns string, data map[string]string) error

+ func (c *Client) CreateOrUpdateNamespace(name string, labels, annotations map[string]string) error

+ func (c *Client) CreateOrUpdateSecret(name, ns string, data map[string][]byte) error

+ func (c *Client) DeleteUnstructured(namespace string, objects ...*unstructured.Unstructured) error

+ func (c *Client) ExecutePodf(namespace, pod, container string, command ...string) (string, string, error)

+ func (c *Client) Executef(node string, timeout time.Duration, command string, args ...interface{}) (string, error)

+ func (c *Client) ExposeIngress(namespace, service string, domain string, port int, ...) error

+ func (c *Client) ForceDeleteNamespace(ns string, timeout time.Duration) error

+ func (c *Client) Get(namespace string, name string, obj runtime.Object) error

+ func (c *Client) GetClientByKind(kind string) (dynamic.NamespaceableResourceInterface, error)

+ func (c *Client) GetClientset() (*kubernetes.Clientset, error)

+ func (c *Client) GetConditionsForNode(name string) (map[v1.NodeConditionType]v1.ConditionStatus, error)

+ func (c *Client) GetConfigMap(namespace, name string) *map[string]string

+ func (c *Client) GetDynamicClient() (dynamic.Interface, error)

+ func (c *Client) GetDynamicClientFor(namespace string, obj runtime.Object) (dynamic.ResourceInterface, *schema.GroupVersionResource, ...)

+ func (c *Client) GetDynamicClientForUser(namespace string, obj runtime.Object, user string) (dynamic.ResourceInterface, *schema.GroupVersionResource, ...)

+ func (c *Client) GetEventsFor(kind string, object metav1.Object) ([]v1.Event, error)

+ func (c *Client) GetFirstPodByLabelSelector(namespace string, labelSelector string) (*v1.Pod, error)

+ func (c *Client) GetHealth() Health

+ func (c *Client) GetKustomize() (*kustomize.Manager, error)

+ func (c *Client) GetMasterNode() (string, error)

+ func (c *Client) GetMasterNodes() ([]string, error)

+ func (c *Client) GetOrCreatePVC(namespace, name, size, class string) error

+ func (c *Client) GetOrCreateSecret(name, ns string, data map[string][]byte) error

+ func (c *Client) GetPodReplicas(pod v1.Pod) (int, error)

+ func (c *Client) GetRESTConfig() (*rest.Config, error)

+ func (c *Client) GetRestClient(obj unstructured.Unstructured) (*cliresource.Helper, error)

+ func (c *Client) GetRestMapper() (meta.RESTMapper, error)

+ func (c *Client) GetSecret(namespace, name string) *map[string][]byte

+ func (c *Client) HasConfigMap(ns, name string) bool

+ func (c *Client) HasSecret(ns, name string) bool

+ func (c *Client) Label(obj runtime.Object, labels map[string]string) error

+ func (c *Client) PingMaster() bool

+ func (c *Client) ResetConnection()

+ func (c *Client) ScalePod(pod v1.Pod, replicas int32) error

+ func (c *Client) StreamLogs(namespace, name string) error

+ func (c *Client) Uncordon(nodeName string) error

+ func (c *Client) WaitForDeployment(ns, name string, timeout time.Duration) error

+ func (c *Client) WaitForNode(name string, timeout time.Duration, condition v1.NodeConditionType, ...) (map[v1.NodeConditionType]v1.ConditionStatus, error)

+ func (c *Client) WaitForPod(ns, name string, timeout time.Duration, phases ...v1.PodPhase) error

+ func (c *Client) WaitForPodCommand(ns, name string, container string, timeout time.Duration, command ...string) error

+ func (c *Client) WaitForResource(kind, namespace, name string, timeout time.Duration) error

+ func (c *Client) WaitForTaintRemoval(name string, timeout time.Duration, taintKey string) error

+ type Health struct

+ CrashLoopBackOff int

+ Error error

+ ErrorPods int

+ PendingPods int

+ ReadyNodes int

+ RunningPods int

+ UnreadyNodes int

+ func (h Health) GetNonReadyPods() int

+ func (h Health) IsDegradedComparedTo(h2 Health, tolerance int) bool

+ func (h Health) String() string

+ type PatchApplier struct

+ Clientset *kubernetes.Clientset

+ FuncMap template.FuncMap

+ Log logr.Logger

+ func NewPatchApplier(clientset *kubernetes.Clientset, log logr.Logger) *PatchApplier

+ func (p *PatchApplier) Apply(resource *unstructured.Unstructured, patchStr string, patchType PatchType) (*unstructured.Unstructured, error)

+ func (p *PatchApplier) JSONPath(object interface{}, jsonpath string) string

+ func (p *PatchApplier) KGet(path, jsonpath string) string

+ type PatchType string

+ var PatchTypeJSON PatchType = "json"

+ var PatchTypeYaml PatchType = "yaml"

+ type ResourcePatch struct

+ APIVersion string

+ Kind string

+ Patch string

+ PatchType PatchType

+ Resource *unstructured.Unstructured

+ type TemplateManager struct

+ Client *Client

+ Log logr.Logger

+ PatchApplier *PatchApplier

+ func NewTemplateManager(c *Client, log logr.Logger) *TemplateManager

+ func (tm *TemplateManager) Run(ctx context.Context, template *templatev1.Template) error