kelemetrixconsumer

Documentation

Index

• type Consumer
  • func (consumer *Consumer) Close(ctx context.Context) error
  • func (consumer *Consumer) HandleMessage(logger logrus.FieldLogger, message *audit.Message)
  • func (consumer *Consumer) Init() error
  • func (consumer *Consumer) Options() manager.Options
  • func (consumer *Consumer) PrepareTagsQuantifiers() error
  • func (consumer *Consumer) Start(ctx context.Context) error
• type Options
  • func (options *Options) EnableFlag() *bool
  • func (options *Options) Setup(fs *pflag.FlagSet)

Types

type Consumer

type Consumer struct {
	Mq       mq.Queue
	Metrics  metrics.Client
	Registry *kelemetrix.Registry
	Config   config.Provider
	// contains filtered or unexported fields
}

func (*Consumer) Close

func (consumer *Consumer) Close(ctx context.Context) error

func (*Consumer) HandleMessage

func (consumer *Consumer) HandleMessage(logger logrus.FieldLogger, message *audit.Message)

func (*Consumer) Init

func (consumer *Consumer) Init() error

func (*Consumer) Options

func (consumer *Consumer) Options() manager.Options

func (*Consumer) PrepareTagsQuantifiers

func (consumer *Consumer) PrepareTagsQuantifiers() error

func (*Consumer) Start

func (consumer *Consumer) Start(ctx context.Context) error

type Options

type Options struct {
	Enable        bool
	ConsumerGroup string
	Partitions    []int32
	LogTags       bool
	LogQuantities bool
}

func (*Options) EnableFlag

func (options *Options) EnableFlag() *bool

func (*Options) Setup

func (options *Options) Setup(fs *pflag.FlagSet)