omsnozzle

Documentation

Index

• type NozzleConfig
• type OMSMessage
• type OmsNozzle
  • func NewOmsNozzle(logger lager.Logger, firehoseClient firehose.Client, omsClient client.Client, ...) *OmsNozzle
  • func (o *OmsNozzle) Start() error

Types

type NozzleConfig

type NozzleConfig struct {
	OmsTypePrefix         string
	OmsBatchTime          time.Duration
	OmsMaxMsgNumPerBatch  int
	ExcludeMetricEvents   bool
	ExcludeLogEvents      bool
	ExcludeHttpEvents     bool
	LogEventCount         bool
	LogEventCountInterval time.Duration
}

type OMSMessage

type OMSMessage interface{}

OMSMessage is a marker inteface for JSON formatted messages published to OMS

type OmsNozzle

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

func NewOmsNozzle

func NewOmsNozzle(logger lager.Logger, firehoseClient firehose.Client, omsClient client.Client, nozzleConfig *NozzleConfig, caching caching.CachingClient) *OmsNozzle

func (*OmsNozzle) Start

func (o *OmsNozzle) Start() error