self

Documentation

Index

• Constants
• func GetParserConfig() conf.MapConf
• func GetReaderConfig() conf.MapConf
• func GetSenderConfig() conf.MapConf
• func SetReaderConfig(readConf conf.MapConf, logpath, filePattern, metapath, from string) conf.MapConf
• func SetSenderConfig(sendConf conf.MapConf, pandora Pandora) conf.MapConf
• type LogRunner
  • func NewLogRunner(rdConf, psConf, sdConf conf.MapConf, envTag string) (*LogRunner, error)
  • func NewLogRunnerWithService(rdConf, psConf, sdConf conf.MapConf, meta *reader.Meta, rd reader.Reader, ...) *LogRunner
  • func (lr *LogRunner) GetParserConfig() conf.MapConf
  • func (lr *LogRunner) GetReaderConfig() conf.MapConf
  • func (lr *LogRunner) GetSenderConfig() conf.MapConf
  • func (lr *LogRunner) GetTransformerConfig() conf.MapConf
  • func (lr *LogRunner) Name() string
  • func (lr *LogRunner) Run()
  • func (lr *LogRunner) Stop() error
  • func (lr *LogRunner) TokenRefresh(token AuthTokens) error

Constants

const (
	DefaultSendTime        = 3
	DefaultSelfLogRepoName = "logkit_self_log"
	DebugPattern           = `^\d{4}/\d{2}/\d{2} \d{2}:\d{2}:\d{2} \[DEBUG\]`
	ValidFilePattern       = "valid_file_pattern"
)

Functions

func GetParserConfig

func GetParserConfig() conf.MapConf

func GetReaderConfig

func GetReaderConfig() conf.MapConf

func GetSenderConfig

func GetSenderConfig() conf.MapConf

func SetReaderConfig

func SetReaderConfig(readConf conf.MapConf, logpath, filePattern, metapath, from string) conf.MapConf

func SetSenderConfig

func SetSenderConfig(sendConf conf.MapConf, pandora Pandora) conf.MapConf

Types

type LogRunner

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

func NewLogRunner

func NewLogRunner(rdConf, psConf, sdConf conf.MapConf, envTag string) (*LogRunner, error)

func NewLogRunnerWithService

func NewLogRunnerWithService(rdConf, psConf, sdConf conf.MapConf,
	meta *reader.Meta, rd reader.Reader, ps parser.Parser, sd sender.Sender, envTag string) *LogRunner

func (*LogRunner) GetParserConfig

func (lr *LogRunner) GetParserConfig() conf.MapConf

func (*LogRunner) GetReaderConfig

func (lr *LogRunner) GetReaderConfig() conf.MapConf

func (*LogRunner) GetSenderConfig

func (lr *LogRunner) GetSenderConfig() conf.MapConf

func (*LogRunner) GetTransformerConfig

func (lr *LogRunner) GetTransformerConfig() conf.MapConf

func (*LogRunner) Name

func (lr *LogRunner) Name() string

func (*LogRunner) Run

func (lr *LogRunner) Run()

func (*LogRunner) Stop

func (lr *LogRunner) Stop() error

func (*LogRunner) TokenRefresh

func (lr *LogRunner) TokenRefresh(token AuthTokens) error