kafkarest

package
v1.5.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 18, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	KEY_SRC_IP   = "source_ip"
	KEY_METHOD   = "method"
	KEY_TOPIC    = "topic"
	KEY_CODE     = "code"
	KEY_RESP_LEN = "resp_len"
	KEY_DURATION = "duration"
	KEY_LOG_TIME = "log_time"
	KEY_ERROR    = "error"
	KEY_WARN     = "warn"
	EMPTY_STRING = ""
)

Variables

This section is empty.

Functions

func NewParser

func NewParser(c conf.MapConf) (parser.Parser, error)

Types

type Parser

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

func (*Parser) Name

func (krp *Parser) Name() string

func (*Parser) Parse

func (krp *Parser) Parse(lines []string) ([]Data, error)

func (*Parser) ParseCode

func (krp *Parser) ParseCode(fields []string) int

func (*Parser) ParseDuration

func (krp *Parser) ParseDuration(fields []string) int

func (*Parser) ParseIp

func (krp *Parser) ParseIp(fields []string) string

func (*Parser) ParseLogTime

func (krp *Parser) ParseLogTime(fields []string) int64

func (*Parser) ParseMethod

func (krp *Parser) ParseMethod(fields []string) string

func (*Parser) ParseRespCL

func (krp *Parser) ParseRespCL(fields []string) int

func (*Parser) ParseTopic

func (krp *Parser) ParseTopic(fields []string) string

func (*Parser) Type

func (krp *Parser) Type() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL