shippers

Documentation

Index

• Variables
• type CFAuditEventsToSplunkShipper
  • func NewCFAuditEventsToSplunkShipper(schedule time.Duration, logger lager.Logger, eventDB db.EventDB, ...) *CFAuditEventsToSplunkShipper
  • func (s *CFAuditEventsToSplunkShipper) Run(ctx context.Context) error

Variables

var (
	CFAuditEventsToSplunkShipperErrorsTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "cf_audit_events_to_splunk_shipper_errors_total",
		Help: "Number of errors encountered by CF Audit Events to Splunk shipper",
	})

	CFAuditEventsToSplunkShipperEventsShippedTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "cf_audit_events_to_splunk_shipper_events_shipped_total",
		Help: "Number of CF audit events shipped to Splunk by CF Audit Events to Splunk shipper",
	})

	CFAuditEventsToSplunkShipperLatestEventTimestamp = prometheus.NewGauge(prometheus.GaugeOpts{
		Name: "cf_audit_events_to_splunk_shipper_latest_event_timestamp",
		Help: "Unix epoch seconds of most recent event shipped to Splunk",
	})

	CFAuditEventsToSplunkShipperShipDurationTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "cf_audit_events_to_splunk_shipper_ship_duration_total",
		Help: "Number of seconds spent shipping events by CF Audit Events to Splunk Shipper",
	})
)

Types

type CFAuditEventsToSplunkShipper

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

func NewCFAuditEventsToSplunkShipper

func NewCFAuditEventsToSplunkShipper(
	schedule time.Duration,
	logger lager.Logger,
	eventDB db.EventDB,
	deployEnv string,
	splunkAPIKey string,
	splunkURL string,
) *CFAuditEventsToSplunkShipper

func (*CFAuditEventsToSplunkShipper) Run

func (s *CFAuditEventsToSplunkShipper) Run(ctx context.Context) error