runtime

Documentation

Overview

Package runtime manages the reflection of Timoni's instances on Kubernetes clusters.

Index

• func ApplyOptions(force bool, wait time.Duration) ssa.ApplyOptions
• func DeleteOptions(name, namespace string) ssa.DeleteOptions
• func NewCustomJobStatusReader(mapper meta.RESTMapper) engine.StatusReader
• func NewResourceManager(rcg genericclioptions.RESTClientGetter) (*ssa.ResourceManager, error)
• func SelectObjectsFromSet(set *ssa.ChangeSet, action ssa.Action) []*unstructured.Unstructured
• func ServerVersion(rcg genericclioptions.RESTClientGetter) (string, error)
• func ToUnstructured(obj apiruntime.Object) (*unstructured.Unstructured, error)
• type InstanceManager
  • func NewInstanceManager(name, namespace, values string, moduleRef apiv1.ModuleReference) *InstanceManager
  • func (m *InstanceManager) AddObjects(objects []*unstructured.Unstructured) error
  • func (m *InstanceManager) Diff(target *apiv1.ResourceInventory) ([]*unstructured.Unstructured, error)
  • func (m *InstanceManager) ListMeta() (object.ObjMetadataSet, error)
  • func (m *InstanceManager) ListObjects() ([]*unstructured.Unstructured, error)
  • func (m *InstanceManager) VersionOf(objMetadata object.ObjMetadata) string
• type ResourceReader
  • func NewResourceReader(resManager *ssa.ResourceManager) *ResourceReader
  • func (r *ResourceReader) Read(ctx context.Context, refs []apiv1.RuntimeResourceRef) (map[string]string, error)
• type StorageManager
  • func NewStorageManager(resManager *ssa.ResourceManager) *StorageManager
  • func (s *StorageManager) Apply(ctx context.Context, instance *apiv1.Instance, createNamespace bool) error
  • func (s *StorageManager) Delete(ctx context.Context, name, namespace string) error
  • func (s *StorageManager) Get(ctx context.Context, name, namespace string) (*apiv1.Instance, error)
  • func (s *StorageManager) GetStaleObjects(ctx context.Context, i *apiv1.Instance) ([]*unstructured.Unstructured, error)
  • func (s *StorageManager) List(ctx context.Context, namespace, bundle string) ([]*apiv1.Instance, error)
  • func (s *StorageManager) ListNamespaces(ctx context.Context) ([]string, error)
  • func (s *StorageManager) NamespaceExists(ctx context.Context, name string) (bool, error)

Functions

func ApplyOptions

func ApplyOptions(force bool, wait time.Duration) ssa.ApplyOptions

ApplyOptions returns the default options for server-side apply operations.

func DeleteOptions

func DeleteOptions(name, namespace string) ssa.DeleteOptions

DeleteOptions returns the default options for delete operations.

func NewCustomJobStatusReader

func NewCustomJobStatusReader(mapper meta.RESTMapper) engine.StatusReader

NewCustomJobStatusReader creates a reader that asserts a Job completion status.

func NewResourceManager

func NewResourceManager(rcg genericclioptions.RESTClientGetter) (*ssa.ResourceManager, error)

NewResourceManager creates a ResourceManager for the given cluster.

func SelectObjectsFromSet

func SelectObjectsFromSet(set *ssa.ChangeSet, action ssa.Action) []*unstructured.Unstructured

SelectObjectsFromSet returns a list of Kubernetes objects from the given changeset filtered by action.

func ServerVersion

func ServerVersion(rcg genericclioptions.RESTClientGetter) (string, error)

ServerVersion retrieves and parses the Kubernetes server's version.

func ToUnstructured

func ToUnstructured(obj apiruntime.Object) (*unstructured.Unstructured, error)

ToUnstructured converts a runtime.Object into an Unstructured object.

Types

type InstanceManager

type InstanceManager struct {
	Instance apiv1.Instance
}

InstanceManager performs operations on the instance's inventory.

func NewInstanceManager

func NewInstanceManager(name, namespace, values string, moduleRef apiv1.ModuleReference) *InstanceManager

NewInstanceManager creates an InstanceManager for the given module.

func (*InstanceManager) AddObjects

func (m *InstanceManager) AddObjects(objects []*unstructured.Unstructured) error

AddObjects extracts the metadata from the given objects and adds it to the instance inventory.

func (*InstanceManager) Diff

func (m *InstanceManager) Diff(target *apiv1.ResourceInventory) ([]*unstructured.Unstructured, error)

Diff returns the slice of objects that do not exist in the target inventory.

func (*InstanceManager) ListMeta

func (m *InstanceManager) ListMeta() (object.ObjMetadataSet, error)

ListMeta returns the inventory entries as object.ObjMetadata objects.

func (*InstanceManager) ListObjects

func (m *InstanceManager) ListObjects() ([]*unstructured.Unstructured, error)

ListObjects returns the inventory entries as unstructured.Unstructured objects.

func (*InstanceManager) VersionOf

func (m *InstanceManager) VersionOf(objMetadata object.ObjMetadata) string

VersionOf returns the API version of the given object if found in this instance.

type ResourceReader

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

ResourceReader fetches resources from the cluster and extract field values.

func NewResourceReader

func NewResourceReader(resManager *ssa.ResourceManager) *ResourceReader

NewResourceReader creates a resource reader for the given cluster.

func (*ResourceReader) Read

func (r *ResourceReader) Read(ctx context.Context, refs []apiv1.RuntimeResourceRef) (map[string]string, error)

Read fetches the resources from the cluster and runs the CUE expressions to select the desired values.

type StorageManager

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

StorageManager manages the inventory in-cluster storage.

func NewStorageManager

func NewStorageManager(resManager *ssa.ResourceManager) *StorageManager

NewStorageManager creates a storage manager for the given cluster.

func (*StorageManager) Apply

func (s *StorageManager) Apply(ctx context.Context, instance *apiv1.Instance, createNamespace bool) error

Apply creates or updates the storage object for the given instance.

func (*StorageManager) Delete

func (s *StorageManager) Delete(ctx context.Context, name, namespace string) error

Delete removes the storage for the given instance name and namespace.

func (*StorageManager) Get

func (s *StorageManager) Get(ctx context.Context, name, namespace string) (*apiv1.Instance, error)

Get retrieves the instance from the storage.

func (*StorageManager) GetStaleObjects

func (s *StorageManager) GetStaleObjects(ctx context.Context, i *apiv1.Instance) ([]*unstructured.Unstructured, error)

GetStaleObjects returns the list of objects metadata subject to pruning.

func (*StorageManager) List

func (s *StorageManager) List(ctx context.Context, namespace, bundle string) ([]*apiv1.Instance, error)

List returns the instances found in the given namespace.

func (*StorageManager) ListNamespaces

func (s *StorageManager) ListNamespaces(ctx context.Context) ([]string, error)

func (*StorageManager) NamespaceExists

func (s *StorageManager) NamespaceExists(ctx context.Context, name string) (bool, error)

NamespaceExists returns false if the namespace is not found.