controller

README

https://github.com/kubernetes/sample-controller https://github.com/kubernetes/kubernetes/tree/master/staging/src/k8s.io/sample-controller https://github.com/kubernetes/community/blob/8cafef897a22026d42f5e5bb3f104febe7e29830/contributors/devel/controllers.md https://engineering.bitnami.com/articles/a-deep-dive-into-kubernetes-controllers.html https://github.com/operator-framework/community-operators/blob/master/docs/best-practices.md

Documentation

Index

• Constants
• func CompileTOSCA(url string, inputs map[string]ard.Value, writer io.Writer, ...) error
• func ExecCloutScriptlet(clout *cloutpkg.Clout, scriptletName string, arguments map[string]string, ...) (string, error)
• func ReadClout(reader io.Reader, urlContext *urlpkg.Context) (*cloutpkg.Clout, error)
• func WriteClout(clout *cloutpkg.Clout, writer io.Writer) error
• type Controller
  • func NewController(context contextpkg.Context, toolName string, site string, clusterMode bool, ...) *Controller
  • func (self *Controller) CompileServiceTemplate(serviceTemplateURL string, inputs map[string]string, cloutPath string, ...) (string, error)
  • func (self *Controller) EventCloutUpdateError(service *resources.Service, err error)
  • func (self *Controller) EventCompilationError(service *resources.Service, err error)
  • func (self *Controller) EventCompiled(service *resources.Service)
  • func (self *Controller) EventInstantiated(service *resources.Service)
  • func (self *Controller) EventInstantiationError(service *resources.Service, err error)
  • func (self *Controller) GetAttributesFromResources(resourceMappings parser.KubernetesResourceMappings) (parser.CloutAttributeValues, error)
  • func (self *Controller) GetResource(resourceMapping *parser.KubernetesResourceMapping) (*unstructured.Unstructured, error)
  • func (self *Controller) NewDelegate(name string) (*clientpkg.Client, error)
  • func (self *Controller) ReadClout(cloutPath string, resolve bool, coerce bool, urlContext *urlpkg.Context) (*cloutpkg.Clout, error)
  • func (self *Controller) Run(concurrency uint, startup func()) error
  • func (self *Controller) Substitute(namespace string, nodeTemplateName string, inputs map[string]interface{}, ...) error
  • func (self *Controller) UpdateServiceInstantiationState(service *resources.Service, state resources.ServiceInstantiationState) (*resources.Service, error)
  • func (self *Controller) UpdateServiceStatusClout(service *resources.Service, cloutPath string, cloutHash string) (*resources.Service, error)
  • func (self *Controller) UpdateServiceStatusMode(service *resources.Service) (*resources.Service, error)
  • func (self *Controller) UpdateServiceStatusNodeStates(service *resources.Service, states parser.OrchestrationNodeStates) (*resources.Service, error)
  • func (self *Controller) UpdateServiceStatusOutputs(service *resources.Service, outputs map[string]string) (*resources.Service, error)
  • func (self *Controller) WriteClout(yaml string, cloutPath string) (string, error)
  • func (self *Controller) WriteServiceClout(yaml string, service *resources.Service) (*resources.Service, error)

Constants

const (
	NamePrefix        = "turandot"
	PartOf            = "Turandot"
	ManagedBy         = "Turandot"
	OperatorImageName = "tliron/turandot-operator"
	CacheDirectory    = "/cache"
)

const (
	EventCompiled           = "Compiled"
	EventCompilationError   = "CompilationError"
	EventInstantiated       = "Instantiated"
	EventInstantiationError = "InstantiationError"
	EventCloutUpdateError   = "CloutUpdateError"
)

Functions

func CompileTOSCA

func CompileTOSCA(url string, inputs map[string]ard.Value, writer io.Writer, urlContext *urlpkg.Context) error

func ExecCloutScriptlet

func ExecCloutScriptlet(clout *cloutpkg.Clout, scriptletName string, arguments map[string]string, urlContext *urlpkg.Context) (string, error)

func ReadClout

func ReadClout(reader io.Reader, urlContext *urlpkg.Context) (*cloutpkg.Clout, error)

func WriteClout

func WriteClout(clout *cloutpkg.Clout, writer io.Writer) error

Types

type Controller

type Controller struct {
	Site string

	Config      *restpkg.Config
	Dynamic     *kubernetesutil.Dynamic
	Kubernetes  kubernetes.Interface
	Turandot    turandotpkg.Interface
	Client      *clientpkg.Client
	CachePath   string
	StopChannel <-chan struct{}

	Processors *kubernetesutil.Processors
	Events     record.EventRecorder

	KubernetesInformerFactory informers.SharedInformerFactory
	TurandotInformerFactory   turandotinformers.SharedInformerFactory

	Services turandotlisters.ServiceLister

	Context contextpkg.Context
	Log     logging.Logger
}

func NewController

func NewController(context contextpkg.Context, toolName string, site string, clusterMode bool, clusterRole string, namespace string, dynamic dynamicpkg.Interface, kubernetes kubernetes.Interface, apiExtensions apiextensionspkg.Interface, turandot turandotpkg.Interface, reposure reposurepkg.Interface, config *restpkg.Config, cachePath string, informerResyncPeriod time.Duration, stopChannel <-chan struct{}) *Controller

func (*Controller) CompileServiceTemplate

func (self *Controller) CompileServiceTemplate(serviceTemplateURL string, inputs map[string]string, cloutPath string, urlContext *urlpkg.Context) (string, error)

func (*Controller) EventCloutUpdateError

func (self *Controller) EventCloutUpdateError(service *resources.Service, err error)

func (*Controller) EventCompilationError

func (self *Controller) EventCompilationError(service *resources.Service, err error)

func (*Controller) EventCompiled

func (self *Controller) EventCompiled(service *resources.Service)

func (*Controller) EventInstantiated

func (self *Controller) EventInstantiated(service *resources.Service)

func (*Controller) EventInstantiationError

func (self *Controller) EventInstantiationError(service *resources.Service, err error)

func (*Controller) GetAttributesFromResources

func (self *Controller) GetAttributesFromResources(resourceMappings parser.KubernetesResourceMappings) (parser.CloutAttributeValues, error)

func (*Controller) GetResource

func (self *Controller) GetResource(resourceMapping *parser.KubernetesResourceMapping) (*unstructured.Unstructured, error)

func (*Controller) NewDelegate

func (self *Controller) NewDelegate(name string) (*clientpkg.Client, error)

func (*Controller) ReadClout

func (self *Controller) ReadClout(cloutPath string, resolve bool, coerce bool, urlContext *urlpkg.Context) (*cloutpkg.Clout, error)

func (*Controller) Run

func (self *Controller) Run(concurrency uint, startup func()) error

func (*Controller) Substitute

func (self *Controller) Substitute(namespace string, nodeTemplateName string, inputs map[string]interface{}, mode string, site string, urlContext *urlpkg.Context) error

func (*Controller) UpdateServiceInstantiationState

func (self *Controller) UpdateServiceInstantiationState(service *resources.Service, state resources.ServiceInstantiationState) (*resources.Service, error)

func (*Controller) UpdateServiceStatusClout

func (self *Controller) UpdateServiceStatusClout(service *resources.Service, cloutPath string, cloutHash string) (*resources.Service, error)

func (*Controller) UpdateServiceStatusMode

func (self *Controller) UpdateServiceStatusMode(service *resources.Service) (*resources.Service, error)

func (*Controller) UpdateServiceStatusNodeStates

func (self *Controller) UpdateServiceStatusNodeStates(service *resources.Service, states parser.OrchestrationNodeStates) (*resources.Service, error)

func (*Controller) UpdateServiceStatusOutputs

func (self *Controller) UpdateServiceStatusOutputs(service *resources.Service, outputs map[string]string) (*resources.Service, error)

func (*Controller) WriteClout

func (self *Controller) WriteClout(yaml string, cloutPath string) (string, error)

func (*Controller) WriteServiceClout

func (self *Controller) WriteServiceClout(yaml string, service *resources.Service) (*resources.Service, error)