fn-dataplane: adding ack type in LogRequestMsg/Ack (#1453)

Ack messages in LogRequestMsg can now specify specific ack type.
2022-10-28 21:29:17 +03:00 · 2019-04-01 15:24:19 -07:00
parent ed6829501a
commit 442073d61a
4 changed files with 133 additions and 76 deletions
--- a/api/agent/grpc/runner.pb.go
+++ b/api/agent/grpc/runner.pb.go
@@ -837,6 +837,7 @@ type LogRequestMsg struct {
 	// Types that are valid to be assigned to Body:
 	//	*LogRequestMsg_Start_
 	//	*LogRequestMsg_Ack_
+	//	*LogRequestMsg_Ready_
 	Body                 isLogRequestMsg_Body `protobuf_oneof:"body"`
 	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
 	XXX_unrecognized     []byte               `json:"-"`
@@ -880,10 +881,16 @@ type LogRequestMsg_Ack_ struct {
 	Ack *LogRequestMsg_Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
 }

+type LogRequestMsg_Ready_ struct {
+	Ready *LogRequestMsg_Ready `protobuf:"bytes,3,opt,name=ready,proto3,oneof"`
+}
+
 func (*LogRequestMsg_Start_) isLogRequestMsg_Body() {}

 func (*LogRequestMsg_Ack_) isLogRequestMsg_Body() {}

+func (*LogRequestMsg_Ready_) isLogRequestMsg_Body() {}
+
 func (m *LogRequestMsg) GetBody() isLogRequestMsg_Body {
 	if m != nil {
 		return m.Body
@@ -905,11 +912,19 @@ func (m *LogRequestMsg) GetAck() *LogRequestMsg_Ack {
 	return nil
 }

+func (m *LogRequestMsg) GetReady() *LogRequestMsg_Ready {
+	if x, ok := m.GetBody().(*LogRequestMsg_Ready_); ok {
+		return x.Ready
+	}
+	return nil
+}
+
 // XXX_OneofWrappers is for the internal use of the proto package.
 func (*LogRequestMsg) XXX_OneofWrappers() []interface{} {
 	return []interface{}{
 		(*LogRequestMsg_Start_)(nil),
 		(*LogRequestMsg_Ack_)(nil),
+		(*LogRequestMsg_Ready_)(nil),
 	}
 }

@@ -953,7 +968,7 @@ func (m *LogRequestMsg_Start) GetConfig() map[string]string {
 	return nil
 }

-// Acknowledgement and re-enable stream message sent by Collectors to Runners
+// Acknowledgement of last data in stream: a message sent by Collectors to Runners
 type LogRequestMsg_Ack struct {
 	XXX_NoUnkeyedLiteral struct{} `json:"-"`
 	XXX_unrecognized     []byte   `json:"-"`
@@ -985,6 +1000,38 @@ func (m *LogRequestMsg_Ack) XXX_DiscardUnknown() {

 var xxx_messageInfo_LogRequestMsg_Ack proto.InternalMessageInfo

+// Enable stream readiness for push: a message sent by Collectors to Runners
+type LogRequestMsg_Ready struct {
+	XXX_NoUnkeyedLiteral struct{} `json:"-"`
+	XXX_unrecognized     []byte   `json:"-"`
+	XXX_sizecache        int32    `json:"-"`
+}
+
+func (m *LogRequestMsg_Ready) Reset()         { *m = LogRequestMsg_Ready{} }
+func (m *LogRequestMsg_Ready) String() string { return proto.CompactTextString(m) }
+func (*LogRequestMsg_Ready) ProtoMessage()    {}
+func (*LogRequestMsg_Ready) Descriptor() ([]byte, []int) {
+	return fileDescriptor_48eceea7e2abc593, []int{11, 2}
+}
+
+func (m *LogRequestMsg_Ready) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_LogRequestMsg_Ready.Unmarshal(m, b)
+}
+func (m *LogRequestMsg_Ready) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_LogRequestMsg_Ready.Marshal(b, m, deterministic)
+}
+func (m *LogRequestMsg_Ready) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_LogRequestMsg_Ready.Merge(m, src)
+}
+func (m *LogRequestMsg_Ready) XXX_Size() int {
+	return xxx_messageInfo_LogRequestMsg_Ready.Size(m)
+}
+func (m *LogRequestMsg_Ready) XXX_DiscardUnknown() {
+	xxx_messageInfo_LogRequestMsg_Ready.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_LogRequestMsg_Ready proto.InternalMessageInfo
+
 // Runners to Collectors
 type LogResponseMsg struct {
 	Data                 []*LogResponseMsg_Container `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
@@ -1212,6 +1259,7 @@ func init() {
 	proto.RegisterType((*LogRequestMsg_Start)(nil), "LogRequestMsg.Start")
 	proto.RegisterMapType((map[string]string)(nil), "LogRequestMsg.Start.ConfigEntry")
 	proto.RegisterType((*LogRequestMsg_Ack)(nil), "LogRequestMsg.Ack")
+	proto.RegisterType((*LogRequestMsg_Ready)(nil), "LogRequestMsg.Ready")
 	proto.RegisterType((*LogResponseMsg)(nil), "LogResponseMsg")
 	proto.RegisterType((*LogResponseMsg_Container)(nil), "LogResponseMsg.Container")
 	proto.RegisterType((*LogResponseMsg_Container_Request)(nil), "LogResponseMsg.Container.Request")
@@ -1221,79 +1269,81 @@ func init() {
 func init() { proto.RegisterFile("runner.proto", fileDescriptor_48eceea7e2abc593) }

 var fileDescriptor_48eceea7e2abc593 = []byte{
-	// 1151 bytes of a gzipped FileDescriptorProto
-	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0xdd, 0x6e, 0x1b, 0x45,
-	0x14, 0xce, 0x7a, 0xed, 0xb5, 0x7d, 0xfc, 0xdb, 0x51, 0x15, 0x2d, 0xa6, 0x02, 0xb3, 0x94, 0xca,
-	0x82, 0x74, 0x43, 0x03, 0x95, 0x42, 0x25, 0x90, 0x42, 0xe2, 0xca, 0x41, 0x29, 0x45, 0xe3, 0x94,
-	0x5b, 0x6b, 0xb2, 0x3b, 0xb6, 0x17, 0xaf, 0x77, 0xcd, 0xcc, 0x6c, 0x68, 0x24, 0xee, 0x79, 0x06,
-	0x24, 0x6e, 0x78, 0x07, 0x1e, 0x82, 0x2b, 0xae, 0x78, 0x12, 0x2e, 0xb8, 0x46, 0xf3, 0xe3, 0xf5,
-	0x4f, 0xda, 0xa4, 0x95, 0xb8, 0xdb, 0xf3, 0x7d, 0x67, 0xe6, 0x9c, 0x33, 0xf3, 0x9d, 0xb3, 0x03,
-	0x75, 0x96, 0x25, 0x09, 0x65, 0xfe, 0x82, 0xa5, 0x22, 0xed, 0xbc, 0x3b, 0x49, 0xd3, 0x49, 0x4c,
-	0xf7, 0x95, 0x75, 0x91, 0x8d, 0xf7, 0xe9, 0x7c, 0x21, 0xae, 0x34, 0xe9, 0xfd, 0x65, 0x41, 0xf9,
-	0x9c, 0x5d, 0x1d, 0x93, 0x38, 0x46, 0x3d, 0x68, 0xcf, 0xd3, 0x90, 0xc6, 0x7c, 0x14, 0x90, 0x38,
-	0x1e, 0xfd, 0xc0, 0xd3, 0xc4, 0xb5, 0xba, 0x56, 0xaf, 0x8a, 0x9b, 0x1a, 0x97, 0x5e, 0xdf, 0xf0,
-	0x34, 0x41, 0x5d, 0xa8, 0xf3, 0x38, 0x15, 0xa3, 0x29, 0xe1, 0xd3, 0x51, 0x14, 0xba, 0x05, 0xe5,
-	0x05, 0x12, 0x1b, 0x10, 0x3e, 0x3d, 0x0d, 0xd1, 0x21, 0x00, 0x7d, 0x29, 0x68, 0xc2, 0xa3, 0x34,
-	0xe1, 0xae, 0xdd, 0xb5, 0x7b, 0xb5, 0x03, 0xd7, 0x37, 0x91, 0xfc, 0x7e, 0x4e, 0xf5, 0x13, 0xc1,
-	0xae, 0xf0, 0x9a, 0x6f, 0xe7, 0x4b, 0x68, 0x6d, 0xd1, 0xa8, 0x0d, 0xf6, 0x8c, 0x5e, 0x99, 0x5c,
-	0xe4, 0x27, 0xba, 0x0b, 0xa5, 0x4b, 0x12, 0x67, 0xd4, 0x44, 0xd6, 0xc6, 0x93, 0xc2, 0xa1, 0xe5,
-	0x3d, 0x82, 0xea, 0x09, 0x11, 0xe4, 0x29, 0x23, 0x73, 0x8a, 0x10, 0x14, 0x43, 0x22, 0x88, 0x5a,
-	0x59, 0xc7, 0xea, 0x5b, 0x6e, 0x46, 0xd3, 0xb1, 0x5a, 0x58, 0xc1, 0xf2, 0xd3, 0xfb, 0x1c, 0x60,
-	0x20, 0xc4, 0x62, 0x40, 0x49, 0x48, 0xd9, 0x9b, 0x06, 0xf3, 0xbe, 0x87, 0xba, 0x5c, 0x85, 0x29,
-	0x5f, 0x3c, 0xa3, 0x82, 0xa0, 0xf7, 0xa1, 0xc6, 0x05, 0x11, 0x19, 0x1f, 0x05, 0x69, 0x48, 0xd5,
-	0xfa, 0x12, 0x06, 0x0d, 0x1d, 0xa7, 0x21, 0x45, 0x1f, 0x41, 0x79, 0xaa, 0x42, 0x70, 0xb7, 0xa0,
-	0xce, 0xa3, 0xe6, 0xaf, 0xc2, 0xe2, 0x25, 0xe7, 0x7d, 0x05, 0x2d, 0x79, 0x46, 0x98, 0xf2, 0x2c,
-	0x16, 0x43, 0x41, 0x98, 0x40, 0x1f, 0x42, 0x71, 0x2a, 0xc4, 0xc2, 0x0d, 0xbb, 0x56, 0xaf, 0x76,
-	0xd0, 0xf0, 0xd7, 0xe3, 0x0e, 0x76, 0xb0, 0x22, 0xbf, 0x76, 0xa0, 0x38, 0xa7, 0x82, 0x78, 0x7f,
-	0x17, 0xa0, 0x2e, 0x37, 0x78, 0x1a, 0x25, 0x11, 0x9f, 0xd2, 0x10, 0xb9, 0x50, 0xe6, 0x59, 0x10,
-	0x50, 0xce, 0x55, 0x52, 0x15, 0xbc, 0x34, 0x25, 0x13, 0x52, 0x41, 0xa2, 0x98, 0x9b, 0xd2, 0x96,
-	0x26, 0xba, 0x07, 0x55, 0xca, 0x58, 0xca, 0x64, 0xe2, 0xae, 0xad, 0x4a, 0x59, 0x01, 0xa8, 0x03,
-	0x15, 0x65, 0x0c, 0x05, 0x73, 0x8b, 0x6a, 0x61, 0x6e, 0xcb, 0x95, 0x01, 0xa3, 0x44, 0xd0, 0xf0,
-	0x48, 0xb8, 0x25, 0x45, 0xae, 0x00, 0xc9, 0x72, 0x59, 0x92, 0x62, 0x1d, 0xcd, 0xe6, 0x00, 0xea,
-	0x42, 0x2d, 0x48, 0xe7, 0x8b, 0x98, 0x6a, 0xbe, 0xac, 0xf8, 0x75, 0x08, 0xed, 0xc1, 0x1d, 0x1e,
-	0x4c, 0x69, 0x98, 0xc5, 0x94, 0x9d, 0x64, 0x8c, 0x88, 0x28, 0x4d, 0xdc, 0x4a, 0xd7, 0xea, 0xd9,
-	0xf8, 0x3a, 0x21, 0xbd, 0xe9, 0x4b, 0x1a, 0x64, 0xd2, 0xc8, 0xbd, 0xab, 0xda, 0xfb, 0x1a, 0x91,
-	0xd7, 0xfc, 0x82, 0x53, 0xe6, 0x82, 0x3a, 0xa9, 0x15, 0xe0, 0x0d, 0xa1, 0x7a, 0x1c, 0x47, 0x34,
-	0x11, 0xcf, 0xf8, 0x04, 0xdd, 0x03, 0x5b, 0x30, 0xad, 0x91, 0xda, 0x41, 0x65, 0x29, 0xeb, 0xc1,
-	0x0e, 0x96, 0x30, 0xea, 0x1a, 0xd5, 0x15, 0x14, 0x0d, 0x7e, 0xae, 0x47, 0x79, 0x57, 0x92, 0x91,
-	0x77, 0x75, 0x91, 0x86, 0x57, 0xde, 0xaf, 0x16, 0x54, 0xb1, 0xea, 0x55, 0xb9, 0xeb, 0x63, 0xa8,
-	0x33, 0x75, 0xeb, 0x23, 0x75, 0x24, 0x66, 0xfb, 0xb6, 0xbf, 0x25, 0x87, 0xc1, 0x0e, 0xae, 0xb1,
-	0x35, 0x75, 0xdc, 0x1a, 0x0e, 0x7d, 0x02, 0x95, 0xb1, 0x51, 0x83, 0xba, 0x4c, 0xa9, 0xa1, 0x75,
-	0x89, 0x0c, 0x76, 0x70, 0xee, 0x90, 0xe7, 0xf6, 0x5b, 0x11, 0xea, 0x3a, 0xb7, 0xa1, 0xd2, 0x30,
-	0xda, 0x05, 0x87, 0x04, 0x22, 0xba, 0xd4, 0x7d, 0x50, 0xc2, 0xc6, 0x92, 0xf8, 0x98, 0x44, 0xb1,
-	0xd9, 0xbb, 0x82, 0x8d, 0x85, 0x9a, 0x50, 0x88, 0x42, 0xa3, 0x8f, 0x42, 0x14, 0xae, 0xab, 0xad,
-	0x74, 0x83, 0xda, 0x9c, 0x9b, 0xd4, 0x56, 0xbe, 0x49, 0x6d, 0x95, 0x1b, 0xd5, 0x56, 0xbd, 0x45,
-	0x6d, 0x70, 0x5d, 0x6d, 0xbb, 0xe0, 0x04, 0x44, 0xaa, 0xca, 0xad, 0xe9, 0xca, 0xb4, 0x85, 0x3e,
-	0x86, 0x36, 0xa3, 0x3f, 0x66, 0x94, 0x0b, 0x8e, 0x69, 0x40, 0xa3, 0x4b, 0x1a, 0xba, 0xf5, 0xae,
-	0xd5, 0x2b, 0xe2, 0x6b, 0x38, 0xea, 0x41, 0x6b, 0x89, 0x0d, 0x48, 0x12, 0xca, 0x63, 0x6a, 0x28,
-	0xd7, 0x6d, 0x18, 0x79, 0x50, 0x9f, 0x85, 0xd9, 0x7c, 0xc1, 0x9f, 0x27, 0x27, 0x11, 0x9f, 0xb9,
-	0x4d, 0xe5, 0xb6, 0x81, 0xbd, 0x5a, 0xff, 0xad, 0xb7, 0xd2, 0x7f, 0xfb, 0x75, 0xfa, 0xdf, 0x83,
-	0x3b, 0x11, 0xff, 0x96, 0x8a, 0x9f, 0x52, 0x36, 0x3b, 0x89, 0x38, 0xb9, 0x90, 0xb9, 0xde, 0x51,
-	0x85, 0x5f, 0x27, 0xbc, 0x4b, 0xa8, 0x1e, 0xa7, 0xc9, 0x38, 0x9a, 0x48, 0xe5, 0xfa, 0xe0, 0x04,
-	0xca, 0x70, 0x2d, 0x35, 0xd9, 0x76, 0xfd, 0x9c, 0x33, 0x5f, 0x7a, 0xce, 0x1b, 0xaf, 0xce, 0x17,
-	0x50, 0x5b, 0x83, 0xdf, 0x6a, 0xbe, 0x37, 0xa1, 0xae, 0x97, 0x6a, 0x55, 0x7a, 0xff, 0x58, 0xd0,
-	0x38, 0x4b, 0x27, 0x58, 0x1f, 0xa6, 0x4c, 0x66, 0x0f, 0x4a, 0xeb, 0xfd, 0x73, 0xd7, 0xdf, 0xa0,
-	0xfd, 0x65, 0x0f, 0x69, 0x27, 0xf4, 0x00, 0x6c, 0x12, 0xcc, 0x4c, 0xf3, 0xa0, 0x2d, 0xdf, 0xa3,
-	0x60, 0x26, 0x9b, 0x9a, 0x04, 0xb3, 0xce, 0xcf, 0x50, 0xd2, 0xed, 0x76, 0xb8, 0x55, 0x6b, 0xf7,
-	0x55, 0xfb, 0xff, 0xcf, 0x55, 0x77, 0x4a, 0x60, 0x1f, 0x05, 0xb3, 0xbc, 0x37, 0xff, 0xb5, 0xa1,
-	0xa9, 0xa2, 0xf2, 0x45, 0x9a, 0x70, 0x2a, 0xab, 0x7e, 0x98, 0xff, 0xea, 0x64, 0x52, 0xef, 0xf8,
-	0x9b, 0xb4, 0xcc, 0x47, 0x90, 0x28, 0xa1, 0x4c, 0x8f, 0x84, 0xce, 0x1f, 0xb6, 0xba, 0x3f, 0x8d,
-	0xa1, 0xfb, 0xd0, 0x20, 0x8b, 0x45, 0x1c, 0x05, 0x4a, 0x09, 0xa7, 0xa1, 0x49, 0x6a, 0x13, 0x44,
-	0xef, 0x01, 0x8c, 0xb3, 0x24, 0x30, 0x2e, 0xe6, 0x9f, 0xbf, 0x42, 0x74, 0x43, 0x99, 0x2d, 0x4f,
-	0xf5, 0x34, 0x50, 0x0d, 0x95, 0x43, 0xe8, 0xb1, 0x49, 0xb2, 0xa8, 0x92, 0xfc, 0xe0, 0xb5, 0x49,
-	0xfa, 0xe6, 0x3c, 0x4d, 0xb2, 0xbf, 0x14, 0xa0, 0x6c, 0x10, 0xd9, 0xd3, 0xa6, 0x71, 0xf2, 0x34,
-	0x57, 0x00, 0x7a, 0x92, 0xcf, 0x42, 0x19, 0xe0, 0xc1, 0xad, 0x01, 0xfc, 0xb3, 0x28, 0xa1, 0x26,
-	0xca, 0xef, 0x16, 0x14, 0xa5, 0x29, 0x43, 0x88, 0x68, 0x4e, 0xb9, 0x20, 0xf3, 0x85, 0x0a, 0x61,
-	0xe3, 0x15, 0x80, 0xfa, 0xe0, 0xf0, 0x34, 0x63, 0x81, 0xbe, 0xa5, 0xe6, 0xc1, 0xc3, 0x37, 0x0b,
-	0xe2, 0x0f, 0xd5, 0x22, 0x6c, 0x16, 0xe7, 0x4f, 0x13, 0x7b, 0xf5, 0x34, 0xf1, 0xba, 0xe0, 0x68,
-	0x2f, 0x04, 0xe0, 0x0c, 0xcf, 0x4f, 0x9e, 0xbf, 0x38, 0x6f, 0xef, 0x98, 0xef, 0x3e, 0xc6, 0x6d,
-	0xeb, 0xe0, 0x4f, 0x0b, 0x9a, 0x7a, 0x28, 0x7f, 0x27, 0x9f, 0x6f, 0x41, 0x1a, 0xa3, 0xfb, 0xe0,
-	0xf4, 0x93, 0x09, 0x99, 0x50, 0x04, 0x7e, 0xfe, 0x87, 0xea, 0x80, 0x9f, 0xff, 0x57, 0x7a, 0xd6,
-	0xa7, 0x16, 0xda, 0x07, 0x67, 0x39, 0xc6, 0x7d, 0xfd, 0x1e, 0xf4, 0x97, 0xef, 0x41, 0xbf, 0x2f,
-	0xdf, 0x83, 0x9d, 0x86, 0xbf, 0x31, 0xed, 0xf7, 0xa0, 0xa5, 0xc5, 0x9a, 0x31, 0xaa, 0x09, 0xb9,
-	0xff, 0xb2, 0xab, 0x3b, 0x0d, 0x7f, 0xbd, 0x0b, 0xd1, 0x23, 0x80, 0xa1, 0x60, 0x94, 0xcc, 0xcf,
-	0xd2, 0x09, 0x47, 0xcd, 0xcd, 0x96, 0xe8, 0xb4, 0xb6, 0x8e, 0x48, 0x66, 0x74, 0xe1, 0xa8, 0xf8,
-	0x9f, 0xfd, 0x17, 0x00, 0x00, 0xff, 0xff, 0xc1, 0x5e, 0x24, 0x5b, 0xad, 0x0a, 0x00, 0x00,
+	// 1171 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0x4f, 0x8f, 0xdb, 0x44,
+	0x14, 0x5f, 0xc7, 0x89, 0x93, 0xbc, 0xfc, 0xed, 0xa8, 0xaa, 0x8c, 0xa9, 0x20, 0x98, 0x52, 0x45,
+	0xb0, 0x75, 0xe9, 0x42, 0xa5, 0x52, 0x09, 0xa4, 0xb2, 0x9b, 0x2a, 0x45, 0x2d, 0x45, 0x93, 0x2d,
+	0xd7, 0x68, 0xd6, 0x9e, 0x24, 0x26, 0x8e, 0x1d, 0x66, 0xc6, 0x4b, 0x23, 0x71, 0xe7, 0x33, 0x20,
+	0x71, 0xe1, 0xc8, 0x9d, 0x0f, 0xc1, 0x89, 0x13, 0x9f, 0x85, 0x33, 0x9a, 0x3f, 0x71, 0xfe, 0x6c,
+	0xbb, 0xdb, 0x4a, 0xdc, 0xfc, 0x7e, 0xbf, 0x37, 0xf3, 0xde, 0xbc, 0xf9, 0xbd, 0xe7, 0x81, 0x26,
+	0xcb, 0xd3, 0x94, 0xb2, 0x60, 0xc9, 0x32, 0x91, 0x79, 0xef, 0x4e, 0xb3, 0x6c, 0x9a, 0xd0, 0xbb,
+	0xca, 0x3a, 0xcb, 0x27, 0x77, 0xe9, 0x62, 0x29, 0x56, 0x9a, 0xf4, 0xff, 0xb6, 0xa0, 0x7a, 0xca,
+	0x56, 0xc7, 0x24, 0x49, 0x50, 0x1f, 0xba, 0x8b, 0x2c, 0xa2, 0x09, 0x1f, 0x87, 0x24, 0x49, 0xc6,
+	0x3f, 0xf0, 0x2c, 0x75, 0xad, 0x9e, 0xd5, 0xaf, 0xe3, 0xb6, 0xc6, 0xa5, 0xd7, 0x37, 0x3c, 0x4b,
+	0x51, 0x0f, 0x9a, 0x3c, 0xc9, 0xc4, 0x78, 0x46, 0xf8, 0x6c, 0x1c, 0x47, 0x6e, 0x49, 0x79, 0x81,
+	0xc4, 0x86, 0x84, 0xcf, 0x9e, 0x44, 0xe8, 0x01, 0x00, 0x7d, 0x29, 0x68, 0xca, 0xe3, 0x2c, 0xe5,
+	0xae, 0xdd, 0xb3, 0xfb, 0x8d, 0x23, 0x37, 0x30, 0x91, 0x82, 0x41, 0x41, 0x0d, 0x52, 0xc1, 0x56,
+	0x78, 0xcb, 0xd7, 0xfb, 0x12, 0x3a, 0x7b, 0x34, 0xea, 0x82, 0x3d, 0xa7, 0x2b, 0x93, 0x8b, 0xfc,
+	0x44, 0xd7, 0xa1, 0x72, 0x4e, 0x92, 0x9c, 0x9a, 0xc8, 0xda, 0x78, 0x58, 0x7a, 0x60, 0xf9, 0xf7,
+	0xa0, 0x7e, 0x42, 0x04, 0x79, 0xcc, 0xc8, 0x82, 0x22, 0x04, 0xe5, 0x88, 0x08, 0xa2, 0x56, 0x36,
+	0xb1, 0xfa, 0x96, 0x9b, 0xd1, 0x6c, 0xa2, 0x16, 0xd6, 0xb0, 0xfc, 0xf4, 0x3f, 0x07, 0x18, 0x0a,
+	0xb1, 0x1c, 0x52, 0x12, 0x51, 0xf6, 0xa6, 0xc1, 0xfc, 0xef, 0xa1, 0x29, 0x57, 0x61, 0xca, 0x97,
+	0xcf, 0xa8, 0x20, 0xe8, 0x7d, 0x68, 0x70, 0x41, 0x44, 0xce, 0xc7, 0x61, 0x16, 0x51, 0xb5, 0xbe,
+	0x82, 0x41, 0x43, 0xc7, 0x59, 0x44, 0xd1, 0x47, 0x50, 0x9d, 0xa9, 0x10, 0xdc, 0x2d, 0xa9, 0x7a,
+	0x34, 0x82, 0x4d, 0x58, 0xbc, 0xe6, 0xfc, 0xaf, 0xa0, 0x23, 0x6b, 0x84, 0x29, 0xcf, 0x13, 0x31,
+	0x12, 0x84, 0x09, 0xf4, 0x21, 0x94, 0x67, 0x42, 0x2c, 0xdd, 0xa8, 0x67, 0xf5, 0x1b, 0x47, 0xad,
+	0x60, 0x3b, 0xee, 0xf0, 0x00, 0x2b, 0xf2, 0x6b, 0x07, 0xca, 0x0b, 0x2a, 0x88, 0xff, 0x4f, 0x09,
+	0x9a, 0x72, 0x83, 0xc7, 0x71, 0x1a, 0xf3, 0x19, 0x8d, 0x90, 0x0b, 0x55, 0x9e, 0x87, 0x21, 0xe5,
+	0x5c, 0x25, 0x55, 0xc3, 0x6b, 0x53, 0x32, 0x11, 0x15, 0x24, 0x4e, 0xb8, 0x39, 0xda, 0xda, 0x44,
+	0x37, 0xa1, 0x4e, 0x19, 0xcb, 0x98, 0x4c, 0xdc, 0xb5, 0xd5, 0x51, 0x36, 0x00, 0xf2, 0xa0, 0xa6,
+	0x8c, 0x91, 0x60, 0x6e, 0x59, 0x2d, 0x2c, 0x6c, 0xb9, 0x32, 0x64, 0x94, 0x08, 0x1a, 0x3d, 0x12,
+	0x6e, 0x45, 0x91, 0x1b, 0x40, 0xb2, 0x5c, 0x1e, 0x49, 0xb1, 0x8e, 0x66, 0x0b, 0x00, 0xf5, 0xa0,
+	0x11, 0x66, 0x8b, 0x65, 0x42, 0x35, 0x5f, 0x55, 0xfc, 0x36, 0x84, 0x0e, 0xe1, 0x1a, 0x0f, 0x67,
+	0x34, 0xca, 0x13, 0xca, 0x4e, 0x72, 0x46, 0x44, 0x9c, 0xa5, 0x6e, 0xad, 0x67, 0xf5, 0x6d, 0x7c,
+	0x91, 0x90, 0xde, 0xf4, 0x25, 0x0d, 0x73, 0x69, 0x14, 0xde, 0x75, 0xed, 0x7d, 0x81, 0x28, 0xce,
+	0xfc, 0x82, 0x53, 0xe6, 0x82, 0xaa, 0xd4, 0x06, 0xf0, 0x47, 0x50, 0x3f, 0x4e, 0x62, 0x9a, 0x8a,
+	0x67, 0x7c, 0x8a, 0x6e, 0x82, 0x2d, 0x98, 0xd6, 0x48, 0xe3, 0xa8, 0xb6, 0x96, 0xf5, 0xf0, 0x00,
+	0x4b, 0x18, 0xf5, 0x8c, 0xea, 0x4a, 0x8a, 0x86, 0xa0, 0xd0, 0xa3, 0xbc, 0x2b, 0xc9, 0xc8, 0xbb,
+	0x3a, 0xcb, 0xa2, 0x95, 0xff, 0xab, 0x05, 0x75, 0xac, 0x7a, 0x55, 0xee, 0x7a, 0x1f, 0x9a, 0x4c,
+	0xdd, 0xfa, 0x58, 0x95, 0xc4, 0x6c, 0xdf, 0x0d, 0xf6, 0xe4, 0x30, 0x3c, 0xc0, 0x0d, 0xb6, 0xa5,
+	0x8e, 0x2b, 0xc3, 0xa1, 0x4f, 0xa0, 0x36, 0x31, 0x6a, 0x50, 0x97, 0x29, 0x35, 0xb4, 0x2d, 0x91,
+	0xe1, 0x01, 0x2e, 0x1c, 0x8a, 0xdc, 0x7e, 0x2b, 0x43, 0x53, 0xe7, 0x36, 0x52, 0x1a, 0x46, 0x37,
+	0xc0, 0x21, 0xa1, 0x88, 0xcf, 0x75, 0x1f, 0x54, 0xb0, 0xb1, 0x24, 0x3e, 0x21, 0x71, 0x62, 0xf6,
+	0xae, 0x61, 0x63, 0xa1, 0x36, 0x94, 0xe2, 0xc8, 0xe8, 0xa3, 0x14, 0x47, 0xdb, 0x6a, 0xab, 0x5c,
+	0xa2, 0x36, 0xe7, 0x32, 0xb5, 0x55, 0x2f, 0x53, 0x5b, 0xed, 0x52, 0xb5, 0xd5, 0xaf, 0x50, 0x1b,
+	0x5c, 0x54, 0xdb, 0x0d, 0x70, 0x42, 0x22, 0x55, 0xe5, 0x36, 0xf4, 0xc9, 0xb4, 0x85, 0x3e, 0x86,
+	0x2e, 0xa3, 0x3f, 0xe6, 0x94, 0x0b, 0x8e, 0x69, 0x48, 0xe3, 0x73, 0x1a, 0xb9, 0xcd, 0x9e, 0xd5,
+	0x2f, 0xe3, 0x0b, 0x38, 0xea, 0x43, 0x67, 0x8d, 0x0d, 0x49, 0x1a, 0xc9, 0x32, 0xb5, 0x94, 0xeb,
+	0x3e, 0x8c, 0x7c, 0x68, 0xce, 0xa3, 0x7c, 0xb1, 0xe4, 0xcf, 0xd3, 0x93, 0x98, 0xcf, 0xdd, 0xb6,
+	0x72, 0xdb, 0xc1, 0x5e, 0xad, 0xff, 0xce, 0x5b, 0xe9, 0xbf, 0xfb, 0x3a, 0xfd, 0x1f, 0xc2, 0xb5,
+	0x98, 0x7f, 0x4b, 0xc5, 0x4f, 0x19, 0x9b, 0x9f, 0xc4, 0x9c, 0x9c, 0xc9, 0x5c, 0xaf, 0xa9, 0x83,
+	0x5f, 0x24, 0xfc, 0x73, 0xa8, 0x1f, 0x67, 0xe9, 0x24, 0x9e, 0x4a, 0xe5, 0x06, 0xe0, 0x84, 0xca,
+	0x70, 0x2d, 0x35, 0xd9, 0x6e, 0x04, 0x05, 0x67, 0xbe, 0xf4, 0x9c, 0x37, 0x5e, 0xde, 0x17, 0xd0,
+	0xd8, 0x82, 0xdf, 0x6a, 0xbe, 0xb7, 0xa1, 0xa9, 0x97, 0x6a, 0x55, 0xfa, 0x7f, 0x94, 0xa0, 0xf5,
+	0x34, 0x9b, 0x62, 0x5d, 0x4c, 0x99, 0xcc, 0x21, 0x54, 0xb6, 0xfb, 0xe7, 0x7a, 0xb0, 0x43, 0x07,
+	0xeb, 0x1e, 0xd2, 0x4e, 0xe8, 0x36, 0xd8, 0x24, 0x9c, 0x9b, 0xe6, 0x41, 0x7b, 0xbe, 0x8f, 0xc2,
+	0xb9, 0x6c, 0x6a, 0x12, 0xca, 0xca, 0x57, 0x18, 0x25, 0xd1, 0xca, 0x34, 0xd0, 0xfe, 0xae, 0x58,
+	0x72, 0x72, 0x57, 0xe5, 0xe4, 0xfd, 0x0c, 0x15, 0xdd, 0x9c, 0x0f, 0xf6, 0x2a, 0xd3, 0x7b, 0x55,
+	0x36, 0xff, 0x73, 0x8d, 0xbc, 0x0a, 0xd8, 0x8f, 0xc2, 0xb9, 0x57, 0x85, 0x8a, 0x4a, 0xab, 0x68,
+	0xe9, 0x7f, 0x6d, 0x68, 0xab, 0xf0, 0x7c, 0x99, 0xa5, 0x9c, 0xca, 0x62, 0xdd, 0x29, 0xfe, 0x90,
+	0x32, 0xbb, 0x77, 0x82, 0x5d, 0x5a, 0x26, 0x26, 0x48, 0x9c, 0x52, 0xa6, 0x27, 0x89, 0xf7, 0xa7,
+	0xad, 0xae, 0x5d, 0x63, 0xe8, 0x16, 0xb4, 0xc8, 0x72, 0x99, 0xc4, 0xa1, 0x12, 0xd0, 0x93, 0xc8,
+	0x64, 0xb7, 0x0b, 0xa2, 0xf7, 0x00, 0x26, 0x79, 0x1a, 0x1a, 0x17, 0xf3, 0x54, 0xd8, 0x20, 0xba,
+	0x0f, 0xcd, 0x96, 0x4f, 0xf4, 0x10, 0x51, 0x7d, 0x58, 0x40, 0xe8, 0xbe, 0x49, 0xb2, 0xac, 0x92,
+	0xfc, 0xe0, 0xb5, 0x49, 0x06, 0xa6, 0xb0, 0x26, 0xd9, 0x5f, 0x4a, 0x50, 0x35, 0x88, 0x1c, 0x05,
+	0xa6, 0xdf, 0x8a, 0x34, 0x37, 0x00, 0x7a, 0x58, 0x8c, 0x50, 0x19, 0xe0, 0xf6, 0x95, 0x01, 0x82,
+	0xa7, 0x71, 0x4a, 0x4d, 0x94, 0xdf, 0x2d, 0x28, 0x4b, 0x53, 0x86, 0x10, 0xf1, 0x82, 0x72, 0x41,
+	0x16, 0x4b, 0x15, 0xc2, 0xc6, 0x1b, 0x00, 0x0d, 0xc0, 0xe1, 0x59, 0xce, 0x42, 0x7d, 0x5d, 0xed,
+	0xa3, 0x3b, 0x6f, 0x16, 0x24, 0x18, 0xa9, 0x45, 0xd8, 0x2c, 0x2e, 0x5e, 0x34, 0xf6, 0xe6, 0x45,
+	0xe3, 0xf7, 0xc0, 0xd1, 0x5e, 0x08, 0xc0, 0x19, 0x9d, 0x9e, 0x3c, 0x7f, 0x71, 0xda, 0x3d, 0x30,
+	0xdf, 0x03, 0x8c, 0xbb, 0xd6, 0xd1, 0x5f, 0x16, 0xb4, 0xf5, 0x2c, 0xff, 0x4e, 0xbe, 0xfa, 0xc2,
+	0x2c, 0x41, 0xb7, 0xc0, 0x19, 0xa4, 0x53, 0x32, 0xa5, 0x08, 0x82, 0xe2, 0xc7, 0xe6, 0x41, 0x50,
+	0xfc, 0x8e, 0xfa, 0xd6, 0xa7, 0x16, 0xba, 0x0b, 0xce, 0x7a, 0xfa, 0x07, 0xfa, 0x19, 0x19, 0xac,
+	0x9f, 0x91, 0xc1, 0x40, 0x3e, 0x23, 0xbd, 0x56, 0xb0, 0xf3, 0x93, 0x38, 0x84, 0x8e, 0x56, 0x6d,
+	0xce, 0xa8, 0x26, 0xe4, 0xfe, 0xeb, 0x61, 0xe0, 0xb5, 0x82, 0xed, 0xe6, 0x45, 0xf7, 0x00, 0x46,
+	0x82, 0x51, 0xb2, 0x78, 0x9a, 0x4d, 0x39, 0x6a, 0xef, 0xf6, 0x86, 0xd7, 0xd9, 0x2b, 0x91, 0xcc,
+	0xe8, 0xcc, 0x51, 0xf1, 0x3f, 0xfb, 0x2f, 0x00, 0x00, 0xff, 0xff, 0xb2, 0x1e, 0x6d, 0xb3, 0xe4,
+	0x0a, 0x00, 0x00,
 }

 // Reference imports to suppress errors if they are not otherwise used.
--- a/api/agent/grpc/runner.proto
+++ b/api/agent/grpc/runner.proto
@@ -98,13 +98,18 @@ message LogRequestMsg {
        map<string,string> config = 1;
    }

-    // Acknowledgement and re-enable stream message sent by Collectors to Runners
+    // Acknowledgement of last data in stream: a message sent by Collectors to Runners
    message Ack {
    }

+    // Enable stream readiness for push: a message sent by Collectors to Runners
+    message Ready {
+    }
+
    oneof body {
        Start start = 1;
        Ack ack = 2;
+        Ready ready = 3;
    }
 }

--- a/go.mod
+++ b/go.mod
@@ -18,7 +18,7 @@ require (
 	github.com/gin-gonic/gin v1.3.0
 	github.com/go-sql-driver/mysql v1.4.0
 	github.com/golang/groupcache v0.0.0-20180924190550-6f2cf27854a4
-	github.com/golang/protobuf v1.2.1-0.20190109072247-347cf4a86c1c
+	github.com/golang/protobuf v1.3.1
 	github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c
 	github.com/grpc-ecosystem/go-grpc-middleware v1.0.0
 	github.com/jmoiron/sqlx v1.2.0
--- a/go.sum
+++ b/go.sum
@@ -92,6 +92,8 @@ github.com/golang/protobuf v1.2.0 h1:P3YflyNX/ehuJFLhxviNdFxQPkGK5cDcApsge1SqnvM
 github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
 github.com/golang/protobuf v1.2.1-0.20190109072247-347cf4a86c1c h1:fQ4P1oAipLwec/j5tfZTYV/e5i9ICSk23uVL+TK9III=
 github.com/golang/protobuf v1.2.1-0.20190109072247-347cf4a86c1c/go.mod h1:Qd/q+1AKNOZr9uGQzbzCmRO6sUih6GTPZv6a1/R87v0=
+github.com/golang/protobuf v1.3.1 h1:YF8+flBXS5eO826T4nzqPrxfhQThhXl0YzfuUPu4SBg=
+github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
 github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c h1:964Od4U6p2jUkFxvCydnIczKteheJEzHRToSGK3Bnlw=
 github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
 github.com/google/go-cloud v0.4.1-0.20181025204856-f29236cc19de/go.mod h1:zIXR03PyBRhLPWwHYkj98zq25qmUVwn1NL8GZB/+lF8=