utils

Documentation

Index

• Constants
• func AddToScheme(scheme *runtime.Scheme) error
• func AlterFieldOfNestedStringMaps(obj interface{}, key string, value string) error
• func CreateNamespacedObjectOnClusterFromYamlDefinition(ctx context.Context, c client.Client, objYaml, namespace string) *unstructured.Unstructured
• func CreateObjectOnClusterFromYamlDefinition(ctx context.Context, c client.Client, objYaml string) *unstructured.Unstructured
• func GetObjectGVK(obj metav1.Object, scheme *runtime.Scheme) (schema.GroupVersionKind, error)
• func GetQualifiedResource(mapper meta.RESTMapper, obj *unstructured.Unstructured) (string, error)
• func GetQualifiedResourceWithName(mapper meta.RESTMapper, obj *unstructured.Unstructured) (string, error)
• func HereYaml(y string) string
• func HereYamlF(y string, args ...interface{}) string
• func SinglePathEvaluate(jsonpathExpression string, obj interface{}) ([]interface{}, error)
• type ConditionList
  • func ExtractConditions(stampedObject *unstructured.Unstructured) ConditionList
  • func (c ConditionList) ConditionWithType(conditionType string) *metav1.Condition
• type KubeconfigRestricted
  • func NewKubeconfigRestricted(input string) (*KubeconfigRestricted, error)
  • func (r *KubeconfigRestricted) AsYAML() string
• type ServiceAccounts
  • func (s *ServiceAccounts) Find(nsName string, saName string) (*KubeconfigRestricted, error)
  • func (s *ServiceAccounts) MakeKubeConfig(secret *corev1.Secret) (string, error)

Constants

const DefaultResyncTime = 10 * time.Hour

Functions

func AddToScheme

func AddToScheme(scheme *runtime.Scheme) error

func AlterFieldOfNestedStringMaps

func AlterFieldOfNestedStringMaps(obj interface{}, key string, value string) error

func CreateNamespacedObjectOnClusterFromYamlDefinition

func CreateNamespacedObjectOnClusterFromYamlDefinition(ctx context.Context, c client.Client, objYaml, namespace string) *unstructured.Unstructured

func CreateObjectOnClusterFromYamlDefinition

func CreateObjectOnClusterFromYamlDefinition(ctx context.Context, c client.Client, objYaml string) *unstructured.Unstructured

func GetObjectGVK

func GetObjectGVK(obj metav1.Object, scheme *runtime.Scheme) (schema.GroupVersionKind, error)

func GetQualifiedResource

func GetQualifiedResource(mapper meta.RESTMapper, obj *unstructured.Unstructured) (string, error)

func GetQualifiedResourceWithName

func GetQualifiedResourceWithName(mapper meta.RESTMapper, obj *unstructured.Unstructured) (string, error)

func HereYaml

func HereYaml(y string) string

func HereYamlF

func HereYamlF(y string, args ...interface{}) string

func SinglePathEvaluate

func SinglePathEvaluate(jsonpathExpression string, obj interface{}) ([]interface{}, error)

Types

type ConditionList

type ConditionList []metav1.Condition

func ExtractConditions

func ExtractConditions(stampedObject *unstructured.Unstructured) ConditionList

func (ConditionList) ConditionWithType

func (c ConditionList) ConditionWithType(conditionType string) *metav1.Condition

type KubeconfigRestricted

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

func NewKubeconfigRestricted

func NewKubeconfigRestricted(input string) (*KubeconfigRestricted, error)

NewKubeconfigRestricted takes kubeconfig yaml as input and returns kubeconfig yaml with certain fields restricted (removed). Developers may find it informative to view their own config at ~/.kube/config

func (*KubeconfigRestricted) AsYAML

func (r *KubeconfigRestricted) AsYAML() string

type ServiceAccounts

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

func (*ServiceAccounts) Find

func (s *ServiceAccounts) Find(nsName string, saName string) (*KubeconfigRestricted, error)

func (*ServiceAccounts) MakeKubeConfig

func (s *ServiceAccounts) MakeKubeConfig(secret *corev1.Secret) (string, error)