kafkarest

Documentation

Index

• Constants
• func NewParser(c conf.MapConf) (parser.Parser, error)
• type Parser
  • func (krp *Parser) Name() string
  • func (krp *Parser) Parse(lines []string) ([]Data, error)
  • func (krp *Parser) ParseCode(fields []string) int
  • func (krp *Parser) ParseDuration(fields []string) int
  • func (krp *Parser) ParseIp(fields []string) string
  • func (krp *Parser) ParseLogTime(fields []string) int64
  • func (krp *Parser) ParseMethod(fields []string) string
  • func (krp *Parser) ParseRespCL(fields []string) int
  • func (krp *Parser) ParseTopic(fields []string) string
  • func (krp *Parser) Type() string

Constants

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 = ""
)

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