processor

Documentation

Index

• Constants
• type FileLoggerService
  • func NewFileLoggerService(c types.FileLoggerConfig) (*FileLoggerService, error)
  • func (fl *FileLoggerService) Log(m LogtailMsg) error
• type ForwardingService
  • func NewForwardingService(addr string) *ForwardingService
  • func (fwd *ForwardingService) Forward(m []byte) error
• type HostInfo
• type HostInfoService
  • func (hs *HostInfoService) Process(msg LogtailMsg) error
• type LogProcessor
• type LogtailMsg
• type Metric
• type MetricType
• type MetricsService
  • func NewMetricsService() *MetricsService
  • func (ms *MetricsService) Process(msg LogtailMsg)
  • func (ms *MetricsService) PromHandler() http.Handler
• type MsgProcessor

Constants

const TailnodeCollection = "tailnode.log.tailscale.io"

const TailtrafficCollection = "tailtraffic.log.tailscale.io"

Types

type FileLoggerService

type FileLoggerService struct {
	BaseDir string
}

func NewFileLoggerService

func NewFileLoggerService(c types.FileLoggerConfig) (*FileLoggerService, error)

func (*FileLoggerService) Log

func (fl *FileLoggerService) Log(m LogtailMsg) error

type ForwardingService

type ForwardingService struct {
	Addr string
}

func NewForwardingService

func NewForwardingService(addr string) *ForwardingService

func (*ForwardingService) Forward

func (fwd *ForwardingService) Forward(m []byte) error

type HostInfo

type HostInfo struct {
	AppConnector    bool   `mapstructure:"AppConnector"`
	BackendLogID    string `mapstructure:"BackendLogID"`
	Container       bool   `mapstructure:"Container"`
	Desktop         bool   `mapstructure:"Desktop"`
	Distro          string `mapstructure:"Distro"`
	DistroVersion   string `mapstructure:"DistroVersion"`
	GoArch          string `mapstructure:"GoArch"`
	GoArchVar       string `mapstructure:"GoArchVar"`
	GoVersion       string `mapstructure:"GoVersion"`
	Hostname        string `mapstructure:"Hostname"`
	IPNVersion      string `mapstructure:"IPNVersion"`
	Machine         string `mapstructure:"Machine"`
	OS              string `mapstructure:"OS"`
	OSVersion       string `mapstructure:"OSVersion"`
	Userspace       bool   `mapstructure:"Userspace"`
	UserspaceRouter bool   `mapstructure:"UserspaceRouter"`
}

type HostInfoService

type HostInfoService struct {
}

func (*HostInfoService) Process

func (hs *HostInfoService) Process(msg LogtailMsg) error

type LogProcessor

type LogProcessor func([]byte)

type LogtailMsg

type LogtailMsg struct {
	Msg        map[string]interface{}
	Collection string
	PrivateID  string
}

type Metric

type Metric struct {
	Name   string
	WireID int
	Value  int
	Type   MetricType
}

type MetricType

type MetricType int64

const (
	Gauge MetricType = iota
	Counter
)

type MetricsService

type MetricsService struct {
	Registry           *prometheus.Registry
	Metrics            map[string]map[int]Metric
	GaugePromMetrics   map[string]*prometheus.GaugeVec
	CounterPromMetrics map[string]*prometheus.CounterVec
}

func NewMetricsService

func NewMetricsService() *MetricsService

func (*MetricsService) Process

func (ms *MetricsService) Process(msg LogtailMsg)

func (*MetricsService) PromHandler

func (ms *MetricsService) PromHandler() http.Handler

type MsgProcessor

type MsgProcessor func(LogtailMsg)