logmessage

Documentation

Index

• type Nrevents
  • func (n Nrevents) AreFiltersEnabled() bool
  • func (n Nrevents) ConvertSourceInstance(i string) int32
  • func (n Nrevents) GetTag(e *loggregator_v2.Envelope, ta string) string
  • func (n Nrevents) HarvestMetrics(entity *entities.Entity, metric *metrics.Metric)
  • func (n Nrevents) IsExcluded(logMessage string, logSource string) bool
  • func (n Nrevents) IsExcludedLogMessage(logMessage string) bool
  • func (n Nrevents) IsExcludedLogSource(logSource string) bool
  • func (n Nrevents) IsIncluded(logMessage string, logSource string) bool
  • func (n Nrevents) IsIncludedLogMessage(logMessage string) bool
  • func (n Nrevents) IsIncludedLogSource(logSource string) bool
  • func (n Nrevents) New() accumulators.Interface
  • func (n Nrevents) Update(e *loggregator_v2.Envelope)

Types

type Nrevents

type Nrevents struct {
	accumulators.Accumulator
	CFAppManager *cfapps.CFAppManager
	// contains filtered or unexported fields
}

Nrevents extends event.Accumulator for Firehose LogMessage Envelope Event Types

func (Nrevents) AreFiltersEnabled

func (n Nrevents) AreFiltersEnabled() bool

AreFiltersEnabled populate struct to eliminate potentially unnecessary filter calls

func (Nrevents) ConvertSourceInstance

func (n Nrevents) ConvertSourceInstance(
	i string,
) int32

ConvertSourceInstance from a string to int32

func (Nrevents) GetTag

func (n Nrevents) GetTag(
	e *loggregator_v2.Envelope,
	ta string,
) string

GetTag ...

func (Nrevents) HarvestMetrics

func (n Nrevents) HarvestMetrics(
	entity *entities.Entity,
	metric *metrics.Metric,
)

HarvestMetrics - stub for LogMessages, which are all events...

func (Nrevents) IsExcluded

func (n Nrevents) IsExcluded(
	logMessage string,
	logSource string,
) bool

IsExcluded ...

func (Nrevents) IsExcludedLogMessage

func (n Nrevents) IsExcludedLogMessage(
	logMessage string,
) bool

IsExcludedLogMessage determines if envelopes with this log message should be dropped.

func (Nrevents) IsExcludedLogSource

func (n Nrevents) IsExcludedLogSource(
	logSource string,
) bool

IsExcludedLogSource determines if envelopes with this log source should be dropped.

func (Nrevents) IsIncluded

func (n Nrevents) IsIncluded(
	logMessage string,
	logSource string,
) bool

IsIncluded ...

func (Nrevents) IsIncludedLogMessage

func (n Nrevents) IsIncludedLogMessage(
	logMessage string,
) bool

IsIncludedLogMessage determines if envelopes with this log message should be included.

func (Nrevents) IsIncludedLogSource

func (n Nrevents) IsIncludedLogSource(
	logSource string,
) bool

IsIncludedLogSource determines if envelopes with this log source should be included.

func (Nrevents) New

func (n Nrevents) New() accumulators.Interface

New satisfies event.Accumulator

func (Nrevents) Update

func (n Nrevents) Update(e *loggregator_v2.Envelope)

Update satisfies event.Accumulator func (n Nrevents) Update(e *events.Envelope) {