demultiplexerimpl

Documentation

Overview

Package demultiplexerimpl defines the aggregator demultiplexer

Package demultiplexerimpl defines the aggregator demultiplexer

Index

• func Module(params Params) fxutil.Module
• type Option
  • func WithContinueOnMissingHostname() Option
  • func WithDogstatsdNoAggregationPipelineConfig() Option
  • func WithFlushInterval(duration time.Duration) Option
• type Params
  • func NewDefaultParams(options ...Option) Params

Functions

func Module

func Module(params Params) fxutil.Module

Module defines the fx options for this component.

Types

type Option

type Option func(*Params)

Option is a function that sets a parameter in the Params struct

func WithContinueOnMissingHostname

func WithContinueOnMissingHostname() Option

WithContinueOnMissingHostname sets the continueOnMissingHostname field to true

func WithDogstatsdNoAggregationPipelineConfig

func WithDogstatsdNoAggregationPipelineConfig() Option

WithDogstatsdNoAggregationPipelineConfig uses the config dogstatsd_no_aggregation_pipeline

func WithFlushInterval

func WithFlushInterval(duration time.Duration) Option

WithFlushInterval sets the flushInterval field to the provided duration

type Params

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

Params contains the parameters for the demultiplexer

func NewDefaultParams

func NewDefaultParams(options ...Option) Params

NewDefaultParams returns the default parameters for the demultiplexer