producer

Documentation

Index

• func RunLocalCommand(command string, arg ...string) (string, string, error)
• type MeteringCommandDetails
• type MeteringEventBufferedProcessor
• type MeteringEventFileLogger
• type MeteringEventProducer
  • func ReadProducerFromConfig(configFile string) (MeteringEventProducer, error)
  • func (p *MeteringEventProducer) HandleError(batchContext *processor.BatchContext, err error)
  • func (p *MeteringEventProducer) Process(batchContext *processor.BatchContext) error
  • func (p *MeteringEventProducer) Run()
• type MeteringJSONFormatter
  • func (f *MeteringJSONFormatter) Format(entry *log.Entry) ([]byte, error)

Functions

func RunLocalCommand

func RunLocalCommand(command string, arg ...string) (string, string, error)

RunLocalCommand run local system command

Types

type MeteringCommandDetails

type MeteringCommandDetails struct {
	Command string
	JSON    bool
}

MeteringCommandDetails holds command details that is used to gather a specific field

type MeteringEventBufferedProcessor

type MeteringEventBufferedProcessor struct {
	ProcessorCommand string
	BatchContext     *processor.BatchContext
}

MeteringEventBufferedProcessor holds buffer and data processor for publishing events

type MeteringEventFileLogger

type MeteringEventFileLogger struct {
	Enabled    bool
	LogFile    string
	MaxSizeMB  int
	MaxBackups int
	MaxAge     int
	Compress   bool
}

MeteringEventFileLogger holds file logger details

type MeteringEventProducer

type MeteringEventProducer struct {
	EventInerval      int
	Fields            log.Fields
	EventIDField      string
	TimestampField    string
	IDGeneratorFields []string
	FieldCommandPairs map[string]MeteringCommandDetails
	FileLogger        *MeteringEventFileLogger
	BufferedProcessor *MeteringEventBufferedProcessor
}

MeteringEventProducer metering producer type which holds required configuration

func ReadProducerFromConfig

func ReadProducerFromConfig(configFile string) (MeteringEventProducer, error)

ReadProducerFromConfig create producer struct from producer configuration

func (*MeteringEventProducer) HandleError

func (p *MeteringEventProducer) HandleError(batchContext *processor.BatchContext, err error)

HandleError handle errors during time based buffer processing (it is not used by this generator)

func (*MeteringEventProducer) Process

func (p *MeteringEventProducer) Process(batchContext *processor.BatchContext) error

Process run local process commands on gathered metering events

func (*MeteringEventProducer) Run

func (p *MeteringEventProducer) Run()

Run start metering event producer

type MeteringJSONFormatter

type MeteringJSONFormatter struct {
}

MeteringJSONFormatter type for custom json formatter

func (*MeteringJSONFormatter) Format

func (f *MeteringJSONFormatter) Format(entry *log.Entry) ([]byte, error)

Format json formatter for logrus entries