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 occured.

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.

Request that the process provide a snapshot of its state.

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

go:generate protoc --gogo_out=./ --python_out=./agent/py/ udf.proto.