Versions in this module Expand all Collapse all v1 v1.4.0 Dec 8, 2017 Changes in this version + const RFC3339Milli + func Debug(l Logger, msg string, ctx []keyvalue.T) + func Err(l Logger, msg string, err error, ctx []keyvalue.T) + func Info(l Logger, msg string, ctx []keyvalue.T) + type AlertServiceHandler struct + L Logger + func (h *AlertServiceHandler) CreatingNewHandlers(length int) + func (h *AlertServiceHandler) Error(msg string, err error, ctx ...keyvalue.T) + func (h *AlertServiceHandler) FoundHandlerRows(length int) + func (h *AlertServiceHandler) FoundNewHandler(key string) + func (h *AlertServiceHandler) MigratingHandlerSpecs() + func (h *AlertServiceHandler) MigratingOldHandlerSpec(spec string) + func (h *AlertServiceHandler) WithHandlerContext(ctx ...keyvalue.T) alertservice.HandlerDiagnostic + type AlertaHandler struct + func (h *AlertaHandler) Error(msg string, err error) + func (h *AlertaHandler) TemplateError(err error, kv keyvalue.T) + func (h *AlertaHandler) WithContext(ctx ...keyvalue.T) alerta.Diagnostic + type BoolField struct + func (s BoolField) Match(key, value string) bool + func (s BoolField) WriteJSONTo(w Writer) (n int64, err error) + func (s BoolField) WriteLogfmtTo(w Writer) (n int64, err error) + type CmdHandler struct + func BootstrapMainHandler() *CmdHandler + func (h *CmdHandler) Error(msg string, err error) + func (h *CmdHandler) GoVersion() + func (h *CmdHandler) Info(msg string) + func (h *CmdHandler) KapacitorStarting(version, branch, commit string) + type Config struct + File string + Level string + func NewConfig() Config + type ConfigOverrideHandler struct + func (h *ConfigOverrideHandler) Error(msg string, err error) + type DeadmanHandler struct + func (h *DeadmanHandler) ConfiguredGlobally() + type Diagnostic interface + CreatedLogSession func(id uuid.UUID, contentType string, tags []tag) + DeletedLogSession func(id uuid.UUID, contentType string, tags []tag) + type DurationField struct + func (s DurationField) Match(key, value string) bool + func (s DurationField) WriteJSONTo(w Writer) (n int64, err error) + func (s DurationField) WriteLogfmtTo(w Writer) (n int64, err error) + type EC2Handler struct + func (h *EC2Handler) WithClusterContext(cluster string) ec2.Diagnostic + type EdgeHandler struct + func (h *EdgeHandler) Collect(mtype edge.MessageType) + func (h *EdgeHandler) Emit(mtype edge.MessageType) + type ErrorField struct + func (s ErrorField) Match(key, value string) bool + func (s ErrorField) WriteJSONTo(w Writer) (n int64, err error) + func (s ErrorField) WriteLogfmtTo(w Writer) (n int64, err error) + type Field interface + Match func(key, value string) bool + WriteJSONTo func(w Writer) (n int64, err error) + WriteLogfmtTo func(w Writer) (n int64, err error) + func Bool(key string, value bool) Field + func Duration(key string, value time.Duration) Field + func Error(err error) Field + func FieldPairs(tags models.Fields) []Field + func Float64(key string, value float64) Field + func GroupedFields(key string, fields []Field) Field + func Int(key string, value int) Field + func Int64(key string, value int64) Field + func String(key string, value string) Field + func Stringer(key string, value fmt.Stringer) Field + func Strings(key string, values []string) Field + func TagPairs(tags models.Tags) []Field + func Time(key string, value time.Time) Field + type Float64Field struct + func (s Float64Field) Match(key, value string) bool + func (s Float64Field) WriteJSONTo(w Writer) (n int64, err error) + func (s Float64Field) WriteLogfmtTo(w Writer) (n int64, err error) + type GroupedField struct + func (s GroupedField) Match(key, value string) bool + func (s GroupedField) WriteJSONTo(w Writer) (n int64, err error) + func (s GroupedField) WriteLogfmtTo(w Writer) (n int64, err error) + type HTTPDHandler struct + func (h *HTTPDHandler) AuthenticationEnabled(enabled bool) + func (h *HTTPDHandler) Error(msg string, err error) + func (h *HTTPDHandler) HTTP(host string, username string, start time.Time, method string, uri string, ...) + func (h *HTTPDHandler) ListeningOn(addr string, proto string) + func (h *HTTPDHandler) NewHTTPServerErrorLogger() *log.Logger + func (h *HTTPDHandler) RecoveryError(msg string, err string, host string, username string, start time.Time, ...) + func (h *HTTPDHandler) ShutdownTimeout() + func (h *HTTPDHandler) StartingService() + func (h *HTTPDHandler) StoppedService() + func (h *HTTPDHandler) WriteBodyReceived(body string) + type HTTPPostHandler struct + func (h *HTTPPostHandler) Error(msg string, err error, ctx ...keyvalue.T) + func (h *HTTPPostHandler) WithContext(ctx ...keyvalue.T) httppost.Diagnostic + type HipChatHandler struct + func (h *HipChatHandler) Error(msg string, err error) + func (h *HipChatHandler) WithContext(ctx ...keyvalue.T) hipchat.Diagnostic + type InfluxDBHandler struct + func (h *InfluxDBHandler) Error(msg string, err error, ctx ...keyvalue.T) + func (h *InfluxDBHandler) InsecureSkipVerify(urls []string) + func (h *InfluxDBHandler) LinkingSubscriptions(cluster string) + func (h *InfluxDBHandler) StartedUDPListener(db string, rp string) + func (h *InfluxDBHandler) UnlinkingSubscriptions(cluster string) + func (h *InfluxDBHandler) WithClusterContext(id string) influxdb.Diagnostic + func (h *InfluxDBHandler) WithUDPContext(db string, rp string) udp.Diagnostic + type Int64Field struct + func (s Int64Field) Match(key, value string) bool + func (s Int64Field) WriteJSONTo(w Writer) (n int64, err error) + func (s Int64Field) WriteLogfmtTo(w Writer) (n int64, err error) + type IntField struct + func (s IntField) Match(key, value string) bool + func (s IntField) WriteJSONTo(w Writer) (n int64, err error) + func (s IntField) WriteLogfmtTo(w Writer) (n int64, err error) + type K8sHandler struct + func (h *K8sHandler) WithClusterContext(cluster string) k8s.Diagnostic + type KapacitorHandler struct + func (h *KapacitorHandler) AlertTriggered(level alert.Level, id string, message string, rows *models.Row) + func (h *KapacitorHandler) ClosingEdge(collected int64, emitted int64) + func (h *KapacitorHandler) Error(msg string, err error, ctx ...keyvalue.T) + func (h *KapacitorHandler) LogBatchData(level, prefix string, batch edge.BufferedBatchMessage) + func (h *KapacitorHandler) LogPointData(level, prefix string, point edge.PointMessage) + func (h *KapacitorHandler) SettingReplicas(new int, old int, id string) + func (h *KapacitorHandler) StartedTask(task string) + func (h *KapacitorHandler) StartingBatchQuery(q string) + func (h *KapacitorHandler) StartingTask(task string) + func (h *KapacitorHandler) StoppedTask(task string) + func (h *KapacitorHandler) StoppedTaskWithError(task string, err error) + func (h *KapacitorHandler) TaskMasterClosed() + func (h *KapacitorHandler) TaskMasterDot(d string) + func (h *KapacitorHandler) TaskMasterOpened() + func (h *KapacitorHandler) UDFLog(s string) + func (h *KapacitorHandler) WithEdgeContext(task, parent, child string) kapacitor.EdgeDiagnostic + func (h *KapacitorHandler) WithNodeContext(node string) kapacitor.NodeDiagnostic + func (h *KapacitorHandler) WithTaskContext(task string) kapacitor.TaskDiagnostic + func (h *KapacitorHandler) WithTaskMasterContext(tm string) kapacitor.Diagnostic + type Level int + const DebugLevel + const ErrorLevel + const InfoLevel + type LoadHandler struct + func (h *LoadHandler) Debug(msg string) + func (h *LoadHandler) Error(msg string, err error) + func (h *LoadHandler) Loading(el string, file string) + type Logger interface + Debug func(msg string, ctx ...Field) + Error func(msg string, ctx ...Field) + Info func(msg string, ctx ...Field) + With func(ctx ...Field) Logger + type MQTTHandler struct + func (h *MQTTHandler) CreatingAlertHandler(c mqtt.HandlerConfig) + func (h *MQTTHandler) Error(msg string, err error) + func (h *MQTTHandler) HandlingEvent() + func (h *MQTTHandler) WithContext(ctx ...keyvalue.T) mqtt.Diagnostic + type MultiLogger struct + func NewMultiLogger(loggers ...Logger) *MultiLogger + func (l *MultiLogger) Debug(msg string, ctx ...Field) + func (l *MultiLogger) Error(msg string, ctx ...Field) + func (l *MultiLogger) Info(msg string, ctx ...Field) + func (l *MultiLogger) With(ctx ...Field) Logger + type NoAuthHandler struct + func (h *NoAuthHandler) FakedSubscriptionUserToken() + func (h *NoAuthHandler) FakedUserAuthentication(username string) + type OpsGenieHandler struct + func (h *OpsGenieHandler) Error(msg string, err error) + func (h *OpsGenieHandler) WithContext(ctx ...keyvalue.T) opsgenie.Diagnostic + type PagerDutyHandler struct + func (h *PagerDutyHandler) Error(msg string, err error) + func (h *PagerDutyHandler) WithContext(ctx ...keyvalue.T) pagerduty.Diagnostic + type PushoverHandler struct + func (h *PushoverHandler) Error(msg string, err error) + func (h *PushoverHandler) WithContext(ctx ...keyvalue.T) pushover.Diagnostic + type ReplayHandler struct + func (h *ReplayHandler) Debug(msg string, ctx ...keyvalue.T) + func (h *ReplayHandler) Error(msg string, err error, ctx ...keyvalue.T) + type ReportingHandler struct + func (h *ReportingHandler) Error(msg string, err error) + type SMTPHandler struct + func (h *SMTPHandler) Error(msg string, err error) + func (h *SMTPHandler) WithContext(ctx ...keyvalue.T) smtp.Diagnostic + type SNMPTrapHandler struct + func (h *SNMPTrapHandler) Error(msg string, err error) + func (h *SNMPTrapHandler) WithContext(ctx ...keyvalue.T) snmptrap.Diagnostic + type ScraperHandler struct + func (h *ScraperHandler) Debug(ctx ...interface{}) + func (h *ScraperHandler) Debugf(s string, ctx ...interface{}) + func (h *ScraperHandler) Debugln(ctx ...interface{}) + func (h *ScraperHandler) Error(ctx ...interface{}) + func (h *ScraperHandler) Errorf(s string, ctx ...interface{}) + func (h *ScraperHandler) Errorln(ctx ...interface{}) + func (h *ScraperHandler) Fatal(ctx ...interface{}) + func (h *ScraperHandler) Fatalf(s string, ctx ...interface{}) + func (h *ScraperHandler) Fatalln(ctx ...interface{}) + func (h *ScraperHandler) Info(ctx ...interface{}) + func (h *ScraperHandler) Infof(s string, ctx ...interface{}) + func (h *ScraperHandler) Infoln(ctx ...interface{}) + func (h *ScraperHandler) SetFormat(string) error + func (h *ScraperHandler) SetLevel(string) error + func (h *ScraperHandler) Warn(ctx ...interface{}) + func (h *ScraperHandler) Warnf(s string, ctx ...interface{}) + func (h *ScraperHandler) Warnln(ctx ...interface{}) + func (h *ScraperHandler) With(key string, value interface{}) plog.Logger + type SensuHandler struct + func (h *SensuHandler) Error(msg string, err error, ctx ...keyvalue.T) + func (h *SensuHandler) WithContext(ctx ...keyvalue.T) sensu.Diagnostic + type ServerHandler struct + func (h *ServerHandler) Debug(msg string, ctx ...keyvalue.T) + func (h *ServerHandler) Error(msg string, err error, ctx ...keyvalue.T) + func (h *ServerHandler) Info(msg string, ctx ...keyvalue.T) + type ServerLogger struct + func NewServerLogger(w io.Writer) *ServerLogger + func (l *ServerLogger) Debug(msg string, ctx ...Field) + func (l *ServerLogger) Error(msg string, ctx ...Field) + func (l *ServerLogger) Info(msg string, ctx ...Field) + func (l *ServerLogger) Log(now time.Time, level string, msg string, ctx []Field) + func (l *ServerLogger) SetLevelF(f func(Level) bool) + func (l *ServerLogger) With(ctx ...Field) Logger + type Service struct + Logger Logger + SessionService *SessionService + func NewService(c Config, stdout, stderr io.Writer) *Service + func (s *Service) Close() error + func (s *Service) NewAlertServiceHandler() *AlertServiceHandler + func (s *Service) NewAlertaHandler() *AlertaHandler + func (s *Service) NewAzureHandler() *ScraperHandler + func (s *Service) NewCmdHandler() *CmdHandler + func (s *Service) NewConfigOverrideHandler() *ConfigOverrideHandler + func (s *Service) NewConsulHandler() *ScraperHandler + func (s *Service) NewDNSHandler() *ScraperHandler + func (s *Service) NewDeadmanHandler() *DeadmanHandler + func (s *Service) NewEC2Handler() *EC2Handler + func (s *Service) NewFileDiscoveryHandler() *ScraperHandler + func (s *Service) NewGCEHandler() *ScraperHandler + func (s *Service) NewHTTPDHandler() *HTTPDHandler + func (s *Service) NewHTTPPostHandler() *HTTPPostHandler + func (s *Service) NewHipChatHandler() *HipChatHandler + func (s *Service) NewInfluxDBHandler() *InfluxDBHandler + func (s *Service) NewK8sHandler() *K8sHandler + func (s *Service) NewKapacitorHandler() *KapacitorHandler + func (s *Service) NewLoadHandler() *LoadHandler + func (s *Service) NewMQTTHandler() *MQTTHandler + func (s *Service) NewMarathonHandler() *ScraperHandler + func (s *Service) NewNerveHandler() *ScraperHandler + func (s *Service) NewNoAuthHandler() *NoAuthHandler + func (s *Service) NewOpsGenieHandler() *OpsGenieHandler + func (s *Service) NewPagerDutyHandler() *PagerDutyHandler + func (s *Service) NewPushoverHandler() *PushoverHandler + func (s *Service) NewReplayHandler() *ReplayHandler + func (s *Service) NewReportingHandler() *ReportingHandler + func (s *Service) NewSMTPHandler() *SMTPHandler + func (s *Service) NewSNMPTrapHandler() *SNMPTrapHandler + func (s *Service) NewScraperHandler() *ScraperHandler + func (s *Service) NewSensuHandler() *SensuHandler + func (s *Service) NewServerHandler() *ServerHandler + func (s *Service) NewServersetHandler() *ScraperHandler + func (s *Service) NewSessionHandler() *SessionHandler + func (s *Service) NewSideloadHandler() *SideloadHandler + func (s *Service) NewSlackHandler() *SlackHandler + func (s *Service) NewStaticDiscoveryHandler() *ScraperHandler + func (s *Service) NewStaticLevelHandler(level string, service string) (*StaticLevelHandler, error) + func (s *Service) NewStatsHandler() *StatsHandler + func (s *Service) NewStorageHandler() *StorageHandler + func (s *Service) NewSwarmHandler() *SwarmHandler + func (s *Service) NewTalkHandler() *TalkHandler + func (s *Service) NewTaskStoreHandler() *TaskStoreHandler + func (s *Service) NewTelegramHandler() *TelegramHandler + func (s *Service) NewTritonHandler() *ScraperHandler + func (s *Service) NewUDFServiceHandler() *UDFServiceHandler + func (s *Service) NewUDPHandler() *UDPHandler + func (s *Service) NewVictorOpsHandler() *VictorOpsHandler + func (s *Service) Open() error + func (s *Service) SetLogLevelFromName(lvl string) error + type Session struct + func (s *Session) Debug(msg string, context, fields []Field) + func (s *Session) Error(msg string, context, fields []Field) + func (s *Session) Info(msg string, context, fields []Field) + func (s *Session) Log(now time.Time, level, msg string, context, fields []Field) + type SessionHandler struct + func (h *SessionHandler) CreatedLogSession(id uuid.UUID, contentType string, tags []tag) + func (h *SessionHandler) DeletedLogSession(id uuid.UUID, contentType string, tags []tag) + type SessionService struct + HTTPDService interface{ ... } + SessionsStore SessionsStore + func NewSessionService() *SessionService + func (s *SessionService) Close() error + func (s *SessionService) NewLogger() *sessionsLogger + func (s *SessionService) Open() error + func (s *SessionService) SetDiagnostic(d Diagnostic) + type SessionsStore interface + Create func(w http.ResponseWriter, contentType string, level Level, tags []tag) *Session + Delete func(s *Session) error + Each func(func(*Session)) + SetDiagnostic func(Diagnostic) + type SideloadHandler struct + func (h *SideloadHandler) Error(msg string, err error) + func (h *SideloadHandler) WithContext(ctx ...keyvalue.T) sideload.Diagnostic + type SlackHandler struct + func (h *SlackHandler) Error(msg string, err error) + func (h *SlackHandler) InsecureSkipVerify() + func (h *SlackHandler) WithContext(ctx ...keyvalue.T) slack.Diagnostic + type StaticLevelHandler struct + func (h *StaticLevelHandler) Write(buf []byte) (int, error) + type StatsHandler struct + func (h *StatsHandler) Error(msg string, err error) + type StorageHandler struct + func (h *StorageHandler) Error(msg string, err error) + type StringField struct + func (s StringField) Match(key, value string) bool + func (s StringField) WriteJSONTo(w Writer) (n int64, err error) + func (s StringField) WriteLogfmtTo(w Writer) (n int64, err error) + type StringerField struct + func (s StringerField) Match(key, value string) bool + func (s StringerField) WriteJSONTo(w Writer) (n int64, err error) + func (s StringerField) WriteLogfmtTo(w Writer) (n int64, err error) + type StringsField struct + func (s StringsField) Match(key, value string) bool + func (s StringsField) WriteJSONTo(w Writer) (n int64, err error) + func (s StringsField) WriteLogfmtTo(w Writer) (n int64, err error) + type SwarmHandler struct + func (h *SwarmHandler) WithClusterContext(cluster string) swarm.Diagnostic + type TalkHandler struct + func (h *TalkHandler) Error(msg string, err error) + func (h *TalkHandler) WithContext(ctx ...keyvalue.T) talk.Diagnostic + type TaskStoreHandler struct + func (h *TaskStoreHandler) AlreadyMigrated(entity, id string) + func (h *TaskStoreHandler) Debug(msg string) + func (h *TaskStoreHandler) Error(msg string, err error, ctx ...keyvalue.T) + func (h *TaskStoreHandler) FinishedTask(taskID string) + func (h *TaskStoreHandler) Migrated(entity, id string) + func (h *TaskStoreHandler) StartedTask(taskID string) + func (h *TaskStoreHandler) StartingTask(taskID string) + type TelegramHandler struct + func (h *TelegramHandler) Error(msg string, err error) + func (h *TelegramHandler) WithContext(ctx ...keyvalue.T) telegram.Diagnostic + type TimeField struct + func (s TimeField) Match(key, value string) bool + func (s TimeField) WriteJSONTo(w Writer) (n int64, err error) + func (s TimeField) WriteLogfmtTo(w Writer) (n int64, err error) + type UDFServiceHandler struct + func (h *UDFServiceHandler) Error(msg string, err error, ctx ...keyvalue.T) + func (h *UDFServiceHandler) LoadedUDFInfo(udf string) + func (h *UDFServiceHandler) UDFLog(msg string) + func (h *UDFServiceHandler) WithUDFContext() udf.Diagnostic + type UDPHandler struct + func (h *UDPHandler) ClosedService() + func (h *UDPHandler) Error(msg string, err error, ctx ...keyvalue.T) + func (h *UDPHandler) StartedListening(addr string) + type VictorOpsHandler struct + func (h *VictorOpsHandler) Error(msg string, err error) + func (h *VictorOpsHandler) WithContext(ctx ...keyvalue.T) victorops.Diagnostic + type WriteFlusher interface + Flush func() + Write func([]byte) (int, error) + type Writer interface + Write func([]byte) (int, error) + WriteByte func(byte) error + WriteString func(string) (int, error) v1.4.0-rc3 Dec 4, 2017 v1.4.0-rc2 Nov 28, 2017 v1.4.0-rc1 Nov 9, 2017
Go to main page