persistence

type InfluxAdapter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type InfluxStore interface {
	ShardIDs() []uint64
	WriteToShard(shardId uint64, points []models.Point) error
	CreateShard(database string, retentionPolicy string, shardId uint64, enabled bool) error
	ShardGroup(shardIds []uint64) tsdb.ShardGroup
	DeleteShard(shardId uint64) error
	TagKeys(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagKeys, error)
	TagValues(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagValues, error)
	Close() error
}

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

type MetricsInitializer interface {
	NewCounter(name string) func(delta uint64)
	NewGauge(name, unit string) func(value float64)
}

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

type WithStoreOption func(*Store)