logsend

type Configuration struct {
	WatchDir     string
	ReadWholeLog bool
	ReadAlway    bool
	SenderName   string

	IsPoll bool
	// contains filtered or unexported fields
}

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

type File struct {
	Tail *tail.Tail
	// contains filtered or unexported fields
}

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

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

type LogLine struct {
	Ts   int64
	Line []byte
}

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

type Sender interface {
	Send(*LogLine)
	Receive()
	SetConfig(interface{}) error
	Name() string
	Stop() error
}

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

type Worker struct {
	Id   int
	Name string
}