cagrr

type ClusterConfig struct {
	Host      string   `yaml:"host"`
	Port      int      `yaml:"port"`
	Interval  string   `yaml:"interval"`
	Keyspaces []string `yaml:"keyspaces"`
}

type Config struct {
	Clusters []ClusterConfig `yaml:"clusters"`
}

type Fixer interface {
	Repair(keyspace string, callback string) ([]Repair, error)
}

type Fragment struct {
	ID       int    `json:"id"`
	Endpoint string `json:"endpoint"`
	Start    string `json:"start"`
	End      string `json:"end"`
}

type Repair struct {
	ID       int64    `json:"id"`
	Fragment Fragment `json:"fragment"`

	T1       time.Time
	T2       time.Time
	Callback string `json:"callback"`
	Keyspace string `json:"keyspace"`
	// contains filtered or unexported fields
}

type RepairStatus struct {
	Repair   Repair `json:"repair"`
	Command  int    `json:"command"`
	Count    int    `json:"count"`
	Duration int    `json:"duration"`
	Error    bool   `json:"error"`
	Message  string `json:"message"`
	Session  string `json:"session"`
	Total    int    `json:"total"`
	Type     string `json:"type"`
}

type Ring struct {
	Host        string
	Port        int
	Cluster     int     `json:"cluster"`
	Name        string  `json:"name"`
	Partitioner string  `json:"partitioner"`
	Tokens      []Token `json:"tokens"`
}

type Token struct {
	ID     string     `json:"key"`
	Ranges []Fragment `json:"ranges"`
}