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

   1 // Code generated by protoc-gen-go. DO NOT EDIT.
   2 // versions:
   3 //      protoc-gen-go v1.22.0-devel
   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, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 417 }
 418
 419 var (
 420         file_lcmservice_proto_rawDescOnce sync.Once
 421         file_lcmservice_proto_rawDescData = file_lcmservice_proto_rawDesc
 422 )
 423
 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)
 427         })
 428         return file_lcmservice_proto_rawDescData
 429 }
 430
 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
 439 }
 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
 452 }
 453
 454 func init() { file_lcmservice_proto_init() }
 455 func file_lcmservice_proto_init() {
 456         if File_lcmservice_proto != nil {
 457                 return
 458         }
 459         if !protoimpl.UnsafeEnabled {
 460                 file_lcmservice_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
 461                         switch v := v.(*InstantiateRequest); i {
 462                         case 0:
 463                                 return &v.state
 464                         case 1:
 465                                 return &v.sizeCache
 466                         case 2:
 467                                 return &v.unknownFields
 468                         default:
 469                                 return nil
 470                         }
 471                 }
 472                 file_lcmservice_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
 473                         switch v := v.(*InstantiateResponse); i {
 474                         case 0:
 475                                 return &v.state
 476                         case 1:
 477                                 return &v.sizeCache
 478                         case 2:
 479                                 return &v.unknownFields
 480                         default:
 481                                 return nil
 482                         }
 483                 }
 484                 file_lcmservice_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
 485                         switch v := v.(*TerminateRequest); i {
 486                         case 0:
 487                                 return &v.state
 488                         case 1:
 489                                 return &v.sizeCache
 490                         case 2:
 491                                 return &v.unknownFields
 492                         default:
 493                                 return nil
 494                         }
 495                 }
 496                 file_lcmservice_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
 497                         switch v := v.(*TerminateResponse); i {
 498                         case 0:
 499                                 return &v.state
 500                         case 1:
 501                                 return &v.sizeCache
 502                         case 2:
 503                                 return &v.unknownFields
 504                         default:
 505                                 return nil
 506                         }
 507                 }
 508                 file_lcmservice_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
 509                         switch v := v.(*QueryRequest); i {
 510                         case 0:
 511                                 return &v.state
 512                         case 1:
 513                                 return &v.sizeCache
 514                         case 2:
 515                                 return &v.unknownFields
 516                         default:
 517                                 return nil
 518                         }
 519                 }
 520                 file_lcmservice_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
 521                         switch v := v.(*QueryResponse); i {
 522                         case 0:
 523                                 return &v.state
 524                         case 1:
 525                                 return &v.sizeCache
 526                         case 2:
 527                                 return &v.unknownFields
 528                         default:
 529                                 return nil
 530                         }
 531                 }
 532         }
 533         file_lcmservice_proto_msgTypes[0].OneofWrappers = []interface{}{
 534                 (*InstantiateRequest_HostIp)(nil),
 535                 (*InstantiateRequest_Package)(nil),
 536         }
 537         type x struct{}
 538         out := protoimpl.TypeBuilder{
 539                 File: protoimpl.DescBuilder{
 540                         GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 541                         RawDescriptor: file_lcmservice_proto_rawDesc,
 542                         NumEnums:      0,
 543                         NumMessages:   6,
 544                         NumExtensions: 0,
 545                         NumServices:   1,
 546                 },
 547                 GoTypes:           file_lcmservice_proto_goTypes,
 548                 DependencyIndexes: file_lcmservice_proto_depIdxs,
 549                 MessageInfos:      file_lcmservice_proto_msgTypes,
 550         }.Build()
 551         File_lcmservice_proto = out.File
 552         file_lcmservice_proto_rawDesc = nil
 553         file_lcmservice_proto_goTypes = nil
 554         file_lcmservice_proto_depIdxs = nil
 555 }
 556
 557 // Reference imports to suppress errors if they are not otherwise used.
 558 var _ context.Context
 559 var _ grpc.ClientConnInterface
 560
 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
 564
 565 // AppLCMClient is the client API for AppLCM service.
 566 //
 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)
 572 }
 573
 574 type appLCMClient struct {
 575         cc grpc.ClientConnInterface
 576 }
 577
 578 func NewAppLCMClient(cc grpc.ClientConnInterface) AppLCMClient {
 579         return &appLCMClient{cc}
 580 }
 581
 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...)
 584         if err != nil {
 585                 return nil, err
 586         }
 587         x := &appLCMInstantiateClient{stream}
 588         return x, nil
 589 }
 590
 591 type AppLCM_InstantiateClient interface {
 592         Send(*InstantiateRequest) error
 593         CloseAndRecv() (*InstantiateResponse, error)
 594         grpc.ClientStream
 595 }
 596
 597 type appLCMInstantiateClient struct {
 598         grpc.ClientStream
 599 }
 600
 601 func (x *appLCMInstantiateClient) Send(m *InstantiateRequest) error {
 602         return x.ClientStream.SendMsg(m)
 603 }
 604
 605 func (x *appLCMInstantiateClient) CloseAndRecv() (*InstantiateResponse, error) {
 606         if err := x.ClientStream.CloseSend(); err != nil {
 607                 return nil, err
 608         }
 609         m := new(InstantiateResponse)
 610         if err := x.ClientStream.RecvMsg(m); err != nil {
 611                 return nil, err
 612         }
 613         return m, nil
 614 }
 615
 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...)
 619         if err != nil {
 620                 return nil, err
 621         }
 622         return out, nil
 623 }
 624
 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...)
 628         if err != nil {
 629                 return nil, err
 630         }
 631         return out, nil
 632 }
 633
 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)
 639 }
 640
 641 // UnimplementedAppLCMServer can be embedded to have forward compatible implementations.
 642 type UnimplementedAppLCMServer struct {
 643 }
 644
 645 func (*UnimplementedAppLCMServer) Instantiate(AppLCM_InstantiateServer) error {
 646         return status.Errorf(codes.Unimplemented, "method Instantiate not implemented")
 647 }
 648 func (*UnimplementedAppLCMServer) Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error) {
 649         return nil, status.Errorf(codes.Unimplemented, "method Terminate not implemented")
 650 }
 651 func (*UnimplementedAppLCMServer) Query(context.Context, *QueryRequest) (*QueryResponse, error) {
 652         return nil, status.Errorf(codes.Unimplemented, "method Query not implemented")
 653 }
 654
 655 func RegisterAppLCMServer(s *grpc.Server, srv AppLCMServer) {
 656         s.RegisterService(&_AppLCM_serviceDesc, srv)
 657 }
 658
 659 func _AppLCM_Instantiate_Handler(srv interface{}, stream grpc.ServerStream) error {
 660         return srv.(AppLCMServer).Instantiate(&appLCMInstantiateServer{stream})
 661 }
 662
 663 type AppLCM_InstantiateServer interface {
 664         SendAndClose(*InstantiateResponse) error
 665         Recv() (*InstantiateRequest, error)
 666         grpc.ServerStream
 667 }
 668
 669 type appLCMInstantiateServer struct {
 670         grpc.ServerStream
 671 }
 672
 673 func (x *appLCMInstantiateServer) SendAndClose(m *InstantiateResponse) error {
 674         return x.ServerStream.SendMsg(m)
 675 }
 676
 677 func (x *appLCMInstantiateServer) Recv() (*InstantiateRequest, error) {
 678         m := new(InstantiateRequest)
 679         if err := x.ServerStream.RecvMsg(m); err != nil {
 680                 return nil, err
 681         }
 682         return m, nil
 683 }
 684
 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 {
 688                 return nil, err
 689         }
 690         if interceptor == nil {
 691                 return srv.(AppLCMServer).Terminate(ctx, in)
 692         }
 693         info := &grpc.UnaryServerInfo{
 694                 Server:     srv,
 695                 FullMethod: "/lcmservice.AppLCM/Terminate",
 696         }
 697         handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 698                 return srv.(AppLCMServer).Terminate(ctx, req.(*TerminateRequest))
 699         }
 700         return interceptor(ctx, in, info, handler)
 701 }
 702
 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 {
 706                 return nil, err
 707         }
 708         if interceptor == nil {
 709                 return srv.(AppLCMServer).Query(ctx, in)
 710         }
 711         info := &grpc.UnaryServerInfo{
 712                 Server:     srv,
 713                 FullMethod: "/lcmservice.AppLCM/Query",
 714         }
 715         handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 716                 return srv.(AppLCMServer).Query(ctx, req.(*QueryRequest))
 717         }
 718         return interceptor(ctx, in, info, handler)
 719 }
 720
 721 var _AppLCM_serviceDesc = grpc.ServiceDesc{
 722         ServiceName: "lcmservice.AppLCM",
 723         HandlerType: (*AppLCMServer)(nil),
 724         Methods: []grpc.MethodDesc{
 725                 {
 726                         MethodName: "terminate",
 727                         Handler:    _AppLCM_Terminate_Handler,
 728                 },
 729                 {
 730                         MethodName: "query",
 731                         Handler:    _AppLCM_Query_Handler,
 732                 },
 733         },
 734         Streams: []grpc.StreamDesc{
 735                 {
 736                         StreamName:    "instantiate",
 737                         Handler:       _AppLCM_Instantiate_Handler,
 738                         ClientStreams: true,
 739                 },
 740         },
 741         Metadata: "lcmservice.proto",
 742 }