consumer

Documentation

Index

• Constants
• type FlumeWatcher
  • func (self *FlumeWatcher) BusinessWatcher(business string, eventType config.ZkEvent)
  • func (self *FlumeWatcher) ChildWatcher(business string, childNode []config.HostPort)
• type SourceManager
  • func NewSourceManager(instancename string, option *config.Option) *SourceManager
  • func (self *SourceManager) Close()
  • func (self *SourceManager) Start()
• type SourceServer

Constants

const (
	MAX_THRIFT_PACKET_SIZE = 12 * 1024 * 1024
)

Types

type FlumeWatcher

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

func (*FlumeWatcher) BusinessWatcher

func (self *FlumeWatcher) BusinessWatcher(business string, eventType config.ZkEvent)

func (*FlumeWatcher) ChildWatcher

func (self *FlumeWatcher) ChildWatcher(business string, childNode []config.HostPort)

type SourceManager

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

func NewSourceManager

func NewSourceManager(instancename string, option *config.Option) *SourceManager

func (*SourceManager) Close

func (self *SourceManager) Close()

func (*SourceManager) Start

func (self *SourceManager) Start()

type SourceServer

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

用于向flume中作为sink 通过thrift客户端写入日志