collectors

Documentation

Index

• Variables
• type CFAuditEventCollector
  • func NewCFAuditEventCollector(schedule time.Duration, logger lager.Logger, ...) *CFAuditEventCollector
  • func (c *CFAuditEventCollector) Run(ctx context.Context) error

Variables

var (
	CFAuditEventCollectorErrorsTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "cf_audit_event_collector_errors_total",
		Help: "Number of errors encountered by CF Audit Event Collector",
	})

	CFAuditEventCollectorEventsCollectedTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "cf_audit_event_collector_events_collected_total",
		Help: "Number of events collected and saved to the DB by CF Audit Event Collector",
	})

	CFAuditEventCollectorEventsCollectDurationTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "cf_audit_event_collector_collect_duration_total",
		Help: "Number of seconds spent collecting events by CF Audit Event Collector",
	})
)

Types

type CFAuditEventCollector

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

func NewCFAuditEventCollector

func NewCFAuditEventCollector(
	schedule time.Duration,
	logger lager.Logger,
	fetcher fetchers.CFAuditEventFetcher,
	eventDB db.EventDB,
) *CFAuditEventCollector

func (*CFAuditEventCollector) Run

func (c *CFAuditEventCollector) Run(ctx context.Context) error