service

Documentation

Index

• func RunE(ctx context.Context, script string) (string, error)
• type Dependencies
  • func (d Dependencies) Inject(ctx context.Context) context.Context
• type HttpProvider
  • func (h *HttpProvider) ReaderFor(ctx context.Context, conf influxdb.Config, bounds flux.Bounds, ...) (influxdb.Reader, error)
  • func (h *HttpProvider) SeriesCardinalityReaderFor(ctx context.Context, conf influxdb.Config, bounds flux.Bounds, ...) (influxdb.Reader, error)
  • func (h *HttpProvider) WriterFor(ctx context.Context, conf influxdb.Config) (influxdb.Writer, error)

Functions

func RunE

func RunE(ctx context.Context, script string) (string, error)

Types

type Dependencies

type Dependencies struct {
	flux.Deps
	// contains filtered or unexported fields
}

func (Dependencies) Inject

func (d Dependencies) Inject(ctx context.Context) context.Context

type HttpProvider

type HttpProvider struct {
	*influxdb.HttpProvider
}

func (*HttpProvider) ReaderFor

func (h *HttpProvider) ReaderFor(
	ctx context.Context, conf influxdb.Config, bounds flux.Bounds,
	predicateSet influxdb.PredicateSet) (influxdb.Reader, error)

func (*HttpProvider) SeriesCardinalityReaderFor

func (h *HttpProvider) SeriesCardinalityReaderFor(ctx context.Context,
	conf influxdb.Config, bounds flux.Bounds, predicateSet influxdb.PredicateSet) (influxdb.Reader, error)

func (*HttpProvider) WriterFor

func (h *HttpProvider) WriterFor(ctx context.Context, conf influxdb.Config) (influxdb.Writer, error)