Skip to content
Permalink
Browse files

minor corrections

  • Loading branch information...
dtregonning committed Aug 10, 2017
1 parent c91917a commit 04fc0342f9e4beabe3297c0b2219fe086f54f4b0
Showing with 3 additions and 3 deletions.
  1. +1 −1 eventsink/splunk.go
  2. +1 −1 nozzle/nozzle.go
  3. +1 −1 splunknozzle/nozzle.go
@@ -165,7 +165,7 @@ func (s *Splunk) buildEvent(fields map[string]interface{}) map[string]interface{
if s.config.Version >= SPLUNK_HEC_FIELDS_SUPPORT_VERSION {
event["fields"] = extraFields
} else {
fields["pcf-metadata"] = extraFields
fields["pcf-extra"] = extraFields
}
event["event"] = fields
return event
@@ -24,7 +24,6 @@ type Nozzle struct {
}

func New(eventSource eventsource.Source, eventRouter eventrouter.Router, config *Config) *Nozzle {

return &Nozzle{
eventRouter: eventRouter,
eventSource: eventSource,
@@ -51,6 +50,7 @@ func (f *Nozzle) Start() error {
f.config.Logger.Info("Give up after retries. Firehose consumer is going to exit")
return lastErr
}

if err := f.eventRouter.Route(event); err != nil {
f.config.Logger.Error("Failed to route event", err)
}
@@ -137,7 +137,7 @@ func (s *SplunkFirehoseNozzle) Run(shutdownChan chan os.Signal, logger lager.Log
return err
}

logger.Info("Running splunk-firehose-nozzle with following environment variables ", s.config.ToMap())
logger.Info("Running splunk-firehose-nozzle with following configuration variables ", s.config.ToMap())

pcfClient, err := s.PCFClient()
if err != nil {

0 comments on commit 04fc034

Please sign in to comment.
You can’t perform that action at this time.