decoder

Documentation

Index

• type Decoder
  • func GetDecoder(format string) (Decoder, error)
  • func GetDecoderWithOptions(format string, option Option) (Decoder, error)
• type Option

Types

type Decoder

type Decoder interface {
	// Decode reader to logs
	Decode(data []byte, req *http.Request, tags map[string]string) (logs []*protocol.Log, err error)
	// DecodeV2 reader to groupEvents
	DecodeV2(data []byte, req *http.Request) (groups []*models.PipelineGroupEvents, err error)
	// ParseRequst gets the request's body raw data and status code.
	ParseRequest(res http.ResponseWriter, req *http.Request, maxBodySize int64) (data []byte, statusCode int, err error)
}

Decoder used to parse buffer to sls logs

func GetDecoder

func GetDecoder(format string) (Decoder, error)

GetDecoder return a new decoder for specific format

func GetDecoderWithOptions

func GetDecoderWithOptions(format string, option Option) (Decoder, error)

type Option

type Option struct {
	FieldsExtend      bool
	DisableUncompress bool
}