processors

README

Processors

Processors are responsible for handling incoming connections.

Processors include routers. They proxy requests to backend implementations. They also audit the request in parallel(or in a synchronized way).

Documentation

Index

• type ConnectionProcessor
• type DataProcessor
• type LogEvent
  • func (e *LogEvent) String() string

Types

type ConnectionProcessor

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

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

type LogEvent

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"`
}

func (*LogEvent) String

func (e *LogEvent) String() string