Versions in this module Expand all Collapse all v0 v0.9.0 Feb 21, 2017 v0.8.5 Feb 21, 2017 Changes in this version type Cluster + Host string + Port int + func (c *Cluster) Fix(jobs <-chan *Repair) + func (c *Cluster) RunRepair(repair *Repair) error + func (c *Cluster) Until(done chan bool) Scheduler type Scheduler + Until func(chan bool) Scheduler v0.8.4 Feb 21, 2017 Changes in this version type ClusterStats + LastClusterSuccess time.Time type RepairStats + LastClusterSuccess time.Time v0.8.3 Feb 20, 2017 v0.8.0 Feb 20, 2017 Changes in this version + type Closer interface + Close func() + type Cluster struct + ID int + Interval string + Keyspaces []*Keyspace + Name string + func (c *Cluster) ObtainBy(o Obtainer) Scheduler + func (c *Cluster) RegulateWith(r Regulator) Scheduler + func (c *Cluster) Schedule(jobs chan *Repair) + func (c *Cluster) TrackIn(t Tracker) Scheduler + type ClusterStats struct + Cluster string + ClusterDuration time.Duration + LastSuccess time.Time type Config + BufferLength int + Conn *Connector + func ReadConfiguration(filename string) (*Config, error) + type Connector struct + Host string + Port int + func (c *Connector) GetTokens(cluster, keyspace string, slices int) (TokenSet, error) + func (c *Connector) ObtainFragments(cluster, keyspace string, slices int) ([]*Fragment, error) + func (c *Connector) ObtainTables(cluster, keyspace string) ([]*Table, error) + func (c *Connector) RunRepair(repair *Repair) error + type DB interface + CreateKey func(keys ...string) string + func NewConsulDb() DB + func NewRedisDb(addr, password string, db int) DB + type DurationQueue interface + Average func() time.Duration + Len func() int + Pop func() time.Duration + Push func(time.Duration) + func NewQueue(size int) DurationQueue type Fixer + func NewFixer(runner RepairRunner) Fixer + Fix func(jobs <-chan *Repair) + type Keyspace struct + Name string + func (k *Keyspace) SetTables(tables []*Table) + func (k *Keyspace) SetTotal(total int) + func (k *Keyspace) Tables() []*Table + func (k *Keyspace) Total() int + type Logger interface + Debug func(message interface{}) Logger + Error func(message interface{}) Logger + Fatal func(message interface{}) Logger + Info func(message interface{}) Logger + Warn func(message interface{}) Logger + WithError func(err error) Logger + WithFields func(str interface{}) Logger + func NewLogger(verb, filename string) Logger + type Navigation struct + Cluster string + Keyspace string + Table string + type Obtainer interface + ObtainFragments func(cluster, keyspace string, slices int) ([]*Fragment, error) + ObtainTables func(cluster, keyspace string) ([]*Table, error) + type Regulator interface + Limit func(key string) + LimitRateTo func(key string, duration time.Duration) time.Duration + Rate func(key string) time.Duration + func NewRegulator(size int) Regulator type Repair + Cluster string + End string + Endpoint string + Start string + Table string + type RepairRunner interface + RunRepair func(repair *Repair) error + type RepairStats struct + Cluster string + ClusterAverage time.Duration + ClusterCompleted int + ClusterDuration time.Duration + ClusterEstimate time.Duration + ClusterPercent float32 + ClusterTotal int + Duration time.Duration + ID int + Keyspace string + KeyspaceAverage time.Duration + KeyspaceCompleted int + KeyspaceDuration time.Duration + KeyspaceEstimate time.Duration + KeyspacePercent float32 + KeyspaceTotal int + Rate time.Duration + Table string + TableAverage time.Duration + TableCompleted int + TableDuration time.Duration + TableEstimate time.Duration + TablePercent float32 + TableTotal int + type Scheduler interface + ObtainBy func(Obtainer) Scheduler + RegulateWith func(Regulator) Scheduler + Schedule func(chan *Repair) + TrackIn func(Tracker) Scheduler + type Server interface + ServeAt func(callback string) Server + func NewServer(tracker Tracker) Server + type Table struct + Name string + Size int64 + Slices int + Weight float32 + func (t *Table) Repairs() []*Repair + func (t *Table) SetRepairs(repairs []*Repair) + func (t *Table) SetTotal(total int) + func (t *Table) Total() int + type TokenSet []Token + type Track struct + Average time.Duration + Completed bool + Count int + Duration time.Duration + Estimate time.Duration + Finished time.Time + Percent float32 + Rate time.Duration + Started time.Time + Total int + func (t *Track) CheckCompletion() + func (t *Track) Complete(duration time.Duration) (int, int, time.Duration, float32, time.Duration, time.Duration) + func (t *Track) IsNew() bool + func (t *Track) IsRepaired(threshold time.Duration) bool + func (t *Track) IsSpoiled(threshold time.Duration) bool + func (t *Track) Restart() + func (t *Track) Skip() + func (t *Track) Start(total int) + type Tracker interface + Complete func(cluster, keyspace, table string, repair int) *RepairStats + IsCompleted func(cluster, keyspace, table string, repair int, threshold time.Duration) bool + Restart func(cluster, keyspace, table string, repair int) + Skip func(cluster, keyspace, table string, repair int) + Start func(cluster, keyspace, table string, repair int) + StartCluster func(cluster string, total int) + StartKeyspace func(cluster, keyspace string, total int) + StartTable func(cluster, keyspace, table string, total int) + func NewTracker(db DB, r Regulator) Tracker + type ValueReader interface + ReadValue func(string, string) []byte + type ValueWriter interface + WriteValue func(string, string, []byte) error v0.7.0 Oct 28, 2016 Changes in this version + type ClusterConfig struct + Host string + Interval string + Keyspaces []string + Port int + type Config struct + Clusters []ClusterConfig + type Fixer interface + Repair func(keyspace string, callback string) ([]Repair, error) + type Fragment struct + End string + Endpoint string + ID int + Start string + func (f Fragment) Repair(r Ring, keyspace string, callback string) Repair + type Repair struct + Callback string + Fragment Fragment + ID int64 + Keyspace string + T1 time.Time + T2 time.Time + func (r *Repair) Duration() time.Duration + func (r *Repair) Run() error + func (r *Repair) StartMeasure() + func (r *Repair) StopMeasure() + type RepairStatus struct + Command int + Count int + Duration int + Error bool + Message string + Repair Repair + Session string + Total int + Type string + type Ring struct + Cluster int + Host string + Name string + Partitioner string + Port int + Tokens []Token + func (r Ring) Count() int + func (r Ring) Obtain(keyspace, callback string, cluster int) ([]repair.Runner, error) + func (r Ring) Repair(keyspace string, callback string) ([]repair.Runner, error) + type Token struct + ID string + Ranges []Fragment
Go to main page