processors

type ConnectionProcessor interface {
	// handleConnection reads the connection and extract the incoming message
	// note that this may be a long connection so take care of the connection reuse.
	ProcessConnection(conn net.Conn) error
	// Do not return until ready
	Start()
	Stop()
}

type DataProcessor interface {
	ParseCommand(bytes []byte) ([]*LogEvent, error)
}

type LogEvent struct {
	Identity   string      `json:"identity"`
	Type       string      `json:"type"`
	Ip         string      `json:"ip"`
	PrimaryKey string      `json:"primary_key"`
	Timestamp  int64       `json:"timestamp"`
	Data       interface{} `json:"data"`
	Before     string      `json:"before"`
	After      string      `json:"after"`
}