consistency

Documentation

Index

• Variables
• func KeepVerifying(agentClient *redis.RemoteAgentClient, statefilePath string, ...)
• func NewStateFileAvailableInstances(path string) *stateFileAvailableInstances
• func StopVerifying()
• type CheckSchedule
  • func NewCheckSchedule(checker Checker, interval time.Duration, logger lager.Logger) *CheckSchedule
  • func (cs *CheckSchedule) Start()
  • func (cs *CheckSchedule) Stop()
• type Checker
• type InconsistencyReporter
• type InstancesNoDataChecker
  • func NewInstancesNoDataChecker(i InstancesProvider, kc Keycounter, r InconsistencyReporter) *InstancesNoDataChecker
  • func (c *InstancesNoDataChecker) Check() error
• type InstancesProvider
• type Keycounter
• type LogReporter
  • func NewLogReporter(logger lager.Logger) *LogReporter
  • func (l *LogReporter) Report(i redis.Instance, err error)

Variables

var ErrHasData = errors.New("redis database not empty")

Functions

func KeepVerifying

func KeepVerifying(agentClient *redis.RemoteAgentClient, statefilePath string, interval time.Duration, logger lager.Logger)

func NewStateFileAvailableInstances

func NewStateFileAvailableInstances(path string) *stateFileAvailableInstances

func StopVerifying

func StopVerifying()

Types

type CheckSchedule

type CheckSchedule struct {
	// contains filtered or unexported fields
}

func NewCheckSchedule

func NewCheckSchedule(checker Checker, interval time.Duration, logger lager.Logger) *CheckSchedule

func (*CheckSchedule) Start

func (cs *CheckSchedule) Start()

func (*CheckSchedule) Stop

func (cs *CheckSchedule) Stop()

type Checker

type Checker interface {
	Check() error
}

type InconsistencyReporter

type InconsistencyReporter interface {
	Report(redis.Instance, error)
}

type InstancesNoDataChecker

type InstancesNoDataChecker struct {
	// contains filtered or unexported fields
}

func NewInstancesNoDataChecker

func NewInstancesNoDataChecker(i InstancesProvider, kc Keycounter, r InconsistencyReporter) *InstancesNoDataChecker

func (*InstancesNoDataChecker) Check

func (c *InstancesNoDataChecker) Check() error

type InstancesProvider

type InstancesProvider interface {
	Instances() ([]redis.Instance, error)
}

type Keycounter

type Keycounter interface {
	Keycount(host string) (int, error)
}

type LogReporter

type LogReporter struct {
	// contains filtered or unexported fields
}

func NewLogReporter

func NewLogReporter(logger lager.Logger) *LogReporter

func (*LogReporter) Report

func (l *LogReporter) Report(i redis.Instance, err error)