1 // Code generated by protoc-gen-go. DO NOT EDIT.
3 // protoc-gen-go v1.22.0-devel
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, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
419 file_lcmservice_proto_rawDescOnce sync.Once
420 file_lcmservice_proto_rawDescData = file_lcmservice_proto_rawDesc
423 func file_lcmservice_proto_rawDescGZIP() []byte {
424 file_lcmservice_proto_rawDescOnce.Do(func() {
425 file_lcmservice_proto_rawDescData = protoimpl.X.CompressGZIP(file_lcmservice_proto_rawDescData)
427 return file_lcmservice_proto_rawDescData
430 var file_lcmservice_proto_msgTypes = make([]protoimpl.MessageInfo, 6)
431 var file_lcmservice_proto_goTypes = []interface{}{
432 (*InstantiateRequest)(nil), // 0: lcmservice.InstantiateRequest
433 (*InstantiateResponse)(nil), // 1: lcmservice.InstantiateResponse
434 (*TerminateRequest)(nil), // 2: lcmservice.TerminateRequest
435 (*TerminateResponse)(nil), // 3: lcmservice.TerminateResponse
436 (*QueryRequest)(nil), // 4: lcmservice.QueryRequest
437 (*QueryResponse)(nil), // 5: lcmservice.QueryResponse
439 var file_lcmservice_proto_depIdxs = []int32{
440 0, // 0: lcmservice.AppLCM.instantiate:input_type -> lcmservice.InstantiateRequest
441 2, // 1: lcmservice.AppLCM.terminate:input_type -> lcmservice.TerminateRequest
442 4, // 2: lcmservice.AppLCM.query:input_type -> lcmservice.QueryRequest
443 1, // 3: lcmservice.AppLCM.instantiate:output_type -> lcmservice.InstantiateResponse
444 3, // 4: lcmservice.AppLCM.terminate:output_type -> lcmservice.TerminateResponse
445 5, // 5: lcmservice.AppLCM.query:output_type -> lcmservice.QueryResponse
446 3, // [3:6] is the sub-list for method output_type
447 0, // [0:3] is the sub-list for method input_type
448 0, // [0:0] is the sub-list for extension type_name
449 0, // [0:0] is the sub-list for extension extendee
450 0, // [0:0] is the sub-list for field type_name
453 func init() { file_lcmservice_proto_init() }
454 func file_lcmservice_proto_init() {
455 if File_lcmservice_proto != nil {
458 if !protoimpl.UnsafeEnabled {
459 file_lcmservice_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
460 switch v := v.(*InstantiateRequest); i {
466 return &v.unknownFields
471 file_lcmservice_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
472 switch v := v.(*InstantiateResponse); i {
478 return &v.unknownFields
483 file_lcmservice_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
484 switch v := v.(*TerminateRequest); i {
490 return &v.unknownFields
495 file_lcmservice_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
496 switch v := v.(*TerminateResponse); i {
502 return &v.unknownFields
507 file_lcmservice_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
508 switch v := v.(*QueryRequest); i {
514 return &v.unknownFields
519 file_lcmservice_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
520 switch v := v.(*QueryResponse); i {
526 return &v.unknownFields
532 file_lcmservice_proto_msgTypes[0].OneofWrappers = []interface{}{
533 (*InstantiateRequest_HostIp)(nil),
534 (*InstantiateRequest_Package)(nil),
537 out := protoimpl.TypeBuilder{
538 File: protoimpl.DescBuilder{
539 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
540 RawDescriptor: file_lcmservice_proto_rawDesc,
546 GoTypes: file_lcmservice_proto_goTypes,
547 DependencyIndexes: file_lcmservice_proto_depIdxs,
548 MessageInfos: file_lcmservice_proto_msgTypes,
550 File_lcmservice_proto = out.File
551 file_lcmservice_proto_rawDesc = nil
552 file_lcmservice_proto_goTypes = nil
553 file_lcmservice_proto_depIdxs = nil
556 // Reference imports to suppress errors if they are not otherwise used.
557 var _ context.Context
558 var _ grpc.ClientConnInterface
560 // This is a compile-time assertion to ensure that this generated file
561 // is compatible with the grpc package it is being compiled against.
562 const _ = grpc.SupportPackageIsVersion6
564 // AppLCMClient is the client API for AppLCM service.
566 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
567 type AppLCMClient interface {
568 Instantiate(ctx context.Context, opts ...grpc.CallOption) (AppLCM_InstantiateClient, error)
569 Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
570 Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
573 type appLCMClient struct {
574 cc grpc.ClientConnInterface
577 func NewAppLCMClient(cc grpc.ClientConnInterface) AppLCMClient {
578 return &appLCMClient{cc}
581 func (c *appLCMClient) Instantiate(ctx context.Context, opts ...grpc.CallOption) (AppLCM_InstantiateClient, error) {
582 stream, err := c.cc.NewStream(ctx, &_AppLCM_serviceDesc.Streams[0], "/lcmservice.AppLCM/instantiate", opts...)
586 x := &appLCMInstantiateClient{stream}
590 type AppLCM_InstantiateClient interface {
591 Send(*InstantiateRequest) error
592 CloseAndRecv() (*InstantiateResponse, error)
596 type appLCMInstantiateClient struct {
600 func (x *appLCMInstantiateClient) Send(m *InstantiateRequest) error {
601 return x.ClientStream.SendMsg(m)
604 func (x *appLCMInstantiateClient) CloseAndRecv() (*InstantiateResponse, error) {
605 if err := x.ClientStream.CloseSend(); err != nil {
608 m := new(InstantiateResponse)
609 if err := x.ClientStream.RecvMsg(m); err != nil {
615 func (c *appLCMClient) Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error) {
616 out := new(TerminateResponse)
617 err := c.cc.Invoke(ctx, "/lcmservice.AppLCM/terminate", in, out, opts...)
624 func (c *appLCMClient) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error) {
625 out := new(QueryResponse)
626 err := c.cc.Invoke(ctx, "/lcmservice.AppLCM/query", in, out, opts...)
633 // AppLCMServer is the server API for AppLCM service.
634 type AppLCMServer interface {
635 Instantiate(AppLCM_InstantiateServer) error
636 Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error)
637 Query(context.Context, *QueryRequest) (*QueryResponse, error)
640 // UnimplementedAppLCMServer can be embedded to have forward compatible implementations.
641 type UnimplementedAppLCMServer struct {
644 func (*UnimplementedAppLCMServer) Instantiate(AppLCM_InstantiateServer) error {
645 return status.Errorf(codes.Unimplemented, "method Instantiate not implemented")
647 func (*UnimplementedAppLCMServer) Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error) {
648 return nil, status.Errorf(codes.Unimplemented, "method Terminate not implemented")
650 func (*UnimplementedAppLCMServer) Query(context.Context, *QueryRequest) (*QueryResponse, error) {
651 return nil, status.Errorf(codes.Unimplemented, "method Query not implemented")
654 func RegisterAppLCMServer(s *grpc.Server, srv AppLCMServer) {
655 s.RegisterService(&_AppLCM_serviceDesc, srv)
658 func _AppLCM_Instantiate_Handler(srv interface{}, stream grpc.ServerStream) error {
659 return srv.(AppLCMServer).Instantiate(&appLCMInstantiateServer{stream})
662 type AppLCM_InstantiateServer interface {
663 SendAndClose(*InstantiateResponse) error
664 Recv() (*InstantiateRequest, error)
668 type appLCMInstantiateServer struct {
672 func (x *appLCMInstantiateServer) SendAndClose(m *InstantiateResponse) error {
673 return x.ServerStream.SendMsg(m)
676 func (x *appLCMInstantiateServer) Recv() (*InstantiateRequest, error) {
677 m := new(InstantiateRequest)
678 if err := x.ServerStream.RecvMsg(m); err != nil {
684 func _AppLCM_Terminate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
685 in := new(TerminateRequest)
686 if err := dec(in); err != nil {
689 if interceptor == nil {
690 return srv.(AppLCMServer).Terminate(ctx, in)
692 info := &grpc.UnaryServerInfo{
694 FullMethod: "/lcmservice.AppLCM/Terminate",
696 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
697 return srv.(AppLCMServer).Terminate(ctx, req.(*TerminateRequest))
699 return interceptor(ctx, in, info, handler)
702 func _AppLCM_Query_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
703 in := new(QueryRequest)
704 if err := dec(in); err != nil {
707 if interceptor == nil {
708 return srv.(AppLCMServer).Query(ctx, in)
710 info := &grpc.UnaryServerInfo{
712 FullMethod: "/lcmservice.AppLCM/Query",
714 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
715 return srv.(AppLCMServer).Query(ctx, req.(*QueryRequest))
717 return interceptor(ctx, in, info, handler)
720 var _AppLCM_serviceDesc = grpc.ServiceDesc{
721 ServiceName: "lcmservice.AppLCM",
722 HandlerType: (*AppLCMServer)(nil),
723 Methods: []grpc.MethodDesc{
725 MethodName: "terminate",
726 Handler: _AppLCM_Terminate_Handler,
730 Handler: _AppLCM_Query_Handler,
733 Streams: []grpc.StreamDesc{
735 StreamName: "instantiate",
736 Handler: _AppLCM_Instantiate_Handler,
740 Metadata: "lcmservice.proto",