CreateMsgTable creates a msg table to store msgs.

NewMsgPipe creates a new msg pipe: - downstream: must be MsgPublisher or MsgAsyncPublisher.

NewMsgPublisher creates a publisher to publish (store) message to MySQL msg tables: - encoder: encoder for messages.

NewPbJsonPublisher creates a msg publisher using protobuf or json for encoding: - If msg is proto.Message, then use protobuf.

PipeOptLogger sets logger for MsgPipe.

PipeOptMaxInflight sets the max number of messages inflight (publishing).

PipeOptRetryWait sets the interval between retries due to all kinds of errors.

DefaultMaxInflight is the default value of PipeOptMaxInflight.

DefaultRetryWait is the default value of PipeOptRetryWait.

MsgPipe pipes messages from MySQL (>=8.0.2) msg tables to downstream.

MsgPipeOption is option in creating MsgPipe.

MsgTableFilter returns true if a given table is a msg table.