manager

Documentation

Index

• Constants
• func NewBackupStatusFromManager(t *managerclient.TaskListItem) (*scyllav1.BackupTaskStatus, error)
• func NewRepairStatusFromManager(t *managerclient.TaskListItem) (*scyllav1.RepairTaskStatus, error)
• type BackupTaskSpec
  • func (b *BackupTaskSpec) GetObjectHash() (string, error)
  • func (b *BackupTaskSpec) GetTaskSpec() *scyllav1.TaskSpec
  • func (b *BackupTaskSpec) ToManager() (*managerclient.Task, error)
  • func (b *BackupTaskSpec) ToStatus() *scyllav1.BackupTaskStatus
• type Controller
  • func NewController(kubeClient kubernetes.Interface, scyllaClient scyllav1client.ScyllaV1Interface, ...) (*Controller, error)
  • func (c *Controller) Run(ctx context.Context, workers int)
• type RepairTaskSpec
  • func (r *RepairTaskSpec) GetObjectHash() (string, error)
  • func (r *RepairTaskSpec) GetTaskSpec() *scyllav1.TaskSpec
  • func (r *RepairTaskSpec) ToManager() (*managerclient.Task, error)
  • func (r *RepairTaskSpec) ToStatus() *scyllav1.RepairTaskStatus

Constants

const (
	ControllerName = "ScyllaManagerController"
)

Functions

func NewBackupStatusFromManager

func NewBackupStatusFromManager(t *managerclient.TaskListItem) (*scyllav1.BackupTaskStatus, error)

func NewRepairStatusFromManager

func NewRepairStatusFromManager(t *managerclient.TaskListItem) (*scyllav1.RepairTaskStatus, error)

Types

type BackupTaskSpec

type BackupTaskSpec scyllav1.BackupTaskSpec

func (*BackupTaskSpec) GetObjectHash

func (b *BackupTaskSpec) GetObjectHash() (string, error)

func (*BackupTaskSpec) GetTaskSpec

func (b *BackupTaskSpec) GetTaskSpec() *scyllav1.TaskSpec

func (*BackupTaskSpec) ToManager

func (b *BackupTaskSpec) ToManager() (*managerclient.Task, error)

func (*BackupTaskSpec) ToStatus

func (b *BackupTaskSpec) ToStatus() *scyllav1.BackupTaskStatus

type Controller

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

func NewController

func NewController(
	kubeClient kubernetes.Interface,
	scyllaClient scyllav1client.ScyllaV1Interface,
	secretInformer corev1informers.SecretInformer,
	scyllaClusterInformer scyllav1informers.ScyllaClusterInformer,
	managerClient *managerclient.Client,
) (*Controller, error)

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, workers int)

type RepairTaskSpec

type RepairTaskSpec scyllav1.RepairTaskSpec

func (*RepairTaskSpec) GetObjectHash

func (r *RepairTaskSpec) GetObjectHash() (string, error)

func (*RepairTaskSpec) GetTaskSpec

func (r *RepairTaskSpec) GetTaskSpec() *scyllav1.TaskSpec

func (*RepairTaskSpec) ToManager

func (r *RepairTaskSpec) ToManager() (*managerclient.Task, error)

func (*RepairTaskSpec) ToStatus

func (r *RepairTaskSpec) ToStatus() *scyllav1.RepairTaskStatus