EventTimeNow returns an EventTime set to time.Now().UTC().

GetChunk searches a marshaled message for the "chunk" option value and returns it.

NewCompressedPackedForwardMessage returns a PackedForwardMessage with a gzip-compressed byte stream.

NewCompressedPackedForwardMessageFromBytes returns a PackedForwardMessage with a gzip-compressed byte stream.

NewForwardMessage creates a ForwardMessage from the supplied tag, EntryList, and MessageOptions.

NewHelo returns a Helo message with the specified options.

NewMessage creates a Message from the supplied tag and record.

NewMessageExt creates a MessageExt from the supplied tag and record.

NewPackedForwardMessage creates a PackedForwardMessage from the supplied tag, EntryList, and MessageOptions.

NewPackedForwardMessageFromBytes creates a PackedForwardMessage from the supplied tag, bytes, and MessageOptions.

NewPing returns a PING message.

NewPingWithAuth returns a PING message containing the username and password to be used for authentication.

NewPong returns a PONG message.

ValidatePingDigest validates that the digest contained in the PING message is valid for the client hostname (as contained in the PING).

ValidatePongDigest validates that the digest contained in the PONG message is valid for the server hostname (as contained in the PONG).

msgp:ignore GzipCompressor.

EntryExt is the basic representation of an individual event.

EntryExt is the basic representation of an individual event, but using the msgpack extension format for the timestamp.

EventTime is the fluent-forward representation of a timestamp.

ForwardMessage is used in Forward mode to send multiple events in a single msgpack array within a single request.

msgp:ignore GzipCompressor.

Helo is the initial handshake message, sent by the server and received by the client.

Message is used to send a single event at a time msgp:tuple Messagemsgp:decode ignore Messagemsgp:unmarshal ignore Messagemsgp:size ignore Messagemsgp:test ignore Message.

MessageExt msgp:tuple MessageExtmsgp:decode ignore MessageExtmsgp:unmarshal ignore MessageExtmsgp:size ignore MessageExtmsgp:test ignore MessageExt.

PackedForwardMessage is just like ForwardMessage, except that the events are carried as a msgpack binary stream msgp:tuple PackedForwardMessagemsgp:decode ignore PackedForwardMessagemsgp:unmarshal ignore PackedForwardMessagemsgp:size ignore PackedForwardMessagemsgp:test ignore PackedForwardMessage.

Ping is the response message sent by the client after receiving a Helo from the server.

Pong is the response message sent by the server after receiving a Ping from the client.

ChunkEncoder wraps methods to encode a message and generate "chunk" IDs for use with Fluent's chunk-ack protocol.

RawMessage is a ChunkEncoder wrapper for []byte.