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         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, 0x42, 0x0e, 0x5a, 0x0c, 0x2e, 0x3b, 0x6c, 0x63, 0x6d, 0x73,
 416         0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 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 }