control

Documentation

Index

• type Authorizer
• type Controller
  • func NewController(mc MetaClient, reader influxdb.Reader, auth Authorizer, authEnabled bool, ...) *Controller
  • func (c *Controller) PrometheusCollectors() []prometheus.Collector
  • func (c *Controller) Query(ctx context.Context, compiler flux.Compiler) (flux.Query, error)
• type MetaClient

Types

type Authorizer

type Authorizer = influxdb.Authorizer

type Controller

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

func NewController

func NewController(mc MetaClient, reader influxdb.Reader, auth Authorizer, authEnabled bool, logger *zap.Logger) *Controller

func (*Controller) PrometheusCollectors

func (c *Controller) PrometheusCollectors() []prometheus.Collector

func (*Controller) Query

func (c *Controller) Query(ctx context.Context, compiler flux.Compiler) (flux.Query, error)

type MetaClient

type MetaClient = coordinator.MetaClient