operator

Documentation

Index

• Variables
• type Controller
  • func NewController(config *config.Config, context *opkit.Context, ...) *Controller
  • func (c *Controller) StartWatch(namespace string, stopCh <-chan struct{}) error
• type Operator
  • func New(config *config.Config) *Operator
  • func (o *Operator) Run(stopChan <-chan struct{})

Variables

var Resource = opkit.CustomResource{
	Name:    "serverlessrelease",
	Plural:  "serverlessreleases",
	Group:   slsapi.GroupName,
	Version: slsapi.Version,
	Scope:   apiextensionsv1beta1.NamespaceScoped,
	Kind:    reflect.TypeOf(slsapiv1.ServerlessRelease{}).Name(),
	ShortNames: []string{
		"sls",
		"slsrelease",
	},
}

Resource represents the CRD for the serverless release

Types

type Controller

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

Controller represents the controller object for the resource

func NewController

func NewController(config *config.Config,
	context *opkit.Context,
	slsClientSet slsclient.ReleaseV1alpha1Interface) *Controller

NewController creates a new Controller

func (*Controller) StartWatch

func (c *Controller) StartWatch(namespace string, stopCh <-chan struct{}) error

StartWatch watches for instances of Object Store custom resources and acts on them

type Operator

type Operator struct {
	Config *config.Config
}

Operator implements the serverless releaser using the operator pattern

func New

func New(config *config.Config) *Operator

New creates a new server from a config

func (*Operator) Run

func (o *Operator) Run(stopChan <-chan struct{})

Run starts the operator listening for Kuberbetes events