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
EnableDeployment bool
EnableDeploymentReplication bool
EnableStorage bool
EnableML bool
EnableBackup bool
EnableApps bool
EnableK2KClusterSync bool
AllowChaos bool
ScalingIntegrationEnabled bool
SingleMode bool
Scope scope.Scope
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
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) StorageOperator ¶
func (o *Operator) StorageOperator() server.StorageOperator
StorageOperator provides the local storage operator (if any)
Source Files
Directories