elasticsearch_bridge

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

type Config struct {
	Addr    string
	Timeout time.Duration
}

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

type GoKitMetrics interface {
	NewCounter(name string) *metric.Counter
	NewGauge(name string) *metric.Gauge
	NewHistogram(name string) *metric.Histogram
	WriteLoop(c <-chan time.Time, w metric.BatchPointsWriter)
}

type HealthRepresentation struct {
	ClusterName                 string  `json:"cluster_name"`
	Status                      string  `json:"status"`
	TimedOut                    bool    `json:"timed_out"`
	NumberOfNodes               int     `json:"number_of_nodes"`
	NumberOfDataNodes           int     `json:"number_of_data_nodes"`
	ActivedPrimaryShards        int     `json:"active_primary_shards"`
	ActiveShards                int     `json:"active_shards"`
	RelocatingShards            int     `json:"relocating_shards"`
	InitializingShards          int     `json:"initializing_shards"`
	UnassignedShards            int     `json:"unassigned_shards"`
	DelayedUnassignedShards     int     `json:"delayed_unassigned_shards"`
	NumberOfPendingTasks        int     `json:"number_of_pending_tasks"`
	NumberOfInFlightFetch       int     `json:"number_of_in_flight_fetch"`
	TaskMaxWaitingInQueueMillis int     `json:"task_max_waiting_in_queue_millis"`
	ActiveShardsPercentAsNumber float64 `json:"active_shards_percent_as_number"`
}

type IndexRepresentation struct {
	Index  string `json:"index"`
	Status string `json:"status"`
}

type IndexSettingsRepresentation struct {
	CreationDate     time.Time `json:"creation_date"`
	NumberOfShards   int       `json:"number_of_shards"`
	NumberOfReplicas int       `json:"number_of_replicas"`
	UUID             string    `json:"uuid"`
}

type Influx interface {
	Ping(timeout time.Duration) (time.Duration, string, error)
	Write(bp influx.BatchPoints) error
	Close() error
}

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

type NoopCounter struct{}

type NoopGauge struct{}

type NoopHistogram struct{}

type NoopMetrics struct{}

type NoopRedis struct{}

type NoopSentry struct{}

type Redis interface {
	Send(commandName string, args ...interface{}) error
}

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

type Sentry interface {
	URL() string
}