1 // Code generated by protoc-gen-go. DO NOT EDIT.
3 // protoc-gen-go v1.22.0-devel
5 // source: lcmservice.proto
14 proto "github.com/golang/protobuf/proto"
15 grpc "google.golang.org/grpc"
16 codes "google.golang.org/grpc/codes"
17 status "google.golang.org/grpc/status"
18 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
19 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
23 // Verify that this generated code is sufficiently up-to-date.
24 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
25 // Verify that runtime/protoimpl is sufficiently up-to-date.
26 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
29 // This is a compile-time assertion that a sufficiently up-to-date version
30 // of the legacy proto package is being used.
31 const _ = proto.ProtoPackageIsVersion4
33 type InstantiateRequest struct {
34 state protoimpl.MessageState
35 sizeCache protoimpl.SizeCache
36 unknownFields protoimpl.UnknownFields
38 // Types that are assignable to Data:
39 // *InstantiateRequest_HostIp
40 // *InstantiateRequest_Package
41 Data isInstantiateRequest_Data `protobuf_oneof:"data"`
44 func (x *InstantiateRequest) Reset() {
45 *x = InstantiateRequest{}
46 if protoimpl.UnsafeEnabled {
47 mi := &file_lcmservice_proto_msgTypes[0]
48 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
49 ms.StoreMessageInfo(mi)
53 func (x *InstantiateRequest) String() string {
54 return protoimpl.X.MessageStringOf(x)
57 func (*InstantiateRequest) ProtoMessage() {}
59 func (x *InstantiateRequest) ProtoReflect() protoreflect.Message {
60 mi := &file_lcmservice_proto_msgTypes[0]
61 if protoimpl.UnsafeEnabled && x != nil {
62 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
63 if ms.LoadMessageInfo() == nil {
64 ms.StoreMessageInfo(mi)
68 return mi.MessageOf(x)
71 // Deprecated: Use InstantiateRequest.ProtoReflect.Descriptor instead.
72 func (*InstantiateRequest) Descriptor() ([]byte, []int) {
73 return file_lcmservice_proto_rawDescGZIP(), []int{0}
76 func (m *InstantiateRequest) GetData() isInstantiateRequest_Data {
83 func (x *InstantiateRequest) GetHostIp() string {
84 if x, ok := x.GetData().(*InstantiateRequest_HostIp); ok {
90 func (x *InstantiateRequest) GetPackage() []byte {
91 if x, ok := x.GetData().(*InstantiateRequest_Package); ok {
97 type isInstantiateRequest_Data interface {
98 isInstantiateRequest_Data()
101 type InstantiateRequest_HostIp struct {
102 HostIp string `protobuf:"bytes,1,opt,name=hostIp,proto3,oneof"`
105 type InstantiateRequest_Package struct {
106 Package []byte `protobuf:"bytes,2,opt,name=package,proto3,oneof"`
109 func (*InstantiateRequest_HostIp) isInstantiateRequest_Data() {}
111 func (*InstantiateRequest_Package) isInstantiateRequest_Data() {}
113 type InstantiateResponse struct {
114 state protoimpl.MessageState
115 sizeCache protoimpl.SizeCache
116 unknownFields protoimpl.UnknownFields
118 WorkloadId string `protobuf:"bytes,1,opt,name=workloadId,proto3" json:"workloadId,omitempty"`
119 Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
122 func (x *InstantiateResponse) Reset() {
123 *x = InstantiateResponse{}
124 if protoimpl.UnsafeEnabled {
125 mi := &file_lcmservice_proto_msgTypes[1]
126 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
127 ms.StoreMessageInfo(mi)
131 func (x *InstantiateResponse) String() string {
132 return protoimpl.X.MessageStringOf(x)
135 func (*InstantiateResponse) ProtoMessage() {}
137 func (x *InstantiateResponse) ProtoReflect() protoreflect.Message {
138 mi := &file_lcmservice_proto_msgTypes[1]
139 if protoimpl.UnsafeEnabled && x != nil {
140 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
141 if ms.LoadMessageInfo() == nil {
142 ms.StoreMessageInfo(mi)
146 return mi.MessageOf(x)
149 // Deprecated: Use InstantiateResponse.ProtoReflect.Descriptor instead.
150 func (*InstantiateResponse) Descriptor() ([]byte, []int) {
151 return file_lcmservice_proto_rawDescGZIP(), []int{1}
154 func (x *InstantiateResponse) GetWorkloadId() string {
161 func (x *InstantiateResponse) GetStatus() string {
168 type TerminateRequest struct {
169 state protoimpl.MessageState
170 sizeCache protoimpl.SizeCache
171 unknownFields protoimpl.UnknownFields
173 HostIp string `protobuf:"bytes,1,opt,name=hostIp,proto3" json:"hostIp,omitempty"`
174 WorkloadId string `protobuf:"bytes,2,opt,name=workloadId,proto3" json:"workloadId,omitempty"`
177 func (x *TerminateRequest) Reset() {
178 *x = TerminateRequest{}
179 if protoimpl.UnsafeEnabled {
180 mi := &file_lcmservice_proto_msgTypes[2]
181 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
182 ms.StoreMessageInfo(mi)
186 func (x *TerminateRequest) String() string {
187 return protoimpl.X.MessageStringOf(x)
190 func (*TerminateRequest) ProtoMessage() {}
192 func (x *TerminateRequest) ProtoReflect() protoreflect.Message {
193 mi := &file_lcmservice_proto_msgTypes[2]
194 if protoimpl.UnsafeEnabled && x != nil {
195 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
196 if ms.LoadMessageInfo() == nil {
197 ms.StoreMessageInfo(mi)
201 return mi.MessageOf(x)
204 // Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.
205 func (*TerminateRequest) Descriptor() ([]byte, []int) {
206 return file_lcmservice_proto_rawDescGZIP(), []int{2}
209 func (x *TerminateRequest) GetHostIp() string {
216 func (x *TerminateRequest) GetWorkloadId() string {
223 type TerminateResponse struct {
224 state protoimpl.MessageState
225 sizeCache protoimpl.SizeCache
226 unknownFields protoimpl.UnknownFields
228 Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
231 func (x *TerminateResponse) Reset() {
232 *x = TerminateResponse{}
233 if protoimpl.UnsafeEnabled {
234 mi := &file_lcmservice_proto_msgTypes[3]
235 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
236 ms.StoreMessageInfo(mi)
240 func (x *TerminateResponse) String() string {
241 return protoimpl.X.MessageStringOf(x)
244 func (*TerminateResponse) ProtoMessage() {}
246 func (x *TerminateResponse) ProtoReflect() protoreflect.Message {
247 mi := &file_lcmservice_proto_msgTypes[3]
248 if protoimpl.UnsafeEnabled && x != nil {
249 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
250 if ms.LoadMessageInfo() == nil {
251 ms.StoreMessageInfo(mi)
255 return mi.MessageOf(x)
258 // Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.
259 func (*TerminateResponse) Descriptor() ([]byte, []int) {
260 return file_lcmservice_proto_rawDescGZIP(), []int{3}
263 func (x *TerminateResponse) GetStatus() string {
270 type QueryRequest struct {
271 state protoimpl.MessageState
272 sizeCache protoimpl.SizeCache
273 unknownFields protoimpl.UnknownFields
275 HostIp string `protobuf:"bytes,1,opt,name=hostIp,proto3" json:"hostIp,omitempty"`
276 WorkloadId string `protobuf:"bytes,2,opt,name=workloadId,proto3" json:"workloadId,omitempty"`
279 func (x *QueryRequest) Reset() {
281 if protoimpl.UnsafeEnabled {
282 mi := &file_lcmservice_proto_msgTypes[4]
283 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
284 ms.StoreMessageInfo(mi)
288 func (x *QueryRequest) String() string {
289 return protoimpl.X.MessageStringOf(x)
292 func (*QueryRequest) ProtoMessage() {}
294 func (x *QueryRequest) ProtoReflect() protoreflect.Message {
295 mi := &file_lcmservice_proto_msgTypes[4]
296 if protoimpl.UnsafeEnabled && x != nil {
297 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
298 if ms.LoadMessageInfo() == nil {
299 ms.StoreMessageInfo(mi)
303 return mi.MessageOf(x)
306 // Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
307 func (*QueryRequest) Descriptor() ([]byte, []int) {
308 return file_lcmservice_proto_rawDescGZIP(), []int{4}
311 func (x *QueryRequest) GetHostIp() string {
318 func (x *QueryRequest) GetWorkloadId() string {
325 type QueryResponse struct {
326 state protoimpl.MessageState
327 sizeCache protoimpl.SizeCache
328 unknownFields protoimpl.UnknownFields
330 Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
333 func (x *QueryResponse) Reset() {
335 if protoimpl.UnsafeEnabled {
336 mi := &file_lcmservice_proto_msgTypes[5]
337 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
338 ms.StoreMessageInfo(mi)
342 func (x *QueryResponse) String() string {
343 return protoimpl.X.MessageStringOf(x)
346 func (*QueryResponse) ProtoMessage() {}
348 func (x *QueryResponse) ProtoReflect() protoreflect.Message {
349 mi := &file_lcmservice_proto_msgTypes[5]
350 if protoimpl.UnsafeEnabled && x != nil {
351 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
352 if ms.LoadMessageInfo() == nil {
353 ms.StoreMessageInfo(mi)
357 return mi.MessageOf(x)
360 // Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.
361 func (*QueryResponse) Descriptor() ([]byte, []int) {
362 return file_lcmservice_proto_rawDescGZIP(), []int{5}
365 func (x *QueryResponse) GetStatus() string {
372 var File_lcmservice_proto protoreflect.FileDescriptor
374 var file_lcmservice_proto_rawDesc = []byte{
375 0x0a, 0x10, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f,
376 0x74, 0x6f, 0x12, 0x0a, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x22, 0x52,
377 0x0a, 0x12, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x52, 0x65, 0x71,
378 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x70, 0x18, 0x01,
379 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x70, 0x12, 0x1a,
380 0x0a, 0x07, 0x70, 0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x48,
381 0x00, 0x52, 0x07, 0x70, 0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x42, 0x06, 0x0a, 0x04, 0x64, 0x61,
382 0x74, 0x61, 0x22, 0x4d, 0x0a, 0x13, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74,
383 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x77, 0x6f, 0x72,
384 0x6b, 0x6c, 0x6f, 0x61, 0x64, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x77,
385 0x6f, 0x72, 0x6b, 0x6c, 0x6f, 0x61, 0x64, 0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61,
386 0x74, 0x75, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75,
387 0x73, 0x22, 0x4a, 0x0a, 0x10, 0x54, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x52, 0x65,
388 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x70, 0x18,
389 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x68, 0x6f, 0x73, 0x74, 0x49, 0x70, 0x12, 0x1e, 0x0a,
390 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x6c, 0x6f, 0x61, 0x64, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28,
391 0x09, 0x52, 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x6c, 0x6f, 0x61, 0x64, 0x49, 0x64, 0x22, 0x2b, 0x0a,
392 0x11, 0x54, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
393 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x01, 0x20, 0x01,
394 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x22, 0x46, 0x0a, 0x0c, 0x51, 0x75,
395 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x68, 0x6f,
396 0x73, 0x74, 0x49, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x68, 0x6f, 0x73, 0x74,
397 0x49, 0x70, 0x12, 0x1e, 0x0a, 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x6c, 0x6f, 0x61, 0x64, 0x49, 0x64,
398 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x77, 0x6f, 0x72, 0x6b, 0x6c, 0x6f, 0x61, 0x64,
399 0x49, 0x64, 0x22, 0x27, 0x0a, 0x0d, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f,
400 0x6e, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x01, 0x20,
401 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x32, 0xe8, 0x01, 0x0a, 0x06,
402 0x41, 0x70, 0x70, 0x4c, 0x43, 0x4d, 0x12, 0x52, 0x0a, 0x0b, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e,
403 0x74, 0x69, 0x61, 0x74, 0x65, 0x12, 0x1e, 0x2e, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69,
404 0x63, 0x65, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x52, 0x65,
405 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69,
406 0x63, 0x65, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x69, 0x61, 0x74, 0x65, 0x52, 0x65,
407 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x12, 0x4a, 0x0a, 0x09, 0x74, 0x65,
408 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x12, 0x1c, 0x2e, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72,
409 0x76, 0x69, 0x63, 0x65, 0x2e, 0x54, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x52, 0x65,
410 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69,
411 0x63, 0x65, 0x2e, 0x54, 0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70,
412 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x3e, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12,
413 0x18, 0x2e, 0x6c, 0x63, 0x6d, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x51, 0x75, 0x65,
414 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x19, 0x2e, 0x6c, 0x63, 0x6d, 0x73,
415 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70,
416 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 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",