internal/pkg/nfnNotify/proto/nfn.pb.go

   1 // Code generated by protoc-gen-go. DO NOT EDIT.
   2 // source: nfn.proto
   3
   4 package nfn
   5
   6 import (
   7         context "context"
   8         fmt "fmt"
   9         proto "github.com/golang/protobuf/proto"
  10         grpc "google.golang.org/grpc"
  11         codes "google.golang.org/grpc/codes"
  12         status "google.golang.org/grpc/status"
  13         math "math"
  14 )
  15
  16 // Reference imports to suppress errors if they are not otherwise used.
  17 var _ = proto.Marshal
  18 var _ = fmt.Errorf
  19 var _ = math.Inf
  20
  21 // This is a compile-time assertion to ensure that this generated file
  22 // is compatible with the proto package it is being compiled against.
  23 // A compilation error at this line likely means your copy of the
  24 // proto package needs to be updated.
  25 const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
  26
  27 type SubscribeContext struct {
  28         NodeName             string   `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
  29         XXX_NoUnkeyedLiteral struct{} `json:"-"`
  30         XXX_unrecognized     []byte   `json:"-"`
  31         XXX_sizecache        int32    `json:"-"`
  32 }
  33
  34 func (m *SubscribeContext) Reset()         { *m = SubscribeContext{} }
  35 func (m *SubscribeContext) String() string { return proto.CompactTextString(m) }
  36 func (*SubscribeContext) ProtoMessage()    {}
  37 func (*SubscribeContext) Descriptor() ([]byte, []int) {
  38         return fileDescriptor_5b809db4a7814953, []int{0}
  39 }
  40
  41 func (m *SubscribeContext) XXX_Unmarshal(b []byte) error {
  42         return xxx_messageInfo_SubscribeContext.Unmarshal(m, b)
  43 }
  44 func (m *SubscribeContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  45         return xxx_messageInfo_SubscribeContext.Marshal(b, m, deterministic)
  46 }
  47 func (m *SubscribeContext) XXX_Merge(src proto.Message) {
  48         xxx_messageInfo_SubscribeContext.Merge(m, src)
  49 }
  50 func (m *SubscribeContext) XXX_Size() int {
  51         return xxx_messageInfo_SubscribeContext.Size(m)
  52 }
  53 func (m *SubscribeContext) XXX_DiscardUnknown() {
  54         xxx_messageInfo_SubscribeContext.DiscardUnknown(m)
  55 }
  56
  57 var xxx_messageInfo_SubscribeContext proto.InternalMessageInfo
  58
  59 func (m *SubscribeContext) GetNodeName() string {
  60         if m != nil {
  61                 return m.NodeName
  62         }
  63         return ""
  64 }
  65
  66 type Notification struct {
  67         CniType string `protobuf:"bytes,1,opt,name=cni_type,json=cniType,proto3" json:"cni_type,omitempty"`
  68         // Types that are valid to be assigned to Payload:
  69         //      *Notification_InSync
  70         //      *Notification_ProviderNwCreate
  71         //      *Notification_ProviderNwRemove
  72         Payload              isNotification_Payload `protobuf_oneof:"payload"`
  73         XXX_NoUnkeyedLiteral struct{}               `json:"-"`
  74         XXX_unrecognized     []byte                 `json:"-"`
  75         XXX_sizecache        int32                  `json:"-"`
  76 }
  77
  78 func (m *Notification) Reset()         { *m = Notification{} }
  79 func (m *Notification) String() string { return proto.CompactTextString(m) }
  80 func (*Notification) ProtoMessage()    {}
  81 func (*Notification) Descriptor() ([]byte, []int) {
  82         return fileDescriptor_5b809db4a7814953, []int{1}
  83 }
  84
  85 func (m *Notification) XXX_Unmarshal(b []byte) error {
  86         return xxx_messageInfo_Notification.Unmarshal(m, b)
  87 }
  88 func (m *Notification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  89         return xxx_messageInfo_Notification.Marshal(b, m, deterministic)
  90 }
  91 func (m *Notification) XXX_Merge(src proto.Message) {
  92         xxx_messageInfo_Notification.Merge(m, src)
  93 }
  94 func (m *Notification) XXX_Size() int {
  95         return xxx_messageInfo_Notification.Size(m)
  96 }
  97 func (m *Notification) XXX_DiscardUnknown() {
  98         xxx_messageInfo_Notification.DiscardUnknown(m)
  99 }
 100
 101 var xxx_messageInfo_Notification proto.InternalMessageInfo
 102
 103 func (m *Notification) GetCniType() string {
 104         if m != nil {
 105                 return m.CniType
 106         }
 107         return ""
 108 }
 109
 110 type isNotification_Payload interface {
 111         isNotification_Payload()
 112 }
 113
 114 type Notification_InSync struct {
 115         InSync *InSync `protobuf:"bytes,2,opt,name=in_sync,json=inSync,proto3,oneof"`
 116 }
 117
 118 type Notification_ProviderNwCreate struct {
 119         ProviderNwCreate *ProviderNetworkCreate `protobuf:"bytes,3,opt,name=provider_nw_create,json=providerNwCreate,proto3,oneof"`
 120 }
 121
 122 type Notification_ProviderNwRemove struct {
 123         ProviderNwRemove *ProviderNetworkRemove `protobuf:"bytes,4,opt,name=provider_nw_remove,json=providerNwRemove,proto3,oneof"`
 124 }
 125
 126 func (*Notification_InSync) isNotification_Payload() {}
 127
 128 func (*Notification_ProviderNwCreate) isNotification_Payload() {}
 129
 130 func (*Notification_ProviderNwRemove) isNotification_Payload() {}
 131
 132 func (m *Notification) GetPayload() isNotification_Payload {
 133         if m != nil {
 134                 return m.Payload
 135         }
 136         return nil
 137 }
 138
 139 func (m *Notification) GetInSync() *InSync {
 140         if x, ok := m.GetPayload().(*Notification_InSync); ok {
 141                 return x.InSync
 142         }
 143         return nil
 144 }
 145
 146 func (m *Notification) GetProviderNwCreate() *ProviderNetworkCreate {
 147         if x, ok := m.GetPayload().(*Notification_ProviderNwCreate); ok {
 148                 return x.ProviderNwCreate
 149         }
 150         return nil
 151 }
 152
 153 func (m *Notification) GetProviderNwRemove() *ProviderNetworkRemove {
 154         if x, ok := m.GetPayload().(*Notification_ProviderNwRemove); ok {
 155                 return x.ProviderNwRemove
 156         }
 157         return nil
 158 }
 159
 160 // XXX_OneofWrappers is for the internal use of the proto package.
 161 func (*Notification) XXX_OneofWrappers() []interface{} {
 162         return []interface{}{
 163                 (*Notification_InSync)(nil),
 164                 (*Notification_ProviderNwCreate)(nil),
 165                 (*Notification_ProviderNwRemove)(nil),
 166         }
 167 }
 168
 169 type ProviderNetworkCreate struct {
 170         ProviderNwName       string    `protobuf:"bytes,1,opt,name=provider_nw_name,json=providerNwName,proto3" json:"provider_nw_name,omitempty"`
 171         Vlan                 *VlanInfo `protobuf:"bytes,2,opt,name=vlan,proto3" json:"vlan,omitempty"`
 172         XXX_NoUnkeyedLiteral struct{}  `json:"-"`
 173         XXX_unrecognized     []byte    `json:"-"`
 174         XXX_sizecache        int32     `json:"-"`
 175 }
 176
 177 func (m *ProviderNetworkCreate) Reset()         { *m = ProviderNetworkCreate{} }
 178 func (m *ProviderNetworkCreate) String() string { return proto.CompactTextString(m) }
 179 func (*ProviderNetworkCreate) ProtoMessage()    {}
 180 func (*ProviderNetworkCreate) Descriptor() ([]byte, []int) {
 181         return fileDescriptor_5b809db4a7814953, []int{2}
 182 }
 183
 184 func (m *ProviderNetworkCreate) XXX_Unmarshal(b []byte) error {
 185         return xxx_messageInfo_ProviderNetworkCreate.Unmarshal(m, b)
 186 }
 187 func (m *ProviderNetworkCreate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 188         return xxx_messageInfo_ProviderNetworkCreate.Marshal(b, m, deterministic)
 189 }
 190 func (m *ProviderNetworkCreate) XXX_Merge(src proto.Message) {
 191         xxx_messageInfo_ProviderNetworkCreate.Merge(m, src)
 192 }
 193 func (m *ProviderNetworkCreate) XXX_Size() int {
 194         return xxx_messageInfo_ProviderNetworkCreate.Size(m)
 195 }
 196 func (m *ProviderNetworkCreate) XXX_DiscardUnknown() {
 197         xxx_messageInfo_ProviderNetworkCreate.DiscardUnknown(m)
 198 }
 199
 200 var xxx_messageInfo_ProviderNetworkCreate proto.InternalMessageInfo
 201
 202 func (m *ProviderNetworkCreate) GetProviderNwName() string {
 203         if m != nil {
 204                 return m.ProviderNwName
 205         }
 206         return ""
 207 }
 208
 209 func (m *ProviderNetworkCreate) GetVlan() *VlanInfo {
 210         if m != nil {
 211                 return m.Vlan
 212         }
 213         return nil
 214 }
 215
 216 type ProviderNetworkRemove struct {
 217         ProviderNwName       string   `protobuf:"bytes,1,opt,name=provider_nw_name,json=providerNwName,proto3" json:"provider_nw_name,omitempty"`
 218         VlanLogicalIntf      string   `protobuf:"bytes,2,opt,name=vlan_logical_intf,json=vlanLogicalIntf,proto3" json:"vlan_logical_intf,omitempty"`
 219         XXX_NoUnkeyedLiteral struct{} `json:"-"`
 220         XXX_unrecognized     []byte   `json:"-"`
 221         XXX_sizecache        int32    `json:"-"`
 222 }
 223
 224 func (m *ProviderNetworkRemove) Reset()         { *m = ProviderNetworkRemove{} }
 225 func (m *ProviderNetworkRemove) String() string { return proto.CompactTextString(m) }
 226 func (*ProviderNetworkRemove) ProtoMessage()    {}
 227 func (*ProviderNetworkRemove) Descriptor() ([]byte, []int) {
 228         return fileDescriptor_5b809db4a7814953, []int{3}
 229 }
 230
 231 func (m *ProviderNetworkRemove) XXX_Unmarshal(b []byte) error {
 232         return xxx_messageInfo_ProviderNetworkRemove.Unmarshal(m, b)
 233 }
 234 func (m *ProviderNetworkRemove) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 235         return xxx_messageInfo_ProviderNetworkRemove.Marshal(b, m, deterministic)
 236 }
 237 func (m *ProviderNetworkRemove) XXX_Merge(src proto.Message) {
 238         xxx_messageInfo_ProviderNetworkRemove.Merge(m, src)
 239 }
 240 func (m *ProviderNetworkRemove) XXX_Size() int {
 241         return xxx_messageInfo_ProviderNetworkRemove.Size(m)
 242 }
 243 func (m *ProviderNetworkRemove) XXX_DiscardUnknown() {
 244         xxx_messageInfo_ProviderNetworkRemove.DiscardUnknown(m)
 245 }
 246
 247 var xxx_messageInfo_ProviderNetworkRemove proto.InternalMessageInfo
 248
 249 func (m *ProviderNetworkRemove) GetProviderNwName() string {
 250         if m != nil {
 251                 return m.ProviderNwName
 252         }
 253         return ""
 254 }
 255
 256 func (m *ProviderNetworkRemove) GetVlanLogicalIntf() string {
 257         if m != nil {
 258                 return m.VlanLogicalIntf
 259         }
 260         return ""
 261 }
 262
 263 type VlanInfo struct {
 264         VlanId               string   `protobuf:"bytes,1,opt,name=vlan_id,json=vlanId,proto3" json:"vlan_id,omitempty"`
 265         ProviderIntf         string   `protobuf:"bytes,2,opt,name=provider_intf,json=providerIntf,proto3" json:"provider_intf,omitempty"`
 266         LogicalIntf          string   `protobuf:"bytes,3,opt,name=logical_intf,json=logicalIntf,proto3" json:"logical_intf,omitempty"`
 267         XXX_NoUnkeyedLiteral struct{} `json:"-"`
 268         XXX_unrecognized     []byte   `json:"-"`
 269         XXX_sizecache        int32    `json:"-"`
 270 }
 271
 272 func (m *VlanInfo) Reset()         { *m = VlanInfo{} }
 273 func (m *VlanInfo) String() string { return proto.CompactTextString(m) }
 274 func (*VlanInfo) ProtoMessage()    {}
 275 func (*VlanInfo) Descriptor() ([]byte, []int) {
 276         return fileDescriptor_5b809db4a7814953, []int{4}
 277 }
 278
 279 func (m *VlanInfo) XXX_Unmarshal(b []byte) error {
 280         return xxx_messageInfo_VlanInfo.Unmarshal(m, b)
 281 }
 282 func (m *VlanInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 283         return xxx_messageInfo_VlanInfo.Marshal(b, m, deterministic)
 284 }
 285 func (m *VlanInfo) XXX_Merge(src proto.Message) {
 286         xxx_messageInfo_VlanInfo.Merge(m, src)
 287 }
 288 func (m *VlanInfo) XXX_Size() int {
 289         return xxx_messageInfo_VlanInfo.Size(m)
 290 }
 291 func (m *VlanInfo) XXX_DiscardUnknown() {
 292         xxx_messageInfo_VlanInfo.DiscardUnknown(m)
 293 }
 294
 295 var xxx_messageInfo_VlanInfo proto.InternalMessageInfo
 296
 297 func (m *VlanInfo) GetVlanId() string {
 298         if m != nil {
 299                 return m.VlanId
 300         }
 301         return ""
 302 }
 303
 304 func (m *VlanInfo) GetProviderIntf() string {
 305         if m != nil {
 306                 return m.ProviderIntf
 307         }
 308         return ""
 309 }
 310
 311 func (m *VlanInfo) GetLogicalIntf() string {
 312         if m != nil {
 313                 return m.LogicalIntf
 314         }
 315         return ""
 316 }
 317
 318 type InSync struct {
 319         XXX_NoUnkeyedLiteral struct{} `json:"-"`
 320         XXX_unrecognized     []byte   `json:"-"`
 321         XXX_sizecache        int32    `json:"-"`
 322 }
 323
 324 func (m *InSync) Reset()         { *m = InSync{} }
 325 func (m *InSync) String() string { return proto.CompactTextString(m) }
 326 func (*InSync) ProtoMessage()    {}
 327 func (*InSync) Descriptor() ([]byte, []int) {
 328         return fileDescriptor_5b809db4a7814953, []int{5}
 329 }
 330
 331 func (m *InSync) XXX_Unmarshal(b []byte) error {
 332         return xxx_messageInfo_InSync.Unmarshal(m, b)
 333 }
 334 func (m *InSync) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 335         return xxx_messageInfo_InSync.Marshal(b, m, deterministic)
 336 }
 337 func (m *InSync) XXX_Merge(src proto.Message) {
 338         xxx_messageInfo_InSync.Merge(m, src)
 339 }
 340 func (m *InSync) XXX_Size() int {
 341         return xxx_messageInfo_InSync.Size(m)
 342 }
 343 func (m *InSync) XXX_DiscardUnknown() {
 344         xxx_messageInfo_InSync.DiscardUnknown(m)
 345 }
 346
 347 var xxx_messageInfo_InSync proto.InternalMessageInfo
 348
 349 func init() {
 350         proto.RegisterType((*SubscribeContext)(nil), "SubscribeContext")
 351         proto.RegisterType((*Notification)(nil), "Notification")
 352         proto.RegisterType((*ProviderNetworkCreate)(nil), "ProviderNetworkCreate")
 353         proto.RegisterType((*ProviderNetworkRemove)(nil), "ProviderNetworkRemove")
 354         proto.RegisterType((*VlanInfo)(nil), "VlanInfo")
 355         proto.RegisterType((*InSync)(nil), "InSync")
 356 }
 357
 358 func init() { proto.RegisterFile("nfn.proto", fileDescriptor_5b809db4a7814953) }
 359
 360 var fileDescriptor_5b809db4a7814953 = []byte{
 361         // 380 bytes of a gzipped FileDescriptorProto
 362         0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x92, 0x4f, 0xaf, 0xd2, 0x40,
 363         0x14, 0xc5, 0xa9, 0x90, 0xfe, 0xb9, 0x80, 0xc2, 0x24, 0x6a, 0xd5, 0x98, 0x60, 0xdd, 0x10, 0x17,
 364         0xc5, 0xe0, 0xd6, 0x95, 0x24, 0x86, 0x26, 0xa6, 0x31, 0xc5, 0xb8, 0xad, 0xc3, 0x74, 0x6a, 0x26,
 365         0xb4, 0x77, 0x9a, 0x32, 0x82, 0xfd, 0xc6, 0xef, 0x63, 0xbc, 0x74, 0x4a, 0x79, 0x85, 0xc7, 0xe6,
 366         0xed, 0xda, 0x73, 0xee, 0x9c, 0xdf, 0xf4, 0xf6, 0x80, 0x83, 0x29, 0xfa, 0x45, 0x29, 0x95, 0xf4,
 367         0x16, 0x30, 0xd9, 0xfc, 0xdb, 0xee, 0x59, 0x29, 0xb6, 0x7c, 0x25, 0x51, 0xf1, 0xff, 0x8a, 0xbc,
 368         0x03, 0x07, 0x65, 0xc2, 0x63, 0xa4, 0x39, 0x77, 0x8d, 0x99, 0x31, 0x77, 0x22, 0xbb, 0x16, 0x42,
 369         0x9a, 0x73, 0xef, 0xce, 0x80, 0x51, 0x28, 0x95, 0x48, 0x05, 0xa3, 0x4a, 0x48, 0x24, 0x6f, 0xc0,
 370         0x66, 0x28, 0x62, 0x55, 0x15, 0xed, 0xb0, 0xc5, 0x50, 0xfc, 0xaa, 0x0a, 0x4e, 0x3c, 0xb0, 0x04,
 371         0xc6, 0xfb, 0x0a, 0x99, 0xfb, 0x6c, 0x66, 0xcc, 0x87, 0x4b, 0xcb, 0x0f, 0x70, 0x53, 0x21, 0x5b,
 372         0xf7, 0x22, 0x53, 0xe8, 0x27, 0xf2, 0x1d, 0x48, 0x51, 0xca, 0x83, 0x48, 0x78, 0x19, 0xe3, 0x31,
 373         0x66, 0x25, 0xa7, 0x8a, 0xbb, 0x7d, 0x3d, 0xfe, 0xca, 0xff, 0x79, 0xb2, 0x42, 0xae, 0x8e, 0xb2,
 374         0xdc, 0xad, 0xb4, 0xbb, 0xee, 0x45, 0x93, 0xf6, 0x4c, 0x78, 0x6c, 0xb4, 0xeb, 0x9c, 0x92, 0xe7,
 375         0xf2, 0xc0, 0xdd, 0xc1, 0xed, 0x9c, 0x48, 0xbb, 0x97, 0x39, 0x8d, 0xf6, 0xcd, 0x01, 0xab, 0xa0,
 376         0x55, 0x26, 0x69, 0xe2, 0xfd, 0x81, 0x97, 0x37, 0xf9, 0x64, 0x0e, 0x93, 0x2e, 0xab, 0xb3, 0xa7,
 377         0xe7, 0x0f, 0x79, 0xf5, 0xb6, 0xc8, 0x7b, 0x18, 0x1c, 0x32, 0x8a, 0xa7, 0xcf, 0x77, 0xfc, 0xdf,
 378         0x19, 0xc5, 0x00, 0x53, 0x19, 0x69, 0xd9, 0xcb, 0x1f, 0x11, 0x9a, 0x5b, 0x3c, 0x81, 0xf0, 0x09,
 379         0xa6, 0x75, 0x54, 0x9c, 0xc9, 0xbf, 0x82, 0xd1, 0x2c, 0x16, 0xa8, 0x52, 0x8d, 0x73, 0xa2, 0x17,
 380         0xb5, 0xf1, 0xa3, 0xd1, 0x03, 0x54, 0xa9, 0xb7, 0x03, 0xbb, 0xbd, 0x00, 0x79, 0x0d, 0x96, 0x3e,
 381         0x27, 0x92, 0x53, 0xb0, 0x59, 0xbf, 0x06, 0x09, 0xf9, 0x08, 0xe3, 0x33, 0xba, 0x13, 0x36, 0x6a,
 382         0xc5, 0x3a, 0x89, 0x7c, 0x80, 0xd1, 0x05, 0xb0, 0xaf, 0x67, 0x86, 0x59, 0x07, 0x66, 0x83, 0xd9,
 383         0xfc, 0xec, 0xe5, 0x57, 0x5d, 0x38, 0x5d, 0x9a, 0x8a, 0x2c, 0xc0, 0x39, 0x17, 0x8e, 0x4c, 0xfd,
 384         0xeb, 0xf2, 0xbd, 0x1d, 0xfb, 0xdd, 0x76, 0x7d, 0x36, 0xb6, 0xa6, 0x2e, 0xea, 0x97, 0xfb, 0x00,
 385         0x00, 0x00, 0xff, 0xff, 0xa6, 0xd9, 0x3e, 0x9e, 0xb5, 0x02, 0x00, 0x00,
 386 }
 387
 388 // Reference imports to suppress errors if they are not otherwise used.
 389 var _ context.Context
 390 var _ grpc.ClientConn
 391
 392 // This is a compile-time assertion to ensure that this generated file
 393 // is compatible with the grpc package it is being compiled against.
 394 const _ = grpc.SupportPackageIsVersion4
 395
 396 // NfnNotifyClient is the client API for NfnNotify service.
 397 //
 398 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
 399 type NfnNotifyClient interface {
 400         Subscribe(ctx context.Context, in *SubscribeContext, opts ...grpc.CallOption) (NfnNotify_SubscribeClient, error)
 401 }
 402
 403 type nfnNotifyClient struct {
 404         cc *grpc.ClientConn
 405 }
 406
 407 func NewNfnNotifyClient(cc *grpc.ClientConn) NfnNotifyClient {
 408         return &nfnNotifyClient{cc}
 409 }
 410
 411 func (c *nfnNotifyClient) Subscribe(ctx context.Context, in *SubscribeContext, opts ...grpc.CallOption) (NfnNotify_SubscribeClient, error) {
 412         stream, err := c.cc.NewStream(ctx, &_NfnNotify_serviceDesc.Streams[0], "/nfnNotify/Subscribe", opts...)
 413         if err != nil {
 414                 return nil, err
 415         }
 416         x := &nfnNotifySubscribeClient{stream}
 417         if err := x.ClientStream.SendMsg(in); err != nil {
 418                 return nil, err
 419         }
 420         if err := x.ClientStream.CloseSend(); err != nil {
 421                 return nil, err
 422         }
 423         return x, nil
 424 }
 425
 426 type NfnNotify_SubscribeClient interface {
 427         Recv() (*Notification, error)
 428         grpc.ClientStream
 429 }
 430
 431 type nfnNotifySubscribeClient struct {
 432         grpc.ClientStream
 433 }
 434
 435 func (x *nfnNotifySubscribeClient) Recv() (*Notification, error) {
 436         m := new(Notification)
 437         if err := x.ClientStream.RecvMsg(m); err != nil {
 438                 return nil, err
 439         }
 440         return m, nil
 441 }
 442
 443 // NfnNotifyServer is the server API for NfnNotify service.
 444 type NfnNotifyServer interface {
 445         Subscribe(*SubscribeContext, NfnNotify_SubscribeServer) error
 446 }
 447
 448 // UnimplementedNfnNotifyServer can be embedded to have forward compatible implementations.
 449 type UnimplementedNfnNotifyServer struct {
 450 }
 451
 452 func (*UnimplementedNfnNotifyServer) Subscribe(req *SubscribeContext, srv NfnNotify_SubscribeServer) error {
 453         return status.Errorf(codes.Unimplemented, "method Subscribe not implemented")
 454 }
 455
 456 func RegisterNfnNotifyServer(s *grpc.Server, srv NfnNotifyServer) {
 457         s.RegisterService(&_NfnNotify_serviceDesc, srv)
 458 }
 459
 460 func _NfnNotify_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) error {
 461         m := new(SubscribeContext)
 462         if err := stream.RecvMsg(m); err != nil {
 463                 return err
 464         }
 465         return srv.(NfnNotifyServer).Subscribe(m, &nfnNotifySubscribeServer{stream})
 466 }
 467
 468 type NfnNotify_SubscribeServer interface {
 469         Send(*Notification) error
 470         grpc.ServerStream
 471 }
 472
 473 type nfnNotifySubscribeServer struct {
 474         grpc.ServerStream
 475 }
 476
 477 func (x *nfnNotifySubscribeServer) Send(m *Notification) error {
 478         return x.ServerStream.SendMsg(m)
 479 }
 480
 481 var _NfnNotify_serviceDesc = grpc.ServiceDesc{
 482         ServiceName: "nfnNotify",
 483         HandlerType: (*NfnNotifyServer)(nil),
 484         Methods:     []grpc.MethodDesc{},
 485         Streams: []grpc.StreamDesc{
 486                 {
 487                         StreamName:    "Subscribe",
 488                         Handler:       _NfnNotify_Subscribe_Handler,
 489                         ServerStreams: true,
 490                 },
 491         },
 492         Metadata: "nfn.proto",
 493 }