Read a message from io.ByteReader by first reading a varint size, and then reading and decoding the message object.

Write the message to the io.Writer with a varint size header.

Indicates the beginning of a batch.

Indicates the end of a batch and contains all meta data associated with the batch.

Sent from the process to Kapacitor indicating an error has occurred.

Request that the process return information about available Options.

Request that the process initialize itself with the provided options.

Respond to Kapacitor whether initialization was successful.

Request that the process respond with a Keepalive to verify it is responding.

Respond to KeepaliveRequest.

Message containing information about a single data point.

Request message wrapper -- sent from Kapacitor to process.

Response message wrapper -- sent from process to Kapacitor.

Request that the process restore its state from a snapshot.

Respond with success or failure to a RestoreRequest.

Server provides an implementation for the core communication with UDFs.

Request that the process provide a snapshot of its state.

Respond to Kapacitor with a serialized snapshot of the running state.

Interface for reading messages If you have an io.Reader wrap your reader in a bufio Reader to stasify this interface.

Interface for communicating with a UDF.