syslog

Documentation

Index

• Constants
• type KentikSyslog
  • func NewSyslogSource(ctx context.Context, log logger.Underlying, logchan chan string, ...) (*KentikSyslog, error)
  • func (ks *KentikSyslog) Close()
  • func (ks *KentikSyslog) HttpInfo() map[string]float64
• type SyslogMetric

Constants

const (
	CHAN_SLACK           = 10000
	DeviceUpdateDuration = 1 * time.Hour
	InstNameSyslog       = "ktranslate-syslog"
	ErrorCheckDuration   = 1 * time.Minute
)

Types

type KentikSyslog

type KentikSyslog struct {
	logger.ContextL
	// contains filtered or unexported fields
}

func NewSyslogSource

func NewSyslogSource(ctx context.Context, log logger.Underlying, logchan chan string, registry go_metrics.Registry, apic *api.KentikApi, resolver *resolv.Resolver, cfg *ktranslate.SyslogInputConfig) (*KentikSyslog, error)

func (*KentikSyslog) Close

func (ks *KentikSyslog) Close()

func (*KentikSyslog) HttpInfo

func (ks *KentikSyslog) HttpInfo() map[string]float64

type SyslogMetric

type SyslogMetric struct {
	Messages go_metrics.Meter
	Errors   go_metrics.Meter
	Queue    go_metrics.Gauge
}