cagrr

type Closer interface {
	Close()
}

type Cluster struct {
	ID        int
	Name      string      `yaml:"name"`
	Interval  string      `yaml:"interval"`
	Keyspaces []*Keyspace `yaml:"keyspaces"`
	Host      string
	Port      int
	// contains filtered or unexported fields
}

type ClusterStats struct {
	Cluster            string
	ClusterDuration    time.Duration
	LastClusterSuccess time.Time
}

type Config struct {
	BufferLength int        `yaml:"buffer"`
	Clusters     []*Cluster `yaml:"clusters"`
}

type DB interface {
	CreateKey(keys ...string) string
	ValueReader
	ValueWriter
	Closer
}

type DurationQueue interface {
	Push(time.Duration)
	Pop() time.Duration
	Len() int
	Average() time.Duration
}

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

type Keyspace struct {
	Name string `yaml:"name"`
	// contains filtered or unexported fields
}

type Logger interface {
	WithError(err error) Logger
	WithFields(str interface{}) Logger
	Debug(message interface{}) Logger
	Error(message interface{}) Logger
	Fatal(message interface{}) Logger
	Warn(message interface{}) Logger
	Info(message interface{}) Logger
}

type Regulator interface {
	LimitRateTo(key string, duration time.Duration) time.Duration
	Limit(key string)
	Rate(key string) time.Duration
}

type Repair struct {
	ID       int    `json:"id"`
	Cluster  string `json:"cluster"`
	Keyspace string `json:"keyspace"`
	Table    string `json:"table"`
	Endpoint string `json:"endpoint"`
	Start    string `json:"start"`
	End      string `json:"end"`
}

type RepairStats struct {
	Cluster            string
	Keyspace           string
	Table              string
	ID                 int
	Duration           time.Duration
	Rate               time.Duration
	TableTotal         int
	TableCompleted     int
	TablePercent       float32
	TableDuration      time.Duration
	TableAverage       time.Duration
	TableEstimate      time.Duration
	KeyspaceTotal      int
	KeyspaceCompleted  int
	KeyspacePercent    float32
	KeyspaceDuration   time.Duration
	KeyspaceAverage    time.Duration
	KeyspaceEstimate   time.Duration
	ClusterTotal       int
	ClusterCompleted   int
	ClusterPercent     float32
	ClusterDuration    time.Duration
	ClusterAverage     time.Duration
	ClusterEstimate    time.Duration
	LastClusterSuccess time.Time
}

type RepairStatus struct {
	Repair  Repair
	Message string
	Type    string
}

type Scheduler interface {
	RegulateWith(Regulator) Scheduler
	Schedule()
	TrackIn(Tracker) Scheduler
	Until(chan bool) Scheduler
}

type Server interface {
	ServeAt(callback string) Server
}

type Table struct {
	Name   string  `yaml:"name"`
	Size   int64   `yaml:"size"`
	Slices int     `yaml:"slices"`
	Weight float32 `yaml:"weight"`
	// contains filtered or unexported fields
}

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

type TokenSet []Token

type Track struct {
	Completed bool
	Count     int
	Total     int
	Percent   float32
	Duration  time.Duration
	Average   time.Duration
	Estimate  time.Duration
	Rate      time.Duration
	Finished  time.Time
	Started   time.Time
}

type Tracker interface {
	Complete(cluster, keyspace, table string, repair int) *RepairStats
	IsCompleted(cluster, keyspace, table string, repair int, threshold time.Duration) bool
	Restart(cluster, keyspace, table string, repair int)
	Skip(cluster, keyspace, table string, repair int)
	Start(cluster, keyspace, table string, repair int)
	StartTable(cluster, keyspace, table string, total int)
	StartKeyspace(cluster, keyspace string, total int)
	StartCluster(cluster string, total int)
}

type ValueReader interface {
	ReadValue(string, string) []byte
}

type ValueWriter interface {
	WriteValue(string, string, []byte) error
}