mecm/mepm/applcm/k8shelm/internal/lcmservice/lcmservice.pb.go

   1 // Code generated by protoc-gen-go. DO NOT EDIT.
   2 // versions:
   3 //      protoc-gen-go v1.22.0
   4 //      protoc        v3.11.4
   5 // source: lcmservice.proto
   6
   7 package lcmservice
   8
   9 import (
  10         context "context"
  11         reflect "reflect"
  12         sync "sync"
  13
  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"
  20 )
  21
  22 const (
  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)
  27 )
  28
  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
  32
  33 type InstantiateRequest struct {
  34         state         protoimpl.MessageState
  35         sizeCache     protoimpl.SizeCache
  36         unknownFields protoimpl.UnknownFields
  37
  38         // Types that are assignable to Data:
  39         //      *InstantiateRequest_HostIp
  40         //      *InstantiateRequest_Package
  41         Data isInstantiateRequest_Data `protobuf_oneof:"data"`
  42 }
  43
  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)
  50         }
  51 }
  52
  53 func (x *InstantiateRequest) String() string {
  54         return protoimpl.X.MessageStringOf(x)
  55 }
  56
  57 func (*InstantiateRequest) ProtoMessage() {}
  58
  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)
  65                 }
  66                 return ms
  67         }
  68         return mi.MessageOf(x)
  69 }
  70
  71 // Deprecated: Use InstantiateRequest.ProtoReflect.Descriptor instead.
  72 func (*InstantiateRequest) Descriptor() ([]byte, []int) {
  73         return file_lcmservice_proto_rawDescGZIP(), []int{0}
  74 }
  75
  76 func (m *InstantiateRequest) GetData() isInstantiateRequest_Data {
  77         if m != nil {
  78                 return m.Data
  79         }
  80         return nil
  81 }
  82
  83 func (x *InstantiateRequest) GetHostIp() string {
  84         if x, ok := x.GetData().(*InstantiateRequest_HostIp); ok {
  85                 return x.HostIp
  86         }
  87         return ""
  88 }
  89
  90 func (x *InstantiateRequest) GetPackage() []byte {
  91         if x, ok := x.GetData().(*InstantiateRequest_Package); ok {
  92                 return x.Package
  93         }
  94         return nil
  95 }
  96
  97 type isInstantiateRequest_Data interface {
  98         isInstantiateRequest_Data()
  99 }
 100
 101 type InstantiateRequest_HostIp struct {
 102         HostIp string `protobuf:"bytes,1,opt,name=hostIp,proto3,oneof"`
 103 }
 104
 105 type InstantiateRequest_Package struct {
 106         Package []byte `protobuf:"bytes,2,opt,name=package,proto3,oneof"`
 107 }
 108
 109 func (*InstantiateRequest_HostIp) isInstantiateRequest_Data() {}
 110
 111 func (*InstantiateRequest_Package) isInstantiateRequest_Data() {}
 112
 113 type InstantiateResponse struct {
 114         state         protoimpl.MessageState
 115         sizeCache     protoimpl.SizeCache
 116         unknownFields protoimpl.UnknownFields
 117
 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"`
 120 }
 121
 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)
 128         }
 129 }
 130
 131 func (x *InstantiateResponse) String() string {
 132         return protoimpl.X.MessageStringOf(x)
 133 }
 134
 135 func (*InstantiateResponse) ProtoMessage() {}
 136
 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)
 143                 }
 144                 return ms
 145         }
 146         return mi.MessageOf(x)
 147 }
 148
 149 // Deprecated: Use InstantiateResponse.ProtoReflect.Descriptor instead.
 150 func (*InstantiateResponse) Descriptor() ([]byte, []int) {
 151         return file_lcmservice_proto_rawDescGZIP(), []int{1}
 152 }
 153
 154 func (x *InstantiateResponse) GetWorkloadId() string {
 155         if x != nil {
 156                 return x.WorkloadId
 157         }
 158         return ""
 159 }
 160
 161 func (x *InstantiateResponse) GetStatus() string {
 162         if x != nil {
 163                 return x.Status
 164         }
 165         return ""
 166 }
 167
 168 type TerminateRequest struct {
 169         state         protoimpl.MessageState
 170         sizeCache     protoimpl.SizeCache
 171         unknownFields protoimpl.UnknownFields
 172
 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"`
 175 }
 176
 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)
 183         }
 184 }
 185
 186 func (x *TerminateRequest) String() string {
 187         return protoimpl.X.MessageStringOf(x)
 188 }
 189
 190 func (*TerminateRequest) ProtoMessage() {}
 191
 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)
 198                 }
 199                 return ms
 200         }
 201         return mi.MessageOf(x)
 202 }
 203
 204 // Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.
 205 func (*TerminateRequest) Descriptor() ([]byte, []int) {
 206         return file_lcmservice_proto_rawDescGZIP(), []int{2}
 207 }
 208
 209 func (x *TerminateRequest) GetHostIp() string {
 210         if x != nil {
 211                 return x.HostIp
 212         }
 213         return ""
 214 }
 215
 216 func (x *TerminateRequest) GetWorkloadId() string {
 217         if x != nil {
 218                 return x.WorkloadId
 219         }
 220         return ""
 221 }
 222
 223 type TerminateResponse struct {
 224         state         protoimpl.MessageState
 225         sizeCache     protoimpl.SizeCache
 226         unknownFields protoimpl.UnknownFields
 227
 228         Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
 229 }
 230
 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)
 237         }
 238 }
 239
 240 func (x *TerminateResponse) String() string {
 241         return protoimpl.X.MessageStringOf(x)
 242 }
 243
 244 func (*TerminateResponse) ProtoMessage() {}
 245
 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)
 252                 }
 253                 return ms
 254         }
 255         return mi.MessageOf(x)
 256 }
 257
 258 // Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.
 259 func (*TerminateResponse) Descriptor() ([]byte, []int) {
 260         return file_lcmservice_proto_rawDescGZIP(), []int{3}
 261 }
 262
 263 func (x *TerminateResponse) GetStatus() string {
 264         if x != nil {
 265                 return x.Status
 266         }
 267         return ""
 268 }
 269
 270 type QueryRequest struct {
 271         state         protoimpl.MessageState
 272         sizeCache     protoimpl.SizeCache
 273         unknownFields protoimpl.UnknownFields
 274
 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"`
 277 }
 278
 279 func (x *QueryRequest) Reset() {
 280         *x = QueryRequest{}
 281         if protoimpl.UnsafeEnabled {
 282                 mi := &file_lcmservice_proto_msgTypes[4]
 283                 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 284                 ms.StoreMessageInfo(mi)
 285         }
 286 }
 287
 288 func (x *QueryRequest) String() string {
 289         return protoimpl.X.MessageStringOf(x)
 290 }
 291
 292 func (*QueryRequest) ProtoMessage() {}
 293
 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)
 300                 }
 301                 return ms
 302         }
 303         return mi.MessageOf(x)
 304 }
 305
 306 // Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
 307 func (*QueryRequest) Descriptor() ([]byte, []int) {
 308         return file_lcmservice_proto_rawDescGZIP(), []int{4}
 309 }
 310
 311 func (x *QueryRequest) GetHostIp() string {
 312         if x != nil {
 313                 return x.HostIp
 314         }
 315         return ""
 316 }
 317
 318 func (x *QueryRequest) GetWorkloadId() string {
 319         if x != nil {
 320                 return x.WorkloadId
 321         }
 322         return ""
 323 }
 324
 325 type QueryResponse struct {
 326         state         protoimpl.MessageState
 327         sizeCache     protoimpl.SizeCache
 328         unknownFields protoimpl.UnknownFields
 329
 330         Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
 331 }
 332
 333 func (x *QueryResponse) Reset() {
 334         *x = QueryResponse{}
 335         if protoimpl.UnsafeEnabled {
 336                 mi := &file_lcmservice_proto_msgTypes[5]
 337                 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 338                 ms.StoreMessageInfo(mi)
 339         }
 340 }
 341
 342 func (x *QueryResponse) String() string {
 343         return protoimpl.X.MessageStringOf(x)
 344 }
 345
 346 func (*QueryResponse) ProtoMessage() {}
 347
 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)
 354                 }
 355                 return ms
 356         }
 357         return mi.MessageOf(x)
 358 }
 359
 360 // Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.
 361 func (*QueryResponse) Descriptor() ([]byte, []int) {
 362         return file_lcmservice_proto_rawDescGZIP(), []int{5}
 363 }
 364
 365 func (x *QueryResponse) GetStatus() string {
 366         if x != nil {
 367                 return x.Status
 368         }
 369         return ""
 370 }
 371
 372 var File_lcmservice_proto protoreflect.FileDescriptor
 373
 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, 0x42, 0x0e, 0x5a, 0x0c, 0x2e, 0x3b, 0x6c, 0x63, 0x6d, 0x73,
 417         0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 418 }
 419
 420 var (
 421         file_lcmservice_proto_rawDescOnce sync.Once
 422         file_lcmservice_proto_rawDescData = file_lcmservice_proto_rawDesc
 423 )
 424
 425 func file_lcmservice_proto_rawDescGZIP() []byte {
 426         file_lcmservice_proto_rawDescOnce.Do(func() {
 427                 file_lcmservice_proto_rawDescData = protoimpl.X.CompressGZIP(file_lcmservice_proto_rawDescData)
 428         })
 429         return file_lcmservice_proto_rawDescData
 430 }
 431
 432 var file_lcmservice_proto_msgTypes = make([]protoimpl.MessageInfo, 6)
 433 var file_lcmservice_proto_goTypes = []interface{}{
 434         (*InstantiateRequest)(nil),  // 0: lcmservice.InstantiateRequest
 435         (*InstantiateResponse)(nil), // 1: lcmservice.InstantiateResponse
 436         (*TerminateRequest)(nil),    // 2: lcmservice.TerminateRequest
 437         (*TerminateResponse)(nil),   // 3: lcmservice.TerminateResponse
 438         (*QueryRequest)(nil),        // 4: lcmservice.QueryRequest
 439         (*QueryResponse)(nil),       // 5: lcmservice.QueryResponse
 440 }
 441 var file_lcmservice_proto_depIdxs = []int32{
 442         0, // 0: lcmservice.AppLCM.instantiate:input_type -> lcmservice.InstantiateRequest
 443         2, // 1: lcmservice.AppLCM.terminate:input_type -> lcmservice.TerminateRequest
 444         4, // 2: lcmservice.AppLCM.query:input_type -> lcmservice.QueryRequest
 445         1, // 3: lcmservice.AppLCM.instantiate:output_type -> lcmservice.InstantiateResponse
 446         3, // 4: lcmservice.AppLCM.terminate:output_type -> lcmservice.TerminateResponse
 447         5, // 5: lcmservice.AppLCM.query:output_type -> lcmservice.QueryResponse
 448         3, // [3:6] is the sub-list for method output_type
 449         0, // [0:3] is the sub-list for method input_type
 450         0, // [0:0] is the sub-list for extension type_name
 451         0, // [0:0] is the sub-list for extension extendee
 452         0, // [0:0] is the sub-list for field type_name
 453 }
 454
 455 func init() { file_lcmservice_proto_init() }
 456 func file_lcmservice_proto_init() {
 457         if File_lcmservice_proto != nil {
 458                 return
 459         }
 460         if !protoimpl.UnsafeEnabled {
 461                 file_lcmservice_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
 462                         switch v := v.(*InstantiateRequest); i {
 463                         case 0:
 464                                 return &v.state
 465                         case 1:
 466                                 return &v.sizeCache
 467                         case 2:
 468                                 return &v.unknownFields
 469                         default:
 470                                 return nil
 471                         }
 472                 }
 473                 file_lcmservice_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
 474                         switch v := v.(*InstantiateResponse); i {
 475                         case 0:
 476                                 return &v.state
 477                         case 1:
 478                                 return &v.sizeCache
 479                         case 2:
 480                                 return &v.unknownFields
 481                         default:
 482                                 return nil
 483                         }
 484                 }
 485                 file_lcmservice_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
 486                         switch v := v.(*TerminateRequest); i {
 487                         case 0:
 488                                 return &v.state
 489                         case 1:
 490                                 return &v.sizeCache
 491                         case 2:
 492                                 return &v.unknownFields
 493                         default:
 494                                 return nil
 495                         }
 496                 }
 497                 file_lcmservice_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
 498                         switch v := v.(*TerminateResponse); i {
 499                         case 0:
 500                                 return &v.state
 501                         case 1:
 502                                 return &v.sizeCache
 503                         case 2:
 504                                 return &v.unknownFields
 505                         default:
 506                                 return nil
 507                         }
 508                 }
 509                 file_lcmservice_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
 510                         switch v := v.(*QueryRequest); i {
 511                         case 0:
 512                                 return &v.state
 513                         case 1:
 514                                 return &v.sizeCache
 515                         case 2:
 516                                 return &v.unknownFields
 517                         default:
 518                                 return nil
 519                         }
 520                 }
 521                 file_lcmservice_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
 522                         switch v := v.(*QueryResponse); i {
 523                         case 0:
 524                                 return &v.state
 525                         case 1:
 526                                 return &v.sizeCache
 527                         case 2:
 528                                 return &v.unknownFields
 529                         default:
 530                                 return nil
 531                         }
 532                 }
 533         }
 534         file_lcmservice_proto_msgTypes[0].OneofWrappers = []interface{}{
 535                 (*InstantiateRequest_HostIp)(nil),
 536                 (*InstantiateRequest_Package)(nil),
 537         }
 538         type x struct{}
 539         out := protoimpl.TypeBuilder{
 540                 File: protoimpl.DescBuilder{
 541                         GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 542                         RawDescriptor: file_lcmservice_proto_rawDesc,
 543                         NumEnums:      0,
 544                         NumMessages:   6,
 545                         NumExtensions: 0,
 546                         NumServices:   1,
 547                 },
 548                 GoTypes:           file_lcmservice_proto_goTypes,
 549                 DependencyIndexes: file_lcmservice_proto_depIdxs,
 550                 MessageInfos:      file_lcmservice_proto_msgTypes,
 551         }.Build()
 552         File_lcmservice_proto = out.File
 553         file_lcmservice_proto_rawDesc = nil
 554         file_lcmservice_proto_goTypes = nil
 555         file_lcmservice_proto_depIdxs = nil
 556 }
 557
 558 // Reference imports to suppress errors if they are not otherwise used.
 559 var _ context.Context
 560 var _ grpc.ClientConnInterface
 561
 562 // This is a compile-time assertion to ensure that this generated file
 563 // is compatible with the grpc package it is being compiled against.
 564 const _ = grpc.SupportPackageIsVersion6
 565
 566 // AppLCMClient is the client API for AppLCM service.
 567 //
 568 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
 569 type AppLCMClient interface {
 570         Instantiate(ctx context.Context, opts ...grpc.CallOption) (AppLCM_InstantiateClient, error)
 571         Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
 572         Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
 573 }
 574
 575 type appLCMClient struct {
 576         cc grpc.ClientConnInterface
 577 }
 578
 579 func NewAppLCMClient(cc grpc.ClientConnInterface) AppLCMClient {
 580         return &appLCMClient{cc}
 581 }
 582
 583 func (c *appLCMClient) Instantiate(ctx context.Context, opts ...grpc.CallOption) (AppLCM_InstantiateClient, error) {
 584         stream, err := c.cc.NewStream(ctx, &_AppLCM_serviceDesc.Streams[0], "/lcmservice.AppLCM/instantiate", opts...)
 585         if err != nil {
 586                 return nil, err
 587         }
 588         x := &appLCMInstantiateClient{stream}
 589         return x, nil
 590 }
 591
 592 type AppLCM_InstantiateClient interface {
 593         Send(*InstantiateRequest) error
 594         CloseAndRecv() (*InstantiateResponse, error)
 595         grpc.ClientStream
 596 }
 597
 598 type appLCMInstantiateClient struct {
 599         grpc.ClientStream
 600 }
 601
 602 func (x *appLCMInstantiateClient) Send(m *InstantiateRequest) error {
 603         return x.ClientStream.SendMsg(m)
 604 }
 605
 606 func (x *appLCMInstantiateClient) CloseAndRecv() (*InstantiateResponse, error) {
 607         if err := x.ClientStream.CloseSend(); err != nil {
 608                 return nil, err
 609         }
 610         m := new(InstantiateResponse)
 611         if err := x.ClientStream.RecvMsg(m); err != nil {
 612                 return nil, err
 613         }
 614         return m, nil
 615 }
 616
 617 func (c *appLCMClient) Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error) {
 618         out := new(TerminateResponse)
 619         err := c.cc.Invoke(ctx, "/lcmservice.AppLCM/terminate", in, out, opts...)
 620         if err != nil {
 621                 return nil, err
 622         }
 623         return out, nil
 624 }
 625
 626 func (c *appLCMClient) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error) {
 627         out := new(QueryResponse)
 628         err := c.cc.Invoke(ctx, "/lcmservice.AppLCM/query", in, out, opts...)
 629         if err != nil {
 630                 return nil, err
 631         }
 632         return out, nil
 633 }
 634
 635 // AppLCMServer is the server API for AppLCM service.
 636 type AppLCMServer interface {
 637         Instantiate(AppLCM_InstantiateServer) error
 638         Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error)
 639         Query(context.Context, *QueryRequest) (*QueryResponse, error)
 640 }
 641
 642 // UnimplementedAppLCMServer can be embedded to have forward compatible implementations.
 643 type UnimplementedAppLCMServer struct {
 644 }
 645
 646 func (*UnimplementedAppLCMServer) Instantiate(AppLCM_InstantiateServer) error {
 647         return status.Errorf(codes.Unimplemented, "method Instantiate not implemented")
 648 }
 649 func (*UnimplementedAppLCMServer) Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error) {
 650         return nil, status.Errorf(codes.Unimplemented, "method Terminate not implemented")
 651 }
 652 func (*UnimplementedAppLCMServer) Query(context.Context, *QueryRequest) (*QueryResponse, error) {
 653         return nil, status.Errorf(codes.Unimplemented, "method Query not implemented")
 654 }
 655
 656 func RegisterAppLCMServer(s *grpc.Server, srv AppLCMServer) {
 657         s.RegisterService(&_AppLCM_serviceDesc, srv)
 658 }
 659
 660 func _AppLCM_Instantiate_Handler(srv interface{}, stream grpc.ServerStream) error {
 661         return srv.(AppLCMServer).Instantiate(&appLCMInstantiateServer{stream})
 662 }
 663
 664 type AppLCM_InstantiateServer interface {
 665         SendAndClose(*InstantiateResponse) error
 666         Recv() (*InstantiateRequest, error)
 667         grpc.ServerStream
 668 }
 669
 670 type appLCMInstantiateServer struct {
 671         grpc.ServerStream
 672 }
 673
 674 func (x *appLCMInstantiateServer) SendAndClose(m *InstantiateResponse) error {
 675         return x.ServerStream.SendMsg(m)
 676 }
 677
 678 func (x *appLCMInstantiateServer) Recv() (*InstantiateRequest, error) {
 679         m := new(InstantiateRequest)
 680         if err := x.ServerStream.RecvMsg(m); err != nil {
 681                 return nil, err
 682         }
 683         return m, nil
 684 }
 685
 686 func _AppLCM_Terminate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 687         in := new(TerminateRequest)
 688         if err := dec(in); err != nil {
 689                 return nil, err
 690         }
 691         if interceptor == nil {
 692                 return srv.(AppLCMServer).Terminate(ctx, in)
 693         }
 694         info := &grpc.UnaryServerInfo{
 695                 Server:     srv,
 696                 FullMethod: "/lcmservice.AppLCM/Terminate",
 697         }
 698         handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 699                 return srv.(AppLCMServer).Terminate(ctx, req.(*TerminateRequest))
 700         }
 701         return interceptor(ctx, in, info, handler)
 702 }
 703
 704 func _AppLCM_Query_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 705         in := new(QueryRequest)
 706         if err := dec(in); err != nil {
 707                 return nil, err
 708         }
 709         if interceptor == nil {
 710                 return srv.(AppLCMServer).Query(ctx, in)
 711         }
 712         info := &grpc.UnaryServerInfo{
 713                 Server:     srv,
 714                 FullMethod: "/lcmservice.AppLCM/Query",
 715         }
 716         handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 717                 return srv.(AppLCMServer).Query(ctx, req.(*QueryRequest))
 718         }
 719         return interceptor(ctx, in, info, handler)
 720 }
 721
 722 var _AppLCM_serviceDesc = grpc.ServiceDesc{
 723         ServiceName: "lcmservice.AppLCM",
 724         HandlerType: (*AppLCMServer)(nil),
 725         Methods: []grpc.MethodDesc{
 726                 {
 727                         MethodName: "terminate",
 728                         Handler:    _AppLCM_Terminate_Handler,
 729                 },
 730                 {
 731                         MethodName: "query",
 732                         Handler:    _AppLCM_Query_Handler,
 733                 },
 734         },
 735         Streams: []grpc.StreamDesc{
 736                 {
 737                         StreamName:    "instantiate",
 738                         Handler:       _AppLCM_Instantiate_Handler,
 739                         ClientStreams: true,
 740                 },
 741         },
 742         Metadata: "lcmservice.proto",
 743 }