internal

type ConnectionHandler interface {
	Connect() error
	Connected() bool
	Close()
	SendData(lines string) error

	Flusher
}

type Flusher interface {
	Flush() error
	GetFailureCount() int64
	Start()
}

type LineHandler struct {
	Reporter      Reporter
	BatchSize     int
	MaxBufferSize int
	FlushTicker   *time.Ticker
	Format        string
	// contains filtered or unexported fields
}

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

type Reporter interface {
	Report(format string, pointLines string) (*http.Response, error)
	Server() string
}