1 // Code generated by protoc-gen-go. DO NOT EDIT.
3 // protoc-gen-go v1.22.0
5 // source: lcmservice.proto
11 proto "github.com/golang/protobuf/proto"
12 grpc "google.golang.org/grpc"
13 codes "google.golang.org/grpc/codes"
14 status "google.golang.org/grpc/status"
15 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
16 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
22 // Verify that this generated code is sufficiently up-to-date.
23 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
24 // Verify that runtime/protoimpl is sufficiently up-to-date.
25 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
28 // This is a compile-time assertion that a sufficiently up-to-date version
29 // of the legacy proto package is being used.
30 const _ = proto.ProtoPackageIsVersion4
32 type InstantiateRequest struct {
33 state protoimpl.MessageState
34 sizeCache protoimpl.SizeCache
35 unknownFields protoimpl.UnknownFields
37 // Types that are assignable to Data:
38 // *InstantiateRequest_HostIp
39 // *InstantiateRequest_Package
40 Data isInstantiateRequest_Data `protobuf_oneof:"data"`
43 func (x *InstantiateRequest) Reset() {
44 *x = InstantiateRequest{}
45 if protoimpl.UnsafeEnabled {
46 mi := &file_lcmservice_proto_msgTypes[0]
47 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
48 ms.StoreMessageInfo(mi)
52 func (x *InstantiateRequest) String() string {
53 return protoimpl.X.MessageStringOf(x)
56 func (*InstantiateRequest) ProtoMessage() {}
58 func (x *InstantiateRequest) ProtoReflect() protoreflect.Message {
59 mi := &file_lcmservice_proto_msgTypes[0]
60 if protoimpl.UnsafeEnabled && x != nil {
61 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
62 if ms.LoadMessageInfo() == nil {
63 ms.StoreMessageInfo(mi)
67 return mi.MessageOf(x)
70 // Deprecated: Use InstantiateRequest.ProtoReflect.Descriptor instead.
71 func (*InstantiateRequest) Descriptor() ([]byte, []int) {
72 return file_lcmservice_proto_rawDescGZIP(), []int{0}
75 func (m *InstantiateRequest) GetData() isInstantiateRequest_Data {
82 func (x *InstantiateRequest) GetHostIp() string {
83 if x, ok := x.GetData().(*InstantiateRequest_HostIp); ok {
89 func (x *InstantiateRequest) GetPackage() []byte {
90 if x, ok := x.GetData().(*InstantiateRequest_Package); ok {
96 type isInstantiateRequest_Data interface {
97 isInstantiateRequest_Data()
100 type InstantiateRequest_HostIp struct {
101 HostIp string `protobuf:"bytes,1,opt,name=hostIp,proto3,oneof"`
104 type InstantiateRequest_Package struct {
105 Package []byte `protobuf:"bytes,2,opt,name=package,proto3,oneof"`
108 func (*InstantiateRequest_HostIp) isInstantiateRequest_Data() {}
110 func (*InstantiateRequest_Package) isInstantiateRequest_Data() {}
112 type InstantiateResponse struct {
113 state protoimpl.MessageState
114 sizeCache protoimpl.SizeCache
115 unknownFields protoimpl.UnknownFields
117 WorkloadId string `protobuf:"bytes,1,opt,name=workloadId,proto3" json:"workloadId,omitempty"`
118 Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
121 func (x *InstantiateResponse) Reset() {
122 *x = InstantiateResponse{}
123 if protoimpl.UnsafeEnabled {
124 mi := &file_lcmservice_proto_msgTypes[1]
125 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
126 ms.StoreMessageInfo(mi)
130 func (x *InstantiateResponse) String() string {
131 return protoimpl.X.MessageStringOf(x)
134 func (*InstantiateResponse) ProtoMessage() {}
136 func (x *InstantiateResponse) ProtoReflect() protoreflect.Message {
137 mi := &file_lcmservice_proto_msgTypes[1]
138 if protoimpl.UnsafeEnabled && x != nil {
139 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
140 if ms.LoadMessageInfo() == nil {
141 ms.StoreMessageInfo(mi)
145 return mi.MessageOf(x)
148 // Deprecated: Use InstantiateResponse.ProtoReflect.Descriptor instead.
149 func (*InstantiateResponse) Descriptor() ([]byte, []int) {
150 return file_lcmservice_proto_rawDescGZIP(), []int{1}
153 func (x *InstantiateResponse) GetWorkloadId() string {
160 func (x *InstantiateResponse) GetStatus() string {
167 type TerminateRequest struct {
168 state protoimpl.MessageState
169 sizeCache protoimpl.SizeCache
170 unknownFields protoimpl.UnknownFields
172 HostIp string `protobuf:"bytes,1,opt,name=hostIp,proto3" json:"hostIp,omitempty"`
173 WorkloadId string `protobuf:"bytes,2,opt,name=workloadId,proto3" json:"workloadId,omitempty"`
176 func (x *TerminateRequest) Reset() {
177 *x = TerminateRequest{}
178 if protoimpl.UnsafeEnabled {
179 mi := &file_lcmservice_proto_msgTypes[2]
180 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
181 ms.StoreMessageInfo(mi)
185 func (x *TerminateRequest) String() string {
186 return protoimpl.X.MessageStringOf(x)
189 func (*TerminateRequest) ProtoMessage() {}
191 func (x *TerminateRequest) ProtoReflect() protoreflect.Message {
192 mi := &file_lcmservice_proto_msgTypes[2]
193 if protoimpl.UnsafeEnabled && x != nil {
194 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
195 if ms.LoadMessageInfo() == nil {
196 ms.StoreMessageInfo(mi)
200 return mi.MessageOf(x)
203 // Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.
204 func (*TerminateRequest) Descriptor() ([]byte, []int) {
205 return file_lcmservice_proto_rawDescGZIP(), []int{2}
208 func (x *TerminateRequest) GetHostIp() string {
215 func (x *TerminateRequest) GetWorkloadId() string {
222 type TerminateResponse struct {
223 state protoimpl.MessageState
224 sizeCache protoimpl.SizeCache
225 unknownFields protoimpl.UnknownFields
227 Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
230 func (x *TerminateResponse) Reset() {
231 *x = TerminateResponse{}
232 if protoimpl.UnsafeEnabled {
233 mi := &file_lcmservice_proto_msgTypes[3]
234 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
235 ms.StoreMessageInfo(mi)
239 func (x *TerminateResponse) String() string {
240 return protoimpl.X.MessageStringOf(x)
243 func (*TerminateResponse) ProtoMessage() {}
245 func (x *TerminateResponse) ProtoReflect() protoreflect.Message {
246 mi := &file_lcmservice_proto_msgTypes[3]
247 if protoimpl.UnsafeEnabled && x != nil {
248 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
249 if ms.LoadMessageInfo() == nil {
250 ms.StoreMessageInfo(mi)
254 return mi.MessageOf(x)
257 // Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.
258 func (*TerminateResponse) Descriptor() ([]byte, []int) {
259 return file_lcmservice_proto_rawDescGZIP(), []int{3}
262 func (x *TerminateResponse) GetStatus() string {
269 type QueryRequest struct {
270 state protoimpl.MessageState
271 sizeCache protoimpl.SizeCache
272 unknownFields protoimpl.UnknownFields
274 HostIp string `protobuf:"bytes,1,opt,name=hostIp,proto3" json:"hostIp,omitempty"`
275 WorkloadId string `protobuf:"bytes,2,opt,name=workloadId,proto3" json:"workloadId,omitempty"`
278 func (x *QueryRequest) Reset() {
280 if protoimpl.UnsafeEnabled {
281 mi := &file_lcmservice_proto_msgTypes[4]
282 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
283 ms.StoreMessageInfo(mi)
287 func (x *QueryRequest) String() string {
288 return protoimpl.X.MessageStringOf(x)
291 func (*QueryRequest) ProtoMessage() {}
293 func (x *QueryRequest) ProtoReflect() protoreflect.Message {
294 mi := &file_lcmservice_proto_msgTypes[4]
295 if protoimpl.UnsafeEnabled && x != nil {
296 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
297 if ms.LoadMessageInfo() == nil {
298 ms.StoreMessageInfo(mi)
302 return mi.MessageOf(x)
305 // Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
306 func (*QueryRequest) Descriptor() ([]byte, []int) {
307 return file_lcmservice_proto_rawDescGZIP(), []int{4}
310 func (x *QueryRequest) GetHostIp() string {
317 func (x *QueryRequest) GetWorkloadId() string {
324 type QueryResponse struct {
325 state protoimpl.MessageState
326 sizeCache protoimpl.SizeCache
327 unknownFields protoimpl.UnknownFields
329 Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
332 func (x *QueryResponse) Reset() {
334 if protoimpl.UnsafeEnabled {
335 mi := &file_lcmservice_proto_msgTypes[5]
336 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
337 ms.StoreMessageInfo(mi)
341 func (x *QueryResponse) String() string {
342 return protoimpl.X.MessageStringOf(x)
345 func (*QueryResponse) ProtoMessage() {}
347 func (x *QueryResponse) ProtoReflect() protoreflect.Message {
348 mi := &file_lcmservice_proto_msgTypes[5]
349 if protoimpl.UnsafeEnabled && x != nil {
350 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
351 if ms.LoadMessageInfo() == nil {
352 ms.StoreMessageInfo(mi)
356 return mi.MessageOf(x)
359 // Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.
360 func (*QueryResponse) Descriptor() ([]byte, []int) {
361 return file_lcmservice_proto_rawDescGZIP(), []int{5}
364 func (x *QueryResponse) GetStatus() string {
371 var File_lcmservice_proto protoreflect.FileDescriptor
373 var file_lcmservice_proto_rawDesc = []byte{
374 0x0a, 0x10, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f,
375 0x74, 0x6f, 0x12, 0x0a, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x22, 0x52,
376 0x0a, 0x12, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71,
377 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x70, 0x18, 0x01,
378 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x70, 0x12, 0x1a,
379 0x0a, 0x07, 0x70, 0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x48,
380 0x00, 0x52, 0x07, 0x70, 0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x42, 0x06, 0x0a, 0x04, 0x64, 0x61,
381 0x74, 0x61, 0x22, 0x4d, 0x0a, 0x13, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74,
382 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x77, 0x6f, 0x72,
383 0x6b, 0x6c, 0x6f, 0x61, 0x64, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x77,
384 0x6f, 0x72, 0x6b, 0x6c, 0x6f, 0x61, 0x64, 0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61,
385 0x74, 0x75, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75,
386 0x73, 0x22, 0x4a, 0x0a, 0x10, 0x54, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x52, 0x65,
387 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x70, 0x18,
388 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x70, 0x12, 0x1e, 0x0a,
389 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x6c, 0x6f, 0x61, 0x64, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28,
390 0x09, 0x52, 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x6c, 0x6f, 0x61, 0x64, 0x49, 0x64, 0x22, 0x2b, 0x0a,
391 0x11, 0x54, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
392 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x01, 0x20, 0x01,
393 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x22, 0x46, 0x0a, 0x0c, 0x51, 0x75,
394 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x68, 0x6f,
395 0x73, 0x74, 0x49, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x68, 0x6f, 0x73, 0x74,
396 0x49, 0x70, 0x12, 0x1e, 0x0a, 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x6c, 0x6f, 0x61, 0x64, 0x49, 0x64,
397 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x6c, 0x6f, 0x61, 0x64,
398 0x49, 0x64, 0x22, 0x27, 0x0a, 0x0d, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f,
399 0x6e, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x01, 0x20,
400 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x32, 0xe8, 0x01, 0x0a, 0x06,
401 0x41, 0x70, 0x70, 0x4c, 0x43, 0x4d, 0x12, 0x52, 0x0a, 0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e,
402 0x74, 0x69, 0x61, 0x74, 0x65, 0x12, 0x1e, 0x2e, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69,
403 0x63, 0x65, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x52, 0x65,
404 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69,
405 0x63, 0x65, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x52, 0x65,
406 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x12, 0x4a, 0x0a, 0x09, 0x74, 0x65,
407 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x12, 0x1c, 0x2e, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72,
408 0x76, 0x69, 0x63, 0x65, 0x2e, 0x54, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x52, 0x65,
409 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69,
410 0x63, 0x65, 0x2e, 0x54, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70,
411 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x3e, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12,
412 0x18, 0x2e, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x51, 0x75, 0x65,
413 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x19, 0x2e, 0x6c, 0x63, 0x6d, 0x73,
414 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70,
415 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x0e, 0x5a, 0x0c, 0x2e, 0x3b, 0x6c, 0x63, 0x6d, 0x73,
416 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
420 file_lcmservice_proto_rawDescOnce sync.Once
421 file_lcmservice_proto_rawDescData = file_lcmservice_proto_rawDesc
424 func file_lcmservice_proto_rawDescGZIP() []byte {
425 file_lcmservice_proto_rawDescOnce.Do(func() {
426 file_lcmservice_proto_rawDescData = protoimpl.X.CompressGZIP(file_lcmservice_proto_rawDescData)
428 return file_lcmservice_proto_rawDescData
431 var file_lcmservice_proto_msgTypes = make([]protoimpl.MessageInfo, 6)
432 var file_lcmservice_proto_goTypes = []interface{}{
433 (*InstantiateRequest)(nil), // 0: lcmservice.InstantiateRequest
434 (*InstantiateResponse)(nil), // 1: lcmservice.InstantiateResponse
435 (*TerminateRequest)(nil), // 2: lcmservice.TerminateRequest
436 (*TerminateResponse)(nil), // 3: lcmservice.TerminateResponse
437 (*QueryRequest)(nil), // 4: lcmservice.QueryRequest
438 (*QueryResponse)(nil), // 5: lcmservice.QueryResponse
440 var file_lcmservice_proto_depIdxs = []int32{
441 0, // 0: lcmservice.AppLCM.instantiate:input_type -> lcmservice.InstantiateRequest
442 2, // 1: lcmservice.AppLCM.terminate:input_type -> lcmservice.TerminateRequest
443 4, // 2: lcmservice.AppLCM.query:input_type -> lcmservice.QueryRequest
444 1, // 3: lcmservice.AppLCM.instantiate:output_type -> lcmservice.InstantiateResponse
445 3, // 4: lcmservice.AppLCM.terminate:output_type -> lcmservice.TerminateResponse
446 5, // 5: lcmservice.AppLCM.query:output_type -> lcmservice.QueryResponse
447 3, // [3:6] is the sub-list for method output_type
448 0, // [0:3] is the sub-list for method input_type
449 0, // [0:0] is the sub-list for extension type_name
450 0, // [0:0] is the sub-list for extension extendee
451 0, // [0:0] is the sub-list for field type_name
454 func init() { file_lcmservice_proto_init() }
455 func file_lcmservice_proto_init() {
456 if File_lcmservice_proto != nil {
459 if !protoimpl.UnsafeEnabled {
460 file_lcmservice_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
461 switch v := v.(*InstantiateRequest); i {
467 return &v.unknownFields
472 file_lcmservice_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
473 switch v := v.(*InstantiateResponse); i {
479 return &v.unknownFields
484 file_lcmservice_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
485 switch v := v.(*TerminateRequest); i {
491 return &v.unknownFields
496 file_lcmservice_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
497 switch v := v.(*TerminateResponse); i {
503 return &v.unknownFields
508 file_lcmservice_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
509 switch v := v.(*QueryRequest); i {
515 return &v.unknownFields
520 file_lcmservice_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
521 switch v := v.(*QueryResponse); i {
527 return &v.unknownFields
533 file_lcmservice_proto_msgTypes[0].OneofWrappers = []interface{}{
534 (*InstantiateRequest_HostIp)(nil),
535 (*InstantiateRequest_Package)(nil),
538 out := protoimpl.TypeBuilder{
539 File: protoimpl.DescBuilder{
540 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
541 RawDescriptor: file_lcmservice_proto_rawDesc,
547 GoTypes: file_lcmservice_proto_goTypes,
548 DependencyIndexes: file_lcmservice_proto_depIdxs,
549 MessageInfos: file_lcmservice_proto_msgTypes,
551 File_lcmservice_proto = out.File
552 file_lcmservice_proto_rawDesc = nil
553 file_lcmservice_proto_goTypes = nil
554 file_lcmservice_proto_depIdxs = nil
557 // Reference imports to suppress errors if they are not otherwise used.
558 var _ context.Context
559 var _ grpc.ClientConnInterface
561 // This is a compile-time assertion to ensure that this generated file
562 // is compatible with the grpc package it is being compiled against.
563 const _ = grpc.SupportPackageIsVersion6
565 // AppLCMClient is the client API for AppLCM service.
567 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
568 type AppLCMClient interface {
569 Instantiate(ctx context.Context, opts ...grpc.CallOption) (AppLCM_InstantiateClient, error)
570 Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
571 Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
574 type appLCMClient struct {
575 cc grpc.ClientConnInterface
578 func NewAppLCMClient(cc grpc.ClientConnInterface) AppLCMClient {
579 return &appLCMClient{cc}
582 func (c *appLCMClient) Instantiate(ctx context.Context, opts ...grpc.CallOption) (AppLCM_InstantiateClient, error) {
583 stream, err := c.cc.NewStream(ctx, &_AppLCM_serviceDesc.Streams[0], "/lcmservice.AppLCM/instantiate", opts...)
587 x := &appLCMInstantiateClient{stream}
591 type AppLCM_InstantiateClient interface {
592 Send(*InstantiateRequest) error
593 CloseAndRecv() (*InstantiateResponse, error)
597 type appLCMInstantiateClient struct {
601 func (x *appLCMInstantiateClient) Send(m *InstantiateRequest) error {
602 return x.ClientStream.SendMsg(m)
605 func (x *appLCMInstantiateClient) CloseAndRecv() (*InstantiateResponse, error) {
606 if err := x.ClientStream.CloseSend(); err != nil {
609 m := new(InstantiateResponse)
610 if err := x.ClientStream.RecvMsg(m); err != nil {
616 func (c *appLCMClient) Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error) {
617 out := new(TerminateResponse)
618 err := c.cc.Invoke(ctx, "/lcmservice.AppLCM/terminate", in, out, opts...)
625 func (c *appLCMClient) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error) {
626 out := new(QueryResponse)
627 err := c.cc.Invoke(ctx, "/lcmservice.AppLCM/query", in, out, opts...)
634 // AppLCMServer is the server API for AppLCM service.
635 type AppLCMServer interface {
636 Instantiate(AppLCM_InstantiateServer) error
637 Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error)
638 Query(context.Context, *QueryRequest) (*QueryResponse, error)
641 // UnimplementedAppLCMServer can be embedded to have forward compatible implementations.
642 type UnimplementedAppLCMServer struct {
645 func (*UnimplementedAppLCMServer) Instantiate(AppLCM_InstantiateServer) error {
646 return status.Errorf(codes.Unimplemented, "method Instantiate not implemented")
648 func (*UnimplementedAppLCMServer) Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error) {
649 return nil, status.Errorf(codes.Unimplemented, "method Terminate not implemented")
651 func (*UnimplementedAppLCMServer) Query(context.Context, *QueryRequest) (*QueryResponse, error) {
652 return nil, status.Errorf(codes.Unimplemented, "method Query not implemented")
655 func RegisterAppLCMServer(s *grpc.Server, srv AppLCMServer) {
656 s.RegisterService(&_AppLCM_serviceDesc, srv)
659 func _AppLCM_Instantiate_Handler(srv interface{}, stream grpc.ServerStream) error {
660 return srv.(AppLCMServer).Instantiate(&appLCMInstantiateServer{stream})
663 type AppLCM_InstantiateServer interface {
664 SendAndClose(*InstantiateResponse) error
665 Recv() (*InstantiateRequest, error)
669 type appLCMInstantiateServer struct {
673 func (x *appLCMInstantiateServer) SendAndClose(m *InstantiateResponse) error {
674 return x.ServerStream.SendMsg(m)
677 func (x *appLCMInstantiateServer) Recv() (*InstantiateRequest, error) {
678 m := new(InstantiateRequest)
679 if err := x.ServerStream.RecvMsg(m); err != nil {
685 func _AppLCM_Terminate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
686 in := new(TerminateRequest)
687 if err := dec(in); err != nil {
690 if interceptor == nil {
691 return srv.(AppLCMServer).Terminate(ctx, in)
693 info := &grpc.UnaryServerInfo{
695 FullMethod: "/lcmservice.AppLCM/Terminate",
697 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
698 return srv.(AppLCMServer).Terminate(ctx, req.(*TerminateRequest))
700 return interceptor(ctx, in, info, handler)
703 func _AppLCM_Query_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
704 in := new(QueryRequest)
705 if err := dec(in); err != nil {
708 if interceptor == nil {
709 return srv.(AppLCMServer).Query(ctx, in)
711 info := &grpc.UnaryServerInfo{
713 FullMethod: "/lcmservice.AppLCM/Query",
715 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
716 return srv.(AppLCMServer).Query(ctx, req.(*QueryRequest))
718 return interceptor(ctx, in, info, handler)
721 var _AppLCM_serviceDesc = grpc.ServiceDesc{
722 ServiceName: "lcmservice.AppLCM",
723 HandlerType: (*AppLCMServer)(nil),
724 Methods: []grpc.MethodDesc{
726 MethodName: "terminate",
727 Handler: _AppLCM_Terminate_Handler,
731 Handler: _AppLCM_Query_Handler,
734 Streams: []grpc.StreamDesc{
736 StreamName: "instantiate",
737 Handler: _AppLCM_Instantiate_Handler,
741 Metadata: "lcmservice.proto",