controller

package
v0.0.0-...-07553be Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 16, 2025 License: Apache-2.0 Imports: 43 Imported by: 0

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

View Source 
const (
	NamePrefix        = "turandot"
	PartOf            = "Turandot"
	ManagedBy         = "Turandot"
	OperatorImageName = "tliron/turandot-operator"
	CacheDirectory    = "/cache"
)
View Source 
const (
	EventCompiled           = "Compiled"
	EventCompilationError   = "CompilationError"
	EventInstantiated       = "Instantiated"
	EventInstantiationError = "InstantiationError"
	EventCloutUpdateError   = "CloutUpdateError"
)

Variables

This section is empty.

Functions

func CompileTOSCA 

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

func ReadClout 

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

func RequireCloutScriptlet 

func RequireCloutScriptlet(clout *cloutpkg.Clout, scriptletName string, arguments map[string]string, urlContext *exturl.Context) (string, 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     commonlog.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(context contextpkg.Context, serviceTemplateURL string, inputs map[string]string, cloutPath string, urlContext *exturl.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(context contextpkg.Context, cloutPath string, resolve bool, coerce bool, urlContext *exturl.Context) (*cloutpkg.Clout, error)

func (*Controller) Run 

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

func (*Controller) Substitute 

func (self *Controller) Substitute(context contextpkg.Context, namespace string, nodeTemplateName string, inputs map[string]any, mode string, site string, urlContext *exturl.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)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.