pandora

Documentation

Index

• Constants
• func NewSender(conf logkitconf.MapConf) (pandoraSender sender.Sender, err error)
• type PandoraOption
• type Sender
  • func (s *Sender) Close() error
  • func (s *Sender) Name() string
  • func (s *Sender) Send(datas []Data) (se error)
  • func (s *Sender) TokenRefresh(mapConf logkitconf.MapConf) error
  • func (s *Sender) UpdateSchemas() error
• type Tokens
• type UserSchema

Constants

const (
	SendTypeRaw    = "raw"
	SendTypeNormal = "normal"
)

const (
	PandoraTypeLong       = "long"
	PandoraTypeFloat      = "float"
	PandoraTypeString     = "string"
	PandoraTypeDate       = "date"
	PandoraTypeBool       = "boolean"
	PandoraTypeArray      = "array"
	PandoraTypeMap        = "map"
	PandoraTypeJsonString = "jsonstring"
)

Functions

func NewSender

func NewSender(conf logkitconf.MapConf) (pandoraSender sender.Sender, err error)

pandora sender

Types

type PandoraOption

type PandoraOption struct {
	UnescapeLine bool
	// contains filtered or unexported fields
}

PandoraOption 创建Pandora Sender的选项

type Sender

type Sender struct {
	UserSchema UserSchema
	// contains filtered or unexported fields
}

pandora sender

func (*Sender) Close

func (s *Sender) Close() error

func (*Sender) Name

func (s *Sender) Name() string

func (*Sender) Send

func (s *Sender) Send(datas []Data) (se error)

func (*Sender) TokenRefresh

func (s *Sender) TokenRefresh(mapConf logkitconf.MapConf) error

func (*Sender) UpdateSchemas

func (s *Sender) UpdateSchemas() error

type Tokens

type Tokens struct {
	LogDBTokens      pipeline.AutoExportLogDBTokens
	TsDBTokens       pipeline.AutoExportTSDBTokens
	KodoTokens       pipeline.AutoExportKodoTokens
	SchemaFreeTokens pipeline.SchemaFreeToken
}

type UserSchema

type UserSchema struct {
	DefaultAll bool
	Fields     map[string]string
}

UserSchema was parsed pandora schema from user's raw schema