Documentation ¶
Index ¶
- Variables
- func RegisterNBIServer(s *grpc.Server, srv NBIServer)
- type ConfigResponse
- func (*ConfigResponse) Descriptor() ([]byte, []int)
- func (m *ConfigResponse) GetNumPons() uint32
- func (*ConfigResponse) ProtoMessage()
- func (m *ConfigResponse) Reset()
- func (m *ConfigResponse) String() string
- func (m *ConfigResponse) XXX_DiscardUnknown()
- func (m *ConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConfigResponse) XXX_Merge(src proto.Message)
- func (m *ConfigResponse) XXX_Size() int
- func (m *ConfigResponse) XXX_Unmarshal(b []byte) error
- type ImpairmentRequest
- func (*ImpairmentRequest) Descriptor() ([]byte, []int)
- func (m *ImpairmentRequest) GetDuration() uint32
- func (m *ImpairmentRequest) GetImpairment() ImpairmentRequest_ImpairmentType
- func (m *ImpairmentRequest) GetOnuId() uint32
- func (m *ImpairmentRequest) GetPonId() uint32
- func (*ImpairmentRequest) ProtoMessage()
- func (m *ImpairmentRequest) Reset()
- func (m *ImpairmentRequest) String() string
- func (m *ImpairmentRequest) XXX_DiscardUnknown()
- func (m *ImpairmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ImpairmentRequest) XXX_Merge(src proto.Message)
- func (m *ImpairmentRequest) XXX_Size() int
- func (m *ImpairmentRequest) XXX_Unmarshal(b []byte) error
- type ImpairmentRequest_ImpairmentType
- type NBIClient
- type NBIServer
- type OnuStatus
- func (*OnuStatus) Descriptor() ([]byte, []int)
- func (m *OnuStatus) GetOnuId() uint32
- func (*OnuStatus) ProtoMessage()
- func (m *OnuStatus) Reset()
- func (m *OnuStatus) String() string
- func (m *OnuStatus) XXX_DiscardUnknown()
- func (m *OnuStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OnuStatus) XXX_Merge(src proto.Message)
- func (m *OnuStatus) XXX_Size() int
- func (m *OnuStatus) XXX_Unmarshal(b []byte) error
- type PloamDiscoveryResponse
- func (*PloamDiscoveryResponse) Descriptor() ([]byte, []int)
- func (m *PloamDiscoveryResponse) GetDistance() uint32
- func (m *PloamDiscoveryResponse) GetPonId() uint32
- func (m *PloamDiscoveryResponse) GetSerialNumber() string
- func (*PloamDiscoveryResponse) ProtoMessage()
- func (m *PloamDiscoveryResponse) Reset()
- func (m *PloamDiscoveryResponse) String() string
- func (m *PloamDiscoveryResponse) XXX_DiscardUnknown()
- func (m *PloamDiscoveryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PloamDiscoveryResponse) XXX_Merge(src proto.Message)
- func (m *PloamDiscoveryResponse) XXX_Size() int
- func (m *PloamDiscoveryResponse) XXX_Unmarshal(b []byte) error
- type PonStatus
- func (*PonStatus) Descriptor() ([]byte, []int)
- func (m *PonStatus) GetOnuStatus() []*OnuStatus
- func (m *PonStatus) GetPonId() uint32
- func (*PonStatus) ProtoMessage()
- func (m *PonStatus) Reset()
- func (m *PonStatus) String() string
- func (m *PonStatus) XXX_DiscardUnknown()
- func (m *PonStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PonStatus) XXX_Merge(src proto.Message)
- func (m *PonStatus) XXX_Size() int
- func (m *PonStatus) XXX_Unmarshal(b []byte) error
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)
- func (m *StatusRequest) GetIncludeOnus() bool
- func (m *StatusRequest) GetPonIds() []uint32
- func (*StatusRequest) ProtoMessage()
- func (m *StatusRequest) Reset()
- func (m *StatusRequest) String() string
- func (m *StatusRequest) XXX_DiscardUnknown()
- func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusRequest) XXX_Merge(src proto.Message)
- func (m *StatusRequest) XXX_Size() int
- func (m *StatusRequest) XXX_Unmarshal(b []byte) error
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)
- func (m *StatusResponse) GetPonStatus() []*PonStatus
- func (*StatusResponse) ProtoMessage()
- func (m *StatusResponse) Reset()
- func (m *StatusResponse) String() string
- func (m *StatusResponse) XXX_DiscardUnknown()
- func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusResponse) XXX_Merge(src proto.Message)
- func (m *StatusResponse) XXX_Size() int
- func (m *StatusResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ImpairmentRequest_ImpairmentType_name = map[int32]string{
0: "TX_LOS",
1: "RX_LOS",
2: "POWER_LOSS",
}
View Source
var ImpairmentRequest_ImpairmentType_value = map[string]int32{
"TX_LOS": 0,
"RX_LOS": 1,
"POWER_LOSS": 2,
}
Functions ¶
func RegisterNBIServer ¶
Types ¶
type ConfigResponse ¶
type ConfigResponse struct { NumPons uint32 `protobuf:"varint,1,opt,name=num_pons,json=numPons,proto3" json:"num_pons,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConfigResponse) Descriptor ¶
func (*ConfigResponse) Descriptor() ([]byte, []int)
func (*ConfigResponse) GetNumPons ¶
func (m *ConfigResponse) GetNumPons() uint32
func (*ConfigResponse) ProtoMessage ¶
func (*ConfigResponse) ProtoMessage()
func (*ConfigResponse) Reset ¶
func (m *ConfigResponse) Reset()
func (*ConfigResponse) String ¶
func (m *ConfigResponse) String() string
func (*ConfigResponse) XXX_DiscardUnknown ¶
func (m *ConfigResponse) XXX_DiscardUnknown()
func (*ConfigResponse) XXX_Marshal ¶
func (m *ConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigResponse) XXX_Merge ¶
func (m *ConfigResponse) XXX_Merge(src proto.Message)
func (*ConfigResponse) XXX_Size ¶
func (m *ConfigResponse) XXX_Size() int
func (*ConfigResponse) XXX_Unmarshal ¶
func (m *ConfigResponse) XXX_Unmarshal(b []byte) error
type ImpairmentRequest ¶
type ImpairmentRequest struct { PonId uint32 `protobuf:"varint,1,opt,name=pon_id,json=ponId,proto3" json:"pon_id,omitempty"` OnuId uint32 `protobuf:"varint,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"` Impairment ImpairmentRequest_ImpairmentType `protobuf:"varint,3,opt,name=impairment,proto3,enum=nbi.ImpairmentRequest_ImpairmentType" json:"impairment,omitempty"` Duration uint32 `protobuf:"varint,6,opt,name=duration,proto3" json:"duration,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TODO: Add other impairments as needed
func (*ImpairmentRequest) Descriptor ¶
func (*ImpairmentRequest) Descriptor() ([]byte, []int)
func (*ImpairmentRequest) GetDuration ¶
func (m *ImpairmentRequest) GetDuration() uint32
func (*ImpairmentRequest) GetImpairment ¶
func (m *ImpairmentRequest) GetImpairment() ImpairmentRequest_ImpairmentType
func (*ImpairmentRequest) GetOnuId ¶
func (m *ImpairmentRequest) GetOnuId() uint32
func (*ImpairmentRequest) GetPonId ¶
func (m *ImpairmentRequest) GetPonId() uint32
func (*ImpairmentRequest) ProtoMessage ¶
func (*ImpairmentRequest) ProtoMessage()
func (*ImpairmentRequest) Reset ¶
func (m *ImpairmentRequest) Reset()
func (*ImpairmentRequest) String ¶
func (m *ImpairmentRequest) String() string
func (*ImpairmentRequest) XXX_DiscardUnknown ¶
func (m *ImpairmentRequest) XXX_DiscardUnknown()
func (*ImpairmentRequest) XXX_Marshal ¶
func (m *ImpairmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ImpairmentRequest) XXX_Merge ¶
func (m *ImpairmentRequest) XXX_Merge(src proto.Message)
func (*ImpairmentRequest) XXX_Size ¶
func (m *ImpairmentRequest) XXX_Size() int
func (*ImpairmentRequest) XXX_Unmarshal ¶
func (m *ImpairmentRequest) XXX_Unmarshal(b []byte) error
type ImpairmentRequest_ImpairmentType ¶
type ImpairmentRequest_ImpairmentType int32
const ( ImpairmentRequest_TX_LOS ImpairmentRequest_ImpairmentType = 0 ImpairmentRequest_RX_LOS ImpairmentRequest_ImpairmentType = 1 ImpairmentRequest_POWER_LOSS ImpairmentRequest_ImpairmentType = 2 )
func (ImpairmentRequest_ImpairmentType) EnumDescriptor ¶
func (ImpairmentRequest_ImpairmentType) EnumDescriptor() ([]byte, []int)
func (ImpairmentRequest_ImpairmentType) String ¶
func (x ImpairmentRequest_ImpairmentType) String() string
type NBIClient ¶
type NBIClient interface { GetConfiguration(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ConfigResponse, error) GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) // Used to send impairment messages to the ONU Mock. Impairment(ctx context.Context, in *ImpairmentRequest, opts ...grpc.CallOption) (*empty.Empty, error) }
NBIClient is the client API for NBI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewNBIClient ¶
func NewNBIClient(cc *grpc.ClientConn) NBIClient
type NBIServer ¶
type NBIServer interface { GetConfiguration(context.Context, *empty.Empty) (*ConfigResponse, error) GetStatus(context.Context, *StatusRequest) (*StatusResponse, error) // Used to send impairment messages to the ONU Mock. Impairment(context.Context, *ImpairmentRequest) (*empty.Empty, error) }
NBIServer is the server API for NBI service.
type OnuStatus ¶
type OnuStatus struct { OnuId uint32 `protobuf:"varint,1,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OnuStatus) Descriptor ¶
func (*OnuStatus) ProtoMessage ¶
func (*OnuStatus) ProtoMessage()
func (*OnuStatus) XXX_DiscardUnknown ¶
func (m *OnuStatus) XXX_DiscardUnknown()
func (*OnuStatus) XXX_Marshal ¶
func (*OnuStatus) XXX_Unmarshal ¶
type PloamDiscoveryResponse ¶
type PloamDiscoveryResponse struct { PonId uint32 `protobuf:"varint,1,opt,name=pon_id,json=ponId,proto3" json:"pon_id,omitempty"` SerialNumber string `protobuf:"bytes,2,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"` Distance uint32 `protobuf:"varint,3,opt,name=distance,proto3" json:"distance,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PloamDiscoveryResponse) Descriptor ¶
func (*PloamDiscoveryResponse) Descriptor() ([]byte, []int)
func (*PloamDiscoveryResponse) GetDistance ¶
func (m *PloamDiscoveryResponse) GetDistance() uint32
func (*PloamDiscoveryResponse) GetPonId ¶
func (m *PloamDiscoveryResponse) GetPonId() uint32
func (*PloamDiscoveryResponse) GetSerialNumber ¶
func (m *PloamDiscoveryResponse) GetSerialNumber() string
func (*PloamDiscoveryResponse) ProtoMessage ¶
func (*PloamDiscoveryResponse) ProtoMessage()
func (*PloamDiscoveryResponse) Reset ¶
func (m *PloamDiscoveryResponse) Reset()
func (*PloamDiscoveryResponse) String ¶
func (m *PloamDiscoveryResponse) String() string
func (*PloamDiscoveryResponse) XXX_DiscardUnknown ¶
func (m *PloamDiscoveryResponse) XXX_DiscardUnknown()
func (*PloamDiscoveryResponse) XXX_Marshal ¶
func (m *PloamDiscoveryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PloamDiscoveryResponse) XXX_Merge ¶
func (m *PloamDiscoveryResponse) XXX_Merge(src proto.Message)
func (*PloamDiscoveryResponse) XXX_Size ¶
func (m *PloamDiscoveryResponse) XXX_Size() int
func (*PloamDiscoveryResponse) XXX_Unmarshal ¶
func (m *PloamDiscoveryResponse) XXX_Unmarshal(b []byte) error
type PonStatus ¶
type PonStatus struct { PonId uint32 `protobuf:"varint,1,opt,name=pon_id,json=ponId,proto3" json:"pon_id,omitempty"` OnuStatus []*OnuStatus `protobuf:"bytes,2,rep,name=onu_status,json=onuStatus,proto3" json:"onu_status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PonStatus) Descriptor ¶
func (*PonStatus) GetOnuStatus ¶
func (*PonStatus) ProtoMessage ¶
func (*PonStatus) ProtoMessage()
func (*PonStatus) XXX_DiscardUnknown ¶
func (m *PonStatus) XXX_DiscardUnknown()
func (*PonStatus) XXX_Marshal ¶
func (*PonStatus) XXX_Unmarshal ¶
type StatusRequest ¶
type StatusRequest struct { PonIds []uint32 `protobuf:"varint,1,rep,packed,name=pon_ids,json=ponIds,proto3" json:"pon_ids,omitempty"` IncludeOnus bool `protobuf:"varint,2,opt,name=include_onus,json=includeOnus,proto3" json:"include_onus,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusRequest) Descriptor ¶
func (*StatusRequest) Descriptor() ([]byte, []int)
func (*StatusRequest) GetIncludeOnus ¶
func (m *StatusRequest) GetIncludeOnus() bool
func (*StatusRequest) GetPonIds ¶
func (m *StatusRequest) GetPonIds() []uint32
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) Reset ¶
func (m *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (m *StatusRequest) String() string
func (*StatusRequest) XXX_DiscardUnknown ¶
func (m *StatusRequest) XXX_DiscardUnknown()
func (*StatusRequest) XXX_Marshal ¶
func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusRequest) XXX_Merge ¶
func (m *StatusRequest) XXX_Merge(src proto.Message)
func (*StatusRequest) XXX_Size ¶
func (m *StatusRequest) XXX_Size() int
func (*StatusRequest) XXX_Unmarshal ¶
func (m *StatusRequest) XXX_Unmarshal(b []byte) error
type StatusResponse ¶
type StatusResponse struct { PonStatus []*PonStatus `protobuf:"bytes,1,rep,name=pon_status,json=ponStatus,proto3" json:"pon_status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusResponse) Descriptor ¶
func (*StatusResponse) Descriptor() ([]byte, []int)
func (*StatusResponse) GetPonStatus ¶
func (m *StatusResponse) GetPonStatus() []*PonStatus
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) Reset ¶
func (m *StatusResponse) Reset()
func (*StatusResponse) String ¶
func (m *StatusResponse) String() string
func (*StatusResponse) XXX_DiscardUnknown ¶
func (m *StatusResponse) XXX_DiscardUnknown()
func (*StatusResponse) XXX_Marshal ¶
func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusResponse) XXX_Merge ¶
func (m *StatusResponse) XXX_Merge(src proto.Message)
func (*StatusResponse) XXX_Size ¶
func (m *StatusResponse) XXX_Size() int
func (*StatusResponse) XXX_Unmarshal ¶
func (m *StatusResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.