Documentation ¶
Index ¶
- type Config
- type SplunkFirehoseNozzle
- func (s *SplunkFirehoseNozzle) AppCache(client cache.AppClient) (cache.Cache, error)
- func (s *SplunkFirehoseNozzle) EventRouter(cache cache.Cache, eventSink eventsink.Sink) (eventrouter.Router, error)
- func (s *SplunkFirehoseNozzle) EventSink(cache cache.Cache) (eventsink.Sink, error)
- func (s *SplunkFirehoseNozzle) EventSource(pcfClient *cfclient.Client) *eventsource.Firehose
- func (s *SplunkFirehoseNozzle) Metric() monitoring.Monitor
- func (s *SplunkFirehoseNozzle) Nozzle(eventSource eventsource.Source, eventRouter eventrouter.Router) *nozzle.Nozzle
- func (s *SplunkFirehoseNozzle) PCFClient() (*cfclient.Client, error)
- func (s *SplunkFirehoseNozzle) Run(shutdownChan chan os.Signal) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { ApiEndpoint string `json:"api-endpoint"` User string `json:"-"` Password string `json:"-"` ClientID string `json:"-"` ClientSecret string `json:"-"` SplunkToken string `json:"-"` SplunkHost string `json:"splunk-host"` SplunkIndex string `json:"splunk-index"` SplunkLoggingIndex string `json:"splunk-logging-index"` JobHost string `json:"job-host"` SkipSSLCF bool `json:"skip-ssl-cf"` SkipSSLSplunk bool `json:"skip-ssl-splunk"` SubscriptionID string `json:"subscription-id"` KeepAlive time.Duration `json:"keep-alive"` AddAppInfo string `json:"add-app-info"` IgnoreMissingApps bool `json:"ignore-missing-apps"` MissingAppCacheTTL time.Duration `json:"missing-app-cache-ttl"` AppCacheTTL time.Duration `json:"app-cache-ttl"` OrgSpaceCacheTTL time.Duration `json:"org-space-cache-ttl"` AppLimits int `json:"app-limits"` AddTags bool `json:"add-tags"` BoltDBPath string `json:"boltdb-path"` WantedEvents string `json:"wanted-events"` ExtraFields string `json:"extra-fields"` FlushInterval time.Duration `json:"flush-interval"` QueueSize int `json:"queue-size"` BatchSize int `json:"batch-size"` Retries int `json:"retries"` HecWorkers int `json:"hec-workers"` RefreshSplunkConnection bool `json:"refresh-splunk-connection"` KeepAliveTimer time.Duration `json:"keep-alive-timer"` Version string `json:"version"` Branch string `json:"branch"` Commit string `json:"commit"` BuildOS string `json:"buildos"` TraceLogging bool `json:"trace-logging"` Debug bool `json:"debug"` StatusMonitorInterval time.Duration `json:"mem-queue-monitor-interval"` SelectedMonitoringMetrics string `json:"selected-monitoring-metrics"` SplunkMetricIndex string `json:"splunk-metric-index"` }
func NewConfigFromCmdFlags ¶
type SplunkFirehoseNozzle ¶
type SplunkFirehoseNozzle struct {
// contains filtered or unexported fields
}
func NewSplunkFirehoseNozzle ¶
func NewSplunkFirehoseNozzle(config *Config, logger lager.Logger) *SplunkFirehoseNozzle
create new function of type *SplunkFirehoseNozzle
func (*SplunkFirehoseNozzle) EventRouter ¶
func (s *SplunkFirehoseNozzle) EventRouter(cache cache.Cache, eventSink eventsink.Sink) (eventrouter.Router, error)
EventRouter creates EventRouter object and setup routes for interested events
func (*SplunkFirehoseNozzle) EventSource ¶
func (s *SplunkFirehoseNozzle) EventSource(pcfClient *cfclient.Client) *eventsource.Firehose
EventSource creates eventsource.Source object which can read events from
func (*SplunkFirehoseNozzle) Metric ¶ added in v1.3.0
func (s *SplunkFirehoseNozzle) Metric() monitoring.Monitor
func (*SplunkFirehoseNozzle) Nozzle ¶
func (s *SplunkFirehoseNozzle) Nozzle(eventSource eventsource.Source, eventRouter eventrouter.Router) *nozzle.Nozzle
Nozzle creates a Nozzle object which glues the event source and event router
Click to show internal directories.
Click to hide internal directories.