tailer

Documentation

Index

• 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 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"`
}

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)