pandora

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: 24 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SendTypeRaw    = "raw"
	SendTypeNormal = "normal"
)
View Source
const (
	PandoraTypeLong       = "long"
	PandoraTypeFloat      = "float"
	PandoraTypeString     = "string"
	PandoraTypeDate       = "date"
	PandoraTypeBool       = "boolean"
	PandoraTypeArray      = "array"
	PandoraTypeMap        = "map"
	PandoraTypeJsonString = "jsonstring"
)

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

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