feature

Documentation

Index

• func Inject(ctx context.Context, flagger Flagger) context.Context
• type BoolFlag
  • func AggregateTransformationTransport() BoolFlag
  • func GroupTransformationGroup() BoolFlag
  • func MqttPoolDialer() BoolFlag
  • func OptimizeUnionTransformation() BoolFlag
  • func VectorizedMap() BoolFlag
• type Flag
  • func ByKey(k string) (Flag, bool)
  • func Flags() []Flag
• type Flagger
• type FloatFlag
• type IntFlag
  • func QueryConcurrencyLimit() IntFlag
• type StringFlag

Functions

func Inject

func Inject(ctx context.Context, flagger Flagger) context.Context

Inject will inject the Flagger into the context.

Types

type BoolFlag

type BoolFlag = feature.BoolFlag

func AggregateTransformationTransport

func AggregateTransformationTransport() BoolFlag

AggregateTransformationTransport - Enable Transport interface for AggregateTransformation

func GroupTransformationGroup

func GroupTransformationGroup() BoolFlag

GroupTransformationGroup - Enable GroupTransformation interface for the group function

func MqttPoolDialer

func MqttPoolDialer() BoolFlag

MqttPoolDialer - MQTT pool dialer

func OptimizeUnionTransformation

func OptimizeUnionTransformation() BoolFlag

OptimizeUnionTransformation - Optimize the union transformation

func VectorizedMap

func VectorizedMap() BoolFlag

VectorizedMap - Enables the version of map that supports vectorized functions

type Flag

type Flag = feature.Flag

func ByKey

func ByKey(k string) (Flag, bool)

ByKey returns the Flag corresponding to the given key.

func Flags

func Flags() []Flag

Flags returns all feature flags.

type Flagger

type Flagger = feature.Flagger

type FloatFlag

type FloatFlag = feature.FloatFlag

type IntFlag

type IntFlag = feature.IntFlag

func QueryConcurrencyLimit

func QueryConcurrencyLimit() IntFlag

QueryConcurrencyLimit - Sets the query concurrency limit for the planner

type StringFlag

type StringFlag = feature.StringFlag