control

Documentation

Overview

Package control provides a query controller.

Index

• type Controller
  • func New(config control.Config) *Controller
  • func (c *Controller) PrometheusCollectors() []prometheus.Collector
  • func (c *Controller) Query(ctx context.Context, req *query.Request) (flux.Query, error)
  • func (c *Controller) Shutdown(ctx context.Context) error

Types

type Controller

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

Controller implements AsyncQueryService by consuming a control.Controller.

func New

func New(config control.Config) *Controller

NewController creates a new Controller specific to platform.

func (*Controller) PrometheusCollectors

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

PrometheusCollectors satisifies the prom.PrometheusCollector interface.

func (*Controller) Query

func (c *Controller) Query(ctx context.Context, req *query.Request) (flux.Query, error)

Query satisfies the AsyncQueryService while ensuring the request is propagated on the context.

func (*Controller) Shutdown

func (c *Controller) Shutdown(ctx context.Context) error

Shutdown shuts down the underlying Controller.