syntax = "proto3";
package collectd;
+option go_package = "collectd.org/rpc/proto";
import "types.proto";
-import "google/protobuf/timestamp.proto";
service Collectd {
- // Dispatch collected values to collectd.
- rpc DispatchValues(DispatchValuesRequest) returns (DispatchValuesReply);
-
// Query a list of values available from collectd's value cache.
- rpc QueryValues(QueryValuesRequest) returns (QueryValuesReply);
+ rpc QueryValues(QueryValuesRequest) returns (stream QueryValuesResponse);
+
+ // DispatchValues sends a stream of ValueLists to the server.
+ rpc DispatchValues(stream DispatchValuesRequest) returns (DispatchValuesResponse);
}
// The arguments to DispatchValues.
message DispatchValuesRequest {
- collectd.types.ValueList values = 1;
+ collectd.types.ValueList value_list = 1;
}
// The response from DispatchValues.
-message DispatchValuesReply {
+message DispatchValuesResponse {
}
// The arguments to QueryValues.
}
// The response from QueryValues.
-message QueryValuesReply {
- repeated collectd.types.ValueList values = 1;
+message QueryValuesResponse {
+ collectd.types.ValueList value_list = 1;
}