operator

Documentation

Index

• type Config
• type Dependencies
• type Event
• type Operator
  • func NewOperator(config Config, deps Dependencies) (*Operator, error)
  • func (o *Operator) DeploymentOperator() server.DeploymentOperator
  • func (o *Operator) DeploymentReplicationOperator() server.DeploymentReplicationOperator
  • func (o *Operator) FindOtherOperators() []server.OperatorReference
  • func (o *Operator) GetDeployment(name string) (server.Deployment, error)
  • func (o *Operator) GetDeploymentReplication(name string) (server.DeploymentReplication, error)
  • func (o *Operator) GetDeploymentReplications() ([]server.DeploymentReplication, error)
  • func (o *Operator) GetDeployments() ([]server.Deployment, error)
  • func (o *Operator) GetLocalStorage(name string) (server.LocalStorage, error)
  • func (o *Operator) GetLocalStorages() ([]server.LocalStorage, error)
  • func (o *Operator) Run()
  • func (o *Operator) StorageOperator() server.StorageOperator

Types

type Config

type Config struct {
	ID                          string
	Namespace                   string
	PodName                     string
	ServiceAccount              string
	LifecycleImage              string
	AlpineImage                 string
	EnableDeployment            bool
	EnableDeploymentReplication bool
	EnableStorage               bool
	AllowChaos                  bool
}

type Dependencies

type Dependencies struct {
	LogService                 logging.Service
	KubeCli                    kubernetes.Interface
	KubeExtCli                 apiextensionsclient.Interface
	CRCli                      versioned.Interface
	EventRecorder              record.EventRecorder
	LivenessProbe              *probe.LivenessProbe
	DeploymentProbe            *probe.ReadyProbe
	DeploymentReplicationProbe *probe.ReadyProbe
	StorageProbe               *probe.ReadyProbe
}

type Event

type Event struct {
	Type                  kwatch.EventType
	Deployment            *deplapi.ArangoDeployment
	DeploymentReplication *replapi.ArangoDeploymentReplication
	LocalStorage          *lsapi.ArangoLocalStorage
}

type Operator

type Operator struct {
	Config
	Dependencies
	// contains filtered or unexported fields
}

func NewOperator

func NewOperator(config Config, deps Dependencies) (*Operator, error)

NewOperator instantiates a new operator from given config & dependencies.

func (*Operator) DeploymentOperator

func (o *Operator) DeploymentOperator() server.DeploymentOperator

DeploymentOperator provides access to the deployment operator.

func (*Operator) DeploymentReplicationOperator

func (o *Operator) DeploymentReplicationOperator() server.DeploymentReplicationOperator

DeploymentReplicationOperator provides access to the deployment replication operator.

func (*Operator) FindOtherOperators

func (o *Operator) FindOtherOperators() []server.OperatorReference

FindOtherOperators looks up references to other operators in the same Kubernetes cluster.

func (*Operator) GetDeployment

func (o *Operator) GetDeployment(name string) (server.Deployment, error)

GetDeployment returns detailed information for a deployment, managed by the operator, with given name

func (*Operator) GetDeploymentReplication

func (o *Operator) GetDeploymentReplication(name string) (server.DeploymentReplication, error)

GetDeploymentReplication returns detailed information for a deployment replication, managed by the operator, with given name

func (*Operator) GetDeploymentReplications

func (o *Operator) GetDeploymentReplications() ([]server.DeploymentReplication, error)

GetDeploymentReplications returns all current deployments

func (*Operator) GetDeployments

func (o *Operator) GetDeployments() ([]server.Deployment, error)

GetDeployments returns all current deployments

func (*Operator) GetLocalStorage

func (o *Operator) GetLocalStorage(name string) (server.LocalStorage, error)

GetLocalStorage returns detailed information for a local, managed by the operator, with given name

func (*Operator) GetLocalStorages

func (o *Operator) GetLocalStorages() ([]server.LocalStorage, error)

GetLocalStorages returns basic information for all local storages managed by the operator

func (*Operator) Run

func (o *Operator) Run()

Run the operator

func (*Operator) StorageOperator

func (o *Operator) StorageOperator() server.StorageOperator

StorageOperator provides the local storage operator (if any)