Method Send

worker/sink_handler.go:39–39

send in bulk to the sink

(messages []SinkMessage)

type Sink interface {
	// send in bulk to the sink
	Send(messages []SinkMessage) error
	// close sink
	Close() error
}