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 ¶
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"`
}
Click to show internal directories.
Click to hide internal directories.