manager

Documentation

Index

• Constants
• type BackupTaskSpec
  • func (b *BackupTaskSpec) GetStartDateOrEmpty() string
  • func (b *BackupTaskSpec) SetStartDate(sd string)
  • func (b *BackupTaskSpec) ToManager() (*managerclient.Task, error)
  • func (b *BackupTaskSpec) ToStatus() *BackupTaskStatus
• type BackupTaskStatus
  • func NewBackupStatusFromManager(t *managerclient.TaskListItem) (*BackupTaskStatus, error)
  • func (b *BackupTaskStatus) GetStartDateOrEmpty() string
• 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) GetStartDateOrEmpty() string
  • func (r *RepairTaskSpec) SetStartDate(sd string)
  • func (r *RepairTaskSpec) ToManager() (*managerclient.Task, error)
  • func (r *RepairTaskSpec) ToStatus() *RepairTaskStatus
• type RepairTaskStatus
  • func NewRepairStatusFromManager(t *managerclient.TaskListItem) (*RepairTaskStatus, error)
  • func (r *RepairTaskStatus) GetStartDateOrEmpty() string

Constants

const (
	ControllerName = "ScyllaManagerController"
)

Types

type BackupTaskSpec

type BackupTaskSpec scyllav1.BackupTaskSpec

func (*BackupTaskSpec) GetStartDateOrEmpty

func (b *BackupTaskSpec) GetStartDateOrEmpty() string

func (*BackupTaskSpec) SetStartDate

func (b *BackupTaskSpec) SetStartDate(sd string)

func (*BackupTaskSpec) ToManager

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

func (*BackupTaskSpec) ToStatus

func (b *BackupTaskSpec) ToStatus() *BackupTaskStatus

type BackupTaskStatus

type BackupTaskStatus scyllav1.BackupTaskStatus

func NewBackupStatusFromManager

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

func (*BackupTaskStatus) GetStartDateOrEmpty

func (b *BackupTaskStatus) GetStartDateOrEmpty() string

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) GetStartDateOrEmpty

func (r *RepairTaskSpec) GetStartDateOrEmpty() string

func (*RepairTaskSpec) SetStartDate

func (r *RepairTaskSpec) SetStartDate(sd string)

func (*RepairTaskSpec) ToManager

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

func (*RepairTaskSpec) ToStatus

func (r *RepairTaskSpec) ToStatus() *RepairTaskStatus

type RepairTaskStatus

type RepairTaskStatus scyllav1.RepairTaskStatus

func NewRepairStatusFromManager

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

func (*RepairTaskStatus) GetStartDateOrEmpty

func (r *RepairTaskStatus) GetStartDateOrEmpty() string