k8s

Documentation

Index

• type Conditionals
• type ForEach
• type ForEachResource
• type MapInterface
• type PatchApplier
  • func NewPatchApplier(clientset *kubernetes.Clientset, schemaManager *SchemaManager, log logr.Logger) (*PatchApplier, error)
  • func (p *PatchApplier) Apply(resource *unstructured.Unstructured, patchStr string, patchType PatchType) (*unstructured.Unstructured, error)
• type PatchType
• type ResourcePatch
• type SchemaCache
  • 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 NewSchemaManager(clientset *kubernetes.Clientset, ...) (*SchemaManager, error)
  • func NewSchemaManagerWithCache(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
  • func NewTemplateManager(c *kommons.Client, log logr.Logger, cache *SchemaCache, ...) (*TemplateManager, error)
  • func (tm *TemplateManager) GetBool(object interface{}, jsonpath string) (bool, error)
  • func (tm *TemplateManager) JSONPath(object interface{}, jsonpath string) (*ForEach, error)
  • func (tm *TemplateManager) Run(ctx context.Context, template *templatev1.Template) error
  • func (tm *TemplateManager) Template(data []byte, vars interface{}) ([]byte, error)
• type TypedField

Types

type Conditionals

type Conditionals struct {
	When string `json:"when"`
}

type ForEach

type ForEach struct {
	IsArray bool
	IsMap   bool
	Array   []interface{}
	Map     map[string]interface{}
}

type ForEachResource

type ForEachResource struct {
	ForEach string `json:"forEach"`
}

type MapInterface

type MapInterface map[string]interface{}

type PatchApplier

type PatchApplier struct {
	Clientset     *kubernetes.Clientset
	Log           logr.Logger
	FuncMap       template.FuncMap
	SchemaManager *SchemaManager
}

func NewPatchApplier

func NewPatchApplier(clientset *kubernetes.Clientset, schemaManager *SchemaManager, log logr.Logger) (*PatchApplier, error)

func (*PatchApplier) Apply

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

type PatchType

type PatchType string

var (
	PatchTypeYaml PatchType = "yaml"
	PatchTypeJSON PatchType = "json"
)

type ResourcePatch

type ResourcePatch struct {
	Resource   *unstructured.Unstructured
	Patch      string
	Kind       string
	APIVersion string
	PatchType  PatchType
}

type SchemaCache

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

func NewSchemaCache

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

func (*SchemaCache) FetchResources

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

func (*SchemaCache) FetchSchema

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

type SchemaManager

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

func NewSchemaManager

func NewSchemaManager(clientset *kubernetes.Clientset, crdClient extapi.ApiextensionsV1beta1Interface, log logr.Logger) (*SchemaManager, error)

func NewSchemaManagerWithCache

func NewSchemaManagerWithCache(clientset *kubernetes.Clientset, crdClient extapi.ApiextensionsV1beta1Interface, cache *SchemaCache, log logr.Logger) (*SchemaManager, error)

func (*SchemaManager) DuckType

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

func (*SchemaManager) FindSchemaForKind

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

func (*SchemaManager) FindTypeForKey

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

func (*SchemaManager) FindTypeForKeyFromSchema

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

type TemplateManager

type TemplateManager struct {
	Client *kommons.Client
	kubernetes.Interface
	Log           logr.Logger
	PatchApplier  *PatchApplier
	SchemaManager *SchemaManager
	FuncMap       template.FuncMap
	Events        record.EventRecorder
}

func NewTemplateManager

func NewTemplateManager(c *kommons.Client, log logr.Logger, cache *SchemaCache, events record.EventRecorder) (*TemplateManager, error)

func (*TemplateManager) GetBool

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

func (*TemplateManager) JSONPath

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

func (*TemplateManager) Run

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

func (*TemplateManager) Template

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

type TypedField

type TypedField struct {
	Types  []string
	Format string
}