 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- type Config
- type Dependencies
- type Event
- type Operator
- 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
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
	ID                          string
	Namespace                   string
	PodName                     string
	ServiceAccount              string
	OperatorImage               string
	SkipLeaderLabel             bool
	EnableDeployment            bool
	EnableDeploymentReplication bool
	EnableStorage               bool
	EnableML                    bool
	EnableAnalytics             bool
	EnableNetworking            bool
	EnablePlatform              bool
	EnableScheduler             bool
	EnableBackup                bool
	EnableApps                  bool
	EnableK2KClusterSync        bool
	AllowChaos                  bool
	ScalingIntegrationEnabled   bool
	SingleMode                  bool
	ReconciliationDelay         time.Duration
	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
	MlProbe                    *probe.ReadyProbe
	AnalyticsProbe             *probe.ReadyProbe
	NetworkingProbe            *probe.ReadyProbe
	PlatformProbe              *probe.ReadyProbe
	SchedulerProbe             *probe.ReadyProbe
	AppsProbe                  *probe.ReadyProbe
	K2KClusterSyncProbe        *probe.ReadyProbe
}
    type Event ¶
type Event struct {
	Type                  kwatch.EventType
	Deployment            *api.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) StorageOperator ¶
func (o *Operator) StorageOperator() server.StorageOperator
StorageOperator provides the local storage operator (if any)