tailer

Documentation

Index

• type LTSVTailer
  • func NewLTSVTailer(file string) (*LTSVTailer, error)
  • func (t *LTSVTailer) Tail(ctx context.Context, data chan<- map[string]string)
• type NginxAccessItem
  • func NewNginxAccessItem(v map[string]string) (*NginxAccessItem, error)
• type PatternTailer
  • func NewPatternTailer(file string, patterns map[string]string) (*PatternTailer, error)
  • func (t *PatternTailer) Tail(ctx context.Context, data chan<- map[string]string)
• type Tailer
  • func NewTailer(file string) (*Tailer, error)
  • func (t *Tailer) Tail(ctx context.Context, data chan<- string)

Types

type LTSVTailer

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

func NewLTSVTailer

func NewLTSVTailer(file string) (*LTSVTailer, error)

func (*LTSVTailer) Tail

func (t *LTSVTailer) Tail(ctx context.Context, data chan<- map[string]string)

type NginxAccessItem

type NginxAccessItem struct {
	BodyBytesSent          string `mapstructure:"body_bytes_sent"`
	Status                 string `mapstructure:"status"`
	RemoteAddress          string `mapstructure:"remote_addr"`
	HTTPUserAgent          string `mapstructure:"http_user_agent"`
	Request                string `mapstructure:"request"`
	BytesSent              string `mapstructure:"bytes_sent"`
	RequestLength          string `mapstructure:"request_length"`
	RequestTime            string `mapstructure:"request_time"`
	GzipRatio              string `mapstructure:"gzip_ratio"`
	ServerProtocol         string `mapstructure:"server_protocol"`
	UpstreamConnectTime    string `mapstructure:"upstream_connect_time"`
	UpstreamHeaderTime     string `mapstructure:"upstream_header_time"`
	UpstreamResponseTime   string `mapstructure:"upstream_response_time"`
	UpstreamResponseLength string `mapstructure:"upstream_response_length"`
	UpstreamStatus         string `mapstructure:"upstream_status"`
	UpstreamCacheStatus    string `mapstructure:"upstream_cache_status"`
}

NginxAccessItem represents the decoded access log data

func NewNginxAccessItem

func NewNginxAccessItem(v map[string]string) (*NginxAccessItem, error)

type PatternTailer

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

func NewPatternTailer

func NewPatternTailer(file string, patterns map[string]string) (*PatternTailer, error)

func (*PatternTailer) Tail

func (t *PatternTailer) Tail(ctx context.Context, data chan<- map[string]string)

type Tailer

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

func NewTailer

func NewTailer(file string) (*Tailer, error)

func (*Tailer) Tail

func (t *Tailer) Tail(ctx context.Context, data chan<- string)