Documentation
¶
Index ¶
Constants ¶
View Source
const (
MAX_THRIFT_PACKET_SIZE = 12 * 1024 * 1024
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
type SourceManager ¶
type SourceManager struct {
// contains filtered or unexported fields
}
func NewSourceManager ¶
func (*SourceManager) Close ¶
func (self *SourceManager) Close()
func (*SourceManager) Start ¶
func (self *SourceManager) Start(ctx context.Context)
type SourceServer ¶
type SourceServer struct {
// contains filtered or unexported fields
}
用于向flume中作为sink 通过thrift客户端写入日志
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.