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
  • func (o *Operator) WrapLogger(in *zerolog.Event) *zerolog.Event

Types

type Config

type Config struct {
	ID                          string
	Namespace                   string
	WatchNamespace              string
	PodName                     string
	ServiceAccount              string
	OperatorImage               string
	ArangoImage                 string
	EnableDeployment            bool
	EnableDeploymentReplication bool
	EnableStorage               bool
	EnableBackup                bool
	EnableApps                  bool
	EnableK2KClusterSync        bool
	AllowChaos                  bool
	ScalingIntegrationEnabled   bool
	SingleMode                  bool
	Scope                       scope.Scope
	ShutdownDelay               time.Duration
	ShutdownTimeout             time.Duration
}

type Dependencies

type Dependencies struct {
	Client                     kclient.Client
	EventRecorder              record.EventRecorder
	LivenessProbe              *probe.LivenessProbe
	DeploymentProbe            *probe.ReadyProbe
	DeploymentReplicationProbe *probe.ReadyProbe
	StorageProbe               *probe.ReadyProbe
	BackupProbe                *probe.ReadyProbe
	AppsProbe                  *probe.ReadyProbe
	K2KClusterSyncProbe        *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)

func (*Operator) WrapLogger

func (o *Operator) WrapLogger(in *zerolog.Event) *zerolog.Event