plugin

Documentation

Index

• Constants
• func ParseEnsembleFile(path string) ([]zkserver, error)
• type EventFilterConfig
• type LogTailPlugin
• type ZooKeeperEventParser
  • func NewZooKeeperEventParser(idprefix string, ensemble []zkserver, config *dt.FieldFilterTreeConfig) (*ZooKeeperEventParser, error)
  • func (self *ZooKeeperEventParser) ParseLine(line string) *dt.Event
• type ZooKeeperPlugin
  • func (self *ZooKeeperPlugin) Init() error
  • func (self *ZooKeeperPlugin) ProvideEventParser() dt.EventParser
  • func (self *ZooKeeperPlugin) ProvideFlags() *flag.FlagSet
  • func (self *ZooKeeperPlugin) ProvideObserverModule() dt.ObserverModule
  • func (self *ZooKeeperPlugin) ValidateFlags() error

Constants

const (
	EID_PREFIX        = "peer@"
	CONF_ID_PREFIX    = "server."
	ZOOKEEPER_LINE_RE = `` /* 139-byte string literal not displayed */
	TAG_ID_RE         = `^(?P<context>[a-zA-Z_\.\$]+):(?P<id>\d+)$`
	TAG_HOST_RE       = `^(?P<context>[a-zA-Z_\.\-\$]+):?(?P<source>[^/]*)/(?P<host>[^:]+):(?P<port>\d+)$`
)

Functions

func ParseEnsembleFile

func ParseEnsembleFile(path string) ([]zkserver, error)

Types

type EventFilterConfig

type EventFilterConfig struct {
	TagContextPattern map[string]string
}

type LogTailPlugin

type LogTailPlugin interface {
	ProvideFlags() *flag.FlagSet
	ValidateFlags() error
	Init() error
	ProvideEventParser() dt.EventParser
	ProvideObserverModule() dt.ObserverModule
}

type ZooKeeperEventParser

type ZooKeeperEventParser struct {
	EntityIdPrefix string
	EIdAddrMap     map[string]string
	AddrEIdMap     map[string]string
	FilterTree     dt.FieldFilterTree
}

func NewZooKeeperEventParser

func NewZooKeeperEventParser(idprefix string, ensemble []zkserver, config *dt.FieldFilterTreeConfig) (*ZooKeeperEventParser, error)

func (*ZooKeeperEventParser) ParseLine

func (self *ZooKeeperEventParser) ParseLine(line string) *dt.Event

type ZooKeeperPlugin

type ZooKeeperPlugin struct {
	Ensemble     []zkserver
	MyId         string
	FilterConfig *dt.FieldFilterTreeConfig
	Parser       dt.EventParser
}

func (*ZooKeeperPlugin) Init

func (self *ZooKeeperPlugin) Init() error

func (*ZooKeeperPlugin) ProvideEventParser

func (self *ZooKeeperPlugin) ProvideEventParser() dt.EventParser

func (*ZooKeeperPlugin) ProvideFlags

func (self *ZooKeeperPlugin) ProvideFlags() *flag.FlagSet

func (*ZooKeeperPlugin) ProvideObserverModule

func (self *ZooKeeperPlugin) ProvideObserverModule() dt.ObserverModule

func (*ZooKeeperPlugin) ValidateFlags

func (self *ZooKeeperPlugin) ValidateFlags() error