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