# Packages
No description provided by the author
# Functions
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.
# Constants
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Variables
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Structs
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.
No description provided by the author
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.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Message containing information about a single data point.
Request message wrapper -- sent from Kapacitor to process.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Response message wrapper -- sent from process to Kapacitor.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
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.
# Interfaces
go:generate protoc --gogo_out=./ --python_out=./agent/py/ udf.proto.