reaper

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 21, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	RepairStateRunning = "RUNNING"
	RepairStatePaused  = "PAUSED"

	OwnerCassandraOperator = "mr-cassop"
)

Variables

View Source
var (
	ClusterNotFound = errors.New("cassandra cluster not found")
)

Functions

This section is empty.

Types

type ReaperClient

type ReaperClient interface {
	IsRunning(ctx context.Context) (bool, error)
	ClusterExists(ctx context.Context) (bool, error)
	Clusters(ctx context.Context) ([]string, error)
	DeleteCluster(ctx context.Context) error
	AddCluster(ctx context.Context, seed string) error
	CreateRepairSchedule(ctx context.Context, repair dbv1alpha1.RepairSchedule) error
	RepairSchedules(ctx context.Context) ([]RepairSchedule, error)
	DeleteRepairSchedule(ctx context.Context, repairScheduleID string) error
	SetRepairScheduleState(ctx context.Context, repairScheduleID string, active bool) error
	RunRepair(ctx context.Context, keyspace, cause string) error
}

func NewReaperClient

func NewReaperClient(url *url.URL, clusterName string, client *http.Client, defaultRepairThreadCount int32) ReaperClient

type RepairRun

type RepairRun struct {
	ID           string `json:"id"`
	State        string `json:"state"`
	Duration     string `json:"duration"`
	ClusterName  string `json:"cluster_name"`
	KeyspaceName string `json:"keyspace_name"`
	Owner        string `json:"owner"`
	Cause        string `json:"cause"`
}

type RepairSchedule

type RepairSchedule struct {
	ID                  string   `json:"id"`
	Owner               string   `json:"owner"`
	State               string   `json:"state"`
	Intensity           float64  `json:"intensity"` // value between 0.0 and 1.0, but must never be 0.0.
	KeyspaceName        string   `json:"keyspace_name"`
	ColumnFamilies      []string `json:"column_families"`
	SegmentCount        int32    `json:"segment_count"`
	RepairParallelism   string   `json:"repair_parallelism"`
	ScheduleDaysBetween int32    `json:"scheduled_days_between"`
	Datacenters         []string `json:"datacenters"`
	IncrementalRepair   bool     `json:"incremental_repair"`
	Tables              []string `json:"tables"`
	RepairThreadCount   int32    `json:"repair_thread_count"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL