diff --git a/commons/cmd b/commons/cmd new file mode 100644 index 0000000..c8674d2 --- /dev/null +++ b/commons/cmd @@ -0,0 +1 @@ +protoc -I commons/ commons/commons.proto --go_out=plugins=grpc:commons diff --git a/commons/commons.pb.go b/commons/commons.pb.go new file mode 100644 index 0000000..430b01d --- /dev/null +++ b/commons/commons.pb.go @@ -0,0 +1,150 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// source: commons.proto + +/* +Package commons is a generated protocol buffer package. + +It is generated from these files: + commons.proto + +It has these top-level messages: +*/ +package commons + +import proto "github.com/golang/protobuf/proto" +import fmt "fmt" +import math "math" + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the proto package it is being compiled against. +// A compilation error at this line likely means your copy of the +// proto package needs to be updated. +const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package + +type DiscoveryEventType int32 + +const ( + DiscoveryEventType_DISCOVERY_START DiscoveryEventType = 0 + DiscoveryEventType_DISCOVERY_HOST_START DiscoveryEventType = 1 + DiscoveryEventType_DISCOVERY_HOST_FOUND DiscoveryEventType = 2 + DiscoveryEventType_DISCOVERY_HOST_DONE DiscoveryEventType = 3 + DiscoveryEventType_DISCOVERY_PORT_START DiscoveryEventType = 4 + DiscoveryEventType_DISCOVERY_PORT_FOUND DiscoveryEventType = 5 + DiscoveryEventType_DISCOVERY_PORT_DONE DiscoveryEventType = 6 + DiscoveryEventType_DISCOVERY_SERVICE_START DiscoveryEventType = 7 + DiscoveryEventType_DISCOVERY_SERVICE_FOUND DiscoveryEventType = 8 + DiscoveryEventType_DISCOVERY_SERVICE_DONE DiscoveryEventType = 9 + DiscoveryEventType_DISCOVERY_DONE DiscoveryEventType = 10 +) + +var DiscoveryEventType_name = map[int32]string{ + 0: "DISCOVERY_START", + 1: "DISCOVERY_HOST_START", + 2: "DISCOVERY_HOST_FOUND", + 3: "DISCOVERY_HOST_DONE", + 4: "DISCOVERY_PORT_START", + 5: "DISCOVERY_PORT_FOUND", + 6: "DISCOVERY_PORT_DONE", + 7: "DISCOVERY_SERVICE_START", + 8: "DISCOVERY_SERVICE_FOUND", + 9: "DISCOVERY_SERVICE_DONE", + 10: "DISCOVERY_DONE", +} +var DiscoveryEventType_value = map[string]int32{ + "DISCOVERY_START": 0, + "DISCOVERY_HOST_START": 1, + "DISCOVERY_HOST_FOUND": 2, + "DISCOVERY_HOST_DONE": 3, + "DISCOVERY_PORT_START": 4, + "DISCOVERY_PORT_FOUND": 5, + "DISCOVERY_PORT_DONE": 6, + "DISCOVERY_SERVICE_START": 7, + "DISCOVERY_SERVICE_FOUND": 8, + "DISCOVERY_SERVICE_DONE": 9, + "DISCOVERY_DONE": 10, +} + +func (x DiscoveryEventType) String() string { + return proto.EnumName(DiscoveryEventType_name, int32(x)) +} +func (DiscoveryEventType) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{0} } + +type TaskEventType int32 + +const ( + TaskEventType_TASK_POL_INTERVAL_UPDATE TaskEventType = 0 + TaskEventType_TASK_SENSOR_START TaskEventType = 1 + TaskEventType_TASK_SENSOR_STOP TaskEventType = 2 + TaskEventType_TASK_SENSOR_ADD TaskEventType = 3 + TaskEventType_TASK_SENSOR_REMOVE TaskEventType = 4 + TaskEventType_TASK_SENSOR_UPDATE TaskEventType = 5 + TaskEventType_TASK_CRAWLER_UPDATE TaskEventType = 6 + TaskEventType_TASK_AGENT_UPDATE TaskEventType = 7 + TaskEventType_TASK_LOG_SEND TaskEventType = 8 + TaskEventType_TASK_DISCOVERY TaskEventType = 9 +) + +var TaskEventType_name = map[int32]string{ + 0: "TASK_POL_INTERVAL_UPDATE", + 1: "TASK_SENSOR_START", + 2: "TASK_SENSOR_STOP", + 3: "TASK_SENSOR_ADD", + 4: "TASK_SENSOR_REMOVE", + 5: "TASK_SENSOR_UPDATE", + 6: "TASK_CRAWLER_UPDATE", + 7: "TASK_AGENT_UPDATE", + 8: "TASK_LOG_SEND", + 9: "TASK_DISCOVERY", +} +var TaskEventType_value = map[string]int32{ + "TASK_POL_INTERVAL_UPDATE": 0, + "TASK_SENSOR_START": 1, + "TASK_SENSOR_STOP": 2, + "TASK_SENSOR_ADD": 3, + "TASK_SENSOR_REMOVE": 4, + "TASK_SENSOR_UPDATE": 5, + "TASK_CRAWLER_UPDATE": 6, + "TASK_AGENT_UPDATE": 7, + "TASK_LOG_SEND": 8, + "TASK_DISCOVERY": 9, +} + +func (x TaskEventType) String() string { + return proto.EnumName(TaskEventType_name, int32(x)) +} +func (TaskEventType) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{1} } + +func init() { + proto.RegisterEnum("DiscoveryEventType", DiscoveryEventType_name, DiscoveryEventType_value) + proto.RegisterEnum("TaskEventType", TaskEventType_name, TaskEventType_value) +} + +func init() { proto.RegisterFile("commons.proto", fileDescriptor0) } + +var fileDescriptor0 = []byte{ + // 302 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0x92, 0xcd, 0x4e, 0xfa, 0x40, + 0x14, 0x47, 0xf9, 0xfa, 0xc3, 0x9f, 0x9b, 0x80, 0xc3, 0x05, 0x81, 0xa8, 0x4f, 0xc0, 0xc2, 0x8d, + 0x4f, 0x30, 0x61, 0xae, 0x48, 0xac, 0x9d, 0x66, 0x66, 0xa8, 0x71, 0xd5, 0x28, 0x61, 0x61, 0x0c, + 0x94, 0x50, 0x42, 0xc2, 0x43, 0xf9, 0x7a, 0xae, 0x4d, 0x87, 0xd2, 0x0f, 0xec, 0xf6, 0x9c, 0xf4, + 0xf4, 0xf6, 0x97, 0x42, 0x67, 0x19, 0xae, 0xd7, 0xe1, 0x26, 0xba, 0xdf, 0xee, 0xc2, 0x7d, 0x38, + 0xf9, 0xae, 0x01, 0x8a, 0xcf, 0x68, 0x19, 0x1e, 0x56, 0xbb, 0x23, 0x1d, 0x56, 0x9b, 0xbd, 0x39, + 0x6e, 0x57, 0xd8, 0x87, 0x2b, 0x31, 0xd7, 0x53, 0xe9, 0x93, 0x7a, 0x0b, 0xb4, 0xe1, 0xca, 0xb0, + 0x0a, 0x8e, 0x61, 0x90, 0xc1, 0x27, 0xa9, 0x4d, 0x62, 0xaa, 0x25, 0xe6, 0x51, 0x2e, 0x5c, 0xc1, + 0x6a, 0x38, 0x82, 0xfe, 0x85, 0x11, 0xd2, 0x25, 0x56, 0x2f, 0x3e, 0xe2, 0x49, 0x75, 0x8e, 0x35, + 0x4a, 0xcc, 0x29, 0xf6, 0xaf, 0x18, 0xb3, 0xc6, 0xc6, 0x9a, 0x78, 0x0b, 0xa3, 0xdc, 0xb9, 0xa4, + 0xfc, 0xf9, 0x94, 0x92, 0x5e, 0xab, 0x5c, 0x9e, 0x92, 0xff, 0xf1, 0x06, 0x86, 0x7f, 0xa5, 0xad, + 0xb6, 0x11, 0xa1, 0x9b, 0x39, 0xcb, 0x60, 0xf2, 0x53, 0x85, 0x8e, 0x79, 0x8f, 0xbe, 0xb2, 0xa9, + 0xee, 0x60, 0x6c, 0xb8, 0x7e, 0x0e, 0x3c, 0xe9, 0x04, 0x73, 0xd7, 0x90, 0xf2, 0xb9, 0x13, 0x2c, + 0x3c, 0xc1, 0x0d, 0xb1, 0x0a, 0x5e, 0x43, 0xcf, 0x5a, 0x4d, 0xae, 0x96, 0x2a, 0x1d, 0x6c, 0x00, + 0xac, 0x88, 0xa5, 0xc7, 0x6a, 0xf1, 0xea, 0x79, 0xca, 0x85, 0x60, 0x75, 0x1c, 0x02, 0xe6, 0xa1, + 0xa2, 0x17, 0xe9, 0x13, 0x6b, 0x5c, 0xf2, 0xe4, 0x8d, 0x76, 0x24, 0xcb, 0xa7, 0x8a, 0xbf, 0x3a, + 0x94, 0x8a, 0x66, 0x7a, 0x0a, 0x9f, 0x91, 0x6b, 0xce, 0xb8, 0x85, 0x3d, 0xe8, 0x58, 0xec, 0xc8, + 0x59, 0xdc, 0x8a, 0x47, 0x41, 0xe8, 0x5a, 0x94, 0x7e, 0x3d, 0x6b, 0x7f, 0x34, 0xed, 0xff, 0xf2, + 0xf0, 0x1b, 0x00, 0x00, 0xff, 0xff, 0x7e, 0x5f, 0x8f, 0x24, 0x40, 0x02, 0x00, 0x00, +} diff --git a/event/cmd b/event/cmd new file mode 100644 index 0000000..9c0385f --- /dev/null +++ b/event/cmd @@ -0,0 +1 @@ +protoc -I$GOPATH/src/ -I event/ event/event.proto --go_out=plugins=grpc:event diff --git a/event/event.pb.go b/event/event.pb.go index 9bab962..cea0b5c 100644 --- a/event/event.pb.go +++ b/event/event.pb.go @@ -9,7 +9,6 @@ It is generated from these files: It has these top-level messages: Empty - DiscoveryEvent TaskResultEvent AgentEvent */ @@ -18,6 +17,7 @@ package event import proto "github.com/golang/protobuf/proto" import fmt "fmt" import math "math" +import commons "loafle.com/overflow/central_api_gateway/commons" import ( context "golang.org/x/net/context" @@ -59,100 +59,6 @@ func (x TaskResultState) String() string { } func (TaskResultState) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{0} } -type DiscoveryEvent_DiscoveryEventType int32 - -const ( - DiscoveryEvent_DISCOVERY_START DiscoveryEvent_DiscoveryEventType = 0 - DiscoveryEvent_DISCOVERY_HOST_START DiscoveryEvent_DiscoveryEventType = 1 - DiscoveryEvent_DISCOVERY_HOST_FOUND DiscoveryEvent_DiscoveryEventType = 2 - DiscoveryEvent_DISCOVERY_HOST_DONE DiscoveryEvent_DiscoveryEventType = 3 - DiscoveryEvent_DISCOVERY_PORT_START DiscoveryEvent_DiscoveryEventType = 4 - DiscoveryEvent_DISCOVERY_PORT_FOUND DiscoveryEvent_DiscoveryEventType = 5 - DiscoveryEvent_DISCOVERY_PORT_DONE DiscoveryEvent_DiscoveryEventType = 6 - DiscoveryEvent_DISCOVERY_SERVICE_START DiscoveryEvent_DiscoveryEventType = 7 - DiscoveryEvent_DISCOVERY_SERVICE_FOUND DiscoveryEvent_DiscoveryEventType = 8 - DiscoveryEvent_DISCOVERY_SERVICE_DONE DiscoveryEvent_DiscoveryEventType = 9 - DiscoveryEvent_DISCOVERY_DONE DiscoveryEvent_DiscoveryEventType = 10 -) - -var DiscoveryEvent_DiscoveryEventType_name = map[int32]string{ - 0: "DISCOVERY_START", - 1: "DISCOVERY_HOST_START", - 2: "DISCOVERY_HOST_FOUND", - 3: "DISCOVERY_HOST_DONE", - 4: "DISCOVERY_PORT_START", - 5: "DISCOVERY_PORT_FOUND", - 6: "DISCOVERY_PORT_DONE", - 7: "DISCOVERY_SERVICE_START", - 8: "DISCOVERY_SERVICE_FOUND", - 9: "DISCOVERY_SERVICE_DONE", - 10: "DISCOVERY_DONE", -} -var DiscoveryEvent_DiscoveryEventType_value = map[string]int32{ - "DISCOVERY_START": 0, - "DISCOVERY_HOST_START": 1, - "DISCOVERY_HOST_FOUND": 2, - "DISCOVERY_HOST_DONE": 3, - "DISCOVERY_PORT_START": 4, - "DISCOVERY_PORT_FOUND": 5, - "DISCOVERY_PORT_DONE": 6, - "DISCOVERY_SERVICE_START": 7, - "DISCOVERY_SERVICE_FOUND": 8, - "DISCOVERY_SERVICE_DONE": 9, - "DISCOVERY_DONE": 10, -} - -func (x DiscoveryEvent_DiscoveryEventType) String() string { - return proto.EnumName(DiscoveryEvent_DiscoveryEventType_name, int32(x)) -} -func (DiscoveryEvent_DiscoveryEventType) EnumDescriptor() ([]byte, []int) { - return fileDescriptor0, []int{1, 0} -} - -type TaskResultEvent_TaskResultEventType int32 - -const ( - TaskResultEvent_TASK_POL_INTERVAL_UPDATE TaskResultEvent_TaskResultEventType = 0 - TaskResultEvent_TASK_SENSOR_START TaskResultEvent_TaskResultEventType = 1 - TaskResultEvent_TASK_SENSOR_STOP TaskResultEvent_TaskResultEventType = 2 - TaskResultEvent_TASK_SENSOR_ADD TaskResultEvent_TaskResultEventType = 3 - TaskResultEvent_TASK_SENSOR_REMOVE TaskResultEvent_TaskResultEventType = 4 - TaskResultEvent_TASK_SENSOR_UPDATE TaskResultEvent_TaskResultEventType = 5 - TaskResultEvent_TASK_CRAWLER_UPDATE TaskResultEvent_TaskResultEventType = 6 - TaskResultEvent_TASK_AGENT_UPDATE TaskResultEvent_TaskResultEventType = 7 - TaskResultEvent_TASK_LOG_SEND TaskResultEvent_TaskResultEventType = 8 -) - -var TaskResultEvent_TaskResultEventType_name = map[int32]string{ - 0: "TASK_POL_INTERVAL_UPDATE", - 1: "TASK_SENSOR_START", - 2: "TASK_SENSOR_STOP", - 3: "TASK_SENSOR_ADD", - 4: "TASK_SENSOR_REMOVE", - 5: "TASK_SENSOR_UPDATE", - 6: "TASK_CRAWLER_UPDATE", - 7: "TASK_AGENT_UPDATE", - 8: "TASK_LOG_SEND", -} -var TaskResultEvent_TaskResultEventType_value = map[string]int32{ - "TASK_POL_INTERVAL_UPDATE": 0, - "TASK_SENSOR_START": 1, - "TASK_SENSOR_STOP": 2, - "TASK_SENSOR_ADD": 3, - "TASK_SENSOR_REMOVE": 4, - "TASK_SENSOR_UPDATE": 5, - "TASK_CRAWLER_UPDATE": 6, - "TASK_AGENT_UPDATE": 7, - "TASK_LOG_SEND": 8, -} - -func (x TaskResultEvent_TaskResultEventType) String() string { - return proto.EnumName(TaskResultEvent_TaskResultEventType_name, int32(x)) -} -func (TaskResultEvent_TaskResultEventType) EnumDescriptor() ([]byte, []int) { - return fileDescriptor0, []int{2, 0} -} - type AgentEvent_AgentEventType int32 const ( @@ -175,7 +81,7 @@ var AgentEvent_AgentEventType_value = map[string]int32{ func (x AgentEvent_AgentEventType) String() string { return proto.EnumName(AgentEvent_AgentEventType_name, int32(x)) } -func (AgentEvent_AgentEventType) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{3, 0} } +func (AgentEvent_AgentEventType) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{2, 0} } type Empty struct { } @@ -185,68 +91,19 @@ func (m *Empty) String() string { return proto.CompactTextString(m) } func (*Empty) ProtoMessage() {} func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} } -// Event-relative area -type DiscoveryEvent struct { - AgentId string `protobuf:"bytes,1,opt,name=agentId" json:"agentId,omitempty"` - TaskId string `protobuf:"bytes,2,opt,name=taskId" json:"taskId,omitempty"` - EvtType DiscoveryEvent_DiscoveryEventType `protobuf:"varint,3,opt,name=evtType,enum=DiscoveryEvent_DiscoveryEventType" json:"evtType,omitempty"` - OccurredDate int64 `protobuf:"varint,4,opt,name=occurredDate" json:"occurredDate,omitempty"` - Data map[string]string `protobuf:"bytes,5,rep,name=data" json:"data,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` -} - -func (m *DiscoveryEvent) Reset() { *m = DiscoveryEvent{} } -func (m *DiscoveryEvent) String() string { return proto.CompactTextString(m) } -func (*DiscoveryEvent) ProtoMessage() {} -func (*DiscoveryEvent) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} } - -func (m *DiscoveryEvent) GetAgentId() string { - if m != nil { - return m.AgentId - } - return "" -} - -func (m *DiscoveryEvent) GetTaskId() string { - if m != nil { - return m.TaskId - } - return "" -} - -func (m *DiscoveryEvent) GetEvtType() DiscoveryEvent_DiscoveryEventType { - if m != nil { - return m.EvtType - } - return DiscoveryEvent_DISCOVERY_START -} - -func (m *DiscoveryEvent) GetOccurredDate() int64 { - if m != nil { - return m.OccurredDate - } - return 0 -} - -func (m *DiscoveryEvent) GetData() map[string]string { - if m != nil { - return m.Data - } - return nil -} - type TaskResultEvent struct { - AgentId string `protobuf:"bytes,1,opt,name=agentId" json:"agentId,omitempty"` - TaskId string `protobuf:"bytes,2,opt,name=taskId" json:"taskId,omitempty"` - EvtType TaskResultEvent_TaskResultEventType `protobuf:"varint,3,opt,name=evtType,enum=TaskResultEvent_TaskResultEventType" json:"evtType,omitempty"` - OccurredDate int64 `protobuf:"varint,4,opt,name=occurredDate" json:"occurredDate,omitempty"` - Result TaskResultState `protobuf:"varint,5,opt,name=result,enum=TaskResultState" json:"result,omitempty"` - Description string `protobuf:"bytes,6,opt,name=description" json:"description,omitempty"` + AgentId string `protobuf:"bytes,1,opt,name=agentId" json:"agentId,omitempty"` + TaskId string `protobuf:"bytes,2,opt,name=taskId" json:"taskId,omitempty"` + EvtType commons.TaskEventType `protobuf:"varint,3,opt,name=evtType,enum=TaskEventType" json:"evtType,omitempty"` + OccurredDate int64 `protobuf:"varint,4,opt,name=occurredDate" json:"occurredDate,omitempty"` + Result TaskResultState `protobuf:"varint,5,opt,name=result,enum=TaskResultState" json:"result,omitempty"` + Data map[string]string `protobuf:"bytes,6,rep,name=data" json:"data,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` } func (m *TaskResultEvent) Reset() { *m = TaskResultEvent{} } func (m *TaskResultEvent) String() string { return proto.CompactTextString(m) } func (*TaskResultEvent) ProtoMessage() {} -func (*TaskResultEvent) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} } +func (*TaskResultEvent) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} } func (m *TaskResultEvent) GetAgentId() string { if m != nil { @@ -262,11 +119,11 @@ func (m *TaskResultEvent) GetTaskId() string { return "" } -func (m *TaskResultEvent) GetEvtType() TaskResultEvent_TaskResultEventType { +func (m *TaskResultEvent) GetEvtType() commons.TaskEventType { if m != nil { return m.EvtType } - return TaskResultEvent_TASK_POL_INTERVAL_UPDATE + return commons.TaskEventType_TASK_POL_INTERVAL_UPDATE } func (m *TaskResultEvent) GetOccurredDate() int64 { @@ -283,11 +140,11 @@ func (m *TaskResultEvent) GetResult() TaskResultState { return TaskResultState_FAILED } -func (m *TaskResultEvent) GetDescription() string { +func (m *TaskResultEvent) GetData() map[string]string { if m != nil { - return m.Description + return m.Data } - return "" + return nil } type AgentEvent struct { @@ -301,7 +158,7 @@ type AgentEvent struct { func (m *AgentEvent) Reset() { *m = AgentEvent{} } func (m *AgentEvent) String() string { return proto.CompactTextString(m) } func (*AgentEvent) ProtoMessage() {} -func (*AgentEvent) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} } +func (*AgentEvent) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} } func (m *AgentEvent) GetAgentId() string { if m != nil { @@ -347,7 +204,7 @@ type AgentEvent_ErrorInfo struct { func (m *AgentEvent_ErrorInfo) Reset() { *m = AgentEvent_ErrorInfo{} } func (m *AgentEvent_ErrorInfo) String() string { return proto.CompactTextString(m) } func (*AgentEvent_ErrorInfo) ProtoMessage() {} -func (*AgentEvent_ErrorInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3, 0} } +func (*AgentEvent_ErrorInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2, 0} } func (m *AgentEvent_ErrorInfo) GetErrorNum() int32 { if m != nil { @@ -372,13 +229,10 @@ func (m *AgentEvent_ErrorInfo) GetErrorMessage() string { func init() { proto.RegisterType((*Empty)(nil), "Empty") - proto.RegisterType((*DiscoveryEvent)(nil), "DiscoveryEvent") proto.RegisterType((*TaskResultEvent)(nil), "TaskResultEvent") proto.RegisterType((*AgentEvent)(nil), "AgentEvent") proto.RegisterType((*AgentEvent_ErrorInfo)(nil), "AgentEvent.ErrorInfo") proto.RegisterEnum("TaskResultState", TaskResultState_name, TaskResultState_value) - proto.RegisterEnum("DiscoveryEvent_DiscoveryEventType", DiscoveryEvent_DiscoveryEventType_name, DiscoveryEvent_DiscoveryEventType_value) - proto.RegisterEnum("TaskResultEvent_TaskResultEventType", TaskResultEvent_TaskResultEventType_name, TaskResultEvent_TaskResultEventType_value) proto.RegisterEnum("AgentEvent_AgentEventType", AgentEvent_AgentEventType_name, AgentEvent_AgentEventType_value) } @@ -390,70 +244,6 @@ var _ grpc.ClientConn // is compatible with the grpc package it is being compiled against. const _ = grpc.SupportPackageIsVersion4 -// Client API for Discovery service - -type DiscoveryClient interface { - Event(ctx context.Context, in *DiscoveryEvent, opts ...grpc.CallOption) (*Empty, error) -} - -type discoveryClient struct { - cc *grpc.ClientConn -} - -func NewDiscoveryClient(cc *grpc.ClientConn) DiscoveryClient { - return &discoveryClient{cc} -} - -func (c *discoveryClient) Event(ctx context.Context, in *DiscoveryEvent, opts ...grpc.CallOption) (*Empty, error) { - out := new(Empty) - err := grpc.Invoke(ctx, "/Discovery/event", in, out, c.cc, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -// Server API for Discovery service - -type DiscoveryServer interface { - Event(context.Context, *DiscoveryEvent) (*Empty, error) -} - -func RegisterDiscoveryServer(s *grpc.Server, srv DiscoveryServer) { - s.RegisterService(&_Discovery_serviceDesc, srv) -} - -func _Discovery_Event_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(DiscoveryEvent) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(DiscoveryServer).Event(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/Discovery/Event", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(DiscoveryServer).Event(ctx, req.(*DiscoveryEvent)) - } - return interceptor(ctx, in, info, handler) -} - -var _Discovery_serviceDesc = grpc.ServiceDesc{ - ServiceName: "Discovery", - HandlerType: (*DiscoveryServer)(nil), - Methods: []grpc.MethodDesc{ - { - MethodName: "event", - Handler: _Discovery_Event_Handler, - }, - }, - Streams: []grpc.StreamDesc{}, - Metadata: "event.proto", -} - // Client API for TaskResult service type TaskResultClient interface { @@ -585,50 +375,37 @@ var _Event_serviceDesc = grpc.ServiceDesc{ func init() { proto.RegisterFile("event.proto", fileDescriptor0) } var fileDescriptor0 = []byte{ - // 719 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x55, 0xdd, 0x6e, 0xda, 0x4a, - 0x10, 0xc6, 0x36, 0x36, 0x61, 0x38, 0x07, 0x9c, 0xc9, 0x9f, 0x0f, 0xe7, 0xe8, 0x08, 0xb9, 0x95, - 0x8a, 0x2a, 0x95, 0xa8, 0xb4, 0x52, 0xab, 0xa8, 0xaa, 0x64, 0xe1, 0x4d, 0x6a, 0x95, 0x60, 0xb4, - 0x76, 0xa8, 0x7a, 0x85, 0x5c, 0xd8, 0x44, 0x51, 0x12, 0x8c, 0x8c, 0x41, 0xe2, 0xa1, 0xfa, 0x06, - 0x7d, 0x96, 0x5e, 0xf7, 0x19, 0x7a, 0x55, 0x79, 0x6d, 0x83, 0x31, 0xa8, 0x55, 0x7b, 0xb7, 0xf3, - 0x7d, 0x33, 0xdf, 0xce, 0xee, 0x7c, 0x5e, 0x43, 0x85, 0x2d, 0xd8, 0x24, 0x6c, 0x4d, 0x03, 0x3f, - 0xf4, 0xf5, 0x12, 0xc8, 0xe4, 0x61, 0x1a, 0x2e, 0xf5, 0x2f, 0x45, 0xa8, 0x9a, 0xb7, 0xb3, 0x91, - 0xbf, 0x60, 0xc1, 0x92, 0x44, 0x19, 0xa8, 0x41, 0xc9, 0xbb, 0x61, 0x93, 0xd0, 0x1a, 0x6b, 0x42, - 0x43, 0x68, 0x96, 0x69, 0x1a, 0xe2, 0x31, 0x28, 0xa1, 0x37, 0xbb, 0xb3, 0xc6, 0x9a, 0xc8, 0x89, - 0x24, 0xc2, 0x37, 0x50, 0x62, 0x8b, 0xd0, 0x5d, 0x4e, 0x99, 0x26, 0x35, 0x84, 0x66, 0xb5, 0xad, - 0xb7, 0x36, 0x35, 0x73, 0x61, 0x94, 0x49, 0xd3, 0x12, 0xd4, 0xe1, 0x2f, 0x7f, 0x34, 0x9a, 0x07, - 0x01, 0x1b, 0x9b, 0x5e, 0xc8, 0xb4, 0x62, 0x43, 0x68, 0x4a, 0x74, 0x03, 0xc3, 0x67, 0x50, 0x1c, - 0x7b, 0xa1, 0xa7, 0xc9, 0x0d, 0xa9, 0x59, 0x69, 0xff, 0xb3, 0x25, 0xef, 0x85, 0x1e, 0x99, 0x84, - 0xc1, 0x92, 0xf2, 0xb4, 0xfa, 0x2b, 0x28, 0xaf, 0x20, 0x54, 0x41, 0xba, 0x63, 0xcb, 0xe4, 0x2c, - 0xd1, 0x12, 0x0f, 0x41, 0x5e, 0x78, 0xf7, 0x73, 0x96, 0x1c, 0x23, 0x0e, 0xce, 0xc4, 0xd7, 0x82, - 0xfe, 0x59, 0x04, 0xdc, 0xee, 0x15, 0x0f, 0xa0, 0x66, 0x5a, 0x4e, 0xc7, 0x1e, 0x10, 0xfa, 0x71, - 0xe8, 0xb8, 0x06, 0x75, 0xd5, 0x02, 0x6a, 0x70, 0xb8, 0x06, 0xdf, 0xd9, 0x8e, 0x9b, 0x30, 0xc2, - 0x0e, 0xe6, 0xdc, 0xbe, 0xea, 0x99, 0xaa, 0x88, 0x27, 0x70, 0x90, 0x63, 0x4c, 0xbb, 0x47, 0x54, - 0x69, 0xb3, 0xa4, 0x6f, 0xd3, 0x54, 0xac, 0xb8, 0x83, 0x89, 0xc5, 0xe4, 0x4d, 0x31, 0xce, 0x70, - 0x31, 0x05, 0xff, 0x85, 0x93, 0x4c, 0xbb, 0x84, 0x0e, 0xac, 0x0e, 0x49, 0xf4, 0x4a, 0xbb, 0xc9, - 0x58, 0x72, 0x0f, 0xeb, 0x70, 0xbc, 0x4d, 0x72, 0xd5, 0x32, 0x22, 0x54, 0xd7, 0x1c, 0xc7, 0x40, - 0xff, 0x2a, 0x41, 0xcd, 0xf5, 0x66, 0x77, 0x94, 0xcd, 0xe6, 0xf7, 0xe1, 0x9f, 0xfa, 0xe7, 0x6d, - 0xde, 0x3f, 0x8f, 0x5b, 0x39, 0xd1, 0x7c, 0xfc, 0xfb, 0x0e, 0x6a, 0x82, 0x12, 0xf0, 0x7a, 0x4d, - 0xe6, 0x5b, 0xa8, 0x19, 0x49, 0x27, 0xf4, 0x42, 0x46, 0x13, 0x1e, 0x1b, 0x50, 0x19, 0xb3, 0xd9, - 0x28, 0xb8, 0x9d, 0x86, 0xb7, 0xfe, 0x44, 0x53, 0x78, 0xab, 0x59, 0x48, 0xff, 0x26, 0xc0, 0xc1, - 0x8e, 0x86, 0xf0, 0x3f, 0xd0, 0x5c, 0xc3, 0x79, 0x3f, 0xec, 0xdb, 0xdd, 0xa1, 0xd5, 0x73, 0x09, - 0x1d, 0x18, 0xdd, 0xe1, 0x55, 0xdf, 0x34, 0x5c, 0xa2, 0x16, 0xf0, 0x08, 0xf6, 0x39, 0xeb, 0x90, - 0x9e, 0x63, 0xd3, 0x95, 0x59, 0x0e, 0x41, 0xdd, 0x84, 0xed, 0xbe, 0x2a, 0x46, 0x8e, 0xcb, 0xa2, - 0x86, 0x69, 0xaa, 0x12, 0x1e, 0x03, 0x66, 0x41, 0x4a, 0x2e, 0xed, 0x01, 0x51, 0x8b, 0x79, 0x3c, - 0xd9, 0x91, 0x1b, 0x84, 0xe3, 0x1d, 0x6a, 0x7c, 0xe8, 0x92, 0x15, 0xa1, 0xac, 0x5a, 0x31, 0x2e, - 0x48, 0xcf, 0x4d, 0xe1, 0x12, 0xee, 0xc3, 0xdf, 0x1c, 0xee, 0xda, 0x17, 0x91, 0x96, 0xa9, 0xee, - 0xe9, 0xdf, 0x45, 0x00, 0x23, 0x1a, 0xdf, 0xaf, 0x66, 0xfb, 0x72, 0x3d, 0x43, 0x91, 0x5f, 0x70, - 0xbd, 0xb5, 0xae, 0xcb, 0x2c, 0x7f, 0x3e, 0x39, 0x69, 0xc7, 0xe4, 0x72, 0xf3, 0x28, 0x6e, 0xcd, - 0x03, 0x4f, 0xa1, 0xc4, 0x82, 0xc0, 0x9a, 0x5c, 0xfb, 0x7c, 0xb8, 0x95, 0xf6, 0x51, 0x76, 0x6f, - 0x12, 0x04, 0x3e, 0x27, 0x69, 0x9a, 0x55, 0x1f, 0x42, 0x79, 0x85, 0x62, 0x1d, 0xf6, 0x58, 0x14, - 0xf4, 0xe6, 0x0f, 0xfc, 0x50, 0x32, 0x5d, 0xc5, 0x88, 0x50, 0xbc, 0x0e, 0xfc, 0x87, 0xc4, 0xaf, - 0x7c, 0x1d, 0xf5, 0xcc, 0xf9, 0x4b, 0x36, 0x9b, 0x79, 0x37, 0x71, 0xcf, 0x65, 0xba, 0x81, 0xe9, - 0x26, 0x54, 0x37, 0x8f, 0x1c, 0xdd, 0x6d, 0x7c, 0xdb, 0x7c, 0xee, 0xc4, 0x54, 0x0b, 0x58, 0x83, - 0x4a, 0x0c, 0x11, 0x4a, 0x6d, 0xaa, 0x0a, 0x58, 0x05, 0x48, 0x73, 0x22, 0x13, 0x3c, 0x3d, 0xcb, - 0x7e, 0x5c, 0xdc, 0xa4, 0x08, 0xa0, 0x9c, 0x1b, 0x56, 0x97, 0xd7, 0x57, 0xa0, 0xe4, 0x5c, 0x75, - 0x3a, 0x84, 0x98, 0x71, 0x6d, 0x9f, 0xda, 0x51, 0x60, 0xf5, 0x2e, 0x54, 0xb1, 0x7d, 0x0a, 0xe5, - 0xd5, 0x43, 0x86, 0x3a, 0xc8, 0xfc, 0xf5, 0xc7, 0x5a, 0xee, 0xe5, 0xac, 0x2b, 0xad, 0xf8, 0x3f, - 0x50, 0x68, 0x3f, 0x07, 0x58, 0x6f, 0x86, 0x8f, 0xd2, 0x0a, 0x35, 0xff, 0xe9, 0x65, 0x4a, 0x9e, - 0x80, 0x1c, 0xdb, 0xe2, 0xff, 0x34, 0xbb, 0x92, 0xb9, 0xf8, 0x75, 0xe2, 0x27, 0x85, 0xff, 0x75, - 0x5e, 0xfc, 0x08, 0x00, 0x00, 0xff, 0xff, 0xe6, 0xb0, 0x7e, 0x78, 0x84, 0x06, 0x00, 0x00, + // 505 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x53, 0xcf, 0x8f, 0x93, 0x40, + 0x14, 0x5e, 0x68, 0xa1, 0xf6, 0xa1, 0x5d, 0x9c, 0xa8, 0x21, 0x1c, 0x4c, 0x53, 0x0f, 0x12, 0x0f, + 0x34, 0x56, 0x13, 0xcd, 0x26, 0x1e, 0x9a, 0x2d, 0x6e, 0x48, 0xb4, 0xdd, 0x4c, 0xf1, 0xdc, 0x8c, + 0x30, 0x6d, 0x9a, 0x02, 0x43, 0x86, 0x69, 0x37, 0xfc, 0x3f, 0xfe, 0x95, 0x9e, 0x0c, 0x03, 0x14, + 0xba, 0x31, 0x7a, 0xe2, 0x7d, 0xdf, 0xfb, 0x31, 0xef, 0x7d, 0xbc, 0x07, 0x06, 0x3d, 0xd1, 0x54, + 0xb8, 0x19, 0x67, 0x82, 0xd9, 0x5f, 0x62, 0x46, 0xb6, 0x31, 0x75, 0x43, 0x96, 0x4c, 0xd9, 0x89, + 0xf2, 0x6d, 0xcc, 0x1e, 0xa6, 0x21, 0x4d, 0x05, 0x27, 0xf1, 0x86, 0x64, 0xfb, 0xcd, 0x8e, 0x08, + 0xfa, 0x40, 0x8a, 0x69, 0xc8, 0x92, 0x84, 0xa5, 0x79, 0xf3, 0xad, 0xd2, 0x27, 0x03, 0xd0, 0xbc, + 0x24, 0x13, 0xc5, 0xe4, 0x97, 0x0a, 0xd7, 0x01, 0xc9, 0x0f, 0x98, 0xe6, 0xc7, 0x58, 0x78, 0xe5, + 0x0b, 0xc8, 0x82, 0x01, 0xd9, 0xd1, 0x54, 0xf8, 0x91, 0xa5, 0x8c, 0x15, 0x67, 0x88, 0x1b, 0x88, + 0x5e, 0x81, 0x2e, 0x48, 0x7e, 0xf0, 0x23, 0x4b, 0x95, 0x8e, 0x1a, 0x21, 0x07, 0x06, 0xf4, 0x24, + 0x82, 0x22, 0xa3, 0x56, 0x6f, 0xac, 0x38, 0xa3, 0xd9, 0xc8, 0x2d, 0x8b, 0xca, 0x72, 0x25, 0x8b, + 0x1b, 0x37, 0x9a, 0xc0, 0x53, 0x16, 0x86, 0x47, 0xce, 0x69, 0xb4, 0x20, 0x82, 0x5a, 0xfd, 0xb1, + 0xe2, 0xf4, 0xf0, 0x05, 0x87, 0x1c, 0xd0, 0xb9, 0x6c, 0xc7, 0xd2, 0x64, 0x31, 0xd3, 0x6d, 0x3b, + 0x5c, 0x0b, 0x22, 0x28, 0xae, 0xfd, 0xc8, 0x85, 0x7e, 0x44, 0x04, 0xb1, 0xf4, 0x71, 0xcf, 0x31, + 0x66, 0xb6, 0xfb, 0x68, 0x12, 0x77, 0x41, 0x04, 0xf1, 0x52, 0xc1, 0x0b, 0x2c, 0xe3, 0xec, 0x4f, + 0x30, 0x3c, 0x53, 0xc8, 0x84, 0xde, 0x81, 0x16, 0xf5, 0x88, 0xa5, 0x89, 0x5e, 0x80, 0x76, 0x22, + 0xf1, 0x91, 0xd6, 0xd3, 0x55, 0xe0, 0x46, 0xfd, 0xac, 0x4c, 0x7e, 0xab, 0x00, 0xf3, 0x52, 0x84, + 0xff, 0x29, 0xf4, 0xb1, 0x55, 0x42, 0x95, 0xcd, 0xdb, 0x6e, 0x9b, 0xd7, 0x31, 0xff, 0xad, 0x4a, + 0xef, 0x2f, 0xaa, 0x8c, 0xc1, 0x88, 0x68, 0x1e, 0xf2, 0x7d, 0x26, 0xf6, 0x2c, 0x95, 0xc2, 0x0d, + 0x71, 0x97, 0x42, 0x53, 0x18, 0x50, 0xce, 0xfd, 0x74, 0xcb, 0xa4, 0x70, 0xc6, 0xec, 0x65, 0xf7, + 0x6d, 0x8f, 0x73, 0x26, 0x9d, 0xb8, 0x89, 0xb2, 0x37, 0x30, 0x3c, 0xb3, 0xc8, 0x86, 0x27, 0xb4, + 0x04, 0xcb, 0x63, 0x22, 0x87, 0xd2, 0xf0, 0x19, 0x23, 0x04, 0xfd, 0x2d, 0x67, 0x49, 0xad, 0x8b, + 0xb4, 0xcb, 0x9e, 0xa5, 0xff, 0x3b, 0xcd, 0x73, 0xb2, 0xab, 0x7a, 0x1e, 0xe2, 0x0b, 0x6e, 0xb2, + 0x80, 0xd1, 0xe5, 0xc8, 0xe8, 0x39, 0x3c, 0x9b, 0xdf, 0x79, 0xcb, 0x60, 0xb3, 0x0e, 0xe6, 0x38, + 0xf0, 0x16, 0xe6, 0x15, 0xba, 0x06, 0xa3, 0xa2, 0x3c, 0x8c, 0x57, 0xd8, 0x54, 0xd0, 0x08, 0xa0, + 0x89, 0x59, 0xdd, 0x9b, 0xea, 0xbb, 0x9b, 0xee, 0x8a, 0xca, 0x05, 0x40, 0x00, 0xfa, 0xd7, 0xb9, + 0xff, 0x4d, 0xe6, 0x1b, 0x30, 0x58, 0xff, 0xb8, 0xbd, 0xf5, 0xbc, 0x45, 0x95, 0x7b, 0x8f, 0x57, + 0x25, 0xf0, 0x97, 0x77, 0xa6, 0x3a, 0x7b, 0x0f, 0xd0, 0xe6, 0xa2, 0x37, 0xa0, 0xc9, 0x23, 0x42, + 0xe6, 0xe3, 0x55, 0xb1, 0x75, 0xb7, 0x3a, 0x88, 0xab, 0xd9, 0x5b, 0xd0, 0xaa, 0xbf, 0xfc, 0xba, + 0x89, 0x36, 0x3a, 0x3a, 0xb6, 0x81, 0x3f, 0x75, 0x79, 0x4b, 0x1f, 0xfe, 0x04, 0x00, 0x00, 0xff, + 0xff, 0xbc, 0xba, 0xfc, 0x41, 0x99, 0x03, 0x00, 0x00, } diff --git a/event/event.proto b/event/event.proto index d4f3488..0ea0e4f 100644 --- a/event/event.proto +++ b/event/event.proto @@ -1,10 +1,8 @@ syntax = "proto3"; -message Empty {} +import "loafle.com/overflow/central_api_gateway/commons/commons.proto"; -service Discovery { - rpc event(DiscoveryEvent) returns (Empty){} -} +message Empty {} enum TaskResultState { FAILED = 0;