overflow_backup_2018_0455/central_api_gateway
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Rename Empty to Void

Browse Source
This commit is contained in:
insanity@loafle.com 2017-05-23 14:20:51 +09:00
parent d01f891c43
commit 2f65275b13
11 changed files with 150 additions and 180 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
commons/commons.pb.go
View File

@ -8,6 +8,7 @@ It is generated from these files:
commons.proto commons.proto
It has these top-level messages: It has these top-level messages:
Void
*/ */
package commons package commons
@ -119,7 +120,16 @@ func (x TaskEventType) String() string {
} }
func (TaskEventType) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{1} } func (TaskEventType) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
type Void struct {
}
func (m *Void) Reset() { *m = Void{} }
func (m *Void) String() string { return proto.CompactTextString(m) }
func (*Void) ProtoMessage() {}
func (*Void) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
func init() { func init() {
proto.RegisterType((*Void)(nil), "Void")
proto.RegisterEnum("DiscoveryEventType", DiscoveryEventType_name, DiscoveryEventType_value) proto.RegisterEnum("DiscoveryEventType", DiscoveryEventType_name, DiscoveryEventType_value)
proto.RegisterEnum("TaskEventType", TaskEventType_name, TaskEventType_value) proto.RegisterEnum("TaskEventType", TaskEventType_name, TaskEventType_value)
} }
@ -127,24 +137,25 @@ func init() {
func init() { proto.RegisterFile("commons.proto", fileDescriptor0) } func init() { proto.RegisterFile("commons.proto", fileDescriptor0) }
var fileDescriptor0 = []byte{ var fileDescriptor0 = []byte{
// 302 bytes of a gzipped FileDescriptorProto // 308 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0x92, 0xcd, 0x4e, 0xfa, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0x92, 0xcd, 0x4e, 0xc2, 0x40,
0x14, 0x47, 0xf9, 0xfa, 0xc3, 0x9f, 0x9b, 0x80, 0xc3, 0x05, 0x81, 0xa8, 0x4f, 0xc0, 0xc2, 0x8d, 0x14, 0x46, 0xf9, 0xb3, 0xc8, 0x4d, 0xc0, 0xe1, 0x82, 0x40, 0xd4, 0x95, 0x4b, 0x16, 0x6e, 0x7c,
0x4f, 0x30, 0x61, 0xae, 0x48, 0xac, 0x9d, 0x66, 0x66, 0xa8, 0x71, 0xd5, 0x28, 0x61, 0x61, 0x0c, 0x82, 0x09, 0x73, 0x45, 0x62, 0xed, 0x34, 0x33, 0x43, 0x8d, 0xab, 0x46, 0x91, 0x05, 0x31, 0x30,
0x94, 0x50, 0x42, 0xc2, 0x43, 0xf9, 0x7a, 0xae, 0x4d, 0x87, 0xd2, 0x0f, 0xec, 0xf6, 0x9c, 0xf4, 0x04, 0x08, 0x09, 0x0f, 0xe5, 0xeb, 0xb9, 0x36, 0x0c, 0x50, 0x28, 0x76, 0x7b, 0x4e, 0x7a, 0x7a,
0xf4, 0xf6, 0x97, 0x42, 0x67, 0x19, 0xae, 0xd7, 0xe1, 0x26, 0xba, 0xdf, 0xee, 0xc2, 0x7d, 0x38, 0xfb, 0xa5, 0x50, 0x1d, 0xd9, 0xe9, 0xd4, 0xce, 0x96, 0x0f, 0xf3, 0x85, 0x5d, 0xd9, 0x7b, 0x0f,
0xf9, 0xae, 0x01, 0x8a, 0xcf, 0x68, 0x19, 0x1e, 0x56, 0xbb, 0x23, 0x1d, 0x56, 0x9b, 0xbd, 0x39, 0x4a, 0x91, 0x9d, 0x7c, 0x75, 0x7f, 0x0a, 0x80, 0x62, 0xb2, 0x1c, 0xd9, 0xf5, 0x78, 0xb1, 0xa1,
0x6e, 0x57, 0xd8, 0x87, 0x2b, 0x31, 0xd7, 0x53, 0xe9, 0x93, 0x7a, 0x0b, 0xb4, 0xe1, 0xca, 0xb0, 0xf5, 0x78, 0xb6, 0x32, 0x9b, 0xf9, 0x18, 0x1b, 0x70, 0x25, 0x06, 0xba, 0x27, 0x23, 0x52, 0xef,
0x0a, 0x8e, 0x61, 0x90, 0xc1, 0x27, 0xa9, 0x4d, 0x62, 0xaa, 0x25, 0xe6, 0x51, 0x2e, 0x5c, 0xc1, 0xb1, 0x36, 0x5c, 0x19, 0x96, 0xc3, 0x0e, 0x34, 0x8f, 0xf0, 0x59, 0x6a, 0xb3, 0x37, 0xf9, 0x0c,
0x6a, 0x38, 0x82, 0xfe, 0x85, 0x11, 0xd2, 0x25, 0x56, 0x2f, 0x3e, 0xe2, 0x49, 0x75, 0x8e, 0x35, 0xf3, 0x24, 0x87, 0x81, 0x60, 0x05, 0x6c, 0x43, 0xe3, 0xcc, 0x08, 0x19, 0x10, 0x2b, 0xa6, 0x1f,
0x4a, 0xcc, 0x29, 0xf6, 0xaf, 0x18, 0xb3, 0xc6, 0xc6, 0x9a, 0x78, 0x0b, 0xa3, 0xdc, 0xb9, 0xa4, 0x09, 0xa5, 0x3a, 0xc4, 0x4a, 0x19, 0x66, 0x17, 0xbb, 0x48, 0xc7, 0x9c, 0x71, 0x31, 0x0f, 0x6f,
0xfc, 0xf9, 0x94, 0x92, 0x5e, 0xab, 0x5c, 0x9e, 0x92, 0xff, 0xf1, 0x06, 0x86, 0x7f, 0xa5, 0xad, 0xa1, 0x7d, 0x72, 0x2e, 0xa9, 0x68, 0xd0, 0xa3, 0x7d, 0xaf, 0x9c, 0x2d, 0x77, 0xc9, 0x4b, 0xbc,
0xb6, 0x11, 0xa1, 0x9b, 0x39, 0xcb, 0x60, 0xf2, 0x53, 0x85, 0x8e, 0x79, 0x8f, 0xbe, 0xb2, 0xa9, 0x81, 0xd6, 0x7f, 0xe9, 0xaa, 0x15, 0x44, 0xa8, 0x1d, 0x9d, 0x63, 0xd0, 0xfd, 0xcd, 0x43, 0xd5,
0xee, 0x60, 0x6c, 0xb8, 0x7e, 0x0e, 0x3c, 0xe9, 0x04, 0x73, 0xd7, 0x90, 0xf2, 0xb9, 0x13, 0x2c, 0x7c, 0x2c, 0xbf, 0x8f, 0x53, 0xdd, 0x41, 0xc7, 0x70, 0xfd, 0x12, 0x87, 0xd2, 0x8f, 0x07, 0x81,
0x3c, 0xc1, 0x0d, 0xb1, 0x0a, 0x5e, 0x43, 0xcf, 0x5a, 0x4d, 0xae, 0x96, 0x2a, 0x1d, 0x6c, 0x00, 0x21, 0x15, 0x71, 0x3f, 0x1e, 0x86, 0x82, 0x1b, 0x62, 0x39, 0xbc, 0x86, 0xba, 0xb3, 0x9a, 0x02,
0xac, 0x88, 0xa5, 0xc7, 0x6a, 0xf1, 0xea, 0x79, 0xca, 0x85, 0x60, 0x75, 0x1c, 0x02, 0xe6, 0xa1, 0x2d, 0x55, 0x32, 0x58, 0x13, 0x58, 0x1a, 0xcb, 0x90, 0x15, 0xb6, 0xab, 0x9f, 0x52, 0x2e, 0x04,
0xa2, 0x17, 0xe9, 0x13, 0x6b, 0x5c, 0xf2, 0xe4, 0x8d, 0x76, 0x24, 0xcb, 0xa7, 0x8a, 0xbf, 0x3a, 0x2b, 0x62, 0x0b, 0xf0, 0x14, 0x2a, 0x7a, 0x95, 0x11, 0xb1, 0xd2, 0x39, 0xdf, 0xbf, 0xd1, 0x8d,
0x94, 0x8a, 0x66, 0x7a, 0x0a, 0x9f, 0x91, 0x6b, 0xce, 0xb8, 0x85, 0x3d, 0xe8, 0x58, 0xec, 0xc8, 0xe4, 0x78, 0x4f, 0xf1, 0x37, 0x9f, 0x12, 0xe1, 0x25, 0xa7, 0xf0, 0x3e, 0x05, 0xe6, 0x80, 0xcb,
0x59, 0xdc, 0x8a, 0x47, 0x41, 0xe8, 0x5a, 0x94, 0x7e, 0x3d, 0x6b, 0x7f, 0x34, 0xed, 0xff, 0xf2, 0x58, 0x87, 0xaa, 0xc3, 0xbe, 0xec, 0x6f, 0x5b, 0xdb, 0x51, 0x10, 0x6a, 0x0e, 0x25, 0x5f, 0xcf,
0xf0, 0x1b, 0x00, 0x00, 0xff, 0xff, 0x7e, 0x5f, 0x8f, 0x24, 0x40, 0x02, 0x00, 0x00, 0x2a, 0x9f, 0x9e, 0xfb, 0x6f, 0x1e, 0xff, 0x02, 0x00, 0x00, 0xff, 0xff, 0x4b, 0x9c, 0xeb, 0xb6,
0x48, 0x02, 0x00, 0x00,
} }

2
commons/commons.proto
View File

@ -1,5 +1,7 @@
syntax = "proto3"; syntax = "proto3";
message Void {}
enum DiscoveryEventType { enum DiscoveryEventType {
DISCOVERY_START = 0; DISCOVERY_START = 0;
DISCOVERY_HOST_START = 1; DISCOVERY_HOST_START = 1;

2
data/cmd
View File

@ -1 +1 @@
protoc -I data/ data/data.proto --go_out=plugins=grpc:data protoc -I$GOPATH/src/ -I data/ data/data.proto --go_out=plugins=grpc:data

65
data/data.pb.go
View File

@ -8,7 +8,6 @@ It is generated from these files:
data.proto data.proto
It has these top-level messages: It has these top-level messages:
Empty
CollectedData CollectedData
*/ */
package data package data
@ -16,6 +15,7 @@ package data
import proto "github.com/golang/protobuf/proto" import proto "github.com/golang/protobuf/proto"
import fmt "fmt" import fmt "fmt"
import math "math" import math "math"
import commons "loafle.com/overflow/central_api_gateway/commons"
import ( import (
context "golang.org/x/net/context" context "golang.org/x/net/context"
@ -33,14 +33,6 @@ var _ = math.Inf
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
type Empty struct {
}
func (m *Empty) Reset() { *m = Empty{} }
func (m *Empty) String() string { return proto.CompactTextString(m) }
func (*Empty) ProtoMessage() {}
func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
type CollectedData struct { type CollectedData struct {
AgentId string `protobuf:"bytes,1,opt,name=agentId" json:"agentId,omitempty"` AgentId string `protobuf:"bytes,1,opt,name=agentId" json:"agentId,omitempty"`
SensorId string `protobuf:"bytes,2,opt,name=sensorId" json:"sensorId,omitempty"` SensorId string `protobuf:"bytes,2,opt,name=sensorId" json:"sensorId,omitempty"`
@ -52,7 +44,7 @@ type CollectedData struct {
func (m *CollectedData) Reset() { *m = CollectedData{} } func (m *CollectedData) Reset() { *m = CollectedData{} }
func (m *CollectedData) String() string { return proto.CompactTextString(m) } func (m *CollectedData) String() string { return proto.CompactTextString(m) }
func (*CollectedData) ProtoMessage() {} func (*CollectedData) ProtoMessage() {}
func (*CollectedData) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} } func (*CollectedData) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
func (m *CollectedData) GetAgentId() string { func (m *CollectedData) GetAgentId() string {
if m != nil { if m != nil {
@ -90,7 +82,6 @@ func (m *CollectedData) GetFinishDate() int64 {
} }
func init() { func init() {
proto.RegisterType((*Empty)(nil), "Empty")
proto.RegisterType((*CollectedData)(nil), "CollectedData") proto.RegisterType((*CollectedData)(nil), "CollectedData")
} }
@ -105,8 +96,8 @@ const _ = grpc.SupportPackageIsVersion4
// Client API for Data service // Client API for Data service
type DataClient interface { type DataClient interface {
SendMetric(ctx context.Context, in *CollectedData, opts ...grpc.CallOption) (*Empty, error) SendMetric(ctx context.Context, in *CollectedData, opts ...grpc.CallOption) (*commons.Void, error)
SendMeta(ctx context.Context, in *CollectedData, opts ...grpc.CallOption) (*Empty, error) SendMeta(ctx context.Context, in *CollectedData, opts ...grpc.CallOption) (*commons.Void, error)
} }
type dataClient struct { type dataClient struct {
@ -117,8 +108,8 @@ func NewDataClient(cc *grpc.ClientConn) DataClient {
return &dataClient{cc} return &dataClient{cc}
} }
func (c *dataClient) SendMetric(ctx context.Context, in *CollectedData, opts ...grpc.CallOption) (*Empty, error) { func (c *dataClient) SendMetric(ctx context.Context, in *CollectedData, opts ...grpc.CallOption) (*commons.Void, error) {
out := new(Empty) out := new(commons.Void)
err := grpc.Invoke(ctx, "/Data/sendMetric", in, out, c.cc, opts...) err := grpc.Invoke(ctx, "/Data/sendMetric", in, out, c.cc, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
@ -126,8 +117,8 @@ func (c *dataClient) SendMetric(ctx context.Context, in *CollectedData, opts ...
return out, nil return out, nil
} }
func (c *dataClient) SendMeta(ctx context.Context, in *CollectedData, opts ...grpc.CallOption) (*Empty, error) { func (c *dataClient) SendMeta(ctx context.Context, in *CollectedData, opts ...grpc.CallOption) (*commons.Void, error) {
out := new(Empty) out := new(commons.Void)
err := grpc.Invoke(ctx, "/Data/sendMeta", in, out, c.cc, opts...) err := grpc.Invoke(ctx, "/Data/sendMeta", in, out, c.cc, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
@ -138,8 +129,8 @@ func (c *dataClient) SendMeta(ctx context.Context, in *CollectedData, opts ...gr
// Server API for Data service // Server API for Data service
type DataServer interface { type DataServer interface {
SendMetric(context.Context, *CollectedData) (*Empty, error) SendMetric(context.Context, *CollectedData) (*commons.Void, error)
SendMeta(context.Context, *CollectedData) (*Empty, error) SendMeta(context.Context, *CollectedData) (*commons.Void, error)
} }
func RegisterDataServer(s *grpc.Server, srv DataServer) { func RegisterDataServer(s *grpc.Server, srv DataServer) {
@ -202,21 +193,23 @@ var _Data_serviceDesc = grpc.ServiceDesc{
func init() { proto.RegisterFile("data.proto", fileDescriptor0) } func init() { proto.RegisterFile("data.proto", fileDescriptor0) }
var fileDescriptor0 = []byte{ var fileDescriptor0 = []byte{
// 244 bytes of a gzipped FileDescriptorProto // 281 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x50, 0xc1, 0x4a, 0xc3, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x90, 0x4f, 0x4b, 0x03, 0x31,
0x14, 0x74, 0x9b, 0xa4, 0x35, 0x4f, 0x14, 0x79, 0x78, 0x58, 0x82, 0x48, 0x28, 0x22, 0x39, 0x48, 0x10, 0xc5, 0xdd, 0x6e, 0xab, 0x76, 0x44, 0x91, 0xe0, 0x21, 0x2c, 0x22, 0xa5, 0x22, 0xf4, 0x20,
0x0e, 0xf5, 0xa0, 0x78, 0xb5, 0x3d, 0xf4, 0xe0, 0x25, 0xf8, 0x03, 0xcf, 0xee, 0x53, 0x83, 0x71, 0xbb, 0x50, 0x0f, 0x8a, 0xe0, 0xc9, 0x7a, 0xe8, 0xc1, 0xcb, 0x1e, 0xbc, 0x96, 0x71, 0x33, 0x5b,
0x53, 0x76, 0x9f, 0x42, 0x7e, 0xd9, 0xaf, 0x90, 0x6c, 0x6b, 0x35, 0x87, 0x5e, 0x96, 0x9d, 0x37, 0x17, 0xb3, 0x49, 0x49, 0xc6, 0x96, 0xfd, 0xca, 0x7e, 0x0a, 0xd9, 0xf4, 0x8f, 0xf6, 0xe0, 0x25,
0xc3, 0x30, 0x33, 0x00, 0x86, 0x84, 0xca, 0xb5, 0x6b, 0xa5, 0x9d, 0x4e, 0x20, 0x59, 0x7c, 0xac, 0xc9, 0x9b, 0xf7, 0x32, 0xfc, 0x66, 0x00, 0x14, 0x32, 0xa6, 0x0b, 0x67, 0xd9, 0x26, 0x4f, 0xda,
0xa5, 0x9b, 0x7e, 0x2b, 0x38, 0x7e, 0x68, 0x9b, 0x86, 0x57, 0xc2, 0x66, 0x4e, 0x42, 0xa8, 0x61, 0x62, 0xa9, 0x29, 0x2d, 0x6c, 0x9d, 0xd9, 0x25, 0xb9, 0x52, 0xdb, 0x55, 0x56, 0x90, 0x61, 0x87,
0x42, 0xaf, 0x6c, 0x65, 0x69, 0xb4, 0xca, 0x55, 0x91, 0x56, 0xbf, 0x10, 0x33, 0x38, 0xf4, 0x6c, 0x7a, 0x86, 0x8b, 0x6a, 0x36, 0x47, 0xa6, 0x15, 0x36, 0x59, 0x61, 0xeb, 0xda, 0x1a, 0xbf, 0xbd,
0x7d, 0xeb, 0x96, 0x46, 0x8f, 0x02, 0xb5, 0xc3, 0x78, 0x0d, 0x71, 0x6f, 0xaf, 0xa3, 0x3c, 0x2a, 0xd7, 0xdf, 0x87, 0xdf, 0x11, 0x9c, 0x3e, 0x5b, 0xad, 0xa9, 0x60, 0x52, 0x13, 0x64, 0x14, 0x12,
0x8e, 0x66, 0xba, 0x1c, 0x78, 0x96, 0xfd, 0xb3, 0xb0, 0xe2, 0xba, 0x2a, 0xa8, 0xf0, 0x1c, 0x52, 0x8e, 0x70, 0x4e, 0x86, 0xa7, 0x4a, 0x46, 0x83, 0x68, 0xd4, 0xcf, 0xb7, 0x52, 0x24, 0x70, 0xec,
0x2f, 0xe4, 0x64, 0x4e, 0xc2, 0x3a, 0xce, 0x55, 0x11, 0x55, 0x7f, 0x07, 0xbc, 0x00, 0x78, 0xa9, 0xc9, 0x78, 0xeb, 0xa6, 0x4a, 0x76, 0x82, 0xb5, 0xd3, 0xe2, 0x16, 0xba, 0x2d, 0x94, 0x8c, 0x07,
0x6d, 0xed, 0xdf, 0x02, 0x9d, 0x04, 0xfa, 0xdf, 0x25, 0xbb, 0x85, 0x74, 0x67, 0x88, 0xa7, 0x10, 0xf1, 0xe8, 0x64, 0x2c, 0xd3, 0xbd, 0x9e, 0x69, 0x7b, 0xbc, 0x18, 0x76, 0x4d, 0x1e, 0x52, 0xe2,
0xbd, 0x73, 0xb7, 0x8d, 0xda, 0x7f, 0xf1, 0x0c, 0x92, 0x2f, 0x6a, 0x3e, 0x79, 0x9b, 0x71, 0x03, 0x12, 0xfa, 0x9e, 0xd1, 0xf1, 0x04, 0x99, 0x64, 0x77, 0x10, 0x8d, 0xe2, 0xfc, 0xb7, 0x20, 0xae,
0xee, 0x47, 0x77, 0x6a, 0xf6, 0x04, 0x71, 0xa8, 0x78, 0x05, 0xe0, 0xd9, 0x9a, 0x47, 0x16, 0x57, 0x00, 0xca, 0xca, 0x54, 0xfe, 0x23, 0xd8, 0xbd, 0x60, 0xff, 0xa9, 0x24, 0xf7, 0xd0, 0xdf, 0x35,
0xaf, 0xf0, 0x64, 0x18, 0x36, 0x1b, 0x97, 0x9b, 0x69, 0x0e, 0xf0, 0x32, 0x14, 0xee, 0x75, 0xb4, 0x14, 0xe7, 0x10, 0x7f, 0x52, 0xb3, 0x41, 0x6d, 0x9f, 0xe2, 0x02, 0x7a, 0x4b, 0xd4, 0x5f, 0xb4,
0x5f, 0xf5, 0x3c, 0x0e, 0x93, 0xde, 0xfc, 0x04, 0x00, 0x00, 0xff, 0xff, 0x16, 0x7f, 0xaf, 0xb1, 0x61, 0x5c, 0x8b, 0xc7, 0xce, 0x43, 0x34, 0xce, 0xa1, 0x1b, 0x46, 0xbc, 0x01, 0xf0, 0x64, 0xd4,
0x60, 0x01, 0x00, 0x00, 0x2b, 0xb1, 0xab, 0x0a, 0x71, 0xb6, 0x0f, 0x9b, 0xf4, 0xd2, 0x37, 0x5b, 0xa9, 0xe1, 0x81, 0xb8,
0x0e, 0xf3, 0xb6, 0x31, 0xfc, 0x37, 0xf4, 0x7e, 0x18, 0xf6, 0x78, 0xf7, 0x13, 0x00, 0x00, 0xff,
0xff, 0x0c, 0xd2, 0x16, 0x23, 0x94, 0x01, 0x00, 0x00,
} }

6
data/data.proto
View File

@ -1,6 +1,6 @@
syntax = "proto3"; syntax = "proto3";
message Empty {} import "loafle.com/overflow/central_api_gateway/commons/commons.proto";
message CollectedData { message CollectedData {
string agentId = 1; string agentId = 1;
@ -11,6 +11,6 @@ message CollectedData {
} }
service Data { service Data {
rpc sendMetric(CollectedData) returns (Empty) {} rpc sendMetric(CollectedData) returns (Void) {}
rpc sendMeta(CollectedData) returns (Empty) {} rpc sendMeta(CollectedData) returns (Void) {}
} }

100
event/event.pb.go
View File

@ -8,7 +8,6 @@ It is generated from these files:
event.proto event.proto
It has these top-level messages: It has these top-level messages:
Empty
TaskResultEvent TaskResultEvent
AgentEvent AgentEvent
*/ */
@ -81,15 +80,7 @@ var AgentEvent_AgentEventType_value = map[string]int32{
func (x AgentEvent_AgentEventType) String() string { func (x AgentEvent_AgentEventType) String() string {
return proto.EnumName(AgentEvent_AgentEventType_name, int32(x)) return proto.EnumName(AgentEvent_AgentEventType_name, int32(x))
} }
func (AgentEvent_AgentEventType) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{2, 0} } func (AgentEvent_AgentEventType) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{1, 0} }
type Empty struct {
}
func (m *Empty) Reset() { *m = Empty{} }
func (m *Empty) String() string { return proto.CompactTextString(m) }
func (*Empty) ProtoMessage() {}
func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
type TaskResultEvent struct { type TaskResultEvent struct {
AgentId string `protobuf:"bytes,1,opt,name=agentId" json:"agentId,omitempty"` AgentId string `protobuf:"bytes,1,opt,name=agentId" json:"agentId,omitempty"`
@ -103,7 +94,7 @@ type TaskResultEvent struct {
func (m *TaskResultEvent) Reset() { *m = TaskResultEvent{} } func (m *TaskResultEvent) Reset() { *m = TaskResultEvent{} }
func (m *TaskResultEvent) String() string { return proto.CompactTextString(m) } func (m *TaskResultEvent) String() string { return proto.CompactTextString(m) }
func (*TaskResultEvent) ProtoMessage() {} func (*TaskResultEvent) ProtoMessage() {}
func (*TaskResultEvent) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} } func (*TaskResultEvent) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
func (m *TaskResultEvent) GetAgentId() string { func (m *TaskResultEvent) GetAgentId() string {
if m != nil { if m != nil {
@ -158,7 +149,7 @@ type AgentEvent struct {
func (m *AgentEvent) Reset() { *m = AgentEvent{} } func (m *AgentEvent) Reset() { *m = AgentEvent{} }
func (m *AgentEvent) String() string { return proto.CompactTextString(m) } func (m *AgentEvent) String() string { return proto.CompactTextString(m) }
func (*AgentEvent) ProtoMessage() {} func (*AgentEvent) ProtoMessage() {}
func (*AgentEvent) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} } func (*AgentEvent) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
func (m *AgentEvent) GetAgentId() string { func (m *AgentEvent) GetAgentId() string {
if m != nil { if m != nil {
@ -204,7 +195,7 @@ type AgentEvent_ErrorInfo struct {
func (m *AgentEvent_ErrorInfo) Reset() { *m = AgentEvent_ErrorInfo{} } func (m *AgentEvent_ErrorInfo) Reset() { *m = AgentEvent_ErrorInfo{} }
func (m *AgentEvent_ErrorInfo) String() string { return proto.CompactTextString(m) } func (m *AgentEvent_ErrorInfo) String() string { return proto.CompactTextString(m) }
func (*AgentEvent_ErrorInfo) ProtoMessage() {} func (*AgentEvent_ErrorInfo) ProtoMessage() {}
func (*AgentEvent_ErrorInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2, 0} } func (*AgentEvent_ErrorInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1, 0} }
func (m *AgentEvent_ErrorInfo) GetErrorNum() int32 { func (m *AgentEvent_ErrorInfo) GetErrorNum() int32 {
if m != nil { if m != nil {
@ -228,7 +219,6 @@ func (m *AgentEvent_ErrorInfo) GetErrorMessage() string {
} }
func init() { func init() {
proto.RegisterType((*Empty)(nil), "Empty")
proto.RegisterType((*TaskResultEvent)(nil), "TaskResultEvent") proto.RegisterType((*TaskResultEvent)(nil), "TaskResultEvent")
proto.RegisterType((*AgentEvent)(nil), "AgentEvent") proto.RegisterType((*AgentEvent)(nil), "AgentEvent")
proto.RegisterType((*AgentEvent_ErrorInfo)(nil), "AgentEvent.ErrorInfo") proto.RegisterType((*AgentEvent_ErrorInfo)(nil), "AgentEvent.ErrorInfo")
@ -247,7 +237,7 @@ const _ = grpc.SupportPackageIsVersion4
// Client API for TaskResult service // Client API for TaskResult service
type TaskResultClient interface { type TaskResultClient interface {
Event(ctx context.Context, in *TaskResultEvent, opts ...grpc.CallOption) (*Empty, error) Event(ctx context.Context, in *TaskResultEvent, opts ...grpc.CallOption) (*commons.Void, error)
} }
type taskResultClient struct { type taskResultClient struct {
@ -258,8 +248,8 @@ func NewTaskResultClient(cc *grpc.ClientConn) TaskResultClient {
return &taskResultClient{cc} return &taskResultClient{cc}
} }
func (c *taskResultClient) Event(ctx context.Context, in *TaskResultEvent, opts ...grpc.CallOption) (*Empty, error) { func (c *taskResultClient) Event(ctx context.Context, in *TaskResultEvent, opts ...grpc.CallOption) (*commons.Void, error) {
out := new(Empty) out := new(commons.Void)
err := grpc.Invoke(ctx, "/TaskResult/event", in, out, c.cc, opts...) err := grpc.Invoke(ctx, "/TaskResult/event", in, out, c.cc, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
@ -270,7 +260,7 @@ func (c *taskResultClient) Event(ctx context.Context, in *TaskResultEvent, opts
// Server API for TaskResult service // Server API for TaskResult service
type TaskResultServer interface { type TaskResultServer interface {
Event(context.Context, *TaskResultEvent) (*Empty, error) Event(context.Context, *TaskResultEvent) (*commons.Void, error)
} }
func RegisterTaskResultServer(s *grpc.Server, srv TaskResultServer) { func RegisterTaskResultServer(s *grpc.Server, srv TaskResultServer) {
@ -311,7 +301,7 @@ var _TaskResult_serviceDesc = grpc.ServiceDesc{
// Client API for Event service // Client API for Event service
type EventClient interface { type EventClient interface {
Event(ctx context.Context, in *AgentEvent, opts ...grpc.CallOption) (*Empty, error) Event(ctx context.Context, in *AgentEvent, opts ...grpc.CallOption) (*commons.Void, error)
} }
type eventClient struct { type eventClient struct {
@ -322,8 +312,8 @@ func NewEventClient(cc *grpc.ClientConn) EventClient {
return &eventClient{cc} return &eventClient{cc}
} }
func (c *eventClient) Event(ctx context.Context, in *AgentEvent, opts ...grpc.CallOption) (*Empty, error) { func (c *eventClient) Event(ctx context.Context, in *AgentEvent, opts ...grpc.CallOption) (*commons.Void, error) {
out := new(Empty) out := new(commons.Void)
err := grpc.Invoke(ctx, "/Event/event", in, out, c.cc, opts...) err := grpc.Invoke(ctx, "/Event/event", in, out, c.cc, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
@ -334,7 +324,7 @@ func (c *eventClient) Event(ctx context.Context, in *AgentEvent, opts ...grpc.Ca
// Server API for Event service // Server API for Event service
type EventServer interface { type EventServer interface {
Event(context.Context, *AgentEvent) (*Empty, error) Event(context.Context, *AgentEvent) (*commons.Void, error)
} }
func RegisterEventServer(s *grpc.Server, srv EventServer) { func RegisterEventServer(s *grpc.Server, srv EventServer) {
@ -375,37 +365,37 @@ var _Event_serviceDesc = grpc.ServiceDesc{
func init() { proto.RegisterFile("event.proto", fileDescriptor0) } func init() { proto.RegisterFile("event.proto", fileDescriptor0) }
var fileDescriptor0 = []byte{ var fileDescriptor0 = []byte{
// 505 bytes of a gzipped FileDescriptorProto // 500 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x53, 0xcf, 0x8f, 0x93, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x53, 0x5d, 0x8b, 0xd3, 0x40,
0x14, 0x5e, 0x68, 0xa1, 0xf6, 0xa1, 0x5d, 0x9c, 0xa8, 0x21, 0x1c, 0x4c, 0x53, 0x0f, 0x12, 0x0f, 0x14, 0xdd, 0xa4, 0x4d, 0x6b, 0x6f, 0xb4, 0x1b, 0x07, 0x95, 0x10, 0x10, 0x42, 0x1e, 0x24, 0xf8,
0x34, 0x56, 0x13, 0xcd, 0x26, 0x1e, 0x9a, 0x2d, 0x6e, 0x48, 0xb4, 0xdd, 0x4c, 0xf1, 0xdc, 0x8c, 0x90, 0x4a, 0x14, 0x94, 0x05, 0x1f, 0xca, 0x26, 0x2e, 0x01, 0x6d, 0x97, 0x69, 0xf4, 0xb5, 0x8c,
0x30, 0x6d, 0x9a, 0x02, 0x43, 0x86, 0x69, 0x37, 0xfc, 0x3f, 0xfe, 0x95, 0x9e, 0x0c, 0x03, 0x14, 0xc9, 0xb4, 0x94, 0x26, 0x99, 0x32, 0x99, 0x76, 0xe9, 0xff, 0xf1, 0x57, 0xfa, 0x24, 0x99, 0x24,
0xba, 0x31, 0x7a, 0xe2, 0x7d, 0xdf, 0xfb, 0x31, 0xef, 0x7d, 0xbc, 0x07, 0x06, 0x3d, 0xd1, 0x54, 0x6d, 0xba, 0x88, 0x3e, 0xf5, 0x9e, 0x73, 0x3f, 0x7a, 0xcf, 0xc9, 0x1d, 0xd0, 0xe9, 0x81, 0x16,
0xb8, 0x19, 0x67, 0x82, 0xd9, 0x5f, 0x62, 0x46, 0xb6, 0x31, 0x75, 0x43, 0x96, 0x4c, 0xd9, 0x89, 0xc2, 0xdb, 0x71, 0x26, 0x98, 0xf5, 0x39, 0x63, 0x64, 0x95, 0x51, 0x2f, 0x61, 0xf9, 0x84, 0x1d,
0xf2, 0x6d, 0xcc, 0x1e, 0xa6, 0x21, 0x4d, 0x05, 0x27, 0xf1, 0x86, 0x64, 0xfb, 0xcd, 0x8e, 0x08, 0x28, 0x5f, 0x65, 0xec, 0x61, 0x92, 0xd0, 0x42, 0x70, 0x92, 0x2d, 0xc9, 0x6e, 0xb3, 0x5c, 0x13,
0xfa, 0x40, 0x8a, 0x69, 0xc8, 0x92, 0x84, 0xa5, 0x79, 0xf3, 0xad, 0xd2, 0x27, 0x03, 0xd0, 0xbc, 0x41, 0x1f, 0xc8, 0x71, 0x92, 0xb0, 0x3c, 0x67, 0x45, 0xd9, 0xfe, 0xd6, 0xed, 0xce, 0x2f, 0x15,
0x24, 0x13, 0xc5, 0xe4, 0x97, 0x0a, 0xd7, 0x01, 0xc9, 0x0f, 0x98, 0xe6, 0xc7, 0x58, 0x78, 0xe5, 0xae, 0x63, 0x52, 0x6e, 0x31, 0x2d, 0xf7, 0x99, 0x08, 0xab, 0xc1, 0xc8, 0x84, 0x21, 0x59, 0xd3,
0x0b, 0xc8, 0x82, 0x01, 0xd9, 0xd1, 0x54, 0xf8, 0x91, 0xa5, 0x8c, 0x15, 0x67, 0x88, 0x1b, 0x88, 0x42, 0x44, 0xa9, 0xa9, 0xd8, 0x8a, 0x3b, 0xc2, 0x2d, 0x44, 0xaf, 0x60, 0x20, 0x48, 0xb9, 0x8d,
0x5e, 0x81, 0x2e, 0x48, 0x7e, 0xf0, 0x23, 0x4b, 0x95, 0x8e, 0x1a, 0x21, 0x07, 0x06, 0xf4, 0x24, 0x52, 0x53, 0x95, 0x89, 0x06, 0x21, 0x17, 0x86, 0xf4, 0x20, 0xe2, 0xe3, 0x8e, 0x9a, 0x3d, 0x5b,
0x82, 0x22, 0xa3, 0x56, 0x6f, 0xac, 0x38, 0xa3, 0xd9, 0xc8, 0x2d, 0x8b, 0xca, 0x72, 0x25, 0x8b, 0x71, 0xc7, 0xfe, 0xd8, 0xab, 0x86, 0xca, 0x71, 0x15, 0x8b, 0xdb, 0x34, 0x72, 0xe0, 0x29, 0x4b,
0x1b, 0x37, 0x9a, 0xc0, 0x53, 0x16, 0x86, 0x47, 0xce, 0x69, 0xb4, 0x20, 0x82, 0x5a, 0xfd, 0xb1, 0x92, 0x3d, 0xe7, 0x34, 0x0d, 0x88, 0xa0, 0x66, 0xdf, 0x56, 0xdc, 0x1e, 0xbe, 0xe0, 0x90, 0x0b,
0xe2, 0xf4, 0xf0, 0x05, 0x87, 0x1c, 0xd0, 0xb9, 0x6c, 0xc7, 0xd2, 0x64, 0x31, 0xd3, 0x6d, 0x3b, 0x03, 0x2e, 0xd7, 0x31, 0x35, 0x39, 0xcc, 0xf0, 0xce, 0x1b, 0x2e, 0x04, 0x11, 0x14, 0x37, 0x79,
0x5c, 0x0b, 0x22, 0x28, 0xae, 0xfd, 0xc8, 0x85, 0x7e, 0x44, 0x04, 0xb1, 0xf4, 0x71, 0xcf, 0x31, 0xe4, 0x41, 0x3f, 0x25, 0x82, 0x98, 0x03, 0xbb, 0xe7, 0xea, 0xbe, 0xe5, 0x3d, 0x52, 0xe2, 0x05,
0x66, 0xb6, 0xfb, 0x68, 0x12, 0x77, 0x41, 0x04, 0xf1, 0x52, 0xc1, 0x0b, 0x2c, 0xe3, 0xec, 0x4f, 0x44, 0x90, 0xb0, 0x10, 0xfc, 0x88, 0x65, 0x9d, 0xf5, 0x11, 0x46, 0x27, 0x0a, 0x19, 0xd0, 0xdb,
0x30, 0x3c, 0x53, 0xc8, 0x84, 0xde, 0x81, 0x16, 0xf5, 0x88, 0xa5, 0x89, 0x5e, 0x80, 0x76, 0x22, 0xd2, 0x63, 0x23, 0xb1, 0x0a, 0xd1, 0x0b, 0xd0, 0x0e, 0x24, 0xdb, 0xd3, 0x46, 0x5d, 0x0d, 0x6e,
0xf1, 0x91, 0xd6, 0xd3, 0x55, 0xe0, 0x46, 0xfd, 0xac, 0x4c, 0x7e, 0xab, 0x00, 0xf3, 0x52, 0x84, 0xd4, 0x4f, 0x8a, 0xf3, 0x5b, 0x05, 0x98, 0x56, 0x26, 0xfc, 0xcf, 0xa1, 0x0f, 0x67, 0x27, 0x54,
0xff, 0x29, 0xf4, 0xb1, 0x55, 0x42, 0x95, 0xcd, 0xdb, 0x6e, 0x9b, 0xd7, 0x31, 0xff, 0xad, 0x4a, 0xb9, 0xbc, 0xe5, 0x9d, 0xfb, 0x3a, 0xe1, 0xbf, 0x5d, 0xe9, 0xfd, 0xc5, 0x15, 0x1b, 0xf4, 0x94,
0xef, 0x2f, 0xaa, 0x8c, 0xc1, 0x88, 0x68, 0x1e, 0xf2, 0x7d, 0x26, 0xf6, 0x2c, 0x95, 0xc2, 0x0d, 0x96, 0x09, 0xdf, 0xec, 0xc4, 0x86, 0x15, 0xd2, 0xb8, 0x11, 0xee, 0x52, 0x68, 0x02, 0x43, 0xca,
0x71, 0x97, 0x42, 0x53, 0x18, 0x50, 0xce, 0xfd, 0x74, 0xcb, 0xa4, 0x70, 0xc6, 0xec, 0x65, 0xf7, 0x79, 0x54, 0xac, 0x98, 0x34, 0x4e, 0xf7, 0x5f, 0x76, 0xff, 0x3b, 0xe4, 0x9c, 0xc9, 0x24, 0x6e,
0x6d, 0x8f, 0x73, 0x26, 0x9d, 0xb8, 0x89, 0xb2, 0x37, 0x30, 0x3c, 0xb3, 0xc8, 0x86, 0x27, 0xb4, 0xab, 0xac, 0x25, 0x8c, 0x4e, 0x2c, 0xb2, 0xe0, 0x09, 0xad, 0xc0, 0x6c, 0x9f, 0x4b, 0x51, 0x1a,
0x04, 0xcb, 0x63, 0x22, 0x87, 0xd2, 0xf0, 0x19, 0x23, 0x04, 0xfd, 0x2d, 0x67, 0x49, 0xad, 0x8b, 0x3e, 0x61, 0x84, 0xa0, 0xbf, 0xe2, 0x2c, 0x6f, 0x7c, 0x91, 0x71, 0xb5, 0xb3, 0xcc, 0x7f, 0xa3,
0xb4, 0xcb, 0x9e, 0xa5, 0xff, 0x3b, 0xcd, 0x73, 0xb2, 0xab, 0x7a, 0x1e, 0xe2, 0x0b, 0x6e, 0xb2, 0x65, 0x49, 0xd6, 0xf5, 0xce, 0x23, 0x7c, 0xc1, 0x39, 0x01, 0x8c, 0x2f, 0x25, 0xa3, 0xe7, 0xf0,
0x80, 0xd1, 0xe5, 0xc8, 0xe8, 0x39, 0x3c, 0x9b, 0xdf, 0x79, 0xcb, 0x60, 0xb3, 0x0e, 0xe6, 0x38, 0x6c, 0x7a, 0x17, 0xce, 0xe2, 0xe5, 0x22, 0x9e, 0xe2, 0x38, 0x0c, 0x8c, 0x2b, 0x74, 0x0d, 0x7a,
0xf0, 0x16, 0xe6, 0x15, 0xba, 0x06, 0xa3, 0xa2, 0x3c, 0x8c, 0x57, 0xd8, 0x54, 0xd0, 0x08, 0xa0, 0x4d, 0x85, 0x18, 0xcf, 0xb1, 0xa1, 0xa0, 0x31, 0x40, 0x5b, 0x33, 0xbf, 0x37, 0xd4, 0xb7, 0x37,
0x89, 0x59, 0xdd, 0x9b, 0xea, 0xbb, 0x9b, 0xee, 0x8a, 0xca, 0x05, 0x40, 0x00, 0xfa, 0xd7, 0xb9, 0xdd, 0x13, 0x95, 0x07, 0x80, 0x00, 0x06, 0x5f, 0xa6, 0xd1, 0x57, 0xd9, 0xaf, 0xc3, 0x70, 0xf1,
0xff, 0x4d, 0xe6, 0x1b, 0x30, 0x58, 0xff, 0xb8, 0xbd, 0xf5, 0xbc, 0x45, 0x95, 0x7b, 0x8f, 0x57, 0xfd, 0xf6, 0x36, 0x0c, 0x83, 0xba, 0xf7, 0x1e, 0xcf, 0x2b, 0x10, 0xcd, 0xee, 0x0c, 0xd5, 0x7f,
0x25, 0xf0, 0x97, 0x77, 0xa6, 0x3a, 0x7b, 0x0f, 0xd0, 0xe6, 0xa2, 0x37, 0xa0, 0xc9, 0x23, 0x42, 0x07, 0x70, 0xee, 0x45, 0x0e, 0x68, 0xf2, 0xed, 0x20, 0xe3, 0xf1, 0xa9, 0x58, 0x9a, 0xf7, 0x83,
0xe6, 0xe3, 0x55, 0xb1, 0x75, 0xb7, 0x3a, 0x88, 0xab, 0xd9, 0x5b, 0xd0, 0xaa, 0xbf, 0xfc, 0xba, 0x6d, 0x52, 0xe7, 0xca, 0x7f, 0x03, 0x5a, 0xfd, 0x91, 0x5f, 0xb7, 0xc5, 0x7a, 0xc7, 0xc6, 0x53,
0x89, 0x36, 0x3a, 0x3a, 0xb6, 0x81, 0x3f, 0x75, 0x79, 0x4b, 0x1f, 0xfe, 0x04, 0x00, 0x00, 0xff, 0xdd, 0xcf, 0x81, 0x7c, 0x40, 0xef, 0xff, 0x04, 0x00, 0x00, 0xff, 0xff, 0xed, 0xf8, 0xb5, 0x83,
0xff, 0xbc, 0xba, 0xfc, 0x41, 0x99, 0x03, 0x00, 0x00, 0x8e, 0x03, 0x00, 0x00,
} }

6
event/event.proto
View File

@ -2,8 +2,6 @@ syntax = "proto3";
import "loafle.com/overflow/central_api_gateway/commons/commons.proto"; import "loafle.com/overflow/central_api_gateway/commons/commons.proto";
message Empty {}
enum TaskResultState { enum TaskResultState {
FAILED = 0; FAILED = 0;
SUCCEED = 1; SUCCEED = 1;
@ -20,7 +18,7 @@ message TaskResultEvent {
} }
service TaskResult { service TaskResult {
rpc event(TaskResultEvent) returns (Empty){} rpc event(TaskResultEvent) returns (Void){}
} }
@ -43,6 +41,6 @@ message AgentEvent {
} }
service Event { service Event {
rpc event(AgentEvent) returns (Empty){} rpc event(AgentEvent) returns (Void){}
} }
//Event-relative area //Event-relative area

33
initialize/initialize.pb.go
View File

@ -8,7 +8,6 @@ It is generated from these files:
initialize.proto initialize.proto
It has these top-level messages: It has these top-level messages:
Empty
AgentInfo AgentInfo
InitResponse InitResponse
*/ */
@ -34,14 +33,6 @@ var _ = math.Inf
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
type Empty struct {
}
func (m *Empty) Reset() { *m = Empty{} }
func (m *Empty) String() string { return proto.CompactTextString(m) }
func (*Empty) ProtoMessage() {}
func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
type AgentInfo struct { type AgentInfo struct {
AgentId string `protobuf:"bytes,1,opt,name=agentId" json:"agentId,omitempty"` AgentId string `protobuf:"bytes,1,opt,name=agentId" json:"agentId,omitempty"`
} }
@ -49,7 +40,7 @@ type AgentInfo struct {
func (m *AgentInfo) Reset() { *m = AgentInfo{} } func (m *AgentInfo) Reset() { *m = AgentInfo{} }
func (m *AgentInfo) String() string { return proto.CompactTextString(m) } func (m *AgentInfo) String() string { return proto.CompactTextString(m) }
func (*AgentInfo) ProtoMessage() {} func (*AgentInfo) ProtoMessage() {}
func (*AgentInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} } func (*AgentInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
func (m *AgentInfo) GetAgentId() string { func (m *AgentInfo) GetAgentId() string {
if m != nil { if m != nil {
@ -65,7 +56,7 @@ type InitResponse struct {
func (m *InitResponse) Reset() { *m = InitResponse{} } func (m *InitResponse) Reset() { *m = InitResponse{} }
func (m *InitResponse) String() string { return proto.CompactTextString(m) } func (m *InitResponse) String() string { return proto.CompactTextString(m) }
func (*InitResponse) ProtoMessage() {} func (*InitResponse) ProtoMessage() {}
func (*InitResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} } func (*InitResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
func (m *InitResponse) GetSecretKey() string { func (m *InitResponse) GetSecretKey() string {
if m != nil { if m != nil {
@ -75,7 +66,6 @@ func (m *InitResponse) GetSecretKey() string {
} }
func init() { func init() {
proto.RegisterType((*Empty)(nil), "Empty")
proto.RegisterType((*AgentInfo)(nil), "AgentInfo") proto.RegisterType((*AgentInfo)(nil), "AgentInfo")
proto.RegisterType((*InitResponse)(nil), "InitResponse") proto.RegisterType((*InitResponse)(nil), "InitResponse")
} }
@ -155,15 +145,14 @@ var _Initializer_serviceDesc = grpc.ServiceDesc{
func init() { proto.RegisterFile("initialize.proto", fileDescriptor0) } func init() { proto.RegisterFile("initialize.proto", fileDescriptor0) }
var fileDescriptor0 = []byte{ var fileDescriptor0 = []byte{
// 153 bytes of a gzipped FileDescriptorProto // 144 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0xc8, 0xcc, 0xcb, 0x2c, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0xc8, 0xcc, 0xcb, 0x2c,
0xc9, 0x4c, 0xcc, 0xc9, 0xac, 0x4a, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x57, 0x62, 0xe7, 0x62, 0xc9, 0x4c, 0xcc, 0xc9, 0xac, 0x4a, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x57, 0x52, 0xe5, 0xe2,
0x75, 0xcd, 0x2d, 0x28, 0xa9, 0x54, 0x52, 0xe5, 0xe2, 0x74, 0x4c, 0x4f, 0xcd, 0x2b, 0xf1, 0xcc, 0x74, 0x4c, 0x4f, 0xcd, 0x2b, 0xf1, 0xcc, 0x4b, 0xcb, 0x17, 0x92, 0xe0, 0x62, 0x4f, 0x04, 0x73,
0x4b, 0xcb, 0x17, 0x92, 0xe0, 0x62, 0x4f, 0x04, 0x73, 0x52, 0x24, 0x18, 0x15, 0x18, 0x35, 0x38, 0x52, 0x24, 0x18, 0x15, 0x18, 0x35, 0x38, 0x83, 0x60, 0x5c, 0x25, 0x1d, 0x2e, 0x1e, 0xcf, 0xbc,
0x83, 0x60, 0x5c, 0x25, 0x1d, 0x2e, 0x1e, 0xcf, 0xbc, 0xcc, 0x92, 0xa0, 0xd4, 0xe2, 0x82, 0xfc, 0xcc, 0x92, 0xa0, 0xd4, 0xe2, 0x82, 0xfc, 0xbc, 0xe2, 0x54, 0x21, 0x19, 0x2e, 0xce, 0xe2, 0xd4,
0xbc, 0xe2, 0x54, 0x21, 0x19, 0x2e, 0xce, 0xe2, 0xd4, 0xe4, 0xa2, 0xd4, 0x12, 0xef, 0xd4, 0x4a, 0xe4, 0xa2, 0xd4, 0x12, 0xef, 0xd4, 0x4a, 0xa8, 0x5a, 0x84, 0x80, 0x91, 0x35, 0x17, 0xb7, 0x27,
0xa8, 0x5a, 0x84, 0x80, 0x91, 0x35, 0x17, 0xb7, 0x27, 0xdc, 0xc6, 0x22, 0x21, 0x1d, 0x2e, 0x5e, 0xdc, 0xa2, 0x22, 0x21, 0x1d, 0x2e, 0x5e, 0xb0, 0x39, 0xc1, 0x25, 0x89, 0x45, 0x25, 0x99, 0x79,
0xb0, 0x39, 0xc1, 0x25, 0x89, 0x45, 0x25, 0x99, 0x79, 0xe9, 0x42, 0x5c, 0x7a, 0x70, 0x3b, 0xa5, 0xe9, 0x42, 0x5c, 0x7a, 0x70, 0x3b, 0xa5, 0x78, 0xf5, 0x90, 0x0d, 0x56, 0x62, 0x48, 0x62, 0x03,
0x78, 0xf5, 0x90, 0x0d, 0x56, 0x62, 0x48, 0x62, 0x03, 0xbb, 0xd0, 0x18, 0x10, 0x00, 0x00, 0xff, 0x3b, 0xcc, 0x18, 0x10, 0x00, 0x00, 0xff, 0xff, 0x40, 0x04, 0xea, 0x0a, 0xac, 0x00, 0x00, 0x00,
0xff, 0x10, 0x56, 0xdb, 0xad, 0xb5, 0x00, 0x00, 0x00,
} }

1
initialize/initialize.proto
View File

@ -1,6 +1,5 @@
syntax = "proto3"; syntax = "proto3";
message Empty {}
message AgentInfo { message AgentInfo {
string agentId = 1; string agentId = 1;

61
task/task.pb.go
View File

@ -8,7 +8,6 @@ It is generated from these files:
task.proto task.proto
It has these top-level messages: It has these top-level messages:
Empty
TaskInfo TaskInfo
TaskList TaskList
*/ */
@ -35,14 +34,6 @@ var _ = math.Inf
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
type Empty struct {
}
func (m *Empty) Reset() { *m = Empty{} }
func (m *Empty) String() string { return proto.CompactTextString(m) }
func (*Empty) ProtoMessage() {}
func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
type TaskInfo struct { type TaskInfo struct {
Command commons.TaskEventType `protobuf:"varint,1,opt,name=command,enum=TaskEventType" json:"command,omitempty"` Command commons.TaskEventType `protobuf:"varint,1,opt,name=command,enum=TaskEventType" json:"command,omitempty"`
TaskId string `protobuf:"bytes,2,opt,name=taskId" json:"taskId,omitempty"` TaskId string `protobuf:"bytes,2,opt,name=taskId" json:"taskId,omitempty"`
@ -52,7 +43,7 @@ type TaskInfo struct {
func (m *TaskInfo) Reset() { *m = TaskInfo{} } func (m *TaskInfo) Reset() { *m = TaskInfo{} }
func (m *TaskInfo) String() string { return proto.CompactTextString(m) } func (m *TaskInfo) String() string { return proto.CompactTextString(m) }
func (*TaskInfo) ProtoMessage() {} func (*TaskInfo) ProtoMessage() {}
func (*TaskInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} } func (*TaskInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
func (m *TaskInfo) GetCommand() commons.TaskEventType { func (m *TaskInfo) GetCommand() commons.TaskEventType {
if m != nil { if m != nil {
@ -82,7 +73,7 @@ type TaskList struct {
func (m *TaskList) Reset() { *m = TaskList{} } func (m *TaskList) Reset() { *m = TaskList{} }
func (m *TaskList) String() string { return proto.CompactTextString(m) } func (m *TaskList) String() string { return proto.CompactTextString(m) }
func (*TaskList) ProtoMessage() {} func (*TaskList) ProtoMessage() {}
func (*TaskList) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} } func (*TaskList) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
func (m *TaskList) GetTaskList() []*TaskInfo { func (m *TaskList) GetTaskList() []*TaskInfo {
if m != nil { if m != nil {
@ -92,7 +83,6 @@ func (m *TaskList) GetTaskList() []*TaskInfo {
} }
func init() { func init() {
proto.RegisterType((*Empty)(nil), "Empty")
proto.RegisterType((*TaskInfo)(nil), "TaskInfo") proto.RegisterType((*TaskInfo)(nil), "TaskInfo")
proto.RegisterType((*TaskList)(nil), "TaskList") proto.RegisterType((*TaskList)(nil), "TaskList")
} }
@ -108,7 +98,7 @@ const _ = grpc.SupportPackageIsVersion4
// Client API for Task service // Client API for Task service
type TaskClient interface { type TaskClient interface {
RequestTask(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TaskList, error) RequestTask(ctx context.Context, in *commons.Void, opts ...grpc.CallOption) (*TaskList, error)
} }
type taskClient struct { type taskClient struct {
@ -119,7 +109,7 @@ func NewTaskClient(cc *grpc.ClientConn) TaskClient {
return &taskClient{cc} return &taskClient{cc}
} }
func (c *taskClient) RequestTask(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TaskList, error) { func (c *taskClient) RequestTask(ctx context.Context, in *commons.Void, opts ...grpc.CallOption) (*TaskList, error) {
out := new(TaskList) out := new(TaskList)
err := grpc.Invoke(ctx, "/Task/requestTask", in, out, c.cc, opts...) err := grpc.Invoke(ctx, "/Task/requestTask", in, out, c.cc, opts...)
if err != nil { if err != nil {
@ -131,7 +121,7 @@ func (c *taskClient) RequestTask(ctx context.Context, in *Empty, opts ...grpc.Ca
// Server API for Task service // Server API for Task service
type TaskServer interface { type TaskServer interface {
RequestTask(context.Context, *Empty) (*TaskList, error) RequestTask(context.Context, *commons.Void) (*TaskList, error)
} }
func RegisterTaskServer(s *grpc.Server, srv TaskServer) { func RegisterTaskServer(s *grpc.Server, srv TaskServer) {
@ -139,7 +129,7 @@ func RegisterTaskServer(s *grpc.Server, srv TaskServer) {
} }
func _Task_RequestTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func _Task_RequestTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(Empty) in := new(commons.Void)
if err := dec(in); err != nil { if err := dec(in); err != nil {
return nil, err return nil, err
} }
@ -151,7 +141,7 @@ func _Task_RequestTask_Handler(srv interface{}, ctx context.Context, dec func(in
FullMethod: "/Task/RequestTask", FullMethod: "/Task/RequestTask",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(TaskServer).RequestTask(ctx, req.(*Empty)) return srv.(TaskServer).RequestTask(ctx, req.(*commons.Void))
} }
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
@ -172,23 +162,22 @@ var _Task_serviceDesc = grpc.ServiceDesc{
func init() { proto.RegisterFile("task.proto", fileDescriptor0) } func init() { proto.RegisterFile("task.proto", fileDescriptor0) }
var fileDescriptor0 = []byte{ var fileDescriptor0 = []byte{
// 276 bytes of a gzipped FileDescriptorProto // 271 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x3c, 0x50, 0xcd, 0x6a, 0xf3, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x3c, 0x90, 0x4f, 0x4b, 0xc3, 0x40,
0x0c, 0xfc, 0x36, 0xff, 0x56, 0x20, 0x7c, 0x6c, 0x4b, 0x31, 0x39, 0x05, 0x43, 0xa9, 0xe9, 0x61, 0x10, 0xc5, 0xdd, 0xfe, 0xb3, 0x99, 0x42, 0x91, 0x55, 0x24, 0xf4, 0x54, 0x03, 0x62, 0xbc, 0x6c,
0x43, 0xdd, 0x43, 0x4b, 0xa1, 0xb7, 0xfa, 0x10, 0xe8, 0xc9, 0xe4, 0x1e, 0x54, 0x7b, 0x5d, 0x82, 0x30, 0x1e, 0x14, 0xc1, 0x9b, 0x3d, 0x14, 0x3c, 0x85, 0xe2, 0xb5, 0x8c, 0xc9, 0x46, 0x42, 0x92,
0xed, 0x5d, 0xd7, 0x56, 0x1c, 0xfc, 0x52, 0x7d, 0xc6, 0xb2, 0xeb, 0x9f, 0x93, 0x34, 0x9a, 0x91, 0xdd, 0x98, 0x4c, 0x53, 0xf2, 0xa5, 0xfc, 0x8c, 0xb2, 0xf9, 0x77, 0xda, 0x79, 0xf3, 0x9b, 0x99,
0x46, 0x0c, 0x00, 0x61, 0x9d, 0x89, 0xb2, 0xd2, 0xa4, 0xb7, 0xef, 0xb9, 0xc6, 0x34, 0x97, 0x22, 0xf7, 0x58, 0x00, 0xc2, 0x2a, 0x15, 0x45, 0xa9, 0x49, 0x6f, 0xde, 0x33, 0x8d, 0x71, 0x26, 0x45,
0xd6, 0xc5, 0x5e, 0x37, 0xb2, 0x4a, 0x73, 0x7d, 0xdd, 0xc7, 0x52, 0x51, 0x85, 0xf9, 0x09, 0xcb, 0xa8, 0x73, 0x4f, 0xd7, 0xb2, 0x8c, 0x33, 0x7d, 0xf6, 0x42, 0xa9, 0xa8, 0xc4, 0xec, 0x88, 0x45,
0xf3, 0xe9, 0x1b, 0x49, 0x5e, 0xb1, 0xdd, 0xc7, 0xba, 0x28, 0xb4, 0xaa, 0x87, 0xda, 0xad, 0x7b, 0x72, 0xfc, 0x41, 0x92, 0x67, 0x6c, 0xbc, 0x50, 0xe7, 0xb9, 0x56, 0xd5, 0xf0, 0x76, 0xeb, 0xce,
0x4b, 0x98, 0x87, 0x45, 0x49, 0xad, 0xf7, 0xcb, 0x60, 0x75, 0xc4, 0x3a, 0x3b, 0xa8, 0x54, 0x73, 0x1f, 0x83, 0xe5, 0x01, 0xab, 0x74, 0xaf, 0x62, 0xcd, 0x5d, 0xb8, 0x34, 0x14, 0x55, 0x64, 0xb3,
0x1f, 0x96, 0x46, 0x86, 0x2a, 0x71, 0xd9, 0x8e, 0xf9, 0x9b, 0x60, 0x23, 0x0c, 0x17, 0x36, 0x52, 0x2d, 0x73, 0xd7, 0xfe, 0x5a, 0x18, 0xb6, 0xab, 0xa5, 0xa2, 0x43, 0x53, 0xc8, 0x60, 0xc0, 0xfc,
0xd1, 0xb1, 0x2d, 0x65, 0x34, 0xd0, 0xfc, 0x0e, 0x16, 0xe6, 0x99, 0x43, 0xe2, 0x4e, 0x76, 0xcc, 0x16, 0x16, 0x26, 0xc3, 0x3e, 0xb2, 0x27, 0x5b, 0xe6, 0x5a, 0x41, 0xaf, 0xf8, 0x03, 0xcc, 0x22,
0x77, 0xa2, 0x1e, 0xf1, 0x07, 0x98, 0x25, 0x48, 0xe8, 0x4e, 0x77, 0x53, 0x7f, 0x1d, 0xdc, 0x88, 0x24, 0xb4, 0xa7, 0xdb, 0xa9, 0xbb, 0xf2, 0xaf, 0xc5, 0x70, 0x5a, 0x7c, 0x20, 0xe1, 0x4e, 0x51,
0xe1, 0xb4, 0xf8, 0x40, 0xc2, 0x50, 0x51, 0xd5, 0x46, 0x56, 0xb0, 0x7d, 0x01, 0x67, 0x1c, 0xf1, 0xd9, 0x04, 0xed, 0xc0, 0xe6, 0x05, 0xac, 0xb1, 0xc5, 0xaf, 0x60, 0x9a, 0xca, 0xa6, 0xf5, 0xb4,
0xff, 0x30, 0xcd, 0x64, 0x6b, 0x3d, 0x9d, 0xc8, 0xb4, 0xfc, 0x16, 0xe6, 0x0d, 0xe6, 0x17, 0xd9, 0x02, 0x53, 0xf2, 0x1b, 0x98, 0xd7, 0x98, 0x9d, 0x64, 0x7f, 0xbe, 0x13, 0x6f, 0x93, 0x57, 0xe6,
0x9f, 0xef, 0xc0, 0xdb, 0xe4, 0x95, 0x79, 0x4f, 0xdd, 0xbf, 0x9f, 0xe7, 0x9a, 0xf8, 0x3d, 0xac, 0x3c, 0x75, 0x79, 0x3f, 0x93, 0x8a, 0xf8, 0x3d, 0x2c, 0xa9, 0xaf, 0x6d, 0xd6, 0x3a, 0x5a, 0xa3,
0xa8, 0xef, 0x5d, 0x66, 0x1d, 0x9d, 0xd1, 0x31, 0x1a, 0xa9, 0xe0, 0x11, 0x66, 0x66, 0xca, 0x3d, 0x63, 0x30, 0x22, 0xff, 0x11, 0x66, 0xa6, 0xcb, 0xef, 0x60, 0x55, 0xca, 0xdf, 0x93, 0xac, 0xa8,
0x58, 0x57, 0xf2, 0xe7, 0x22, 0x6b, 0xb2, 0x70, 0x21, 0x6c, 0x04, 0xdb, 0x6e, 0xc7, 0x28, 0xbd, 0x95, 0x73, 0xf1, 0xa5, 0x93, 0x68, 0xd3, 0xad, 0x98, 0x41, 0xe7, 0xe2, 0x7b, 0xd1, 0xfe, 0xca,
0x7f, 0x5f, 0x0b, 0x9b, 0xcf, 0xf3, 0x5f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x5e, 0xaf, 0x68, 0x2f, 0xf3, 0x7f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x5b, 0xb2, 0x5e, 0xe8, 0x62, 0x01, 0x00, 0x00,
0x6c, 0x01, 0x00, 0x00,
} }

3
task/task.proto
View File

@ -2,7 +2,6 @@ syntax = "proto3";
import "loafle.com/overflow/central_api_gateway/commons/commons.proto"; import "loafle.com/overflow/central_api_gateway/commons/commons.proto";
message Empty {}
message TaskInfo { message TaskInfo {
TaskEventType command = 1; TaskEventType command = 1;
@ -15,7 +14,7 @@ message TaskList {
} }
service Task { service Task {
rpc requestTask(Empty) returns (TaskList) {} rpc requestTask(Void) returns (TaskList) {}
} }