Starting BBSim API Server
Adding SerialNumber to GetDeviceInfo response (it's now required by
VOLTHA)
Change-Id: If726b5c313b6a424f54682aef68c001f6de51b57
diff --git a/Makefile b/Makefile
index 199d28c..82a57cd 100644
--- a/Makefile
+++ b/Makefile
@@ -13,35 +13,35 @@
# limitations under the License.
VERSION ?= $(shell cat ./VERSION)
+DIFF ?= $(git diff --shortstat 2> /dev/null | tail -n1)
+GIT_STATUS ?= $(shell [[ $DIFF != "" ]] && echo "Dirty" || echo "Clean")
## Docker related
DOCKER_TAG ?= ${VERSION}
DOCKER_REPOSITORY ?= voltha/
DOCKER_REGISTRY ?= ""
-DOCKER_BUILD_ARGS ?=
-
-## Docker labels. Only set ref and commit date if committed
-DOCKER_LABEL_VCS_URL ?= $(shell git remote get-url $(shell git remote))
-DOCKER_LABEL_VCS_REF ?= $(shell git diff-index --quiet HEAD -- && git rev-parse HEAD || echo "unknown")
-DOCKER_LABEL_COMMIT_DATE ?= $(shell git diff-index --quiet HEAD -- && git show -s --format=%cd --date=iso-strict HEAD || echo "unknown" )
-DOCKER_LABEL_BUILD_DATE ?= $(shell date -u "+%Y-%m-%dT%H:%M:%SZ")
# Public targets
all: help
-protos: api/openolt.pb.go # @HELP Build proto files
+protos: api/openolt/openolt.pb.go api/bbsim/bbsim.pb.go # @HELP Build proto files
build: protos # @HELP Build the binary
- GO111MODULE=on go build -i -v -o ./cmd/bbsim ./internal/bbsim
+ GO111MODULE=on go build -i -v \
+ -ldflags "-X main.buildTime=$(shell date +”%Y/%m/%d-%H:%M:%S”) \
+ -X main.commitHash=$(shell git log --pretty=format:%H -n 1) \
+ -X main.gitStatus=${GIT_STATUS} \
+ -X main.version=${VERSION}" \
+ -o ./cmd/bbsim ./internal/bbsim
test: protos # @HELP Execute unit tests
GO111MODULE=on go test ./internal/bbsim
-docker-build:
- docker build -t ${DOCKER_REGISTRY}${DOCKER_REPOSITORY}bbsim:${DOCKER_TAG} -f build/package/Dockerfile .
+docker-build: # @HELP Build a docker container
+ docker build --build-arg GIT_STATUS=${GIT_STATUS} -t ${DOCKER_REGISTRY}${DOCKER_REPOSITORY}bbsim:${DOCKER_TAG} -f build/package/Dockerfile .
-docker-push:
+docker-push: # @HELP Push a docker container to a registry
docker push ${DOCKER_REGISTRY}${DOCKER_REPOSITORY}bbsim:${DOCKER_TAG}
help: # @HELP Print the command options
@@ -61,7 +61,14 @@
# Internals
-api/openolt.pb.go: api/openolt.proto
+api/openolt/openolt.pb.go: api/openolt/openolt.proto
+ @protoc -I . \
+ -I${GOPATH}/src \
+ -I${GOPATH}/src/github.com/grpc-ecosystem/grpc-gateway/third_party/googleapis \
+ --go_out=plugins=grpc:./ \
+ $<
+
+api/bbsim/bbsim.pb.go: api/bbsim/bbsim.proto
@protoc -I . \
-I${GOPATH}/src \
-I${GOPATH}/src/github.com/grpc-ecosystem/grpc-gateway/third_party/googleapis \
diff --git a/README.md b/README.md
index bda5abc..20fc7b4 100644
--- a/README.md
+++ b/README.md
@@ -1,4 +1,84 @@
# BroadBand Simular (BBSim)
+## Build
+
+BBSim is managed via a `Makefile`, plese run the following command
+to display all the available targets
+
+```
+make help
+```
+
+## Usage
+
+### Deploy on Kubernets
+
+Once VOLTHA is deployed you can deploy BBsim using the helm chart provided in the repo:
+
+```
+cd deployments/helm-chart
+helm install -n bbsim bbsim
+```
+
+### OLT Provisioning
+
+Once `BBSim` is up and running you can provision the OLT in VOLTHA.
+
+When you install the `BBSim` helm chart you'll notice that the last line of the output
+prints the service name and port:
+
+```
+NOTES:
+BBSim deployed with release name: bbsim
+
+OLT ID: 0
+# of NNI Ports: 1
+# of PON Ports: 1
+# of ONU Ports: 1
+Total ONUs: (total: 1)
+
+OLT is listening on: "voltha.svc.bbsim-olt-id-0:50060"
+```
+
+#### VOLTHA 1.X
+
+Connect to the voltha CLI and execute this commands:
+
+```
+preprovision_olt -t openolt -H voltha.svc.bbsim-olt-id-0:50060
+enable
+```
+
+## Control API
+
+BBSim comes with a gRPC interface to control the internal state.
+We plan to provide a `bbsimctl` at certain point, meanwhile you can use `grpcurl`:
+
+```
+$ export BBSIM_IP="$(kubectl get -n voltha service/bbsim -o go-template='{{.spec.clusterIP}}')"
+$ grpcurl -plaintext $BBSIM_IP:50070 bbsim.BBSim/Version
+{
+ "version": "0.0.1-alpha",
+ "buildTime": "”2019.08.09.084157”",
+ "commitHash": "9ef7241b07a83c326ef152320428f204f7eff43d"
+}
+
+
+$ grpcurl -plaintext $BBSIM_IP:50070 bbsim.BBSim/GetOlt
+{
+ "ID": 22,
+ "OperState": "up",
+ "NNIPorts": [
+ {
+ "OperState": "down"
+ }
+ ],
+ "PONPorts": [
+ {
+ "OperState": "down"
+ }
+ ]
+}
+```
> This project strucutre is based on [golang-standards/project-layout](https://github.com/golang-standards/project-layout).
\ No newline at end of file
diff --git a/api/.gitignore b/api/.gitignore
new file mode 100644
index 0000000..5a7fb48
--- /dev/null
+++ b/api/.gitignore
@@ -0,0 +1 @@
+**/*.pb.go
\ No newline at end of file
diff --git a/api/bbsim/bbsim.proto b/api/bbsim/bbsim.proto
new file mode 100644
index 0000000..f49023b
--- /dev/null
+++ b/api/bbsim/bbsim.proto
@@ -0,0 +1,47 @@
+// Copyright (c) 2018 Open Networking Foundation
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at:
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+syntax = "proto3";
+package bbsim;
+
+message PONPort {
+ int32 ID = 1;
+ string OperState = 2;
+}
+
+message NNIPort {
+ int32 ID = 1;
+ string OperState = 2;
+}
+
+message Olt {
+ int32 ID = 1;
+ string OperState = 2;
+ repeated NNIPort NNIPorts = 3;
+ repeated PONPort PONPorts = 4;
+}
+
+message VersionNumber {
+ string version = 1;
+ string buildTime = 2;
+ string commitHash = 3;
+ string gitStatus = 4;
+}
+
+message Empty {}
+
+service BBSim {
+ rpc Version(Empty) returns (VersionNumber) {}
+ rpc GetOlt(Empty) returns (Olt) {}
+}
\ No newline at end of file
diff --git a/api/openolt.pb.go b/api/openolt.pb.go
deleted file mode 100644
index 7259c21..0000000
--- a/api/openolt.pb.go
+++ /dev/null
@@ -1,4684 +0,0 @@
-// Code generated by protoc-gen-go. DO NOT EDIT.
-// source: api/openolt.proto
-
-package openolt
-
-import (
- context "context"
- fmt "fmt"
- proto "github.com/golang/protobuf/proto"
- _ "google.golang.org/genproto/googleapis/api/annotations"
- grpc "google.golang.org/grpc"
- codes "google.golang.org/grpc/codes"
- status "google.golang.org/grpc/status"
- math "math"
-)
-
-// Reference imports to suppress errors if they are not otherwise used.
-var _ = proto.Marshal
-var _ = fmt.Errorf
-var _ = math.Inf
-
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the proto package it is being compiled against.
-// A compilation error at this line likely means your copy of the
-// proto package needs to be updated.
-const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
-
-type Direction int32
-
-const (
- Direction_UPSTREAM Direction = 0
- Direction_DOWNSTREAM Direction = 1
- Direction_BIDIRECTIONAL Direction = 2
-)
-
-var Direction_name = map[int32]string{
- 0: "UPSTREAM",
- 1: "DOWNSTREAM",
- 2: "BIDIRECTIONAL",
-}
-
-var Direction_value = map[string]int32{
- "UPSTREAM": 0,
- "DOWNSTREAM": 1,
- "BIDIRECTIONAL": 2,
-}
-
-func (x Direction) String() string {
- return proto.EnumName(Direction_name, int32(x))
-}
-
-func (Direction) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{0}
-}
-
-type SchedulingPolicy int32
-
-const (
- SchedulingPolicy_WRR SchedulingPolicy = 0
- SchedulingPolicy_StrictPriority SchedulingPolicy = 1
- SchedulingPolicy_Hybrid SchedulingPolicy = 2
-)
-
-var SchedulingPolicy_name = map[int32]string{
- 0: "WRR",
- 1: "StrictPriority",
- 2: "Hybrid",
-}
-
-var SchedulingPolicy_value = map[string]int32{
- "WRR": 0,
- "StrictPriority": 1,
- "Hybrid": 2,
-}
-
-func (x SchedulingPolicy) String() string {
- return proto.EnumName(SchedulingPolicy_name, int32(x))
-}
-
-func (SchedulingPolicy) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{1}
-}
-
-type AdditionalBW int32
-
-const (
- AdditionalBW_AdditionalBW_None AdditionalBW = 0
- AdditionalBW_AdditionalBW_NA AdditionalBW = 1
- AdditionalBW_AdditionalBW_BestEffort AdditionalBW = 2
- AdditionalBW_AdditionalBW_Auto AdditionalBW = 3
-)
-
-var AdditionalBW_name = map[int32]string{
- 0: "AdditionalBW_None",
- 1: "AdditionalBW_NA",
- 2: "AdditionalBW_BestEffort",
- 3: "AdditionalBW_Auto",
-}
-
-var AdditionalBW_value = map[string]int32{
- "AdditionalBW_None": 0,
- "AdditionalBW_NA": 1,
- "AdditionalBW_BestEffort": 2,
- "AdditionalBW_Auto": 3,
-}
-
-func (x AdditionalBW) String() string {
- return proto.EnumName(AdditionalBW_name, int32(x))
-}
-
-func (AdditionalBW) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{2}
-}
-
-type DiscardPolicy int32
-
-const (
- DiscardPolicy_TailDrop DiscardPolicy = 0
- DiscardPolicy_WTailDrop DiscardPolicy = 1
- DiscardPolicy_Red DiscardPolicy = 2
- DiscardPolicy_WRed DiscardPolicy = 3
-)
-
-var DiscardPolicy_name = map[int32]string{
- 0: "TailDrop",
- 1: "WTailDrop",
- 2: "Red",
- 3: "WRed",
-}
-
-var DiscardPolicy_value = map[string]int32{
- "TailDrop": 0,
- "WTailDrop": 1,
- "Red": 2,
- "WRed": 3,
-}
-
-func (x DiscardPolicy) String() string {
- return proto.EnumName(DiscardPolicy_name, int32(x))
-}
-
-func (DiscardPolicy) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{3}
-}
-
-type InferredAdditionBWIndication int32
-
-const (
- InferredAdditionBWIndication_InferredAdditionBWIndication_None InferredAdditionBWIndication = 0
- InferredAdditionBWIndication_InferredAdditionBWIndication_Assured InferredAdditionBWIndication = 1
- InferredAdditionBWIndication_InferredAdditionBWIndication_BestEffort InferredAdditionBWIndication = 2
-)
-
-var InferredAdditionBWIndication_name = map[int32]string{
- 0: "InferredAdditionBWIndication_None",
- 1: "InferredAdditionBWIndication_Assured",
- 2: "InferredAdditionBWIndication_BestEffort",
-}
-
-var InferredAdditionBWIndication_value = map[string]int32{
- "InferredAdditionBWIndication_None": 0,
- "InferredAdditionBWIndication_Assured": 1,
- "InferredAdditionBWIndication_BestEffort": 2,
-}
-
-func (x InferredAdditionBWIndication) String() string {
- return proto.EnumName(InferredAdditionBWIndication_name, int32(x))
-}
-
-func (InferredAdditionBWIndication) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{4}
-}
-
-type DeviceInfo_DeviceResourceRanges_Pool_PoolType int32
-
-const (
- DeviceInfo_DeviceResourceRanges_Pool_ONU_ID DeviceInfo_DeviceResourceRanges_Pool_PoolType = 0
- DeviceInfo_DeviceResourceRanges_Pool_ALLOC_ID DeviceInfo_DeviceResourceRanges_Pool_PoolType = 1
- DeviceInfo_DeviceResourceRanges_Pool_GEMPORT_ID DeviceInfo_DeviceResourceRanges_Pool_PoolType = 2
- DeviceInfo_DeviceResourceRanges_Pool_FLOW_ID DeviceInfo_DeviceResourceRanges_Pool_PoolType = 3
-)
-
-var DeviceInfo_DeviceResourceRanges_Pool_PoolType_name = map[int32]string{
- 0: "ONU_ID",
- 1: "ALLOC_ID",
- 2: "GEMPORT_ID",
- 3: "FLOW_ID",
-}
-
-var DeviceInfo_DeviceResourceRanges_Pool_PoolType_value = map[string]int32{
- "ONU_ID": 0,
- "ALLOC_ID": 1,
- "GEMPORT_ID": 2,
- "FLOW_ID": 3,
-}
-
-func (x DeviceInfo_DeviceResourceRanges_Pool_PoolType) String() string {
- return proto.EnumName(DeviceInfo_DeviceResourceRanges_Pool_PoolType_name, int32(x))
-}
-
-func (DeviceInfo_DeviceResourceRanges_Pool_PoolType) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{15, 0, 0, 0}
-}
-
-type DeviceInfo_DeviceResourceRanges_Pool_SharingType int32
-
-const (
- DeviceInfo_DeviceResourceRanges_Pool_DEDICATED_PER_INTF DeviceInfo_DeviceResourceRanges_Pool_SharingType = 0
- DeviceInfo_DeviceResourceRanges_Pool_SHARED_BY_ALL_INTF_ALL_TECH DeviceInfo_DeviceResourceRanges_Pool_SharingType = 1
- DeviceInfo_DeviceResourceRanges_Pool_SHARED_BY_ALL_INTF_SAME_TECH DeviceInfo_DeviceResourceRanges_Pool_SharingType = 2
-)
-
-var DeviceInfo_DeviceResourceRanges_Pool_SharingType_name = map[int32]string{
- 0: "DEDICATED_PER_INTF",
- 1: "SHARED_BY_ALL_INTF_ALL_TECH",
- 2: "SHARED_BY_ALL_INTF_SAME_TECH",
-}
-
-var DeviceInfo_DeviceResourceRanges_Pool_SharingType_value = map[string]int32{
- "DEDICATED_PER_INTF": 0,
- "SHARED_BY_ALL_INTF_ALL_TECH": 1,
- "SHARED_BY_ALL_INTF_SAME_TECH": 2,
-}
-
-func (x DeviceInfo_DeviceResourceRanges_Pool_SharingType) String() string {
- return proto.EnumName(DeviceInfo_DeviceResourceRanges_Pool_SharingType_name, int32(x))
-}
-
-func (DeviceInfo_DeviceResourceRanges_Pool_SharingType) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{15, 0, 0, 1}
-}
-
-type Indication struct {
- // Types that are valid to be assigned to Data:
- // *Indication_OltInd
- // *Indication_IntfInd
- // *Indication_IntfOperInd
- // *Indication_OnuDiscInd
- // *Indication_OnuInd
- // *Indication_OmciInd
- // *Indication_PktInd
- // *Indication_PortStats
- // *Indication_FlowStats
- // *Indication_AlarmInd
- Data isIndication_Data `protobuf_oneof:"data"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Indication) Reset() { *m = Indication{} }
-func (m *Indication) String() string { return proto.CompactTextString(m) }
-func (*Indication) ProtoMessage() {}
-func (*Indication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{0}
-}
-
-func (m *Indication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Indication.Unmarshal(m, b)
-}
-func (m *Indication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Indication.Marshal(b, m, deterministic)
-}
-func (m *Indication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Indication.Merge(m, src)
-}
-func (m *Indication) XXX_Size() int {
- return xxx_messageInfo_Indication.Size(m)
-}
-func (m *Indication) XXX_DiscardUnknown() {
- xxx_messageInfo_Indication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Indication proto.InternalMessageInfo
-
-type isIndication_Data interface {
- isIndication_Data()
-}
-
-type Indication_OltInd struct {
- OltInd *OltIndication `protobuf:"bytes,1,opt,name=olt_ind,json=oltInd,proto3,oneof"`
-}
-
-type Indication_IntfInd struct {
- IntfInd *IntfIndication `protobuf:"bytes,2,opt,name=intf_ind,json=intfInd,proto3,oneof"`
-}
-
-type Indication_IntfOperInd struct {
- IntfOperInd *IntfOperIndication `protobuf:"bytes,3,opt,name=intf_oper_ind,json=intfOperInd,proto3,oneof"`
-}
-
-type Indication_OnuDiscInd struct {
- OnuDiscInd *OnuDiscIndication `protobuf:"bytes,4,opt,name=onu_disc_ind,json=onuDiscInd,proto3,oneof"`
-}
-
-type Indication_OnuInd struct {
- OnuInd *OnuIndication `protobuf:"bytes,5,opt,name=onu_ind,json=onuInd,proto3,oneof"`
-}
-
-type Indication_OmciInd struct {
- OmciInd *OmciIndication `protobuf:"bytes,6,opt,name=omci_ind,json=omciInd,proto3,oneof"`
-}
-
-type Indication_PktInd struct {
- PktInd *PacketIndication `protobuf:"bytes,7,opt,name=pkt_ind,json=pktInd,proto3,oneof"`
-}
-
-type Indication_PortStats struct {
- PortStats *PortStatistics `protobuf:"bytes,8,opt,name=port_stats,json=portStats,proto3,oneof"`
-}
-
-type Indication_FlowStats struct {
- FlowStats *FlowStatistics `protobuf:"bytes,9,opt,name=flow_stats,json=flowStats,proto3,oneof"`
-}
-
-type Indication_AlarmInd struct {
- AlarmInd *AlarmIndication `protobuf:"bytes,10,opt,name=alarm_ind,json=alarmInd,proto3,oneof"`
-}
-
-func (*Indication_OltInd) isIndication_Data() {}
-
-func (*Indication_IntfInd) isIndication_Data() {}
-
-func (*Indication_IntfOperInd) isIndication_Data() {}
-
-func (*Indication_OnuDiscInd) isIndication_Data() {}
-
-func (*Indication_OnuInd) isIndication_Data() {}
-
-func (*Indication_OmciInd) isIndication_Data() {}
-
-func (*Indication_PktInd) isIndication_Data() {}
-
-func (*Indication_PortStats) isIndication_Data() {}
-
-func (*Indication_FlowStats) isIndication_Data() {}
-
-func (*Indication_AlarmInd) isIndication_Data() {}
-
-func (m *Indication) GetData() isIndication_Data {
- if m != nil {
- return m.Data
- }
- return nil
-}
-
-func (m *Indication) GetOltInd() *OltIndication {
- if x, ok := m.GetData().(*Indication_OltInd); ok {
- return x.OltInd
- }
- return nil
-}
-
-func (m *Indication) GetIntfInd() *IntfIndication {
- if x, ok := m.GetData().(*Indication_IntfInd); ok {
- return x.IntfInd
- }
- return nil
-}
-
-func (m *Indication) GetIntfOperInd() *IntfOperIndication {
- if x, ok := m.GetData().(*Indication_IntfOperInd); ok {
- return x.IntfOperInd
- }
- return nil
-}
-
-func (m *Indication) GetOnuDiscInd() *OnuDiscIndication {
- if x, ok := m.GetData().(*Indication_OnuDiscInd); ok {
- return x.OnuDiscInd
- }
- return nil
-}
-
-func (m *Indication) GetOnuInd() *OnuIndication {
- if x, ok := m.GetData().(*Indication_OnuInd); ok {
- return x.OnuInd
- }
- return nil
-}
-
-func (m *Indication) GetOmciInd() *OmciIndication {
- if x, ok := m.GetData().(*Indication_OmciInd); ok {
- return x.OmciInd
- }
- return nil
-}
-
-func (m *Indication) GetPktInd() *PacketIndication {
- if x, ok := m.GetData().(*Indication_PktInd); ok {
- return x.PktInd
- }
- return nil
-}
-
-func (m *Indication) GetPortStats() *PortStatistics {
- if x, ok := m.GetData().(*Indication_PortStats); ok {
- return x.PortStats
- }
- return nil
-}
-
-func (m *Indication) GetFlowStats() *FlowStatistics {
- if x, ok := m.GetData().(*Indication_FlowStats); ok {
- return x.FlowStats
- }
- return nil
-}
-
-func (m *Indication) GetAlarmInd() *AlarmIndication {
- if x, ok := m.GetData().(*Indication_AlarmInd); ok {
- return x.AlarmInd
- }
- return nil
-}
-
-// XXX_OneofWrappers is for the internal use of the proto package.
-func (*Indication) XXX_OneofWrappers() []interface{} {
- return []interface{}{
- (*Indication_OltInd)(nil),
- (*Indication_IntfInd)(nil),
- (*Indication_IntfOperInd)(nil),
- (*Indication_OnuDiscInd)(nil),
- (*Indication_OnuInd)(nil),
- (*Indication_OmciInd)(nil),
- (*Indication_PktInd)(nil),
- (*Indication_PortStats)(nil),
- (*Indication_FlowStats)(nil),
- (*Indication_AlarmInd)(nil),
- }
-}
-
-type AlarmIndication struct {
- // Types that are valid to be assigned to Data:
- // *AlarmIndication_LosInd
- // *AlarmIndication_DyingGaspInd
- // *AlarmIndication_OnuAlarmInd
- // *AlarmIndication_OnuStartupFailInd
- // *AlarmIndication_OnuSignalDegradeInd
- // *AlarmIndication_OnuDriftOfWindowInd
- // *AlarmIndication_OnuLossOmciInd
- // *AlarmIndication_OnuSignalsFailInd
- // *AlarmIndication_OnuTiwiInd
- // *AlarmIndication_OnuActivationFailInd
- // *AlarmIndication_OnuProcessingErrorInd
- Data isAlarmIndication_Data `protobuf_oneof:"data"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *AlarmIndication) Reset() { *m = AlarmIndication{} }
-func (m *AlarmIndication) String() string { return proto.CompactTextString(m) }
-func (*AlarmIndication) ProtoMessage() {}
-func (*AlarmIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{1}
-}
-
-func (m *AlarmIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_AlarmIndication.Unmarshal(m, b)
-}
-func (m *AlarmIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_AlarmIndication.Marshal(b, m, deterministic)
-}
-func (m *AlarmIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_AlarmIndication.Merge(m, src)
-}
-func (m *AlarmIndication) XXX_Size() int {
- return xxx_messageInfo_AlarmIndication.Size(m)
-}
-func (m *AlarmIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_AlarmIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_AlarmIndication proto.InternalMessageInfo
-
-type isAlarmIndication_Data interface {
- isAlarmIndication_Data()
-}
-
-type AlarmIndication_LosInd struct {
- LosInd *LosIndication `protobuf:"bytes,1,opt,name=los_ind,json=losInd,proto3,oneof"`
-}
-
-type AlarmIndication_DyingGaspInd struct {
- DyingGaspInd *DyingGaspIndication `protobuf:"bytes,2,opt,name=dying_gasp_ind,json=dyingGaspInd,proto3,oneof"`
-}
-
-type AlarmIndication_OnuAlarmInd struct {
- OnuAlarmInd *OnuAlarmIndication `protobuf:"bytes,3,opt,name=onu_alarm_ind,json=onuAlarmInd,proto3,oneof"`
-}
-
-type AlarmIndication_OnuStartupFailInd struct {
- OnuStartupFailInd *OnuStartupFailureIndication `protobuf:"bytes,4,opt,name=onu_startup_fail_ind,json=onuStartupFailInd,proto3,oneof"`
-}
-
-type AlarmIndication_OnuSignalDegradeInd struct {
- OnuSignalDegradeInd *OnuSignalDegradeIndication `protobuf:"bytes,5,opt,name=onu_signal_degrade_ind,json=onuSignalDegradeInd,proto3,oneof"`
-}
-
-type AlarmIndication_OnuDriftOfWindowInd struct {
- OnuDriftOfWindowInd *OnuDriftOfWindowIndication `protobuf:"bytes,6,opt,name=onu_drift_of_window_ind,json=onuDriftOfWindowInd,proto3,oneof"`
-}
-
-type AlarmIndication_OnuLossOmciInd struct {
- OnuLossOmciInd *OnuLossOfOmciChannelIndication `protobuf:"bytes,7,opt,name=onu_loss_omci_ind,json=onuLossOmciInd,proto3,oneof"`
-}
-
-type AlarmIndication_OnuSignalsFailInd struct {
- OnuSignalsFailInd *OnuSignalsFailureIndication `protobuf:"bytes,8,opt,name=onu_signals_fail_ind,json=onuSignalsFailInd,proto3,oneof"`
-}
-
-type AlarmIndication_OnuTiwiInd struct {
- OnuTiwiInd *OnuTransmissionInterferenceWarning `protobuf:"bytes,9,opt,name=onu_tiwi_ind,json=onuTiwiInd,proto3,oneof"`
-}
-
-type AlarmIndication_OnuActivationFailInd struct {
- OnuActivationFailInd *OnuActivationFailureIndication `protobuf:"bytes,10,opt,name=onu_activation_fail_ind,json=onuActivationFailInd,proto3,oneof"`
-}
-
-type AlarmIndication_OnuProcessingErrorInd struct {
- OnuProcessingErrorInd *OnuProcessingErrorIndication `protobuf:"bytes,11,opt,name=onu_processing_error_ind,json=onuProcessingErrorInd,proto3,oneof"`
-}
-
-func (*AlarmIndication_LosInd) isAlarmIndication_Data() {}
-
-func (*AlarmIndication_DyingGaspInd) isAlarmIndication_Data() {}
-
-func (*AlarmIndication_OnuAlarmInd) isAlarmIndication_Data() {}
-
-func (*AlarmIndication_OnuStartupFailInd) isAlarmIndication_Data() {}
-
-func (*AlarmIndication_OnuSignalDegradeInd) isAlarmIndication_Data() {}
-
-func (*AlarmIndication_OnuDriftOfWindowInd) isAlarmIndication_Data() {}
-
-func (*AlarmIndication_OnuLossOmciInd) isAlarmIndication_Data() {}
-
-func (*AlarmIndication_OnuSignalsFailInd) isAlarmIndication_Data() {}
-
-func (*AlarmIndication_OnuTiwiInd) isAlarmIndication_Data() {}
-
-func (*AlarmIndication_OnuActivationFailInd) isAlarmIndication_Data() {}
-
-func (*AlarmIndication_OnuProcessingErrorInd) isAlarmIndication_Data() {}
-
-func (m *AlarmIndication) GetData() isAlarmIndication_Data {
- if m != nil {
- return m.Data
- }
- return nil
-}
-
-func (m *AlarmIndication) GetLosInd() *LosIndication {
- if x, ok := m.GetData().(*AlarmIndication_LosInd); ok {
- return x.LosInd
- }
- return nil
-}
-
-func (m *AlarmIndication) GetDyingGaspInd() *DyingGaspIndication {
- if x, ok := m.GetData().(*AlarmIndication_DyingGaspInd); ok {
- return x.DyingGaspInd
- }
- return nil
-}
-
-func (m *AlarmIndication) GetOnuAlarmInd() *OnuAlarmIndication {
- if x, ok := m.GetData().(*AlarmIndication_OnuAlarmInd); ok {
- return x.OnuAlarmInd
- }
- return nil
-}
-
-func (m *AlarmIndication) GetOnuStartupFailInd() *OnuStartupFailureIndication {
- if x, ok := m.GetData().(*AlarmIndication_OnuStartupFailInd); ok {
- return x.OnuStartupFailInd
- }
- return nil
-}
-
-func (m *AlarmIndication) GetOnuSignalDegradeInd() *OnuSignalDegradeIndication {
- if x, ok := m.GetData().(*AlarmIndication_OnuSignalDegradeInd); ok {
- return x.OnuSignalDegradeInd
- }
- return nil
-}
-
-func (m *AlarmIndication) GetOnuDriftOfWindowInd() *OnuDriftOfWindowIndication {
- if x, ok := m.GetData().(*AlarmIndication_OnuDriftOfWindowInd); ok {
- return x.OnuDriftOfWindowInd
- }
- return nil
-}
-
-func (m *AlarmIndication) GetOnuLossOmciInd() *OnuLossOfOmciChannelIndication {
- if x, ok := m.GetData().(*AlarmIndication_OnuLossOmciInd); ok {
- return x.OnuLossOmciInd
- }
- return nil
-}
-
-func (m *AlarmIndication) GetOnuSignalsFailInd() *OnuSignalsFailureIndication {
- if x, ok := m.GetData().(*AlarmIndication_OnuSignalsFailInd); ok {
- return x.OnuSignalsFailInd
- }
- return nil
-}
-
-func (m *AlarmIndication) GetOnuTiwiInd() *OnuTransmissionInterferenceWarning {
- if x, ok := m.GetData().(*AlarmIndication_OnuTiwiInd); ok {
- return x.OnuTiwiInd
- }
- return nil
-}
-
-func (m *AlarmIndication) GetOnuActivationFailInd() *OnuActivationFailureIndication {
- if x, ok := m.GetData().(*AlarmIndication_OnuActivationFailInd); ok {
- return x.OnuActivationFailInd
- }
- return nil
-}
-
-func (m *AlarmIndication) GetOnuProcessingErrorInd() *OnuProcessingErrorIndication {
- if x, ok := m.GetData().(*AlarmIndication_OnuProcessingErrorInd); ok {
- return x.OnuProcessingErrorInd
- }
- return nil
-}
-
-// XXX_OneofWrappers is for the internal use of the proto package.
-func (*AlarmIndication) XXX_OneofWrappers() []interface{} {
- return []interface{}{
- (*AlarmIndication_LosInd)(nil),
- (*AlarmIndication_DyingGaspInd)(nil),
- (*AlarmIndication_OnuAlarmInd)(nil),
- (*AlarmIndication_OnuStartupFailInd)(nil),
- (*AlarmIndication_OnuSignalDegradeInd)(nil),
- (*AlarmIndication_OnuDriftOfWindowInd)(nil),
- (*AlarmIndication_OnuLossOmciInd)(nil),
- (*AlarmIndication_OnuSignalsFailInd)(nil),
- (*AlarmIndication_OnuTiwiInd)(nil),
- (*AlarmIndication_OnuActivationFailInd)(nil),
- (*AlarmIndication_OnuProcessingErrorInd)(nil),
- }
-}
-
-type OltIndication struct {
- OperState string `protobuf:"bytes,1,opt,name=oper_state,json=operState,proto3" json:"oper_state,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OltIndication) Reset() { *m = OltIndication{} }
-func (m *OltIndication) String() string { return proto.CompactTextString(m) }
-func (*OltIndication) ProtoMessage() {}
-func (*OltIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{2}
-}
-
-func (m *OltIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OltIndication.Unmarshal(m, b)
-}
-func (m *OltIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OltIndication.Marshal(b, m, deterministic)
-}
-func (m *OltIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OltIndication.Merge(m, src)
-}
-func (m *OltIndication) XXX_Size() int {
- return xxx_messageInfo_OltIndication.Size(m)
-}
-func (m *OltIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OltIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OltIndication proto.InternalMessageInfo
-
-func (m *OltIndication) GetOperState() string {
- if m != nil {
- return m.OperState
- }
- return ""
-}
-
-type IntfIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OperState string `protobuf:"bytes,2,opt,name=oper_state,json=operState,proto3" json:"oper_state,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *IntfIndication) Reset() { *m = IntfIndication{} }
-func (m *IntfIndication) String() string { return proto.CompactTextString(m) }
-func (*IntfIndication) ProtoMessage() {}
-func (*IntfIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{3}
-}
-
-func (m *IntfIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_IntfIndication.Unmarshal(m, b)
-}
-func (m *IntfIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_IntfIndication.Marshal(b, m, deterministic)
-}
-func (m *IntfIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_IntfIndication.Merge(m, src)
-}
-func (m *IntfIndication) XXX_Size() int {
- return xxx_messageInfo_IntfIndication.Size(m)
-}
-func (m *IntfIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_IntfIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_IntfIndication proto.InternalMessageInfo
-
-func (m *IntfIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *IntfIndication) GetOperState() string {
- if m != nil {
- return m.OperState
- }
- return ""
-}
-
-type OnuDiscIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- SerialNumber *SerialNumber `protobuf:"bytes,2,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuDiscIndication) Reset() { *m = OnuDiscIndication{} }
-func (m *OnuDiscIndication) String() string { return proto.CompactTextString(m) }
-func (*OnuDiscIndication) ProtoMessage() {}
-func (*OnuDiscIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{4}
-}
-
-func (m *OnuDiscIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuDiscIndication.Unmarshal(m, b)
-}
-func (m *OnuDiscIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuDiscIndication.Marshal(b, m, deterministic)
-}
-func (m *OnuDiscIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuDiscIndication.Merge(m, src)
-}
-func (m *OnuDiscIndication) XXX_Size() int {
- return xxx_messageInfo_OnuDiscIndication.Size(m)
-}
-func (m *OnuDiscIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuDiscIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuDiscIndication proto.InternalMessageInfo
-
-func (m *OnuDiscIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuDiscIndication) GetSerialNumber() *SerialNumber {
- if m != nil {
- return m.SerialNumber
- }
- return nil
-}
-
-type OnuIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- OperState string `protobuf:"bytes,3,opt,name=oper_state,json=operState,proto3" json:"oper_state,omitempty"`
- AdminState string `protobuf:"bytes,5,opt,name=admin_state,json=adminState,proto3" json:"admin_state,omitempty"`
- SerialNumber *SerialNumber `protobuf:"bytes,4,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuIndication) Reset() { *m = OnuIndication{} }
-func (m *OnuIndication) String() string { return proto.CompactTextString(m) }
-func (*OnuIndication) ProtoMessage() {}
-func (*OnuIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{5}
-}
-
-func (m *OnuIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuIndication.Unmarshal(m, b)
-}
-func (m *OnuIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuIndication.Marshal(b, m, deterministic)
-}
-func (m *OnuIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuIndication.Merge(m, src)
-}
-func (m *OnuIndication) XXX_Size() int {
- return xxx_messageInfo_OnuIndication.Size(m)
-}
-func (m *OnuIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuIndication proto.InternalMessageInfo
-
-func (m *OnuIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OnuIndication) GetOperState() string {
- if m != nil {
- return m.OperState
- }
- return ""
-}
-
-func (m *OnuIndication) GetAdminState() string {
- if m != nil {
- return m.AdminState
- }
- return ""
-}
-
-func (m *OnuIndication) GetSerialNumber() *SerialNumber {
- if m != nil {
- return m.SerialNumber
- }
- return nil
-}
-
-type IntfOperIndication struct {
- Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
- IntfId uint32 `protobuf:"fixed32,2,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OperState string `protobuf:"bytes,3,opt,name=oper_state,json=operState,proto3" json:"oper_state,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *IntfOperIndication) Reset() { *m = IntfOperIndication{} }
-func (m *IntfOperIndication) String() string { return proto.CompactTextString(m) }
-func (*IntfOperIndication) ProtoMessage() {}
-func (*IntfOperIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{6}
-}
-
-func (m *IntfOperIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_IntfOperIndication.Unmarshal(m, b)
-}
-func (m *IntfOperIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_IntfOperIndication.Marshal(b, m, deterministic)
-}
-func (m *IntfOperIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_IntfOperIndication.Merge(m, src)
-}
-func (m *IntfOperIndication) XXX_Size() int {
- return xxx_messageInfo_IntfOperIndication.Size(m)
-}
-func (m *IntfOperIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_IntfOperIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_IntfOperIndication proto.InternalMessageInfo
-
-func (m *IntfOperIndication) GetType() string {
- if m != nil {
- return m.Type
- }
- return ""
-}
-
-func (m *IntfOperIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *IntfOperIndication) GetOperState() string {
- if m != nil {
- return m.OperState
- }
- return ""
-}
-
-type OmciIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- Pkt []byte `protobuf:"bytes,3,opt,name=pkt,proto3" json:"pkt,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OmciIndication) Reset() { *m = OmciIndication{} }
-func (m *OmciIndication) String() string { return proto.CompactTextString(m) }
-func (*OmciIndication) ProtoMessage() {}
-func (*OmciIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{7}
-}
-
-func (m *OmciIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OmciIndication.Unmarshal(m, b)
-}
-func (m *OmciIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OmciIndication.Marshal(b, m, deterministic)
-}
-func (m *OmciIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OmciIndication.Merge(m, src)
-}
-func (m *OmciIndication) XXX_Size() int {
- return xxx_messageInfo_OmciIndication.Size(m)
-}
-func (m *OmciIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OmciIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OmciIndication proto.InternalMessageInfo
-
-func (m *OmciIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OmciIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OmciIndication) GetPkt() []byte {
- if m != nil {
- return m.Pkt
- }
- return nil
-}
-
-type PacketIndication struct {
- IntfType string `protobuf:"bytes,5,opt,name=intf_type,json=intfType,proto3" json:"intf_type,omitempty"`
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- GemportId uint32 `protobuf:"fixed32,2,opt,name=gemport_id,json=gemportId,proto3" json:"gemport_id,omitempty"`
- FlowId uint32 `protobuf:"fixed32,3,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
- PortNo uint32 `protobuf:"fixed32,6,opt,name=port_no,json=portNo,proto3" json:"port_no,omitempty"`
- Cookie uint64 `protobuf:"fixed64,7,opt,name=cookie,proto3" json:"cookie,omitempty"`
- Pkt []byte `protobuf:"bytes,4,opt,name=pkt,proto3" json:"pkt,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *PacketIndication) Reset() { *m = PacketIndication{} }
-func (m *PacketIndication) String() string { return proto.CompactTextString(m) }
-func (*PacketIndication) ProtoMessage() {}
-func (*PacketIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{8}
-}
-
-func (m *PacketIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_PacketIndication.Unmarshal(m, b)
-}
-func (m *PacketIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_PacketIndication.Marshal(b, m, deterministic)
-}
-func (m *PacketIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_PacketIndication.Merge(m, src)
-}
-func (m *PacketIndication) XXX_Size() int {
- return xxx_messageInfo_PacketIndication.Size(m)
-}
-func (m *PacketIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_PacketIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_PacketIndication proto.InternalMessageInfo
-
-func (m *PacketIndication) GetIntfType() string {
- if m != nil {
- return m.IntfType
- }
- return ""
-}
-
-func (m *PacketIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *PacketIndication) GetGemportId() uint32 {
- if m != nil {
- return m.GemportId
- }
- return 0
-}
-
-func (m *PacketIndication) GetFlowId() uint32 {
- if m != nil {
- return m.FlowId
- }
- return 0
-}
-
-func (m *PacketIndication) GetPortNo() uint32 {
- if m != nil {
- return m.PortNo
- }
- return 0
-}
-
-func (m *PacketIndication) GetCookie() uint64 {
- if m != nil {
- return m.Cookie
- }
- return 0
-}
-
-func (m *PacketIndication) GetPkt() []byte {
- if m != nil {
- return m.Pkt
- }
- return nil
-}
-
-type Interface struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Interface) Reset() { *m = Interface{} }
-func (m *Interface) String() string { return proto.CompactTextString(m) }
-func (*Interface) ProtoMessage() {}
-func (*Interface) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{9}
-}
-
-func (m *Interface) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Interface.Unmarshal(m, b)
-}
-func (m *Interface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Interface.Marshal(b, m, deterministic)
-}
-func (m *Interface) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Interface.Merge(m, src)
-}
-func (m *Interface) XXX_Size() int {
- return xxx_messageInfo_Interface.Size(m)
-}
-func (m *Interface) XXX_DiscardUnknown() {
- xxx_messageInfo_Interface.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Interface proto.InternalMessageInfo
-
-func (m *Interface) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-type Heartbeat struct {
- HeartbeatSignature uint32 `protobuf:"fixed32,1,opt,name=heartbeat_signature,json=heartbeatSignature,proto3" json:"heartbeat_signature,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Heartbeat) Reset() { *m = Heartbeat{} }
-func (m *Heartbeat) String() string { return proto.CompactTextString(m) }
-func (*Heartbeat) ProtoMessage() {}
-func (*Heartbeat) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{10}
-}
-
-func (m *Heartbeat) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Heartbeat.Unmarshal(m, b)
-}
-func (m *Heartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Heartbeat.Marshal(b, m, deterministic)
-}
-func (m *Heartbeat) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Heartbeat.Merge(m, src)
-}
-func (m *Heartbeat) XXX_Size() int {
- return xxx_messageInfo_Heartbeat.Size(m)
-}
-func (m *Heartbeat) XXX_DiscardUnknown() {
- xxx_messageInfo_Heartbeat.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Heartbeat proto.InternalMessageInfo
-
-func (m *Heartbeat) GetHeartbeatSignature() uint32 {
- if m != nil {
- return m.HeartbeatSignature
- }
- return 0
-}
-
-type Onu struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- SerialNumber *SerialNumber `protobuf:"bytes,3,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"`
- Pir uint32 `protobuf:"fixed32,4,opt,name=pir,proto3" json:"pir,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Onu) Reset() { *m = Onu{} }
-func (m *Onu) String() string { return proto.CompactTextString(m) }
-func (*Onu) ProtoMessage() {}
-func (*Onu) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{11}
-}
-
-func (m *Onu) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Onu.Unmarshal(m, b)
-}
-func (m *Onu) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Onu.Marshal(b, m, deterministic)
-}
-func (m *Onu) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Onu.Merge(m, src)
-}
-func (m *Onu) XXX_Size() int {
- return xxx_messageInfo_Onu.Size(m)
-}
-func (m *Onu) XXX_DiscardUnknown() {
- xxx_messageInfo_Onu.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Onu proto.InternalMessageInfo
-
-func (m *Onu) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *Onu) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *Onu) GetSerialNumber() *SerialNumber {
- if m != nil {
- return m.SerialNumber
- }
- return nil
-}
-
-func (m *Onu) GetPir() uint32 {
- if m != nil {
- return m.Pir
- }
- return 0
-}
-
-type OmciMsg struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- Pkt []byte `protobuf:"bytes,3,opt,name=pkt,proto3" json:"pkt,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OmciMsg) Reset() { *m = OmciMsg{} }
-func (m *OmciMsg) String() string { return proto.CompactTextString(m) }
-func (*OmciMsg) ProtoMessage() {}
-func (*OmciMsg) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{12}
-}
-
-func (m *OmciMsg) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OmciMsg.Unmarshal(m, b)
-}
-func (m *OmciMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OmciMsg.Marshal(b, m, deterministic)
-}
-func (m *OmciMsg) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OmciMsg.Merge(m, src)
-}
-func (m *OmciMsg) XXX_Size() int {
- return xxx_messageInfo_OmciMsg.Size(m)
-}
-func (m *OmciMsg) XXX_DiscardUnknown() {
- xxx_messageInfo_OmciMsg.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OmciMsg proto.InternalMessageInfo
-
-func (m *OmciMsg) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OmciMsg) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OmciMsg) GetPkt() []byte {
- if m != nil {
- return m.Pkt
- }
- return nil
-}
-
-type OnuPacket struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- PortNo uint32 `protobuf:"fixed32,4,opt,name=port_no,json=portNo,proto3" json:"port_no,omitempty"`
- Pkt []byte `protobuf:"bytes,3,opt,name=pkt,proto3" json:"pkt,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuPacket) Reset() { *m = OnuPacket{} }
-func (m *OnuPacket) String() string { return proto.CompactTextString(m) }
-func (*OnuPacket) ProtoMessage() {}
-func (*OnuPacket) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{13}
-}
-
-func (m *OnuPacket) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuPacket.Unmarshal(m, b)
-}
-func (m *OnuPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuPacket.Marshal(b, m, deterministic)
-}
-func (m *OnuPacket) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuPacket.Merge(m, src)
-}
-func (m *OnuPacket) XXX_Size() int {
- return xxx_messageInfo_OnuPacket.Size(m)
-}
-func (m *OnuPacket) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuPacket.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuPacket proto.InternalMessageInfo
-
-func (m *OnuPacket) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuPacket) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OnuPacket) GetPortNo() uint32 {
- if m != nil {
- return m.PortNo
- }
- return 0
-}
-
-func (m *OnuPacket) GetPkt() []byte {
- if m != nil {
- return m.Pkt
- }
- return nil
-}
-
-type UplinkPacket struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- Pkt []byte `protobuf:"bytes,2,opt,name=pkt,proto3" json:"pkt,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *UplinkPacket) Reset() { *m = UplinkPacket{} }
-func (m *UplinkPacket) String() string { return proto.CompactTextString(m) }
-func (*UplinkPacket) ProtoMessage() {}
-func (*UplinkPacket) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{14}
-}
-
-func (m *UplinkPacket) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_UplinkPacket.Unmarshal(m, b)
-}
-func (m *UplinkPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_UplinkPacket.Marshal(b, m, deterministic)
-}
-func (m *UplinkPacket) XXX_Merge(src proto.Message) {
- xxx_messageInfo_UplinkPacket.Merge(m, src)
-}
-func (m *UplinkPacket) XXX_Size() int {
- return xxx_messageInfo_UplinkPacket.Size(m)
-}
-func (m *UplinkPacket) XXX_DiscardUnknown() {
- xxx_messageInfo_UplinkPacket.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_UplinkPacket proto.InternalMessageInfo
-
-func (m *UplinkPacket) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *UplinkPacket) GetPkt() []byte {
- if m != nil {
- return m.Pkt
- }
- return nil
-}
-
-type DeviceInfo struct {
- Vendor string `protobuf:"bytes,1,opt,name=vendor,proto3" json:"vendor,omitempty"`
- Model string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
- HardwareVersion string `protobuf:"bytes,3,opt,name=hardware_version,json=hardwareVersion,proto3" json:"hardware_version,omitempty"`
- FirmwareVersion string `protobuf:"bytes,4,opt,name=firmware_version,json=firmwareVersion,proto3" json:"firmware_version,omitempty"`
- DeviceId string `protobuf:"bytes,16,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
- DeviceSerialNumber string `protobuf:"bytes,17,opt,name=device_serial_number,json=deviceSerialNumber,proto3" json:"device_serial_number,omitempty"`
- // Total number of pon intf ports on the device
- PonPorts uint32 `protobuf:"fixed32,12,opt,name=pon_ports,json=ponPorts,proto3" json:"pon_ports,omitempty"`
- // If using global per-device technology profile. To be deprecated
- Technology string `protobuf:"bytes,5,opt,name=technology,proto3" json:"technology,omitempty"`
- OnuIdStart uint32 `protobuf:"fixed32,6,opt,name=onu_id_start,json=onuIdStart,proto3" json:"onu_id_start,omitempty"`
- OnuIdEnd uint32 `protobuf:"fixed32,7,opt,name=onu_id_end,json=onuIdEnd,proto3" json:"onu_id_end,omitempty"`
- AllocIdStart uint32 `protobuf:"fixed32,8,opt,name=alloc_id_start,json=allocIdStart,proto3" json:"alloc_id_start,omitempty"`
- AllocIdEnd uint32 `protobuf:"fixed32,9,opt,name=alloc_id_end,json=allocIdEnd,proto3" json:"alloc_id_end,omitempty"`
- GemportIdStart uint32 `protobuf:"fixed32,10,opt,name=gemport_id_start,json=gemportIdStart,proto3" json:"gemport_id_start,omitempty"`
- GemportIdEnd uint32 `protobuf:"fixed32,11,opt,name=gemport_id_end,json=gemportIdEnd,proto3" json:"gemport_id_end,omitempty"`
- FlowIdStart uint32 `protobuf:"fixed32,13,opt,name=flow_id_start,json=flowIdStart,proto3" json:"flow_id_start,omitempty"`
- FlowIdEnd uint32 `protobuf:"fixed32,14,opt,name=flow_id_end,json=flowIdEnd,proto3" json:"flow_id_end,omitempty"`
- Ranges []*DeviceInfo_DeviceResourceRanges `protobuf:"bytes,15,rep,name=ranges,proto3" json:"ranges,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *DeviceInfo) Reset() { *m = DeviceInfo{} }
-func (m *DeviceInfo) String() string { return proto.CompactTextString(m) }
-func (*DeviceInfo) ProtoMessage() {}
-func (*DeviceInfo) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{15}
-}
-
-func (m *DeviceInfo) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_DeviceInfo.Unmarshal(m, b)
-}
-func (m *DeviceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_DeviceInfo.Marshal(b, m, deterministic)
-}
-func (m *DeviceInfo) XXX_Merge(src proto.Message) {
- xxx_messageInfo_DeviceInfo.Merge(m, src)
-}
-func (m *DeviceInfo) XXX_Size() int {
- return xxx_messageInfo_DeviceInfo.Size(m)
-}
-func (m *DeviceInfo) XXX_DiscardUnknown() {
- xxx_messageInfo_DeviceInfo.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_DeviceInfo proto.InternalMessageInfo
-
-func (m *DeviceInfo) GetVendor() string {
- if m != nil {
- return m.Vendor
- }
- return ""
-}
-
-func (m *DeviceInfo) GetModel() string {
- if m != nil {
- return m.Model
- }
- return ""
-}
-
-func (m *DeviceInfo) GetHardwareVersion() string {
- if m != nil {
- return m.HardwareVersion
- }
- return ""
-}
-
-func (m *DeviceInfo) GetFirmwareVersion() string {
- if m != nil {
- return m.FirmwareVersion
- }
- return ""
-}
-
-func (m *DeviceInfo) GetDeviceId() string {
- if m != nil {
- return m.DeviceId
- }
- return ""
-}
-
-func (m *DeviceInfo) GetDeviceSerialNumber() string {
- if m != nil {
- return m.DeviceSerialNumber
- }
- return ""
-}
-
-func (m *DeviceInfo) GetPonPorts() uint32 {
- if m != nil {
- return m.PonPorts
- }
- return 0
-}
-
-func (m *DeviceInfo) GetTechnology() string {
- if m != nil {
- return m.Technology
- }
- return ""
-}
-
-func (m *DeviceInfo) GetOnuIdStart() uint32 {
- if m != nil {
- return m.OnuIdStart
- }
- return 0
-}
-
-func (m *DeviceInfo) GetOnuIdEnd() uint32 {
- if m != nil {
- return m.OnuIdEnd
- }
- return 0
-}
-
-func (m *DeviceInfo) GetAllocIdStart() uint32 {
- if m != nil {
- return m.AllocIdStart
- }
- return 0
-}
-
-func (m *DeviceInfo) GetAllocIdEnd() uint32 {
- if m != nil {
- return m.AllocIdEnd
- }
- return 0
-}
-
-func (m *DeviceInfo) GetGemportIdStart() uint32 {
- if m != nil {
- return m.GemportIdStart
- }
- return 0
-}
-
-func (m *DeviceInfo) GetGemportIdEnd() uint32 {
- if m != nil {
- return m.GemportIdEnd
- }
- return 0
-}
-
-func (m *DeviceInfo) GetFlowIdStart() uint32 {
- if m != nil {
- return m.FlowIdStart
- }
- return 0
-}
-
-func (m *DeviceInfo) GetFlowIdEnd() uint32 {
- if m != nil {
- return m.FlowIdEnd
- }
- return 0
-}
-
-func (m *DeviceInfo) GetRanges() []*DeviceInfo_DeviceResourceRanges {
- if m != nil {
- return m.Ranges
- }
- return nil
-}
-
-type DeviceInfo_DeviceResourceRanges struct {
- // List of 0 or more intf_ids that use the same technology and pools.
- // If 0 intf_ids supplied, it implies ALL interfaces
- IntfIds []uint32 `protobuf:"fixed32,1,rep,packed,name=intf_ids,json=intfIds,proto3" json:"intf_ids,omitempty"`
- // Technology profile for this pool
- Technology string `protobuf:"bytes,2,opt,name=technology,proto3" json:"technology,omitempty"`
- Pools []*DeviceInfo_DeviceResourceRanges_Pool `protobuf:"bytes,3,rep,name=pools,proto3" json:"pools,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *DeviceInfo_DeviceResourceRanges) Reset() { *m = DeviceInfo_DeviceResourceRanges{} }
-func (m *DeviceInfo_DeviceResourceRanges) String() string { return proto.CompactTextString(m) }
-func (*DeviceInfo_DeviceResourceRanges) ProtoMessage() {}
-func (*DeviceInfo_DeviceResourceRanges) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{15, 0}
-}
-
-func (m *DeviceInfo_DeviceResourceRanges) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_DeviceInfo_DeviceResourceRanges.Unmarshal(m, b)
-}
-func (m *DeviceInfo_DeviceResourceRanges) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_DeviceInfo_DeviceResourceRanges.Marshal(b, m, deterministic)
-}
-func (m *DeviceInfo_DeviceResourceRanges) XXX_Merge(src proto.Message) {
- xxx_messageInfo_DeviceInfo_DeviceResourceRanges.Merge(m, src)
-}
-func (m *DeviceInfo_DeviceResourceRanges) XXX_Size() int {
- return xxx_messageInfo_DeviceInfo_DeviceResourceRanges.Size(m)
-}
-func (m *DeviceInfo_DeviceResourceRanges) XXX_DiscardUnknown() {
- xxx_messageInfo_DeviceInfo_DeviceResourceRanges.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_DeviceInfo_DeviceResourceRanges proto.InternalMessageInfo
-
-func (m *DeviceInfo_DeviceResourceRanges) GetIntfIds() []uint32 {
- if m != nil {
- return m.IntfIds
- }
- return nil
-}
-
-func (m *DeviceInfo_DeviceResourceRanges) GetTechnology() string {
- if m != nil {
- return m.Technology
- }
- return ""
-}
-
-func (m *DeviceInfo_DeviceResourceRanges) GetPools() []*DeviceInfo_DeviceResourceRanges_Pool {
- if m != nil {
- return m.Pools
- }
- return nil
-}
-
-type DeviceInfo_DeviceResourceRanges_Pool struct {
- Type DeviceInfo_DeviceResourceRanges_Pool_PoolType `protobuf:"varint,1,opt,name=type,proto3,enum=openolt.DeviceInfo_DeviceResourceRanges_Pool_PoolType" json:"type,omitempty"`
- Sharing DeviceInfo_DeviceResourceRanges_Pool_SharingType `protobuf:"varint,2,opt,name=sharing,proto3,enum=openolt.DeviceInfo_DeviceResourceRanges_Pool_SharingType" json:"sharing,omitempty"`
- Start uint32 `protobuf:"fixed32,3,opt,name=start,proto3" json:"start,omitempty"`
- End uint32 `protobuf:"fixed32,4,opt,name=end,proto3" json:"end,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *DeviceInfo_DeviceResourceRanges_Pool) Reset() { *m = DeviceInfo_DeviceResourceRanges_Pool{} }
-func (m *DeviceInfo_DeviceResourceRanges_Pool) String() string { return proto.CompactTextString(m) }
-func (*DeviceInfo_DeviceResourceRanges_Pool) ProtoMessage() {}
-func (*DeviceInfo_DeviceResourceRanges_Pool) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{15, 0, 0}
-}
-
-func (m *DeviceInfo_DeviceResourceRanges_Pool) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_DeviceInfo_DeviceResourceRanges_Pool.Unmarshal(m, b)
-}
-func (m *DeviceInfo_DeviceResourceRanges_Pool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_DeviceInfo_DeviceResourceRanges_Pool.Marshal(b, m, deterministic)
-}
-func (m *DeviceInfo_DeviceResourceRanges_Pool) XXX_Merge(src proto.Message) {
- xxx_messageInfo_DeviceInfo_DeviceResourceRanges_Pool.Merge(m, src)
-}
-func (m *DeviceInfo_DeviceResourceRanges_Pool) XXX_Size() int {
- return xxx_messageInfo_DeviceInfo_DeviceResourceRanges_Pool.Size(m)
-}
-func (m *DeviceInfo_DeviceResourceRanges_Pool) XXX_DiscardUnknown() {
- xxx_messageInfo_DeviceInfo_DeviceResourceRanges_Pool.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_DeviceInfo_DeviceResourceRanges_Pool proto.InternalMessageInfo
-
-func (m *DeviceInfo_DeviceResourceRanges_Pool) GetType() DeviceInfo_DeviceResourceRanges_Pool_PoolType {
- if m != nil {
- return m.Type
- }
- return DeviceInfo_DeviceResourceRanges_Pool_ONU_ID
-}
-
-func (m *DeviceInfo_DeviceResourceRanges_Pool) GetSharing() DeviceInfo_DeviceResourceRanges_Pool_SharingType {
- if m != nil {
- return m.Sharing
- }
- return DeviceInfo_DeviceResourceRanges_Pool_DEDICATED_PER_INTF
-}
-
-func (m *DeviceInfo_DeviceResourceRanges_Pool) GetStart() uint32 {
- if m != nil {
- return m.Start
- }
- return 0
-}
-
-func (m *DeviceInfo_DeviceResourceRanges_Pool) GetEnd() uint32 {
- if m != nil {
- return m.End
- }
- return 0
-}
-
-type Classifier struct {
- OTpid uint32 `protobuf:"fixed32,1,opt,name=o_tpid,json=oTpid,proto3" json:"o_tpid,omitempty"`
- OVid uint32 `protobuf:"fixed32,2,opt,name=o_vid,json=oVid,proto3" json:"o_vid,omitempty"`
- ITpid uint32 `protobuf:"fixed32,3,opt,name=i_tpid,json=iTpid,proto3" json:"i_tpid,omitempty"`
- IVid uint32 `protobuf:"fixed32,4,opt,name=i_vid,json=iVid,proto3" json:"i_vid,omitempty"`
- OPbits uint32 `protobuf:"fixed32,5,opt,name=o_pbits,json=oPbits,proto3" json:"o_pbits,omitempty"`
- IPbits uint32 `protobuf:"fixed32,6,opt,name=i_pbits,json=iPbits,proto3" json:"i_pbits,omitempty"`
- EthType uint32 `protobuf:"fixed32,7,opt,name=eth_type,json=ethType,proto3" json:"eth_type,omitempty"`
- DstMac []byte `protobuf:"bytes,8,opt,name=dst_mac,json=dstMac,proto3" json:"dst_mac,omitempty"`
- SrcMac []byte `protobuf:"bytes,9,opt,name=src_mac,json=srcMac,proto3" json:"src_mac,omitempty"`
- IpProto uint32 `protobuf:"fixed32,10,opt,name=ip_proto,json=ipProto,proto3" json:"ip_proto,omitempty"`
- DstIp uint32 `protobuf:"fixed32,11,opt,name=dst_ip,json=dstIp,proto3" json:"dst_ip,omitempty"`
- SrcIp uint32 `protobuf:"fixed32,12,opt,name=src_ip,json=srcIp,proto3" json:"src_ip,omitempty"`
- SrcPort uint32 `protobuf:"fixed32,13,opt,name=src_port,json=srcPort,proto3" json:"src_port,omitempty"`
- DstPort uint32 `protobuf:"fixed32,14,opt,name=dst_port,json=dstPort,proto3" json:"dst_port,omitempty"`
- PktTagType string `protobuf:"bytes,15,opt,name=pkt_tag_type,json=pktTagType,proto3" json:"pkt_tag_type,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Classifier) Reset() { *m = Classifier{} }
-func (m *Classifier) String() string { return proto.CompactTextString(m) }
-func (*Classifier) ProtoMessage() {}
-func (*Classifier) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{16}
-}
-
-func (m *Classifier) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Classifier.Unmarshal(m, b)
-}
-func (m *Classifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Classifier.Marshal(b, m, deterministic)
-}
-func (m *Classifier) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Classifier.Merge(m, src)
-}
-func (m *Classifier) XXX_Size() int {
- return xxx_messageInfo_Classifier.Size(m)
-}
-func (m *Classifier) XXX_DiscardUnknown() {
- xxx_messageInfo_Classifier.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Classifier proto.InternalMessageInfo
-
-func (m *Classifier) GetOTpid() uint32 {
- if m != nil {
- return m.OTpid
- }
- return 0
-}
-
-func (m *Classifier) GetOVid() uint32 {
- if m != nil {
- return m.OVid
- }
- return 0
-}
-
-func (m *Classifier) GetITpid() uint32 {
- if m != nil {
- return m.ITpid
- }
- return 0
-}
-
-func (m *Classifier) GetIVid() uint32 {
- if m != nil {
- return m.IVid
- }
- return 0
-}
-
-func (m *Classifier) GetOPbits() uint32 {
- if m != nil {
- return m.OPbits
- }
- return 0
-}
-
-func (m *Classifier) GetIPbits() uint32 {
- if m != nil {
- return m.IPbits
- }
- return 0
-}
-
-func (m *Classifier) GetEthType() uint32 {
- if m != nil {
- return m.EthType
- }
- return 0
-}
-
-func (m *Classifier) GetDstMac() []byte {
- if m != nil {
- return m.DstMac
- }
- return nil
-}
-
-func (m *Classifier) GetSrcMac() []byte {
- if m != nil {
- return m.SrcMac
- }
- return nil
-}
-
-func (m *Classifier) GetIpProto() uint32 {
- if m != nil {
- return m.IpProto
- }
- return 0
-}
-
-func (m *Classifier) GetDstIp() uint32 {
- if m != nil {
- return m.DstIp
- }
- return 0
-}
-
-func (m *Classifier) GetSrcIp() uint32 {
- if m != nil {
- return m.SrcIp
- }
- return 0
-}
-
-func (m *Classifier) GetSrcPort() uint32 {
- if m != nil {
- return m.SrcPort
- }
- return 0
-}
-
-func (m *Classifier) GetDstPort() uint32 {
- if m != nil {
- return m.DstPort
- }
- return 0
-}
-
-func (m *Classifier) GetPktTagType() string {
- if m != nil {
- return m.PktTagType
- }
- return ""
-}
-
-type ActionCmd struct {
- AddOuterTag bool `protobuf:"varint,1,opt,name=add_outer_tag,json=addOuterTag,proto3" json:"add_outer_tag,omitempty"`
- RemoveOuterTag bool `protobuf:"varint,2,opt,name=remove_outer_tag,json=removeOuterTag,proto3" json:"remove_outer_tag,omitempty"`
- TrapToHost bool `protobuf:"varint,3,opt,name=trap_to_host,json=trapToHost,proto3" json:"trap_to_host,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *ActionCmd) Reset() { *m = ActionCmd{} }
-func (m *ActionCmd) String() string { return proto.CompactTextString(m) }
-func (*ActionCmd) ProtoMessage() {}
-func (*ActionCmd) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{17}
-}
-
-func (m *ActionCmd) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_ActionCmd.Unmarshal(m, b)
-}
-func (m *ActionCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_ActionCmd.Marshal(b, m, deterministic)
-}
-func (m *ActionCmd) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ActionCmd.Merge(m, src)
-}
-func (m *ActionCmd) XXX_Size() int {
- return xxx_messageInfo_ActionCmd.Size(m)
-}
-func (m *ActionCmd) XXX_DiscardUnknown() {
- xxx_messageInfo_ActionCmd.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_ActionCmd proto.InternalMessageInfo
-
-func (m *ActionCmd) GetAddOuterTag() bool {
- if m != nil {
- return m.AddOuterTag
- }
- return false
-}
-
-func (m *ActionCmd) GetRemoveOuterTag() bool {
- if m != nil {
- return m.RemoveOuterTag
- }
- return false
-}
-
-func (m *ActionCmd) GetTrapToHost() bool {
- if m != nil {
- return m.TrapToHost
- }
- return false
-}
-
-type Action struct {
- Cmd *ActionCmd `protobuf:"bytes,1,opt,name=cmd,proto3" json:"cmd,omitempty"`
- OVid uint32 `protobuf:"fixed32,2,opt,name=o_vid,json=oVid,proto3" json:"o_vid,omitempty"`
- OPbits uint32 `protobuf:"fixed32,3,opt,name=o_pbits,json=oPbits,proto3" json:"o_pbits,omitempty"`
- OTpid uint32 `protobuf:"fixed32,4,opt,name=o_tpid,json=oTpid,proto3" json:"o_tpid,omitempty"`
- IVid uint32 `protobuf:"fixed32,5,opt,name=i_vid,json=iVid,proto3" json:"i_vid,omitempty"`
- IPbits uint32 `protobuf:"fixed32,6,opt,name=i_pbits,json=iPbits,proto3" json:"i_pbits,omitempty"`
- ITpid uint32 `protobuf:"fixed32,7,opt,name=i_tpid,json=iTpid,proto3" json:"i_tpid,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Action) Reset() { *m = Action{} }
-func (m *Action) String() string { return proto.CompactTextString(m) }
-func (*Action) ProtoMessage() {}
-func (*Action) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{18}
-}
-
-func (m *Action) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Action.Unmarshal(m, b)
-}
-func (m *Action) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Action.Marshal(b, m, deterministic)
-}
-func (m *Action) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Action.Merge(m, src)
-}
-func (m *Action) XXX_Size() int {
- return xxx_messageInfo_Action.Size(m)
-}
-func (m *Action) XXX_DiscardUnknown() {
- xxx_messageInfo_Action.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Action proto.InternalMessageInfo
-
-func (m *Action) GetCmd() *ActionCmd {
- if m != nil {
- return m.Cmd
- }
- return nil
-}
-
-func (m *Action) GetOVid() uint32 {
- if m != nil {
- return m.OVid
- }
- return 0
-}
-
-func (m *Action) GetOPbits() uint32 {
- if m != nil {
- return m.OPbits
- }
- return 0
-}
-
-func (m *Action) GetOTpid() uint32 {
- if m != nil {
- return m.OTpid
- }
- return 0
-}
-
-func (m *Action) GetIVid() uint32 {
- if m != nil {
- return m.IVid
- }
- return 0
-}
-
-func (m *Action) GetIPbits() uint32 {
- if m != nil {
- return m.IPbits
- }
- return 0
-}
-
-func (m *Action) GetITpid() uint32 {
- if m != nil {
- return m.ITpid
- }
- return 0
-}
-
-type Flow struct {
- AccessIntfId int32 `protobuf:"fixed32,1,opt,name=access_intf_id,json=accessIntfId,proto3" json:"access_intf_id,omitempty"`
- OnuId int32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- UniId int32 `protobuf:"fixed32,11,opt,name=uni_id,json=uniId,proto3" json:"uni_id,omitempty"`
- FlowId uint32 `protobuf:"fixed32,3,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
- FlowType string `protobuf:"bytes,4,opt,name=flow_type,json=flowType,proto3" json:"flow_type,omitempty"`
- AllocId int32 `protobuf:"fixed32,10,opt,name=alloc_id,json=allocId,proto3" json:"alloc_id,omitempty"`
- NetworkIntfId int32 `protobuf:"fixed32,5,opt,name=network_intf_id,json=networkIntfId,proto3" json:"network_intf_id,omitempty"`
- GemportId int32 `protobuf:"fixed32,6,opt,name=gemport_id,json=gemportId,proto3" json:"gemport_id,omitempty"`
- Classifier *Classifier `protobuf:"bytes,7,opt,name=classifier,proto3" json:"classifier,omitempty"`
- Action *Action `protobuf:"bytes,8,opt,name=action,proto3" json:"action,omitempty"`
- Priority int32 `protobuf:"fixed32,9,opt,name=priority,proto3" json:"priority,omitempty"`
- Cookie uint64 `protobuf:"fixed64,12,opt,name=cookie,proto3" json:"cookie,omitempty"`
- PortNo uint32 `protobuf:"fixed32,13,opt,name=port_no,json=portNo,proto3" json:"port_no,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Flow) Reset() { *m = Flow{} }
-func (m *Flow) String() string { return proto.CompactTextString(m) }
-func (*Flow) ProtoMessage() {}
-func (*Flow) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{19}
-}
-
-func (m *Flow) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Flow.Unmarshal(m, b)
-}
-func (m *Flow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Flow.Marshal(b, m, deterministic)
-}
-func (m *Flow) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Flow.Merge(m, src)
-}
-func (m *Flow) XXX_Size() int {
- return xxx_messageInfo_Flow.Size(m)
-}
-func (m *Flow) XXX_DiscardUnknown() {
- xxx_messageInfo_Flow.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Flow proto.InternalMessageInfo
-
-func (m *Flow) GetAccessIntfId() int32 {
- if m != nil {
- return m.AccessIntfId
- }
- return 0
-}
-
-func (m *Flow) GetOnuId() int32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *Flow) GetUniId() int32 {
- if m != nil {
- return m.UniId
- }
- return 0
-}
-
-func (m *Flow) GetFlowId() uint32 {
- if m != nil {
- return m.FlowId
- }
- return 0
-}
-
-func (m *Flow) GetFlowType() string {
- if m != nil {
- return m.FlowType
- }
- return ""
-}
-
-func (m *Flow) GetAllocId() int32 {
- if m != nil {
- return m.AllocId
- }
- return 0
-}
-
-func (m *Flow) GetNetworkIntfId() int32 {
- if m != nil {
- return m.NetworkIntfId
- }
- return 0
-}
-
-func (m *Flow) GetGemportId() int32 {
- if m != nil {
- return m.GemportId
- }
- return 0
-}
-
-func (m *Flow) GetClassifier() *Classifier {
- if m != nil {
- return m.Classifier
- }
- return nil
-}
-
-func (m *Flow) GetAction() *Action {
- if m != nil {
- return m.Action
- }
- return nil
-}
-
-func (m *Flow) GetPriority() int32 {
- if m != nil {
- return m.Priority
- }
- return 0
-}
-
-func (m *Flow) GetCookie() uint64 {
- if m != nil {
- return m.Cookie
- }
- return 0
-}
-
-func (m *Flow) GetPortNo() uint32 {
- if m != nil {
- return m.PortNo
- }
- return 0
-}
-
-type SerialNumber struct {
- VendorId []byte `protobuf:"bytes,1,opt,name=vendor_id,json=vendorId,proto3" json:"vendor_id,omitempty"`
- VendorSpecific []byte `protobuf:"bytes,2,opt,name=vendor_specific,json=vendorSpecific,proto3" json:"vendor_specific,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *SerialNumber) Reset() { *m = SerialNumber{} }
-func (m *SerialNumber) String() string { return proto.CompactTextString(m) }
-func (*SerialNumber) ProtoMessage() {}
-func (*SerialNumber) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{20}
-}
-
-func (m *SerialNumber) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_SerialNumber.Unmarshal(m, b)
-}
-func (m *SerialNumber) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_SerialNumber.Marshal(b, m, deterministic)
-}
-func (m *SerialNumber) XXX_Merge(src proto.Message) {
- xxx_messageInfo_SerialNumber.Merge(m, src)
-}
-func (m *SerialNumber) XXX_Size() int {
- return xxx_messageInfo_SerialNumber.Size(m)
-}
-func (m *SerialNumber) XXX_DiscardUnknown() {
- xxx_messageInfo_SerialNumber.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_SerialNumber proto.InternalMessageInfo
-
-func (m *SerialNumber) GetVendorId() []byte {
- if m != nil {
- return m.VendorId
- }
- return nil
-}
-
-func (m *SerialNumber) GetVendorSpecific() []byte {
- if m != nil {
- return m.VendorSpecific
- }
- return nil
-}
-
-type PortStatistics struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- RxBytes uint64 `protobuf:"fixed64,2,opt,name=rx_bytes,json=rxBytes,proto3" json:"rx_bytes,omitempty"`
- RxPackets uint64 `protobuf:"fixed64,3,opt,name=rx_packets,json=rxPackets,proto3" json:"rx_packets,omitempty"`
- RxUcastPackets uint64 `protobuf:"fixed64,4,opt,name=rx_ucast_packets,json=rxUcastPackets,proto3" json:"rx_ucast_packets,omitempty"`
- RxMcastPackets uint64 `protobuf:"fixed64,5,opt,name=rx_mcast_packets,json=rxMcastPackets,proto3" json:"rx_mcast_packets,omitempty"`
- RxBcastPackets uint64 `protobuf:"fixed64,6,opt,name=rx_bcast_packets,json=rxBcastPackets,proto3" json:"rx_bcast_packets,omitempty"`
- RxErrorPackets uint64 `protobuf:"fixed64,7,opt,name=rx_error_packets,json=rxErrorPackets,proto3" json:"rx_error_packets,omitempty"`
- TxBytes uint64 `protobuf:"fixed64,8,opt,name=tx_bytes,json=txBytes,proto3" json:"tx_bytes,omitempty"`
- TxPackets uint64 `protobuf:"fixed64,9,opt,name=tx_packets,json=txPackets,proto3" json:"tx_packets,omitempty"`
- TxUcastPackets uint64 `protobuf:"fixed64,10,opt,name=tx_ucast_packets,json=txUcastPackets,proto3" json:"tx_ucast_packets,omitempty"`
- TxMcastPackets uint64 `protobuf:"fixed64,11,opt,name=tx_mcast_packets,json=txMcastPackets,proto3" json:"tx_mcast_packets,omitempty"`
- TxBcastPackets uint64 `protobuf:"fixed64,12,opt,name=tx_bcast_packets,json=txBcastPackets,proto3" json:"tx_bcast_packets,omitempty"`
- TxErrorPackets uint64 `protobuf:"fixed64,13,opt,name=tx_error_packets,json=txErrorPackets,proto3" json:"tx_error_packets,omitempty"`
- RxCrcErrors uint64 `protobuf:"fixed64,14,opt,name=rx_crc_errors,json=rxCrcErrors,proto3" json:"rx_crc_errors,omitempty"`
- BipErrors uint64 `protobuf:"fixed64,15,opt,name=bip_errors,json=bipErrors,proto3" json:"bip_errors,omitempty"`
- Timestamp uint32 `protobuf:"fixed32,16,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *PortStatistics) Reset() { *m = PortStatistics{} }
-func (m *PortStatistics) String() string { return proto.CompactTextString(m) }
-func (*PortStatistics) ProtoMessage() {}
-func (*PortStatistics) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{21}
-}
-
-func (m *PortStatistics) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_PortStatistics.Unmarshal(m, b)
-}
-func (m *PortStatistics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_PortStatistics.Marshal(b, m, deterministic)
-}
-func (m *PortStatistics) XXX_Merge(src proto.Message) {
- xxx_messageInfo_PortStatistics.Merge(m, src)
-}
-func (m *PortStatistics) XXX_Size() int {
- return xxx_messageInfo_PortStatistics.Size(m)
-}
-func (m *PortStatistics) XXX_DiscardUnknown() {
- xxx_messageInfo_PortStatistics.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_PortStatistics proto.InternalMessageInfo
-
-func (m *PortStatistics) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *PortStatistics) GetRxBytes() uint64 {
- if m != nil {
- return m.RxBytes
- }
- return 0
-}
-
-func (m *PortStatistics) GetRxPackets() uint64 {
- if m != nil {
- return m.RxPackets
- }
- return 0
-}
-
-func (m *PortStatistics) GetRxUcastPackets() uint64 {
- if m != nil {
- return m.RxUcastPackets
- }
- return 0
-}
-
-func (m *PortStatistics) GetRxMcastPackets() uint64 {
- if m != nil {
- return m.RxMcastPackets
- }
- return 0
-}
-
-func (m *PortStatistics) GetRxBcastPackets() uint64 {
- if m != nil {
- return m.RxBcastPackets
- }
- return 0
-}
-
-func (m *PortStatistics) GetRxErrorPackets() uint64 {
- if m != nil {
- return m.RxErrorPackets
- }
- return 0
-}
-
-func (m *PortStatistics) GetTxBytes() uint64 {
- if m != nil {
- return m.TxBytes
- }
- return 0
-}
-
-func (m *PortStatistics) GetTxPackets() uint64 {
- if m != nil {
- return m.TxPackets
- }
- return 0
-}
-
-func (m *PortStatistics) GetTxUcastPackets() uint64 {
- if m != nil {
- return m.TxUcastPackets
- }
- return 0
-}
-
-func (m *PortStatistics) GetTxMcastPackets() uint64 {
- if m != nil {
- return m.TxMcastPackets
- }
- return 0
-}
-
-func (m *PortStatistics) GetTxBcastPackets() uint64 {
- if m != nil {
- return m.TxBcastPackets
- }
- return 0
-}
-
-func (m *PortStatistics) GetTxErrorPackets() uint64 {
- if m != nil {
- return m.TxErrorPackets
- }
- return 0
-}
-
-func (m *PortStatistics) GetRxCrcErrors() uint64 {
- if m != nil {
- return m.RxCrcErrors
- }
- return 0
-}
-
-func (m *PortStatistics) GetBipErrors() uint64 {
- if m != nil {
- return m.BipErrors
- }
- return 0
-}
-
-func (m *PortStatistics) GetTimestamp() uint32 {
- if m != nil {
- return m.Timestamp
- }
- return 0
-}
-
-type FlowStatistics struct {
- FlowId uint32 `protobuf:"fixed32,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
- RxBytes uint64 `protobuf:"fixed64,2,opt,name=rx_bytes,json=rxBytes,proto3" json:"rx_bytes,omitempty"`
- RxPackets uint64 `protobuf:"fixed64,3,opt,name=rx_packets,json=rxPackets,proto3" json:"rx_packets,omitempty"`
- TxBytes uint64 `protobuf:"fixed64,8,opt,name=tx_bytes,json=txBytes,proto3" json:"tx_bytes,omitempty"`
- TxPackets uint64 `protobuf:"fixed64,9,opt,name=tx_packets,json=txPackets,proto3" json:"tx_packets,omitempty"`
- Timestamp uint32 `protobuf:"fixed32,16,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *FlowStatistics) Reset() { *m = FlowStatistics{} }
-func (m *FlowStatistics) String() string { return proto.CompactTextString(m) }
-func (*FlowStatistics) ProtoMessage() {}
-func (*FlowStatistics) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{22}
-}
-
-func (m *FlowStatistics) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_FlowStatistics.Unmarshal(m, b)
-}
-func (m *FlowStatistics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_FlowStatistics.Marshal(b, m, deterministic)
-}
-func (m *FlowStatistics) XXX_Merge(src proto.Message) {
- xxx_messageInfo_FlowStatistics.Merge(m, src)
-}
-func (m *FlowStatistics) XXX_Size() int {
- return xxx_messageInfo_FlowStatistics.Size(m)
-}
-func (m *FlowStatistics) XXX_DiscardUnknown() {
- xxx_messageInfo_FlowStatistics.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_FlowStatistics proto.InternalMessageInfo
-
-func (m *FlowStatistics) GetFlowId() uint32 {
- if m != nil {
- return m.FlowId
- }
- return 0
-}
-
-func (m *FlowStatistics) GetRxBytes() uint64 {
- if m != nil {
- return m.RxBytes
- }
- return 0
-}
-
-func (m *FlowStatistics) GetRxPackets() uint64 {
- if m != nil {
- return m.RxPackets
- }
- return 0
-}
-
-func (m *FlowStatistics) GetTxBytes() uint64 {
- if m != nil {
- return m.TxBytes
- }
- return 0
-}
-
-func (m *FlowStatistics) GetTxPackets() uint64 {
- if m != nil {
- return m.TxPackets
- }
- return 0
-}
-
-func (m *FlowStatistics) GetTimestamp() uint32 {
- if m != nil {
- return m.Timestamp
- }
- return 0
-}
-
-type LosIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *LosIndication) Reset() { *m = LosIndication{} }
-func (m *LosIndication) String() string { return proto.CompactTextString(m) }
-func (*LosIndication) ProtoMessage() {}
-func (*LosIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{23}
-}
-
-func (m *LosIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_LosIndication.Unmarshal(m, b)
-}
-func (m *LosIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_LosIndication.Marshal(b, m, deterministic)
-}
-func (m *LosIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_LosIndication.Merge(m, src)
-}
-func (m *LosIndication) XXX_Size() int {
- return xxx_messageInfo_LosIndication.Size(m)
-}
-func (m *LosIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_LosIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_LosIndication proto.InternalMessageInfo
-
-func (m *LosIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *LosIndication) GetStatus() string {
- if m != nil {
- return m.Status
- }
- return ""
-}
-
-type DyingGaspIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *DyingGaspIndication) Reset() { *m = DyingGaspIndication{} }
-func (m *DyingGaspIndication) String() string { return proto.CompactTextString(m) }
-func (*DyingGaspIndication) ProtoMessage() {}
-func (*DyingGaspIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{24}
-}
-
-func (m *DyingGaspIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_DyingGaspIndication.Unmarshal(m, b)
-}
-func (m *DyingGaspIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_DyingGaspIndication.Marshal(b, m, deterministic)
-}
-func (m *DyingGaspIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_DyingGaspIndication.Merge(m, src)
-}
-func (m *DyingGaspIndication) XXX_Size() int {
- return xxx_messageInfo_DyingGaspIndication.Size(m)
-}
-func (m *DyingGaspIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_DyingGaspIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_DyingGaspIndication proto.InternalMessageInfo
-
-func (m *DyingGaspIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *DyingGaspIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *DyingGaspIndication) GetStatus() string {
- if m != nil {
- return m.Status
- }
- return ""
-}
-
-type OnuAlarmIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- LosStatus string `protobuf:"bytes,3,opt,name=los_status,json=losStatus,proto3" json:"los_status,omitempty"`
- LobStatus string `protobuf:"bytes,4,opt,name=lob_status,json=lobStatus,proto3" json:"lob_status,omitempty"`
- LopcMissStatus string `protobuf:"bytes,5,opt,name=lopc_miss_status,json=lopcMissStatus,proto3" json:"lopc_miss_status,omitempty"`
- LopcMicErrorStatus string `protobuf:"bytes,6,opt,name=lopc_mic_error_status,json=lopcMicErrorStatus,proto3" json:"lopc_mic_error_status,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuAlarmIndication) Reset() { *m = OnuAlarmIndication{} }
-func (m *OnuAlarmIndication) String() string { return proto.CompactTextString(m) }
-func (*OnuAlarmIndication) ProtoMessage() {}
-func (*OnuAlarmIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{25}
-}
-
-func (m *OnuAlarmIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuAlarmIndication.Unmarshal(m, b)
-}
-func (m *OnuAlarmIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuAlarmIndication.Marshal(b, m, deterministic)
-}
-func (m *OnuAlarmIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuAlarmIndication.Merge(m, src)
-}
-func (m *OnuAlarmIndication) XXX_Size() int {
- return xxx_messageInfo_OnuAlarmIndication.Size(m)
-}
-func (m *OnuAlarmIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuAlarmIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuAlarmIndication proto.InternalMessageInfo
-
-func (m *OnuAlarmIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuAlarmIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OnuAlarmIndication) GetLosStatus() string {
- if m != nil {
- return m.LosStatus
- }
- return ""
-}
-
-func (m *OnuAlarmIndication) GetLobStatus() string {
- if m != nil {
- return m.LobStatus
- }
- return ""
-}
-
-func (m *OnuAlarmIndication) GetLopcMissStatus() string {
- if m != nil {
- return m.LopcMissStatus
- }
- return ""
-}
-
-func (m *OnuAlarmIndication) GetLopcMicErrorStatus() string {
- if m != nil {
- return m.LopcMicErrorStatus
- }
- return ""
-}
-
-type OnuStartupFailureIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuStartupFailureIndication) Reset() { *m = OnuStartupFailureIndication{} }
-func (m *OnuStartupFailureIndication) String() string { return proto.CompactTextString(m) }
-func (*OnuStartupFailureIndication) ProtoMessage() {}
-func (*OnuStartupFailureIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{26}
-}
-
-func (m *OnuStartupFailureIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuStartupFailureIndication.Unmarshal(m, b)
-}
-func (m *OnuStartupFailureIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuStartupFailureIndication.Marshal(b, m, deterministic)
-}
-func (m *OnuStartupFailureIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuStartupFailureIndication.Merge(m, src)
-}
-func (m *OnuStartupFailureIndication) XXX_Size() int {
- return xxx_messageInfo_OnuStartupFailureIndication.Size(m)
-}
-func (m *OnuStartupFailureIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuStartupFailureIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuStartupFailureIndication proto.InternalMessageInfo
-
-func (m *OnuStartupFailureIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuStartupFailureIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OnuStartupFailureIndication) GetStatus() string {
- if m != nil {
- return m.Status
- }
- return ""
-}
-
-type OnuSignalDegradeIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
- InverseBitErrorRate uint32 `protobuf:"fixed32,4,opt,name=inverse_bit_error_rate,json=inverseBitErrorRate,proto3" json:"inverse_bit_error_rate,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuSignalDegradeIndication) Reset() { *m = OnuSignalDegradeIndication{} }
-func (m *OnuSignalDegradeIndication) String() string { return proto.CompactTextString(m) }
-func (*OnuSignalDegradeIndication) ProtoMessage() {}
-func (*OnuSignalDegradeIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{27}
-}
-
-func (m *OnuSignalDegradeIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuSignalDegradeIndication.Unmarshal(m, b)
-}
-func (m *OnuSignalDegradeIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuSignalDegradeIndication.Marshal(b, m, deterministic)
-}
-func (m *OnuSignalDegradeIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuSignalDegradeIndication.Merge(m, src)
-}
-func (m *OnuSignalDegradeIndication) XXX_Size() int {
- return xxx_messageInfo_OnuSignalDegradeIndication.Size(m)
-}
-func (m *OnuSignalDegradeIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuSignalDegradeIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuSignalDegradeIndication proto.InternalMessageInfo
-
-func (m *OnuSignalDegradeIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuSignalDegradeIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OnuSignalDegradeIndication) GetStatus() string {
- if m != nil {
- return m.Status
- }
- return ""
-}
-
-func (m *OnuSignalDegradeIndication) GetInverseBitErrorRate() uint32 {
- if m != nil {
- return m.InverseBitErrorRate
- }
- return 0
-}
-
-type OnuDriftOfWindowIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
- Drift uint32 `protobuf:"fixed32,4,opt,name=drift,proto3" json:"drift,omitempty"`
- NewEqd uint32 `protobuf:"fixed32,5,opt,name=new_eqd,json=newEqd,proto3" json:"new_eqd,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuDriftOfWindowIndication) Reset() { *m = OnuDriftOfWindowIndication{} }
-func (m *OnuDriftOfWindowIndication) String() string { return proto.CompactTextString(m) }
-func (*OnuDriftOfWindowIndication) ProtoMessage() {}
-func (*OnuDriftOfWindowIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{28}
-}
-
-func (m *OnuDriftOfWindowIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuDriftOfWindowIndication.Unmarshal(m, b)
-}
-func (m *OnuDriftOfWindowIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuDriftOfWindowIndication.Marshal(b, m, deterministic)
-}
-func (m *OnuDriftOfWindowIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuDriftOfWindowIndication.Merge(m, src)
-}
-func (m *OnuDriftOfWindowIndication) XXX_Size() int {
- return xxx_messageInfo_OnuDriftOfWindowIndication.Size(m)
-}
-func (m *OnuDriftOfWindowIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuDriftOfWindowIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuDriftOfWindowIndication proto.InternalMessageInfo
-
-func (m *OnuDriftOfWindowIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuDriftOfWindowIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OnuDriftOfWindowIndication) GetStatus() string {
- if m != nil {
- return m.Status
- }
- return ""
-}
-
-func (m *OnuDriftOfWindowIndication) GetDrift() uint32 {
- if m != nil {
- return m.Drift
- }
- return 0
-}
-
-func (m *OnuDriftOfWindowIndication) GetNewEqd() uint32 {
- if m != nil {
- return m.NewEqd
- }
- return 0
-}
-
-type OnuLossOfOmciChannelIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuLossOfOmciChannelIndication) Reset() { *m = OnuLossOfOmciChannelIndication{} }
-func (m *OnuLossOfOmciChannelIndication) String() string { return proto.CompactTextString(m) }
-func (*OnuLossOfOmciChannelIndication) ProtoMessage() {}
-func (*OnuLossOfOmciChannelIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{29}
-}
-
-func (m *OnuLossOfOmciChannelIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuLossOfOmciChannelIndication.Unmarshal(m, b)
-}
-func (m *OnuLossOfOmciChannelIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuLossOfOmciChannelIndication.Marshal(b, m, deterministic)
-}
-func (m *OnuLossOfOmciChannelIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuLossOfOmciChannelIndication.Merge(m, src)
-}
-func (m *OnuLossOfOmciChannelIndication) XXX_Size() int {
- return xxx_messageInfo_OnuLossOfOmciChannelIndication.Size(m)
-}
-func (m *OnuLossOfOmciChannelIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuLossOfOmciChannelIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuLossOfOmciChannelIndication proto.InternalMessageInfo
-
-func (m *OnuLossOfOmciChannelIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuLossOfOmciChannelIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OnuLossOfOmciChannelIndication) GetStatus() string {
- if m != nil {
- return m.Status
- }
- return ""
-}
-
-type OnuSignalsFailureIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
- InverseBitErrorRate uint32 `protobuf:"fixed32,4,opt,name=inverse_bit_error_rate,json=inverseBitErrorRate,proto3" json:"inverse_bit_error_rate,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuSignalsFailureIndication) Reset() { *m = OnuSignalsFailureIndication{} }
-func (m *OnuSignalsFailureIndication) String() string { return proto.CompactTextString(m) }
-func (*OnuSignalsFailureIndication) ProtoMessage() {}
-func (*OnuSignalsFailureIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{30}
-}
-
-func (m *OnuSignalsFailureIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuSignalsFailureIndication.Unmarshal(m, b)
-}
-func (m *OnuSignalsFailureIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuSignalsFailureIndication.Marshal(b, m, deterministic)
-}
-func (m *OnuSignalsFailureIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuSignalsFailureIndication.Merge(m, src)
-}
-func (m *OnuSignalsFailureIndication) XXX_Size() int {
- return xxx_messageInfo_OnuSignalsFailureIndication.Size(m)
-}
-func (m *OnuSignalsFailureIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuSignalsFailureIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuSignalsFailureIndication proto.InternalMessageInfo
-
-func (m *OnuSignalsFailureIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuSignalsFailureIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OnuSignalsFailureIndication) GetStatus() string {
- if m != nil {
- return m.Status
- }
- return ""
-}
-
-func (m *OnuSignalsFailureIndication) GetInverseBitErrorRate() uint32 {
- if m != nil {
- return m.InverseBitErrorRate
- }
- return 0
-}
-
-type OnuTransmissionInterferenceWarning struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
- Drift uint32 `protobuf:"fixed32,4,opt,name=drift,proto3" json:"drift,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuTransmissionInterferenceWarning) Reset() { *m = OnuTransmissionInterferenceWarning{} }
-func (m *OnuTransmissionInterferenceWarning) String() string { return proto.CompactTextString(m) }
-func (*OnuTransmissionInterferenceWarning) ProtoMessage() {}
-func (*OnuTransmissionInterferenceWarning) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{31}
-}
-
-func (m *OnuTransmissionInterferenceWarning) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuTransmissionInterferenceWarning.Unmarshal(m, b)
-}
-func (m *OnuTransmissionInterferenceWarning) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuTransmissionInterferenceWarning.Marshal(b, m, deterministic)
-}
-func (m *OnuTransmissionInterferenceWarning) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuTransmissionInterferenceWarning.Merge(m, src)
-}
-func (m *OnuTransmissionInterferenceWarning) XXX_Size() int {
- return xxx_messageInfo_OnuTransmissionInterferenceWarning.Size(m)
-}
-func (m *OnuTransmissionInterferenceWarning) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuTransmissionInterferenceWarning.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuTransmissionInterferenceWarning proto.InternalMessageInfo
-
-func (m *OnuTransmissionInterferenceWarning) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuTransmissionInterferenceWarning) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *OnuTransmissionInterferenceWarning) GetStatus() string {
- if m != nil {
- return m.Status
- }
- return ""
-}
-
-func (m *OnuTransmissionInterferenceWarning) GetDrift() uint32 {
- if m != nil {
- return m.Drift
- }
- return 0
-}
-
-type OnuActivationFailureIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuActivationFailureIndication) Reset() { *m = OnuActivationFailureIndication{} }
-func (m *OnuActivationFailureIndication) String() string { return proto.CompactTextString(m) }
-func (*OnuActivationFailureIndication) ProtoMessage() {}
-func (*OnuActivationFailureIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{32}
-}
-
-func (m *OnuActivationFailureIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuActivationFailureIndication.Unmarshal(m, b)
-}
-func (m *OnuActivationFailureIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuActivationFailureIndication.Marshal(b, m, deterministic)
-}
-func (m *OnuActivationFailureIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuActivationFailureIndication.Merge(m, src)
-}
-func (m *OnuActivationFailureIndication) XXX_Size() int {
- return xxx_messageInfo_OnuActivationFailureIndication.Size(m)
-}
-func (m *OnuActivationFailureIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuActivationFailureIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuActivationFailureIndication proto.InternalMessageInfo
-
-func (m *OnuActivationFailureIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuActivationFailureIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-type OnuProcessingErrorIndication struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *OnuProcessingErrorIndication) Reset() { *m = OnuProcessingErrorIndication{} }
-func (m *OnuProcessingErrorIndication) String() string { return proto.CompactTextString(m) }
-func (*OnuProcessingErrorIndication) ProtoMessage() {}
-func (*OnuProcessingErrorIndication) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{33}
-}
-
-func (m *OnuProcessingErrorIndication) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_OnuProcessingErrorIndication.Unmarshal(m, b)
-}
-func (m *OnuProcessingErrorIndication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_OnuProcessingErrorIndication.Marshal(b, m, deterministic)
-}
-func (m *OnuProcessingErrorIndication) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OnuProcessingErrorIndication.Merge(m, src)
-}
-func (m *OnuProcessingErrorIndication) XXX_Size() int {
- return xxx_messageInfo_OnuProcessingErrorIndication.Size(m)
-}
-func (m *OnuProcessingErrorIndication) XXX_DiscardUnknown() {
- xxx_messageInfo_OnuProcessingErrorIndication.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_OnuProcessingErrorIndication proto.InternalMessageInfo
-
-func (m *OnuProcessingErrorIndication) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *OnuProcessingErrorIndication) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-type Scheduler struct {
- Direction Direction `protobuf:"varint,1,opt,name=direction,proto3,enum=openolt.Direction" json:"direction,omitempty"`
- AdditionalBw AdditionalBW `protobuf:"varint,2,opt,name=additional_bw,json=additionalBw,proto3,enum=openolt.AdditionalBW" json:"additional_bw,omitempty"`
- Priority uint32 `protobuf:"fixed32,3,opt,name=priority,proto3" json:"priority,omitempty"`
- Weight uint32 `protobuf:"fixed32,4,opt,name=weight,proto3" json:"weight,omitempty"`
- SchedPolicy SchedulingPolicy `protobuf:"varint,5,opt,name=sched_policy,json=schedPolicy,proto3,enum=openolt.SchedulingPolicy" json:"sched_policy,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Scheduler) Reset() { *m = Scheduler{} }
-func (m *Scheduler) String() string { return proto.CompactTextString(m) }
-func (*Scheduler) ProtoMessage() {}
-func (*Scheduler) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{34}
-}
-
-func (m *Scheduler) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Scheduler.Unmarshal(m, b)
-}
-func (m *Scheduler) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Scheduler.Marshal(b, m, deterministic)
-}
-func (m *Scheduler) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Scheduler.Merge(m, src)
-}
-func (m *Scheduler) XXX_Size() int {
- return xxx_messageInfo_Scheduler.Size(m)
-}
-func (m *Scheduler) XXX_DiscardUnknown() {
- xxx_messageInfo_Scheduler.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Scheduler proto.InternalMessageInfo
-
-func (m *Scheduler) GetDirection() Direction {
- if m != nil {
- return m.Direction
- }
- return Direction_UPSTREAM
-}
-
-func (m *Scheduler) GetAdditionalBw() AdditionalBW {
- if m != nil {
- return m.AdditionalBw
- }
- return AdditionalBW_AdditionalBW_None
-}
-
-func (m *Scheduler) GetPriority() uint32 {
- if m != nil {
- return m.Priority
- }
- return 0
-}
-
-func (m *Scheduler) GetWeight() uint32 {
- if m != nil {
- return m.Weight
- }
- return 0
-}
-
-func (m *Scheduler) GetSchedPolicy() SchedulingPolicy {
- if m != nil {
- return m.SchedPolicy
- }
- return SchedulingPolicy_WRR
-}
-
-type TrafficShapingInfo struct {
- Cir uint32 `protobuf:"fixed32,1,opt,name=cir,proto3" json:"cir,omitempty"`
- Cbs uint32 `protobuf:"fixed32,2,opt,name=cbs,proto3" json:"cbs,omitempty"`
- Pir uint32 `protobuf:"fixed32,3,opt,name=pir,proto3" json:"pir,omitempty"`
- Pbs uint32 `protobuf:"fixed32,4,opt,name=pbs,proto3" json:"pbs,omitempty"`
- Gir uint32 `protobuf:"fixed32,5,opt,name=gir,proto3" json:"gir,omitempty"`
- AddBwInd InferredAdditionBWIndication `protobuf:"varint,6,opt,name=add_bw_ind,json=addBwInd,proto3,enum=openolt.InferredAdditionBWIndication" json:"add_bw_ind,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *TrafficShapingInfo) Reset() { *m = TrafficShapingInfo{} }
-func (m *TrafficShapingInfo) String() string { return proto.CompactTextString(m) }
-func (*TrafficShapingInfo) ProtoMessage() {}
-func (*TrafficShapingInfo) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{35}
-}
-
-func (m *TrafficShapingInfo) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_TrafficShapingInfo.Unmarshal(m, b)
-}
-func (m *TrafficShapingInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_TrafficShapingInfo.Marshal(b, m, deterministic)
-}
-func (m *TrafficShapingInfo) XXX_Merge(src proto.Message) {
- xxx_messageInfo_TrafficShapingInfo.Merge(m, src)
-}
-func (m *TrafficShapingInfo) XXX_Size() int {
- return xxx_messageInfo_TrafficShapingInfo.Size(m)
-}
-func (m *TrafficShapingInfo) XXX_DiscardUnknown() {
- xxx_messageInfo_TrafficShapingInfo.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_TrafficShapingInfo proto.InternalMessageInfo
-
-func (m *TrafficShapingInfo) GetCir() uint32 {
- if m != nil {
- return m.Cir
- }
- return 0
-}
-
-func (m *TrafficShapingInfo) GetCbs() uint32 {
- if m != nil {
- return m.Cbs
- }
- return 0
-}
-
-func (m *TrafficShapingInfo) GetPir() uint32 {
- if m != nil {
- return m.Pir
- }
- return 0
-}
-
-func (m *TrafficShapingInfo) GetPbs() uint32 {
- if m != nil {
- return m.Pbs
- }
- return 0
-}
-
-func (m *TrafficShapingInfo) GetGir() uint32 {
- if m != nil {
- return m.Gir
- }
- return 0
-}
-
-func (m *TrafficShapingInfo) GetAddBwInd() InferredAdditionBWIndication {
- if m != nil {
- return m.AddBwInd
- }
- return InferredAdditionBWIndication_InferredAdditionBWIndication_None
-}
-
-type Tcont struct {
- Direction Direction `protobuf:"varint,1,opt,name=direction,proto3,enum=openolt.Direction" json:"direction,omitempty"`
- AllocId uint32 `protobuf:"fixed32,2,opt,name=alloc_id,json=allocId,proto3" json:"alloc_id,omitempty"`
- Scheduler *Scheduler `protobuf:"bytes,3,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
- TrafficShapingInfo *TrafficShapingInfo `protobuf:"bytes,4,opt,name=traffic_shaping_info,json=trafficShapingInfo,proto3" json:"traffic_shaping_info,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Tcont) Reset() { *m = Tcont{} }
-func (m *Tcont) String() string { return proto.CompactTextString(m) }
-func (*Tcont) ProtoMessage() {}
-func (*Tcont) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{36}
-}
-
-func (m *Tcont) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Tcont.Unmarshal(m, b)
-}
-func (m *Tcont) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Tcont.Marshal(b, m, deterministic)
-}
-func (m *Tcont) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Tcont.Merge(m, src)
-}
-func (m *Tcont) XXX_Size() int {
- return xxx_messageInfo_Tcont.Size(m)
-}
-func (m *Tcont) XXX_DiscardUnknown() {
- xxx_messageInfo_Tcont.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Tcont proto.InternalMessageInfo
-
-func (m *Tcont) GetDirection() Direction {
- if m != nil {
- return m.Direction
- }
- return Direction_UPSTREAM
-}
-
-func (m *Tcont) GetAllocId() uint32 {
- if m != nil {
- return m.AllocId
- }
- return 0
-}
-
-func (m *Tcont) GetScheduler() *Scheduler {
- if m != nil {
- return m.Scheduler
- }
- return nil
-}
-
-func (m *Tcont) GetTrafficShapingInfo() *TrafficShapingInfo {
- if m != nil {
- return m.TrafficShapingInfo
- }
- return nil
-}
-
-type Tconts struct {
- IntfId uint32 `protobuf:"fixed32,1,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
- OnuId uint32 `protobuf:"fixed32,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
- UniId uint32 `protobuf:"fixed32,4,opt,name=uni_id,json=uniId,proto3" json:"uni_id,omitempty"`
- PortNo uint32 `protobuf:"fixed32,5,opt,name=port_no,json=portNo,proto3" json:"port_no,omitempty"`
- Tconts []*Tcont `protobuf:"bytes,3,rep,name=tconts,proto3" json:"tconts,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Tconts) Reset() { *m = Tconts{} }
-func (m *Tconts) String() string { return proto.CompactTextString(m) }
-func (*Tconts) ProtoMessage() {}
-func (*Tconts) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{37}
-}
-
-func (m *Tconts) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Tconts.Unmarshal(m, b)
-}
-func (m *Tconts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Tconts.Marshal(b, m, deterministic)
-}
-func (m *Tconts) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Tconts.Merge(m, src)
-}
-func (m *Tconts) XXX_Size() int {
- return xxx_messageInfo_Tconts.Size(m)
-}
-func (m *Tconts) XXX_DiscardUnknown() {
- xxx_messageInfo_Tconts.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Tconts proto.InternalMessageInfo
-
-func (m *Tconts) GetIntfId() uint32 {
- if m != nil {
- return m.IntfId
- }
- return 0
-}
-
-func (m *Tconts) GetOnuId() uint32 {
- if m != nil {
- return m.OnuId
- }
- return 0
-}
-
-func (m *Tconts) GetUniId() uint32 {
- if m != nil {
- return m.UniId
- }
- return 0
-}
-
-func (m *Tconts) GetPortNo() uint32 {
- if m != nil {
- return m.PortNo
- }
- return 0
-}
-
-func (m *Tconts) GetTconts() []*Tcont {
- if m != nil {
- return m.Tconts
- }
- return nil
-}
-
-type TailDropDiscardConfig struct {
- QueueSize uint32 `protobuf:"fixed32,1,opt,name=queue_size,json=queueSize,proto3" json:"queue_size,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *TailDropDiscardConfig) Reset() { *m = TailDropDiscardConfig{} }
-func (m *TailDropDiscardConfig) String() string { return proto.CompactTextString(m) }
-func (*TailDropDiscardConfig) ProtoMessage() {}
-func (*TailDropDiscardConfig) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{38}
-}
-
-func (m *TailDropDiscardConfig) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_TailDropDiscardConfig.Unmarshal(m, b)
-}
-func (m *TailDropDiscardConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_TailDropDiscardConfig.Marshal(b, m, deterministic)
-}
-func (m *TailDropDiscardConfig) XXX_Merge(src proto.Message) {
- xxx_messageInfo_TailDropDiscardConfig.Merge(m, src)
-}
-func (m *TailDropDiscardConfig) XXX_Size() int {
- return xxx_messageInfo_TailDropDiscardConfig.Size(m)
-}
-func (m *TailDropDiscardConfig) XXX_DiscardUnknown() {
- xxx_messageInfo_TailDropDiscardConfig.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_TailDropDiscardConfig proto.InternalMessageInfo
-
-func (m *TailDropDiscardConfig) GetQueueSize() uint32 {
- if m != nil {
- return m.QueueSize
- }
- return 0
-}
-
-type RedDiscardConfig struct {
- MinThreshold uint32 `protobuf:"fixed32,1,opt,name=min_threshold,json=minThreshold,proto3" json:"min_threshold,omitempty"`
- MaxThreshold uint32 `protobuf:"fixed32,2,opt,name=max_threshold,json=maxThreshold,proto3" json:"max_threshold,omitempty"`
- MaxProbability uint32 `protobuf:"fixed32,3,opt,name=max_probability,json=maxProbability,proto3" json:"max_probability,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *RedDiscardConfig) Reset() { *m = RedDiscardConfig{} }
-func (m *RedDiscardConfig) String() string { return proto.CompactTextString(m) }
-func (*RedDiscardConfig) ProtoMessage() {}
-func (*RedDiscardConfig) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{39}
-}
-
-func (m *RedDiscardConfig) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_RedDiscardConfig.Unmarshal(m, b)
-}
-func (m *RedDiscardConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_RedDiscardConfig.Marshal(b, m, deterministic)
-}
-func (m *RedDiscardConfig) XXX_Merge(src proto.Message) {
- xxx_messageInfo_RedDiscardConfig.Merge(m, src)
-}
-func (m *RedDiscardConfig) XXX_Size() int {
- return xxx_messageInfo_RedDiscardConfig.Size(m)
-}
-func (m *RedDiscardConfig) XXX_DiscardUnknown() {
- xxx_messageInfo_RedDiscardConfig.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_RedDiscardConfig proto.InternalMessageInfo
-
-func (m *RedDiscardConfig) GetMinThreshold() uint32 {
- if m != nil {
- return m.MinThreshold
- }
- return 0
-}
-
-func (m *RedDiscardConfig) GetMaxThreshold() uint32 {
- if m != nil {
- return m.MaxThreshold
- }
- return 0
-}
-
-func (m *RedDiscardConfig) GetMaxProbability() uint32 {
- if m != nil {
- return m.MaxProbability
- }
- return 0
-}
-
-type WRedDiscardConfig struct {
- Green *RedDiscardConfig `protobuf:"bytes,1,opt,name=green,proto3" json:"green,omitempty"`
- Yellow *RedDiscardConfig `protobuf:"bytes,2,opt,name=yellow,proto3" json:"yellow,omitempty"`
- Red *RedDiscardConfig `protobuf:"bytes,3,opt,name=red,proto3" json:"red,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *WRedDiscardConfig) Reset() { *m = WRedDiscardConfig{} }
-func (m *WRedDiscardConfig) String() string { return proto.CompactTextString(m) }
-func (*WRedDiscardConfig) ProtoMessage() {}
-func (*WRedDiscardConfig) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{40}
-}
-
-func (m *WRedDiscardConfig) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_WRedDiscardConfig.Unmarshal(m, b)
-}
-func (m *WRedDiscardConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_WRedDiscardConfig.Marshal(b, m, deterministic)
-}
-func (m *WRedDiscardConfig) XXX_Merge(src proto.Message) {
- xxx_messageInfo_WRedDiscardConfig.Merge(m, src)
-}
-func (m *WRedDiscardConfig) XXX_Size() int {
- return xxx_messageInfo_WRedDiscardConfig.Size(m)
-}
-func (m *WRedDiscardConfig) XXX_DiscardUnknown() {
- xxx_messageInfo_WRedDiscardConfig.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_WRedDiscardConfig proto.InternalMessageInfo
-
-func (m *WRedDiscardConfig) GetGreen() *RedDiscardConfig {
- if m != nil {
- return m.Green
- }
- return nil
-}
-
-func (m *WRedDiscardConfig) GetYellow() *RedDiscardConfig {
- if m != nil {
- return m.Yellow
- }
- return nil
-}
-
-func (m *WRedDiscardConfig) GetRed() *RedDiscardConfig {
- if m != nil {
- return m.Red
- }
- return nil
-}
-
-type DiscardConfig struct {
- DiscardPolicy DiscardPolicy `protobuf:"varint,1,opt,name=discard_policy,json=discardPolicy,proto3,enum=openolt.DiscardPolicy" json:"discard_policy,omitempty"`
- // Types that are valid to be assigned to DiscardConfig:
- // *DiscardConfig_TailDropDiscardConfig
- // *DiscardConfig_RedDiscardConfig
- // *DiscardConfig_WredDiscardConfig
- DiscardConfig isDiscardConfig_DiscardConfig `protobuf_oneof:"discard_config"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *DiscardConfig) Reset() { *m = DiscardConfig{} }
-func (m *DiscardConfig) String() string { return proto.CompactTextString(m) }
-func (*DiscardConfig) ProtoMessage() {}
-func (*DiscardConfig) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{41}
-}
-
-func (m *DiscardConfig) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_DiscardConfig.Unmarshal(m, b)
-}
-func (m *DiscardConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_DiscardConfig.Marshal(b, m, deterministic)
-}
-func (m *DiscardConfig) XXX_Merge(src proto.Message) {
- xxx_messageInfo_DiscardConfig.Merge(m, src)
-}
-func (m *DiscardConfig) XXX_Size() int {
- return xxx_messageInfo_DiscardConfig.Size(m)
-}
-func (m *DiscardConfig) XXX_DiscardUnknown() {
- xxx_messageInfo_DiscardConfig.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_DiscardConfig proto.InternalMessageInfo
-
-func (m *DiscardConfig) GetDiscardPolicy() DiscardPolicy {
- if m != nil {
- return m.DiscardPolicy
- }
- return DiscardPolicy_TailDrop
-}
-
-type isDiscardConfig_DiscardConfig interface {
- isDiscardConfig_DiscardConfig()
-}
-
-type DiscardConfig_TailDropDiscardConfig struct {
- TailDropDiscardConfig *TailDropDiscardConfig `protobuf:"bytes,2,opt,name=tail_drop_discard_config,json=tailDropDiscardConfig,proto3,oneof"`
-}
-
-type DiscardConfig_RedDiscardConfig struct {
- RedDiscardConfig *RedDiscardConfig `protobuf:"bytes,3,opt,name=red_discard_config,json=redDiscardConfig,proto3,oneof"`
-}
-
-type DiscardConfig_WredDiscardConfig struct {
- WredDiscardConfig *WRedDiscardConfig `protobuf:"bytes,4,opt,name=wred_discard_config,json=wredDiscardConfig,proto3,oneof"`
-}
-
-func (*DiscardConfig_TailDropDiscardConfig) isDiscardConfig_DiscardConfig() {}
-
-func (*DiscardConfig_RedDiscardConfig) isDiscardConfig_DiscardConfig() {}
-
-func (*DiscardConfig_WredDiscardConfig) isDiscardConfig_DiscardConfig() {}
-
-func (m *DiscardConfig) GetDiscardConfig() isDiscardConfig_DiscardConfig {
- if m != nil {
- return m.DiscardConfig
- }
- return nil
-}
-
-func (m *DiscardConfig) GetTailDropDiscardConfig() *TailDropDiscardConfig {
- if x, ok := m.GetDiscardConfig().(*DiscardConfig_TailDropDiscardConfig); ok {
- return x.TailDropDiscardConfig
- }
- return nil
-}
-
-func (m *DiscardConfig) GetRedDiscardConfig() *RedDiscardConfig {
- if x, ok := m.GetDiscardConfig().(*DiscardConfig_RedDiscardConfig); ok {
- return x.RedDiscardConfig
- }
- return nil
-}
-
-func (m *DiscardConfig) GetWredDiscardConfig() *WRedDiscardConfig {
- if x, ok := m.GetDiscardConfig().(*DiscardConfig_WredDiscardConfig); ok {
- return x.WredDiscardConfig
- }
- return nil
-}
-
-// XXX_OneofWrappers is for the internal use of the proto package.
-func (*DiscardConfig) XXX_OneofWrappers() []interface{} {
- return []interface{}{
- (*DiscardConfig_TailDropDiscardConfig)(nil),
- (*DiscardConfig_RedDiscardConfig)(nil),
- (*DiscardConfig_WredDiscardConfig)(nil),
- }
-}
-
-type Empty struct {
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Empty) Reset() { *m = Empty{} }
-func (m *Empty) String() string { return proto.CompactTextString(m) }
-func (*Empty) ProtoMessage() {}
-func (*Empty) Descriptor() ([]byte, []int) {
- return fileDescriptor_92401af474ed2ba9, []int{42}
-}
-
-func (m *Empty) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Empty.Unmarshal(m, b)
-}
-func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Empty.Marshal(b, m, deterministic)
-}
-func (m *Empty) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Empty.Merge(m, src)
-}
-func (m *Empty) XXX_Size() int {
- return xxx_messageInfo_Empty.Size(m)
-}
-func (m *Empty) XXX_DiscardUnknown() {
- xxx_messageInfo_Empty.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Empty proto.InternalMessageInfo
-
-func init() {
- proto.RegisterEnum("openolt.Direction", Direction_name, Direction_value)
- proto.RegisterEnum("openolt.SchedulingPolicy", SchedulingPolicy_name, SchedulingPolicy_value)
- proto.RegisterEnum("openolt.AdditionalBW", AdditionalBW_name, AdditionalBW_value)
- proto.RegisterEnum("openolt.DiscardPolicy", DiscardPolicy_name, DiscardPolicy_value)
- proto.RegisterEnum("openolt.InferredAdditionBWIndication", InferredAdditionBWIndication_name, InferredAdditionBWIndication_value)
- proto.RegisterEnum("openolt.DeviceInfo_DeviceResourceRanges_Pool_PoolType", DeviceInfo_DeviceResourceRanges_Pool_PoolType_name, DeviceInfo_DeviceResourceRanges_Pool_PoolType_value)
- proto.RegisterEnum("openolt.DeviceInfo_DeviceResourceRanges_Pool_SharingType", DeviceInfo_DeviceResourceRanges_Pool_SharingType_name, DeviceInfo_DeviceResourceRanges_Pool_SharingType_value)
- proto.RegisterType((*Indication)(nil), "openolt.Indication")
- proto.RegisterType((*AlarmIndication)(nil), "openolt.AlarmIndication")
- proto.RegisterType((*OltIndication)(nil), "openolt.OltIndication")
- proto.RegisterType((*IntfIndication)(nil), "openolt.IntfIndication")
- proto.RegisterType((*OnuDiscIndication)(nil), "openolt.OnuDiscIndication")
- proto.RegisterType((*OnuIndication)(nil), "openolt.OnuIndication")
- proto.RegisterType((*IntfOperIndication)(nil), "openolt.IntfOperIndication")
- proto.RegisterType((*OmciIndication)(nil), "openolt.OmciIndication")
- proto.RegisterType((*PacketIndication)(nil), "openolt.PacketIndication")
- proto.RegisterType((*Interface)(nil), "openolt.Interface")
- proto.RegisterType((*Heartbeat)(nil), "openolt.Heartbeat")
- proto.RegisterType((*Onu)(nil), "openolt.Onu")
- proto.RegisterType((*OmciMsg)(nil), "openolt.OmciMsg")
- proto.RegisterType((*OnuPacket)(nil), "openolt.OnuPacket")
- proto.RegisterType((*UplinkPacket)(nil), "openolt.UplinkPacket")
- proto.RegisterType((*DeviceInfo)(nil), "openolt.DeviceInfo")
- proto.RegisterType((*DeviceInfo_DeviceResourceRanges)(nil), "openolt.DeviceInfo.DeviceResourceRanges")
- proto.RegisterType((*DeviceInfo_DeviceResourceRanges_Pool)(nil), "openolt.DeviceInfo.DeviceResourceRanges.Pool")
- proto.RegisterType((*Classifier)(nil), "openolt.Classifier")
- proto.RegisterType((*ActionCmd)(nil), "openolt.ActionCmd")
- proto.RegisterType((*Action)(nil), "openolt.Action")
- proto.RegisterType((*Flow)(nil), "openolt.Flow")
- proto.RegisterType((*SerialNumber)(nil), "openolt.SerialNumber")
- proto.RegisterType((*PortStatistics)(nil), "openolt.PortStatistics")
- proto.RegisterType((*FlowStatistics)(nil), "openolt.FlowStatistics")
- proto.RegisterType((*LosIndication)(nil), "openolt.LosIndication")
- proto.RegisterType((*DyingGaspIndication)(nil), "openolt.DyingGaspIndication")
- proto.RegisterType((*OnuAlarmIndication)(nil), "openolt.OnuAlarmIndication")
- proto.RegisterType((*OnuStartupFailureIndication)(nil), "openolt.OnuStartupFailureIndication")
- proto.RegisterType((*OnuSignalDegradeIndication)(nil), "openolt.OnuSignalDegradeIndication")
- proto.RegisterType((*OnuDriftOfWindowIndication)(nil), "openolt.OnuDriftOfWindowIndication")
- proto.RegisterType((*OnuLossOfOmciChannelIndication)(nil), "openolt.OnuLossOfOmciChannelIndication")
- proto.RegisterType((*OnuSignalsFailureIndication)(nil), "openolt.OnuSignalsFailureIndication")
- proto.RegisterType((*OnuTransmissionInterferenceWarning)(nil), "openolt.OnuTransmissionInterferenceWarning")
- proto.RegisterType((*OnuActivationFailureIndication)(nil), "openolt.OnuActivationFailureIndication")
- proto.RegisterType((*OnuProcessingErrorIndication)(nil), "openolt.OnuProcessingErrorIndication")
- proto.RegisterType((*Scheduler)(nil), "openolt.Scheduler")
- proto.RegisterType((*TrafficShapingInfo)(nil), "openolt.TrafficShapingInfo")
- proto.RegisterType((*Tcont)(nil), "openolt.Tcont")
- proto.RegisterType((*Tconts)(nil), "openolt.Tconts")
- proto.RegisterType((*TailDropDiscardConfig)(nil), "openolt.TailDropDiscardConfig")
- proto.RegisterType((*RedDiscardConfig)(nil), "openolt.RedDiscardConfig")
- proto.RegisterType((*WRedDiscardConfig)(nil), "openolt.WRedDiscardConfig")
- proto.RegisterType((*DiscardConfig)(nil), "openolt.DiscardConfig")
- proto.RegisterType((*Empty)(nil), "openolt.Empty")
-}
-
-func init() { proto.RegisterFile("api/openolt.proto", fileDescriptor_92401af474ed2ba9) }
-
-var fileDescriptor_92401af474ed2ba9 = []byte{
- // 3626 bytes of a gzipped FileDescriptorProto
- 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x5a, 0xcd, 0x73, 0x1c, 0x49,
- 0x56, 0x57, 0xab, 0x5b, 0xfd, 0xf1, 0xfa, 0x53, 0x29, 0x4b, 0x96, 0x65, 0xaf, 0x57, 0xd4, 0x7a,
- 0xd7, 0xc6, 0x13, 0x8c, 0x67, 0x3c, 0x1b, 0x0b, 0x3b, 0x3b, 0xb0, 0x23, 0xa9, 0x65, 0xab, 0x41,
- 0x72, 0x2b, 0x4a, 0xed, 0x15, 0x0b, 0x41, 0xd4, 0x56, 0x57, 0x65, 0x77, 0x67, 0xa8, 0xba, 0xb2,
- 0x26, 0x33, 0xdb, 0x2d, 0x2f, 0xb7, 0x05, 0xee, 0x04, 0x1b, 0x1c, 0x20, 0xe0, 0xc6, 0x8d, 0x23,
- 0x17, 0x22, 0x38, 0x72, 0xe1, 0x40, 0x70, 0x01, 0xce, 0x5c, 0xb8, 0xf1, 0x2f, 0x70, 0x20, 0xf2,
- 0xa3, 0xbe, 0xba, 0x25, 0xd9, 0x72, 0x98, 0xd8, 0x8b, 0xa2, 0xf3, 0xbd, 0xdf, 0xfb, 0x65, 0xbe,
- 0xcc, 0xf7, 0x5e, 0x7e, 0x94, 0x60, 0xdd, 0x8d, 0xc8, 0x33, 0x1a, 0xe1, 0x90, 0x06, 0xe2, 0xd3,
- 0x88, 0x51, 0x41, 0x51, 0xc5, 0x34, 0x77, 0x1e, 0x8c, 0x29, 0x1d, 0x07, 0xf8, 0x99, 0x84, 0xb8,
- 0x61, 0x48, 0x85, 0x2b, 0x08, 0x0d, 0xb9, 0x86, 0x59, 0xff, 0x5a, 0x02, 0xe8, 0x85, 0x3e, 0xf1,
- 0x94, 0x14, 0x7d, 0x0e, 0x15, 0x1a, 0x08, 0x87, 0x84, 0xfe, 0x76, 0x61, 0xb7, 0xf0, 0xa4, 0xfe,
- 0x7c, 0xeb, 0xd3, 0x98, 0xb6, 0x1f, 0x88, 0x14, 0x78, 0xb4, 0x62, 0x97, 0xa9, 0x12, 0xa0, 0xef,
- 0x43, 0x95, 0x84, 0x62, 0xa4, 0x6c, 0x56, 0x95, 0xcd, 0xdd, 0xc4, 0xa6, 0x17, 0x8a, 0x51, 0xce,
- 0xa8, 0x42, 0xb4, 0x04, 0xed, 0x41, 0x53, 0x59, 0xd1, 0x08, 0x33, 0x65, 0x5a, 0x54, 0xa6, 0xf7,
- 0x73, 0xa6, 0xfd, 0x08, 0xb3, 0x9c, 0x79, 0x9d, 0xa4, 0x52, 0xf4, 0x3b, 0xd0, 0xa0, 0xe1, 0xcc,
- 0xf1, 0x09, 0xf7, 0x14, 0x43, 0x49, 0x31, 0xec, 0xa4, 0x03, 0x0e, 0x67, 0x5d, 0xc2, 0xbd, 0x1c,
- 0x01, 0xd0, 0x44, 0xa8, 0x7c, 0x0d, 0x67, 0xca, 0x74, 0x6d, 0xd1, 0xd7, 0x70, 0xb6, 0xe0, 0xab,
- 0x12, 0x48, 0x5f, 0xe9, 0xd4, 0x23, 0xca, 0xa6, 0xbc, 0xe0, 0x6b, 0x7f, 0xea, 0x91, 0xbc, 0xaf,
- 0x54, 0x4b, 0xd0, 0xf7, 0xa1, 0x12, 0x5d, 0xe8, 0x49, 0xad, 0x28, 0xa3, 0x7b, 0x89, 0xd1, 0xa9,
- 0xeb, 0x5d, 0xe0, 0x85, 0x79, 0x8d, 0x2e, 0xd4, 0xbc, 0xfe, 0x16, 0x40, 0x44, 0x99, 0x70, 0xb8,
- 0x70, 0x05, 0xdf, 0xae, 0x2e, 0xf4, 0x76, 0x4a, 0x99, 0x38, 0x93, 0x4b, 0xc9, 0x05, 0xf1, 0xf8,
- 0xd1, 0x8a, 0x5d, 0x8b, 0x8c, 0x84, 0x4b, 0xcb, 0x51, 0x40, 0xe7, 0xc6, 0xb2, 0xb6, 0x60, 0xf9,
- 0x22, 0xa0, 0xf3, 0xbc, 0xe5, 0xc8, 0x48, 0x38, 0xfa, 0x4d, 0xa8, 0xb9, 0x81, 0xcb, 0xa6, 0x6a,
- 0xac, 0xa0, 0x0c, 0xb7, 0x13, 0xc3, 0x3d, 0xa9, 0xc9, 0x0d, 0xb5, 0xea, 0x1a, 0xd1, 0x7e, 0x19,
- 0x4a, 0xbe, 0x2b, 0x5c, 0xeb, 0xef, 0x2b, 0xd0, 0x5e, 0xc0, 0xc9, 0x79, 0x0e, 0x28, 0xbf, 0x32,
- 0xa6, 0x8e, 0x29, 0xcf, 0xfb, 0x1e, 0x28, 0x01, 0xea, 0x42, 0xcb, 0x7f, 0x4b, 0xc2, 0xb1, 0x33,
- 0x76, 0x79, 0x94, 0x89, 0xac, 0x07, 0x89, 0x65, 0x57, 0xaa, 0x5f, 0xba, 0x3c, 0xca, 0xd9, 0x37,
- 0xfc, 0x8c, 0x58, 0xc6, 0x98, 0x5c, 0xe0, 0xd4, 0xa3, 0xc5, 0x18, 0xeb, 0x87, 0xb3, 0x65, 0xa7,
- 0xea, 0x34, 0x95, 0xa2, 0x73, 0xb8, 0x23, 0x29, 0xb8, 0x70, 0x99, 0x98, 0x45, 0xce, 0xc8, 0x25,
- 0x41, 0x26, 0xd6, 0x1e, 0x65, 0x99, 0xce, 0x34, 0xe6, 0x85, 0x4b, 0x82, 0x19, 0xc3, 0x39, 0xca,
- 0x75, 0x9a, 0x53, 0x4b, 0xe2, 0x3f, 0x80, 0x2d, 0x45, 0x4c, 0xc6, 0xa1, 0x1b, 0x38, 0x3e, 0x1e,
- 0x33, 0xd7, 0xc7, 0x99, 0x58, 0xfc, 0x4e, 0x8e, 0x5a, 0xa1, 0xba, 0x1a, 0x94, 0x63, 0xde, 0xa0,
- 0xcb, 0x5a, 0xf4, 0x87, 0x70, 0x57, 0x25, 0x06, 0x23, 0x23, 0xe1, 0xd0, 0x91, 0x33, 0x27, 0xa1,
- 0x4f, 0xe7, 0x99, 0xa0, 0xcd, 0x91, 0x77, 0x25, 0xac, 0x3f, 0x3a, 0x57, 0xa0, 0x25, 0xf2, 0x45,
- 0x2d, 0x1a, 0x80, 0xf4, 0xc6, 0x09, 0x28, 0xe7, 0x4e, 0x92, 0x0b, 0x3a, 0xac, 0x1f, 0x67, 0x69,
- 0x8f, 0x29, 0xe7, 0xfd, 0x91, 0x4c, 0x8a, 0x83, 0x89, 0x1b, 0x86, 0x38, 0xc8, 0x51, 0xb7, 0xa8,
- 0x41, 0x98, 0x14, 0x89, 0xe7, 0x59, 0xb9, 0xc2, 0xd3, 0x79, 0xae, 0x5e, 0x31, 0xcf, 0x1a, 0x73,
- 0xed, 0x3c, 0xa7, 0x6a, 0x49, 0xdc, 0xd7, 0x45, 0x42, 0x90, 0xb9, 0x1e, 0xa9, 0xce, 0x86, 0x4f,
- 0xb2, 0x84, 0x03, 0xe6, 0x86, 0x7c, 0x4a, 0x38, 0x27, 0x34, 0xec, 0x85, 0x02, 0xb3, 0x11, 0x66,
- 0x38, 0xf4, 0xf0, 0xb9, 0xcb, 0x42, 0x12, 0x8e, 0x4d, 0xd5, 0x18, 0x90, 0xb9, 0x1a, 0xe9, 0xcf,
- 0xf4, 0xe4, 0xba, 0x9e, 0x20, 0x6f, 0x54, 0xbf, 0xe9, 0x60, 0x61, 0x79, 0x16, 0xf6, 0x12, 0xd8,
- 0x55, 0xe3, 0x95, 0x3e, 0xe7, 0x11, 0xba, 0x87, 0x6d, 0xd9, 0x43, 0xc4, 0xa8, 0x87, 0x39, 0x97,
- 0x59, 0x80, 0x19, 0xa3, 0xba, 0x4a, 0xd6, 0x55, 0x17, 0xdf, 0xcd, 0x76, 0x71, 0x9a, 0xe0, 0x0e,
- 0x25, 0x2c, 0xd7, 0xc1, 0x26, 0xbd, 0x4a, 0x9f, 0x64, 0xeb, 0xa7, 0xd0, 0xcc, 0x55, 0x75, 0xf4,
- 0x2d, 0x00, 0x55, 0x90, 0x65, 0xe5, 0xc0, 0x2a, 0x5b, 0x6b, 0x76, 0x4d, 0x4a, 0x64, 0x79, 0xc0,
- 0xd6, 0x11, 0xb4, 0xf2, 0x15, 0x1d, 0xdd, 0x85, 0x8a, 0x2e, 0xfe, 0x3a, 0xb7, 0x2b, 0x76, 0x59,
- 0x15, 0x78, 0x7f, 0x81, 0x69, 0x75, 0x91, 0x69, 0x02, 0xeb, 0x4b, 0xe5, 0xf9, 0x7a, 0xb2, 0x2f,
- 0xa1, 0xc9, 0x31, 0x23, 0x6e, 0xe0, 0x84, 0xb3, 0xe9, 0x10, 0x33, 0x53, 0x0d, 0x36, 0x93, 0x69,
- 0x38, 0x53, 0xda, 0x57, 0x4a, 0x69, 0x37, 0x78, 0xa6, 0x65, 0xfd, 0x53, 0x01, 0x9a, 0xb9, 0x72,
- 0x7e, 0x7d, 0x37, 0x9b, 0x50, 0x56, 0x1b, 0x82, 0xae, 0x36, 0x15, 0x7b, 0x4d, 0x56, 0xfd, 0x45,
- 0x57, 0x8a, 0x0b, 0xae, 0xa0, 0x6f, 0x43, 0xdd, 0xf5, 0xa7, 0x24, 0x34, 0xfa, 0x35, 0xa5, 0x07,
- 0x25, 0xd2, 0x80, 0xa5, 0xd1, 0x97, 0xde, 0x7f, 0xf4, 0x3f, 0x03, 0xb4, 0xbc, 0x11, 0x22, 0x04,
- 0x25, 0xf1, 0x36, 0x8a, 0x17, 0x48, 0xfd, 0xce, 0x7a, 0xb5, 0x7a, 0xc3, 0x4a, 0x2c, 0x0e, 0xdf,
- 0xb2, 0xa1, 0x95, 0xdf, 0xb9, 0x6e, 0x3d, 0x3f, 0x1d, 0x28, 0x46, 0x17, 0x42, 0x31, 0x37, 0x6c,
- 0xf9, 0xd3, 0xfa, 0xe7, 0x02, 0x74, 0x16, 0x77, 0x36, 0x74, 0x1f, 0x6a, 0x8a, 0x56, 0x8d, 0x5c,
- 0xcf, 0x92, 0x3a, 0x38, 0x0c, 0x16, 0x46, 0xbf, 0x14, 0x47, 0x63, 0x3c, 0x55, 0x1b, 0x61, 0xd2,
- 0x6f, 0xcd, 0x48, 0x7a, 0xbe, 0xb4, 0x53, 0x5b, 0x1d, 0xd1, 0xc5, 0xbd, 0x62, 0x97, 0x65, 0x53,
- 0x2b, 0x94, 0x51, 0x48, 0x55, 0xcd, 0xab, 0xd8, 0x65, 0xd9, 0x7c, 0x45, 0xd1, 0x16, 0x94, 0x3d,
- 0x4a, 0x2f, 0x08, 0x56, 0x45, 0xab, 0x6c, 0x9b, 0x56, 0xec, 0x45, 0x29, 0xf5, 0xe2, 0x11, 0xd4,
- 0x74, 0x39, 0x70, 0xbd, 0xeb, 0x07, 0x68, 0x7d, 0x05, 0xb5, 0x23, 0xec, 0x32, 0x31, 0xc4, 0xae,
- 0x40, 0xcf, 0x60, 0x63, 0x12, 0x37, 0x74, 0x31, 0x13, 0x33, 0x86, 0x8d, 0x05, 0x4a, 0x54, 0x67,
- 0xb1, 0xc6, 0xfa, 0x93, 0x02, 0x14, 0xfb, 0xe1, 0xec, 0xd6, 0x73, 0xbe, 0x14, 0x53, 0xc5, 0xf7,
- 0x8e, 0x29, 0xe5, 0x29, 0xd1, 0x51, 0x58, 0xb1, 0xe5, 0x4f, 0xeb, 0xf7, 0xa0, 0x22, 0x63, 0xe0,
- 0x84, 0x8f, 0x3f, 0xc2, 0xe2, 0x8f, 0xa0, 0x26, 0xab, 0x92, 0x5a, 0xfe, 0x5b, 0xd3, 0x65, 0x96,
- 0xad, 0x94, 0x5b, 0xb6, 0xe5, 0x7e, 0x7e, 0x08, 0x8d, 0xd7, 0x51, 0x40, 0xc2, 0x8b, 0x77, 0x75,
- 0x65, 0x4c, 0x57, 0x53, 0xd3, 0xbf, 0xa8, 0x01, 0x74, 0xf1, 0x1b, 0xe2, 0xe1, 0x5e, 0x38, 0x52,
- 0x21, 0xf1, 0x06, 0x87, 0x3e, 0x65, 0x26, 0xa1, 0x4c, 0x0b, 0xdd, 0x81, 0xb5, 0x29, 0xf5, 0x71,
- 0x60, 0xca, 0x97, 0x6e, 0xa0, 0x5f, 0x87, 0xce, 0xc4, 0x65, 0xfe, 0xdc, 0x65, 0xd8, 0x79, 0x83,
- 0x99, 0xdc, 0x35, 0x4c, 0x56, 0xb5, 0x63, 0xf9, 0x4f, 0xb4, 0x58, 0x42, 0x47, 0x84, 0x4d, 0x73,
- 0xd0, 0x92, 0x86, 0xc6, 0xf2, 0x18, 0x7a, 0x1f, 0x6a, 0xbe, 0x1a, 0x91, 0x1c, 0x7f, 0x47, 0x67,
- 0x87, 0x16, 0xf4, 0x7c, 0xf4, 0x19, 0xdc, 0x31, 0xca, 0xfc, 0xa2, 0xaf, 0x2b, 0x1c, 0xd2, 0xba,
- 0xec, 0x8a, 0x4b, 0xba, 0x88, 0x86, 0x8e, 0x9c, 0x3c, 0xbe, 0xdd, 0x50, 0xd3, 0x51, 0x8d, 0x68,
- 0x28, 0x4f, 0x8d, 0x1c, 0x3d, 0x04, 0x10, 0xd8, 0x9b, 0x84, 0x34, 0xa0, 0xe3, 0xb7, 0x71, 0xc1,
- 0x4a, 0x25, 0x68, 0x57, 0xef, 0x99, 0xc4, 0xd7, 0xe7, 0x1e, 0x93, 0x40, 0xa0, 0x56, 0x48, 0x1d,
- 0x63, 0xd0, 0x03, 0x00, 0x83, 0xc0, 0x66, 0xf7, 0xaf, 0xd8, 0x55, 0xa5, 0x3f, 0x0c, 0x7d, 0xf4,
- 0x08, 0x5a, 0x6e, 0x10, 0x50, 0x2f, 0x65, 0xa8, 0x2a, 0x44, 0x43, 0x49, 0x63, 0x8e, 0x5d, 0x68,
- 0x24, 0x28, 0x6c, 0x76, 0xe6, 0x8a, 0x0d, 0x06, 0x23, 0x79, 0x9e, 0x40, 0x27, 0xcd, 0x7d, 0xc3,
- 0x04, 0x0a, 0xd5, 0x4a, 0x2a, 0x80, 0xe6, 0x7a, 0x04, 0xad, 0x0c, 0x12, 0x9b, 0x8d, 0xb2, 0x62,
- 0x37, 0x12, 0x9c, 0xe4, 0xb3, 0xa0, 0x69, 0x8a, 0x85, 0x21, 0x6b, 0x2a, 0x50, 0x5d, 0x97, 0x0c,
- 0xcd, 0xf4, 0x10, 0xea, 0x31, 0x46, 0xd2, 0xb4, 0x74, 0xc1, 0xd1, 0x08, 0xc9, 0xf1, 0x35, 0x94,
- 0x99, 0x1b, 0x8e, 0x31, 0xdf, 0x6e, 0xef, 0x16, 0x9f, 0xd4, 0x9f, 0x3f, 0x49, 0x4f, 0xa4, 0x49,
- 0x40, 0x99, 0x9f, 0x36, 0xe6, 0x74, 0xc6, 0x3c, 0x6c, 0x2b, 0xbc, 0x6d, 0xec, 0x76, 0xfe, 0xb2,
- 0x04, 0x77, 0xae, 0x02, 0xa0, 0x7b, 0xf1, 0x45, 0xca, 0xe7, 0xdb, 0x85, 0xdd, 0xe2, 0x93, 0x8a,
- 0xb9, 0x2d, 0xf9, 0x8b, 0x2b, 0xb6, 0xba, 0xb4, 0x62, 0x07, 0xb0, 0x16, 0x51, 0x1a, 0xf0, 0xed,
- 0xa2, 0x1a, 0xd4, 0x6f, 0xbc, 0xef, 0xa0, 0x3e, 0x3d, 0xa5, 0x34, 0xb0, 0xb5, 0xed, 0xce, 0xff,
- 0xae, 0x42, 0x49, 0xb6, 0xd1, 0xef, 0x66, 0xb6, 0x97, 0xd6, 0xf3, 0x1f, 0xdc, 0x8a, 0x4c, 0xfd,
- 0x91, 0x25, 0xdd, 0x6c, 0x4b, 0x67, 0x50, 0xe1, 0x13, 0x97, 0x91, 0x70, 0xac, 0x86, 0xdd, 0x7a,
- 0xfe, 0xc3, 0xdb, 0xd1, 0x9d, 0x69, 0x63, 0xc5, 0x18, 0x33, 0xc9, 0xc4, 0xd4, 0x0b, 0xa8, 0x6b,
- 0xbe, 0x6e, 0xc8, 0x3c, 0xc7, 0xe6, 0x68, 0x5e, 0xb1, 0xe5, 0x4f, 0x6b, 0x0f, 0xaa, 0xf1, 0x70,
- 0x10, 0x40, 0xb9, 0xff, 0xea, 0xb5, 0xd3, 0xeb, 0x76, 0x56, 0x50, 0x03, 0xaa, 0x7b, 0xc7, 0xc7,
- 0xfd, 0x03, 0xd9, 0x2a, 0xa0, 0x16, 0xc0, 0xcb, 0xc3, 0x93, 0xd3, 0xbe, 0x3d, 0x90, 0xed, 0x55,
- 0x54, 0x87, 0xca, 0x8b, 0xe3, 0xfe, 0xb9, 0x6c, 0x14, 0xad, 0x09, 0xd4, 0x33, 0x43, 0x40, 0x5b,
- 0x80, 0xba, 0x87, 0xdd, 0xde, 0xc1, 0xde, 0xe0, 0xb0, 0xeb, 0x9c, 0x1e, 0xda, 0x4e, 0xef, 0xd5,
- 0xe0, 0x45, 0x67, 0x05, 0x7d, 0x1b, 0xee, 0x9f, 0x1d, 0xed, 0xd9, 0x87, 0x5d, 0x67, 0xff, 0xa7,
- 0xce, 0xde, 0xf1, 0xb1, 0x92, 0xab, 0x1f, 0x83, 0xc3, 0x83, 0xa3, 0x4e, 0x01, 0xed, 0xc2, 0x83,
- 0x2b, 0x00, 0x67, 0x7b, 0x27, 0x87, 0x1a, 0xb1, 0x6a, 0xfd, 0x69, 0x11, 0xe0, 0x20, 0x70, 0x39,
- 0x27, 0x23, 0x82, 0x99, 0x2a, 0x90, 0x8e, 0x88, 0x92, 0x6a, 0xb6, 0x46, 0x07, 0x11, 0xf1, 0xd1,
- 0x06, 0xac, 0x51, 0xe7, 0x4d, 0x52, 0x36, 0x4b, 0xf4, 0x27, 0x44, 0x15, 0x53, 0xa2, 0xb1, 0x66,
- 0x42, 0x48, 0x8c, 0x25, 0x0a, 0xab, 0xa7, 0xa4, 0x44, 0x24, 0xf6, 0x2e, 0x54, 0xa8, 0x13, 0x0d,
- 0x89, 0xe0, 0x2a, 0xf3, 0x2b, 0x76, 0x99, 0x9e, 0xca, 0x96, 0xaa, 0x9f, 0x46, 0x61, 0x76, 0x4c,
- 0xa2, 0x15, 0xf7, 0xa0, 0x8a, 0xc5, 0x44, 0xef, 0xdb, 0x3a, 0xd5, 0x2b, 0x58, 0x4c, 0xe2, 0x6d,
- 0xdb, 0xe7, 0xc2, 0x99, 0xba, 0x9e, 0x4a, 0xf1, 0x86, 0x5d, 0xf6, 0xb9, 0x38, 0x71, 0x3d, 0xa9,
- 0xe0, 0xcc, 0x53, 0x8a, 0x9a, 0x56, 0x70, 0xe6, 0x49, 0x85, 0x0c, 0xf2, 0xc8, 0x51, 0x6f, 0x0f,
- 0x26, 0x97, 0x2b, 0x24, 0x3a, 0x55, 0x2f, 0x16, 0x9b, 0x20, 0xad, 0x1d, 0x12, 0x99, 0xe4, 0x5d,
- 0xf3, 0xb9, 0xe8, 0x45, 0x52, 0x2c, 0xa9, 0x48, 0x64, 0xea, 0xd8, 0x1a, 0x67, 0x5e, 0x2f, 0x92,
- 0x44, 0x52, 0x2c, 0xb3, 0xdb, 0xe4, 0xb1, 0xec, 0x51, 0x16, 0x38, 0xa9, 0x92, 0x44, 0x4a, 0xa5,
- 0x13, 0x58, 0x8e, 0x52, 0xa9, 0x76, 0xa1, 0x21, 0xaf, 0xe2, 0xc2, 0x1d, 0x6b, 0x7f, 0xda, 0x3a,
- 0x95, 0xa2, 0x0b, 0x31, 0x70, 0xd5, 0x0a, 0x5b, 0x7f, 0x0c, 0x35, 0x79, 0x24, 0xa7, 0xe1, 0xc1,
- 0x54, 0x55, 0x0c, 0xd7, 0xf7, 0x1d, 0x3a, 0x13, 0x98, 0x49, 0x23, 0xb5, 0x16, 0x55, 0xbb, 0xee,
- 0xfa, 0x7e, 0x5f, 0xca, 0x06, 0xee, 0x58, 0x56, 0x29, 0x86, 0xa7, 0xf4, 0x0d, 0xce, 0xc0, 0x56,
- 0x15, 0xac, 0xa5, 0xe5, 0x09, 0x72, 0x17, 0x1a, 0x82, 0xb9, 0x91, 0x23, 0xa8, 0x33, 0xa1, 0x5c,
- 0x47, 0x6f, 0xd5, 0x06, 0x29, 0x1b, 0xd0, 0x23, 0xca, 0x85, 0xf5, 0x8f, 0x05, 0x28, 0xeb, 0xde,
- 0xd1, 0x23, 0x28, 0x7a, 0xd3, 0xf8, 0xc6, 0x8c, 0xd2, 0x4b, 0x78, 0x3c, 0x36, 0x5b, 0xaa, 0xaf,
- 0x0e, 0x87, 0xcc, 0x12, 0x17, 0x73, 0x4b, 0x9c, 0xc6, 0x54, 0x69, 0x21, 0xa6, 0x74, 0x9c, 0xac,
- 0xe5, 0xe3, 0xe4, 0xea, 0x70, 0x48, 0x83, 0xad, 0x92, 0x09, 0x36, 0xeb, 0x6f, 0x8b, 0x50, 0x7a,
- 0x11, 0xd0, 0xb9, 0xaa, 0xfe, 0x9e, 0xbc, 0x71, 0x38, 0xd9, 0xed, 0xb8, 0x6d, 0x37, 0xb4, 0xb4,
- 0x77, 0xd5, 0xfe, 0xdf, 0x8e, 0xf7, 0xff, 0x4d, 0x28, 0xcf, 0x42, 0x22, 0xc5, 0x75, 0x2d, 0x9e,
- 0x85, 0xe4, 0xa6, 0x63, 0xde, 0x7d, 0x50, 0xb5, 0x59, 0x2f, 0xa6, 0xde, 0x5a, 0xab, 0x52, 0xa0,
- 0xa2, 0xf3, 0x1e, 0x54, 0xe3, 0x1d, 0x46, 0xc5, 0x5a, 0xdb, 0xae, 0x98, 0xdd, 0x05, 0x7d, 0x0f,
- 0xda, 0x21, 0x16, 0x73, 0xca, 0x2e, 0x92, 0x51, 0xae, 0x29, 0x44, 0xd3, 0x88, 0x7b, 0x57, 0x1d,
- 0x3f, 0xcb, 0x0a, 0x92, 0x39, 0x7e, 0x7e, 0x01, 0xe0, 0x25, 0x29, 0x6b, 0x6e, 0xc1, 0x1b, 0xc9,
- 0x5a, 0xa5, 0xd9, 0x6c, 0x67, 0x60, 0xe8, 0x31, 0x94, 0x5d, 0xb5, 0x8a, 0xe6, 0x76, 0xdb, 0x5e,
- 0x58, 0x5c, 0xdb, 0xa8, 0xd1, 0x0e, 0x54, 0x23, 0x46, 0x28, 0x23, 0xe2, 0xad, 0xca, 0xa2, 0xb6,
- 0x9d, 0xb4, 0x33, 0xc7, 0xd8, 0x46, 0xee, 0x18, 0x9b, 0x39, 0x40, 0x35, 0xb3, 0x07, 0x28, 0x6b,
- 0x00, 0x8d, 0xc5, 0x13, 0x82, 0x3e, 0xe6, 0xc4, 0x2b, 0xd4, 0xb0, 0xab, 0x5a, 0xd0, 0xf3, 0xd1,
- 0x63, 0x68, 0x1b, 0x25, 0x8f, 0xb0, 0x47, 0x46, 0xc4, 0x33, 0xc7, 0xa7, 0x96, 0x16, 0x9f, 0x19,
- 0xa9, 0xf5, 0x6f, 0x25, 0x68, 0xe5, 0x9f, 0xa2, 0xae, 0x3f, 0x87, 0xdd, 0x83, 0x2a, 0xbb, 0x74,
- 0x86, 0x6f, 0x05, 0xe6, 0x8a, 0xad, 0x6c, 0x57, 0xd8, 0xe5, 0xbe, 0x6c, 0xca, 0x69, 0x66, 0x97,
- 0x4e, 0xa4, 0x0e, 0x72, 0x3a, 0x68, 0xcb, 0x76, 0x8d, 0x5d, 0xea, 0x93, 0x1d, 0x57, 0x29, 0x76,
- 0xe9, 0xcc, 0x3c, 0x57, 0x66, 0xb5, 0x01, 0x95, 0x14, 0xa8, 0xc5, 0x2e, 0x5f, 0x4b, 0x71, 0x1e,
- 0x39, 0xcd, 0x21, 0xd7, 0x62, 0xe4, 0xc9, 0x32, 0x72, 0x98, 0x43, 0x96, 0x63, 0xe4, 0xfe, 0x32,
- 0x52, 0xdf, 0xc1, 0x63, 0x64, 0x25, 0x46, 0xaa, 0x3b, 0x75, 0x8c, 0xbc, 0x07, 0x55, 0x11, 0x7b,
- 0x58, 0xd5, 0x1e, 0x8a, 0xd4, 0x43, 0x91, 0x7a, 0x58, 0xd3, 0x1e, 0x8a, 0xac, 0x87, 0x62, 0xd1,
- 0x43, 0xd0, 0x7d, 0x88, 0x25, 0x0f, 0xc5, 0xa2, 0x87, 0xf5, 0x18, 0x79, 0xb2, 0x8c, 0xcc, 0x7b,
- 0xd8, 0x88, 0x91, 0xfb, 0xcb, 0xc8, 0xbc, 0x87, 0xcd, 0x18, 0x99, 0xf3, 0xd0, 0x82, 0x26, 0xbb,
- 0x74, 0x3c, 0xe6, 0x69, 0x34, 0x57, 0xf5, 0xb5, 0x6c, 0xd7, 0xd9, 0xe5, 0x01, 0xf3, 0x14, 0x52,
- 0xb9, 0x3a, 0x24, 0x51, 0x0c, 0x68, 0x6b, 0x57, 0x87, 0x24, 0x32, 0xea, 0x07, 0x50, 0x13, 0x64,
- 0x8a, 0xb9, 0x70, 0xa7, 0x91, 0x3a, 0xe9, 0x56, 0xec, 0x54, 0x20, 0xaf, 0xeb, 0xad, 0xfc, 0x0b,
- 0x65, 0x36, 0xf9, 0x0b, 0xb9, 0xe4, 0xff, 0xf0, 0x80, 0xfa, 0xf0, 0x85, 0xba, 0x79, 0xf4, 0x5f,
- 0x43, 0x33, 0xf7, 0xa4, 0x79, 0x7d, 0x32, 0x6c, 0x41, 0x59, 0x5e, 0xc8, 0x67, 0xdc, 0x9c, 0xe6,
- 0x4c, 0xcb, 0xfa, 0x23, 0xd8, 0xb8, 0xe2, 0x69, 0xf3, 0xd6, 0xf7, 0xa8, 0x94, 0xbe, 0x98, 0xa3,
- 0xff, 0xaf, 0x02, 0xa0, 0xe5, 0x57, 0xcf, 0x0f, 0x79, 0x12, 0x09, 0x28, 0x77, 0x72, 0x5d, 0xd4,
- 0x02, 0xca, 0xcf, 0x94, 0x40, 0xab, 0x87, 0xb1, 0xba, 0x14, 0xab, 0x87, 0x46, 0xfd, 0x04, 0x3a,
- 0x01, 0x8d, 0x3c, 0x67, 0x4a, 0x78, 0xc2, 0xa1, 0x6f, 0x21, 0x2d, 0x29, 0x3f, 0x21, 0x3c, 0x26,
- 0xfa, 0x1c, 0x36, 0x0d, 0xd2, 0x04, 0x5c, 0x0c, 0x2f, 0xeb, 0x9b, 0x8f, 0x86, 0xeb, 0xc0, 0xd3,
- 0x26, 0x16, 0x86, 0xfb, 0x37, 0x3c, 0xc6, 0x7e, 0xb4, 0x89, 0xfc, 0xab, 0x02, 0xec, 0x5c, 0xff,
- 0x32, 0xfb, 0xb1, 0xba, 0x41, 0x5f, 0xc0, 0x16, 0x09, 0xe5, 0xd5, 0x11, 0x3b, 0x43, 0x22, 0xcc,
- 0x1c, 0x30, 0x57, 0x60, 0xb3, 0x83, 0x6f, 0x18, 0xed, 0x3e, 0x11, 0x6a, 0x12, 0x6c, 0x57, 0x60,
- 0xeb, 0x97, 0x7a, 0x6c, 0xd7, 0x3c, 0xec, 0x7e, 0xb4, 0xb1, 0xdd, 0x81, 0x35, 0xf5, 0xc4, 0x1c,
- 0x1f, 0x26, 0x54, 0x43, 0xb2, 0x87, 0x78, 0xee, 0xe0, 0x6f, 0xe2, 0xe3, 0x44, 0x39, 0xc4, 0xf3,
- 0xc3, 0x6f, 0x7c, 0x6b, 0x02, 0x0f, 0x6f, 0x7e, 0x16, 0xfe, 0x68, 0x6b, 0xf3, 0xd7, 0x05, 0x1d,
- 0x03, 0xd7, 0x3c, 0x14, 0xff, 0x6a, 0x17, 0xe7, 0x17, 0x05, 0xb0, 0xde, 0xfd, 0xe8, 0xfc, 0xff,
- 0xbb, 0x48, 0xd6, 0xa9, 0x5a, 0x8b, 0x1b, 0x1e, 0xa7, 0x6f, 0xdb, 0xbf, 0xf5, 0x0a, 0x1e, 0xdc,
- 0xf4, 0x16, 0x7d, 0x6b, 0xbe, 0xff, 0x29, 0x40, 0xed, 0xcc, 0x9b, 0x60, 0x7f, 0x16, 0x60, 0x86,
- 0x3e, 0x83, 0x9a, 0x4f, 0x18, 0xd6, 0xa7, 0x26, 0x7d, 0x2d, 0x4d, 0x8f, 0xc4, 0xdd, 0x58, 0x63,
- 0xa7, 0x20, 0xf4, 0xa5, 0x3a, 0xb9, 0x13, 0xf9, 0xdb, 0x0d, 0x9c, 0xe1, 0xdc, 0xdc, 0x3e, 0xd3,
- 0x07, 0xb2, 0xbd, 0x44, 0xbb, 0x7f, 0x6e, 0x37, 0x52, 0xec, 0xfe, 0x3c, 0x77, 0xee, 0x2a, 0x9a,
- 0xb7, 0x93, 0xcc, 0xb9, 0x6b, 0x8e, 0xc9, 0x78, 0x12, 0x4f, 0xa8, 0x69, 0xa1, 0xaf, 0xa0, 0xc1,
- 0xe5, 0x70, 0x9d, 0x88, 0x06, 0xc4, 0xd3, 0xaf, 0x2a, 0xad, 0xcc, 0x87, 0x3e, 0xe3, 0x0b, 0x09,
- 0xc7, 0xa7, 0x0a, 0x60, 0xd7, 0x15, 0x5c, 0x37, 0xac, 0x7f, 0x28, 0x00, 0x1a, 0x30, 0x77, 0x34,
- 0x22, 0xde, 0xd9, 0xc4, 0x8d, 0x48, 0x38, 0x56, 0x0f, 0x53, 0x1d, 0x28, 0x7a, 0x84, 0x99, 0x09,
- 0x93, 0x3f, 0x95, 0x64, 0xc8, 0xcd, 0x54, 0xc9, 0x9f, 0xf1, 0x6b, 0x5e, 0x31, 0x79, 0xcd, 0x53,
- 0x92, 0x21, 0x4f, 0xde, 0xf7, 0x34, 0x66, 0x4c, 0x98, 0xc9, 0x47, 0xf9, 0x13, 0x1d, 0x00, 0xc8,
- 0x8b, 0xcd, 0x30, 0xfd, 0x2a, 0xd4, 0xca, 0x7c, 0x55, 0xe8, 0x85, 0x23, 0xcc, 0x18, 0xf6, 0xe3,
- 0x39, 0xda, 0x3f, 0x4f, 0x57, 0xd2, 0xae, 0xba, 0xbe, 0xbf, 0x2f, 0xeb, 0x89, 0xf5, 0x9f, 0x05,
- 0x58, 0x1b, 0x78, 0x34, 0x14, 0x1f, 0xb0, 0x3e, 0xd9, 0xb3, 0xb9, 0xf6, 0x26, 0x39, 0x9b, 0x7f,
- 0x06, 0x35, 0x1e, 0xaf, 0xbc, 0x79, 0xd7, 0x44, 0x8b, 0xf3, 0x88, 0x99, 0x9d, 0x82, 0xd0, 0x09,
- 0xdc, 0x11, 0x7a, 0xf6, 0x1c, 0xae, 0xa7, 0xcf, 0x21, 0xe1, 0x88, 0x9a, 0x87, 0xf6, 0xf4, 0x7b,
- 0xdf, 0xf2, 0x14, 0xdb, 0x48, 0x2c, 0xc9, 0xac, 0x3f, 0x2f, 0x40, 0x59, 0xf9, 0xc5, 0x6f, 0x9d,
- 0x86, 0xe9, 0xfd, 0xc5, 0xe4, 0x5b, 0x72, 0x7f, 0x89, 0x4f, 0xe5, 0x6b, 0xb9, 0x67, 0xcd, 0xef,
- 0x41, 0x59, 0xa8, 0x9e, 0xcc, 0xcb, 0x4d, 0x2b, 0x1d, 0xab, 0x14, 0xdb, 0x46, 0x6b, 0xfd, 0x00,
- 0x36, 0x07, 0x2e, 0x09, 0xba, 0x8c, 0x46, 0x5d, 0xc2, 0x3d, 0x97, 0xf9, 0x07, 0x34, 0x1c, 0x91,
- 0xb1, 0xdc, 0x6a, 0xbf, 0x99, 0xe1, 0x19, 0x76, 0x38, 0xf9, 0x79, 0xfc, 0xd0, 0x5c, 0x53, 0x92,
- 0x33, 0xf2, 0x73, 0x6c, 0xfd, 0x59, 0x01, 0x3a, 0x36, 0xf6, 0xf3, 0x36, 0xdf, 0x81, 0xe6, 0x94,
- 0x84, 0x8e, 0x98, 0x30, 0xcc, 0x27, 0x34, 0x88, 0x5d, 0x6b, 0x4c, 0x49, 0x38, 0x88, 0x65, 0x0a,
- 0xe4, 0x5e, 0x66, 0x40, 0xab, 0x06, 0xe4, 0x5e, 0xa6, 0xa0, 0xc7, 0xd0, 0x96, 0xa0, 0x88, 0xd1,
- 0xa1, 0x3b, 0x24, 0x41, 0x9a, 0x30, 0xad, 0xa9, 0x7b, 0x79, 0x9a, 0x4a, 0xad, 0xbf, 0x2b, 0xc0,
- 0xfa, 0xf9, 0xd2, 0x40, 0x9e, 0xc1, 0xda, 0x98, 0x61, 0x1c, 0x9a, 0x5b, 0x6e, 0x9a, 0x2d, 0x8b,
- 0x48, 0x5b, 0xe3, 0xd0, 0xe7, 0x50, 0x7e, 0x8b, 0x83, 0x80, 0xce, 0xcd, 0x17, 0xa0, 0x1b, 0x2c,
- 0x0c, 0x10, 0x7d, 0x02, 0x45, 0x86, 0xe3, 0x4f, 0xbf, 0x37, 0xe0, 0x25, 0xca, 0xfa, 0x8f, 0x55,
- 0x68, 0xe6, 0x87, 0xf8, 0xdb, 0xd0, 0xf2, 0xb5, 0x20, 0xce, 0x6c, 0x1d, 0xde, 0x5b, 0x99, 0xf0,
- 0x56, 0x6a, 0x93, 0xd6, 0x4d, 0x3f, 0xdb, 0x44, 0x3f, 0x85, 0x6d, 0xe1, 0x92, 0xc0, 0xf1, 0x19,
- 0x8d, 0x9c, 0x98, 0xc8, 0x53, 0xd4, 0xc6, 0x85, 0x87, 0xe9, 0x8a, 0x5f, 0xb5, 0xc0, 0x47, 0x2b,
- 0xf6, 0xa6, 0xb8, 0x72, 0xe5, 0x7b, 0x80, 0x18, 0xf6, 0x17, 0x49, 0xdf, 0xe5, 0xe7, 0xd1, 0x8a,
- 0xdd, 0x61, 0x8b, 0xeb, 0x70, 0x0c, 0x1b, 0xf3, 0x2b, 0xb8, 0x16, 0xff, 0xa1, 0xe2, 0xfc, 0x0a,
- 0xb2, 0xf5, 0xf9, 0x22, 0xdb, 0x7e, 0x27, 0x9d, 0x32, 0x4d, 0x64, 0x55, 0x60, 0xed, 0x70, 0x1a,
- 0x89, 0xb7, 0x4f, 0xbf, 0x82, 0x5a, 0x52, 0x0d, 0x50, 0x03, 0xaa, 0xaf, 0x4f, 0xcf, 0x06, 0xf6,
- 0xe1, 0xde, 0x49, 0x67, 0x05, 0xb5, 0x00, 0xba, 0xfd, 0xf3, 0x57, 0xa6, 0x5d, 0x40, 0xeb, 0xd0,
- 0xdc, 0xef, 0x75, 0x7b, 0xf6, 0xe1, 0xc1, 0xa0, 0xd7, 0x7f, 0xb5, 0x77, 0xdc, 0x59, 0x7d, 0xfa,
- 0x23, 0xe8, 0x2c, 0x96, 0x51, 0x54, 0x81, 0xe2, 0xb9, 0x6d, 0x77, 0x56, 0x10, 0x82, 0xd6, 0x99,
- 0x60, 0xc4, 0x13, 0xa7, 0xa6, 0x54, 0x77, 0x0a, 0x08, 0xa0, 0x7c, 0xf4, 0x76, 0xc8, 0x88, 0xdf,
- 0x59, 0x7d, 0x1a, 0x42, 0x23, 0x5b, 0xf2, 0xd1, 0x26, 0xac, 0x67, 0xdb, 0xce, 0x2b, 0x1a, 0xe2,
- 0xce, 0x0a, 0xda, 0x80, 0x76, 0x5e, 0xbc, 0xd7, 0x29, 0xa0, 0xfb, 0x70, 0x37, 0x27, 0xdc, 0xc7,
- 0x5c, 0x1c, 0x8e, 0x46, 0x94, 0x89, 0xce, 0xea, 0x12, 0xd1, 0xde, 0x4c, 0xd0, 0x4e, 0xf1, 0xe9,
- 0x8f, 0x93, 0x48, 0x32, 0x23, 0x6d, 0x40, 0x35, 0x5e, 0xe1, 0xce, 0x0a, 0x6a, 0x42, 0xed, 0x3c,
- 0x69, 0x16, 0xa4, 0x1b, 0x36, 0xf6, 0x3b, 0xab, 0xa8, 0x0a, 0x25, 0x39, 0xcd, 0x9d, 0xe2, 0xd3,
- 0xbf, 0x29, 0xc0, 0x83, 0x9b, 0x0a, 0x31, 0xfa, 0x2e, 0xfc, 0xda, 0x4d, 0xfa, 0xd8, 0xa3, 0x27,
- 0xf0, 0xe8, 0x46, 0xd8, 0x1e, 0xe7, 0x33, 0x86, 0xfd, 0x4e, 0x01, 0x7d, 0x02, 0x8f, 0x6f, 0x44,
- 0x66, 0xdd, 0x7e, 0xfe, 0x2f, 0x0d, 0xa8, 0xf4, 0x75, 0x60, 0xa0, 0x2e, 0x40, 0x97, 0x70, 0x77,
- 0x18, 0xe0, 0x7e, 0x20, 0x50, 0x5a, 0xc3, 0xd4, 0xa2, 0xef, 0x2c, 0xb4, 0xad, 0xad, 0x5f, 0xfc,
- 0xfb, 0x7f, 0xff, 0x72, 0xb5, 0x63, 0xd5, 0x9f, 0xbd, 0xf9, 0xfc, 0x99, 0xb1, 0xfb, 0xb2, 0xf0,
- 0x14, 0xbd, 0x80, 0xba, 0x8d, 0x71, 0xf8, 0xbe, 0x34, 0x77, 0x15, 0xcd, 0xba, 0xd5, 0x90, 0x34,
- 0xb1, 0xa1, 0xe4, 0x39, 0x84, 0xba, 0x39, 0xd9, 0xe0, 0x7e, 0x38, 0x43, 0x8d, 0xec, 0xc7, 0xf2,
- 0x25, 0x96, 0x6d, 0xc5, 0x82, 0xac, 0xa6, 0x64, 0x39, 0xd4, 0x9d, 0x87, 0x33, 0x49, 0x73, 0x04,
- 0xcd, 0x2e, 0x76, 0xdf, 0x9b, 0xe8, 0x9e, 0x22, 0xda, 0xb0, 0x5a, 0x19, 0xaf, 0x0c, 0xd3, 0x01,
- 0xd4, 0xba, 0x38, 0xc0, 0xb7, 0x1e, 0x4e, 0x62, 0x24, 0x49, 0x4e, 0x00, 0x5e, 0x62, 0xa1, 0xbe,
- 0x64, 0x8f, 0xe8, 0x02, 0xcb, 0x35, 0xff, 0xb8, 0x94, 0x1f, 0x53, 0x6a, 0x2d, 0xe9, 0x7a, 0x00,
- 0xe6, 0x93, 0x5f, 0x7f, 0x26, 0x50, 0x27, 0xf7, 0x5f, 0x4c, 0x27, 0x7c, 0x7c, 0xb3, 0x7b, 0xa9,
- 0xa5, 0xa4, 0xea, 0x43, 0x23, 0xf9, 0xe0, 0x27, 0xc9, 0x50, 0xee, 0xbf, 0x13, 0x94, 0x78, 0x89,
- 0xee, 0xbe, 0xa2, 0xdb, 0xb4, 0x3a, 0x8a, 0x2e, 0x63, 0x2d, 0x09, 0x7f, 0x1f, 0xda, 0xd9, 0x2f,
- 0x7b, 0x92, 0x33, 0x3d, 0xb7, 0x65, 0x35, 0x4b, 0xb4, 0x0f, 0x15, 0xed, 0xb6, 0xb5, 0x21, 0x69,
- 0x17, 0x38, 0x24, 0xf3, 0xd7, 0x50, 0x79, 0x11, 0xd0, 0xf9, 0x9e, 0xef, 0xa3, 0x66, 0xee, 0x1f,
- 0xa2, 0x6e, 0x0e, 0x52, 0x63, 0xa3, 0x83, 0x14, 0x64, 0xcb, 0x56, 0x2f, 0xbb, 0xef, 0x22, 0xc9,
- 0x4d, 0x5a, 0x6a, 0x26, 0x79, 0xce, 0xa0, 0x95, 0x7c, 0x36, 0x3e, 0x98, 0x60, 0xef, 0x62, 0x29,
- 0xde, 0xd3, 0x69, 0x4c, 0x80, 0xd6, 0xb7, 0x14, 0xe1, 0x5d, 0x0b, 0x49, 0xc2, 0xbc, 0xbd, 0x8e,
- 0x91, 0xba, 0x0e, 0xe1, 0x53, 0x1a, 0xf6, 0x46, 0x99, 0x85, 0x48, 0xbe, 0x63, 0x2f, 0x0d, 0x71,
- 0x47, 0x31, 0xde, 0xb1, 0xda, 0x69, 0xfc, 0x2b, 0x63, 0x49, 0x77, 0x0a, 0xd5, 0x97, 0x58, 0x5c,
- 0xcf, 0x75, 0xdd, 0xff, 0xf9, 0xe5, 0x53, 0x33, 0xa6, 0x30, 0xa1, 0x62, 0x52, 0xe3, 0xfd, 0x47,
- 0x98, 0x0b, 0x95, 0xac, 0xb5, 0x24, 0xb4, 0xa1, 0xf9, 0x12, 0x8b, 0xcc, 0xb7, 0xdc, 0xc5, 0x59,
- 0xdc, 0xb8, 0xe2, 0x73, 0x93, 0xf5, 0x40, 0x51, 0x6e, 0x59, 0xeb, 0x66, 0x7c, 0xa9, 0x4a, 0x72,
- 0xfe, 0x18, 0xca, 0x36, 0x1e, 0x52, 0xfa, 0xee, 0x12, 0xb4, 0xa9, 0x78, 0xda, 0x16, 0xe8, 0x12,
- 0x24, 0x6d, 0x24, 0xc1, 0x6b, 0x58, 0x3f, 0xa0, 0x41, 0x80, 0xbd, 0xec, 0xb3, 0xe8, 0xbb, 0xb8,
- 0x76, 0x15, 0xd7, 0x8e, 0xb5, 0x29, 0xb9, 0x96, 0xcc, 0x25, 0xed, 0x31, 0x34, 0x0e, 0x18, 0x76,
- 0x05, 0x36, 0x67, 0xd3, 0x76, 0xfe, 0xac, 0xc8, 0x6f, 0x9e, 0xb9, 0xac, 0xa9, 0x61, 0xd3, 0xd1,
- 0xf8, 0x41, 0x6c, 0x59, 0x53, 0xc9, 0xf6, 0x23, 0xe8, 0xe8, 0xe0, 0xc9, 0xec, 0x4f, 0xd7, 0x2f,
- 0x45, 0x26, 0x54, 0x56, 0x3e, 0x2b, 0x0c, 0xcb, 0xea, 0x73, 0xd0, 0x17, 0xff, 0x17, 0x00, 0x00,
- 0xff, 0xff, 0x76, 0x3f, 0xf9, 0x3e, 0xc6, 0x2a, 0x00, 0x00,
-}
-
-// Reference imports to suppress errors if they are not otherwise used.
-var _ context.Context
-var _ grpc.ClientConn
-
-// This is a compile-time assertion to ensure that this generated file
-// is compatible with the grpc package it is being compiled against.
-const _ = grpc.SupportPackageIsVersion4
-
-// OpenoltClient is the client API for Openolt service.
-//
-// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
-type OpenoltClient interface {
- DisableOlt(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
- ReenableOlt(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
- ActivateOnu(ctx context.Context, in *Onu, opts ...grpc.CallOption) (*Empty, error)
- DeactivateOnu(ctx context.Context, in *Onu, opts ...grpc.CallOption) (*Empty, error)
- DeleteOnu(ctx context.Context, in *Onu, opts ...grpc.CallOption) (*Empty, error)
- GetOnuInfo(ctx context.Context, in *Onu, opts ...grpc.CallOption) (*OnuIndication, error)
- OmciMsgOut(ctx context.Context, in *OmciMsg, opts ...grpc.CallOption) (*Empty, error)
- OnuPacketOut(ctx context.Context, in *OnuPacket, opts ...grpc.CallOption) (*Empty, error)
- UplinkPacketOut(ctx context.Context, in *UplinkPacket, opts ...grpc.CallOption) (*Empty, error)
- FlowAdd(ctx context.Context, in *Flow, opts ...grpc.CallOption) (*Empty, error)
- FlowRemove(ctx context.Context, in *Flow, opts ...grpc.CallOption) (*Empty, error)
- HeartbeatCheck(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Heartbeat, error)
- EnablePonIf(ctx context.Context, in *Interface, opts ...grpc.CallOption) (*Empty, error)
- GetPonIf(ctx context.Context, in *Interface, opts ...grpc.CallOption) (*IntfIndication, error)
- DisablePonIf(ctx context.Context, in *Interface, opts ...grpc.CallOption) (*Empty, error)
- GetDeviceInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DeviceInfo, error)
- Reboot(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
- CollectStatistics(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
- CreateTconts(ctx context.Context, in *Tconts, opts ...grpc.CallOption) (*Empty, error)
- RemoveTconts(ctx context.Context, in *Tconts, opts ...grpc.CallOption) (*Empty, error)
- EnableIndication(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Openolt_EnableIndicationClient, error)
-}
-
-type openoltClient struct {
- cc *grpc.ClientConn
-}
-
-func NewOpenoltClient(cc *grpc.ClientConn) OpenoltClient {
- return &openoltClient{cc}
-}
-
-func (c *openoltClient) DisableOlt(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/DisableOlt", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) ReenableOlt(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/ReenableOlt", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) ActivateOnu(ctx context.Context, in *Onu, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/ActivateOnu", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) DeactivateOnu(ctx context.Context, in *Onu, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/DeactivateOnu", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) DeleteOnu(ctx context.Context, in *Onu, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/DeleteOnu", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) GetOnuInfo(ctx context.Context, in *Onu, opts ...grpc.CallOption) (*OnuIndication, error) {
- out := new(OnuIndication)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/GetOnuInfo", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) OmciMsgOut(ctx context.Context, in *OmciMsg, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/OmciMsgOut", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) OnuPacketOut(ctx context.Context, in *OnuPacket, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/OnuPacketOut", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) UplinkPacketOut(ctx context.Context, in *UplinkPacket, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/UplinkPacketOut", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) FlowAdd(ctx context.Context, in *Flow, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/FlowAdd", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) FlowRemove(ctx context.Context, in *Flow, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/FlowRemove", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) HeartbeatCheck(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Heartbeat, error) {
- out := new(Heartbeat)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/HeartbeatCheck", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) EnablePonIf(ctx context.Context, in *Interface, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/EnablePonIf", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) GetPonIf(ctx context.Context, in *Interface, opts ...grpc.CallOption) (*IntfIndication, error) {
- out := new(IntfIndication)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/GetPonIf", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) DisablePonIf(ctx context.Context, in *Interface, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/DisablePonIf", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) GetDeviceInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DeviceInfo, error) {
- out := new(DeviceInfo)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/GetDeviceInfo", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) Reboot(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/Reboot", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) CollectStatistics(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/CollectStatistics", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) CreateTconts(ctx context.Context, in *Tconts, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/CreateTconts", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) RemoveTconts(ctx context.Context, in *Tconts, opts ...grpc.CallOption) (*Empty, error) {
- out := new(Empty)
- err := c.cc.Invoke(ctx, "/openolt.Openolt/RemoveTconts", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
-func (c *openoltClient) EnableIndication(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Openolt_EnableIndicationClient, error) {
- stream, err := c.cc.NewStream(ctx, &_Openolt_serviceDesc.Streams[0], "/openolt.Openolt/EnableIndication", opts...)
- if err != nil {
- return nil, err
- }
- x := &openoltEnableIndicationClient{stream}
- if err := x.ClientStream.SendMsg(in); err != nil {
- return nil, err
- }
- if err := x.ClientStream.CloseSend(); err != nil {
- return nil, err
- }
- return x, nil
-}
-
-type Openolt_EnableIndicationClient interface {
- Recv() (*Indication, error)
- grpc.ClientStream
-}
-
-type openoltEnableIndicationClient struct {
- grpc.ClientStream
-}
-
-func (x *openoltEnableIndicationClient) Recv() (*Indication, error) {
- m := new(Indication)
- if err := x.ClientStream.RecvMsg(m); err != nil {
- return nil, err
- }
- return m, nil
-}
-
-// OpenoltServer is the server API for Openolt service.
-type OpenoltServer interface {
- DisableOlt(context.Context, *Empty) (*Empty, error)
- ReenableOlt(context.Context, *Empty) (*Empty, error)
- ActivateOnu(context.Context, *Onu) (*Empty, error)
- DeactivateOnu(context.Context, *Onu) (*Empty, error)
- DeleteOnu(context.Context, *Onu) (*Empty, error)
- GetOnuInfo(context.Context, *Onu) (*OnuIndication, error)
- OmciMsgOut(context.Context, *OmciMsg) (*Empty, error)
- OnuPacketOut(context.Context, *OnuPacket) (*Empty, error)
- UplinkPacketOut(context.Context, *UplinkPacket) (*Empty, error)
- FlowAdd(context.Context, *Flow) (*Empty, error)
- FlowRemove(context.Context, *Flow) (*Empty, error)
- HeartbeatCheck(context.Context, *Empty) (*Heartbeat, error)
- EnablePonIf(context.Context, *Interface) (*Empty, error)
- GetPonIf(context.Context, *Interface) (*IntfIndication, error)
- DisablePonIf(context.Context, *Interface) (*Empty, error)
- GetDeviceInfo(context.Context, *Empty) (*DeviceInfo, error)
- Reboot(context.Context, *Empty) (*Empty, error)
- CollectStatistics(context.Context, *Empty) (*Empty, error)
- CreateTconts(context.Context, *Tconts) (*Empty, error)
- RemoveTconts(context.Context, *Tconts) (*Empty, error)
- EnableIndication(*Empty, Openolt_EnableIndicationServer) error
-}
-
-// UnimplementedOpenoltServer can be embedded to have forward compatible implementations.
-type UnimplementedOpenoltServer struct {
-}
-
-func (*UnimplementedOpenoltServer) DisableOlt(ctx context.Context, req *Empty) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method DisableOlt not implemented")
-}
-func (*UnimplementedOpenoltServer) ReenableOlt(ctx context.Context, req *Empty) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method ReenableOlt not implemented")
-}
-func (*UnimplementedOpenoltServer) ActivateOnu(ctx context.Context, req *Onu) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method ActivateOnu not implemented")
-}
-func (*UnimplementedOpenoltServer) DeactivateOnu(ctx context.Context, req *Onu) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method DeactivateOnu not implemented")
-}
-func (*UnimplementedOpenoltServer) DeleteOnu(ctx context.Context, req *Onu) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method DeleteOnu not implemented")
-}
-func (*UnimplementedOpenoltServer) GetOnuInfo(ctx context.Context, req *Onu) (*OnuIndication, error) {
- return nil, status.Errorf(codes.Unimplemented, "method GetOnuInfo not implemented")
-}
-func (*UnimplementedOpenoltServer) OmciMsgOut(ctx context.Context, req *OmciMsg) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method OmciMsgOut not implemented")
-}
-func (*UnimplementedOpenoltServer) OnuPacketOut(ctx context.Context, req *OnuPacket) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method OnuPacketOut not implemented")
-}
-func (*UnimplementedOpenoltServer) UplinkPacketOut(ctx context.Context, req *UplinkPacket) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method UplinkPacketOut not implemented")
-}
-func (*UnimplementedOpenoltServer) FlowAdd(ctx context.Context, req *Flow) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method FlowAdd not implemented")
-}
-func (*UnimplementedOpenoltServer) FlowRemove(ctx context.Context, req *Flow) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method FlowRemove not implemented")
-}
-func (*UnimplementedOpenoltServer) HeartbeatCheck(ctx context.Context, req *Empty) (*Heartbeat, error) {
- return nil, status.Errorf(codes.Unimplemented, "method HeartbeatCheck not implemented")
-}
-func (*UnimplementedOpenoltServer) EnablePonIf(ctx context.Context, req *Interface) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method EnablePonIf not implemented")
-}
-func (*UnimplementedOpenoltServer) GetPonIf(ctx context.Context, req *Interface) (*IntfIndication, error) {
- return nil, status.Errorf(codes.Unimplemented, "method GetPonIf not implemented")
-}
-func (*UnimplementedOpenoltServer) DisablePonIf(ctx context.Context, req *Interface) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method DisablePonIf not implemented")
-}
-func (*UnimplementedOpenoltServer) GetDeviceInfo(ctx context.Context, req *Empty) (*DeviceInfo, error) {
- return nil, status.Errorf(codes.Unimplemented, "method GetDeviceInfo not implemented")
-}
-func (*UnimplementedOpenoltServer) Reboot(ctx context.Context, req *Empty) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method Reboot not implemented")
-}
-func (*UnimplementedOpenoltServer) CollectStatistics(ctx context.Context, req *Empty) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method CollectStatistics not implemented")
-}
-func (*UnimplementedOpenoltServer) CreateTconts(ctx context.Context, req *Tconts) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method CreateTconts not implemented")
-}
-func (*UnimplementedOpenoltServer) RemoveTconts(ctx context.Context, req *Tconts) (*Empty, error) {
- return nil, status.Errorf(codes.Unimplemented, "method RemoveTconts not implemented")
-}
-func (*UnimplementedOpenoltServer) EnableIndication(req *Empty, srv Openolt_EnableIndicationServer) error {
- return status.Errorf(codes.Unimplemented, "method EnableIndication not implemented")
-}
-
-func RegisterOpenoltServer(s *grpc.Server, srv OpenoltServer) {
- s.RegisterService(&_Openolt_serviceDesc, srv)
-}
-
-func _Openolt_DisableOlt_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Empty)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).DisableOlt(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/DisableOlt",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).DisableOlt(ctx, req.(*Empty))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_ReenableOlt_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Empty)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).ReenableOlt(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/ReenableOlt",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).ReenableOlt(ctx, req.(*Empty))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_ActivateOnu_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Onu)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).ActivateOnu(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/ActivateOnu",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).ActivateOnu(ctx, req.(*Onu))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_DeactivateOnu_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Onu)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).DeactivateOnu(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/DeactivateOnu",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).DeactivateOnu(ctx, req.(*Onu))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_DeleteOnu_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Onu)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).DeleteOnu(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/DeleteOnu",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).DeleteOnu(ctx, req.(*Onu))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_GetOnuInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Onu)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).GetOnuInfo(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/GetOnuInfo",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).GetOnuInfo(ctx, req.(*Onu))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_OmciMsgOut_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(OmciMsg)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).OmciMsgOut(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/OmciMsgOut",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).OmciMsgOut(ctx, req.(*OmciMsg))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_OnuPacketOut_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(OnuPacket)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).OnuPacketOut(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/OnuPacketOut",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).OnuPacketOut(ctx, req.(*OnuPacket))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_UplinkPacketOut_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(UplinkPacket)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).UplinkPacketOut(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/UplinkPacketOut",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).UplinkPacketOut(ctx, req.(*UplinkPacket))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_FlowAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Flow)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).FlowAdd(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/FlowAdd",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).FlowAdd(ctx, req.(*Flow))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_FlowRemove_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Flow)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).FlowRemove(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/FlowRemove",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).FlowRemove(ctx, req.(*Flow))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_HeartbeatCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Empty)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).HeartbeatCheck(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/HeartbeatCheck",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).HeartbeatCheck(ctx, req.(*Empty))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_EnablePonIf_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Interface)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).EnablePonIf(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/EnablePonIf",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).EnablePonIf(ctx, req.(*Interface))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_GetPonIf_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Interface)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).GetPonIf(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/GetPonIf",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).GetPonIf(ctx, req.(*Interface))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_DisablePonIf_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Interface)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).DisablePonIf(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/DisablePonIf",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).DisablePonIf(ctx, req.(*Interface))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_GetDeviceInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Empty)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).GetDeviceInfo(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/GetDeviceInfo",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).GetDeviceInfo(ctx, req.(*Empty))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_Reboot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Empty)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).Reboot(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/Reboot",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).Reboot(ctx, req.(*Empty))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_CollectStatistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Empty)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).CollectStatistics(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/CollectStatistics",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).CollectStatistics(ctx, req.(*Empty))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_CreateTconts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Tconts)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).CreateTconts(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/CreateTconts",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).CreateTconts(ctx, req.(*Tconts))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_RemoveTconts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(Tconts)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(OpenoltServer).RemoveTconts(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/openolt.Openolt/RemoveTconts",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(OpenoltServer).RemoveTconts(ctx, req.(*Tconts))
- }
- return interceptor(ctx, in, info, handler)
-}
-
-func _Openolt_EnableIndication_Handler(srv interface{}, stream grpc.ServerStream) error {
- m := new(Empty)
- if err := stream.RecvMsg(m); err != nil {
- return err
- }
- return srv.(OpenoltServer).EnableIndication(m, &openoltEnableIndicationServer{stream})
-}
-
-type Openolt_EnableIndicationServer interface {
- Send(*Indication) error
- grpc.ServerStream
-}
-
-type openoltEnableIndicationServer struct {
- grpc.ServerStream
-}
-
-func (x *openoltEnableIndicationServer) Send(m *Indication) error {
- return x.ServerStream.SendMsg(m)
-}
-
-var _Openolt_serviceDesc = grpc.ServiceDesc{
- ServiceName: "openolt.Openolt",
- HandlerType: (*OpenoltServer)(nil),
- Methods: []grpc.MethodDesc{
- {
- MethodName: "DisableOlt",
- Handler: _Openolt_DisableOlt_Handler,
- },
- {
- MethodName: "ReenableOlt",
- Handler: _Openolt_ReenableOlt_Handler,
- },
- {
- MethodName: "ActivateOnu",
- Handler: _Openolt_ActivateOnu_Handler,
- },
- {
- MethodName: "DeactivateOnu",
- Handler: _Openolt_DeactivateOnu_Handler,
- },
- {
- MethodName: "DeleteOnu",
- Handler: _Openolt_DeleteOnu_Handler,
- },
- {
- MethodName: "GetOnuInfo",
- Handler: _Openolt_GetOnuInfo_Handler,
- },
- {
- MethodName: "OmciMsgOut",
- Handler: _Openolt_OmciMsgOut_Handler,
- },
- {
- MethodName: "OnuPacketOut",
- Handler: _Openolt_OnuPacketOut_Handler,
- },
- {
- MethodName: "UplinkPacketOut",
- Handler: _Openolt_UplinkPacketOut_Handler,
- },
- {
- MethodName: "FlowAdd",
- Handler: _Openolt_FlowAdd_Handler,
- },
- {
- MethodName: "FlowRemove",
- Handler: _Openolt_FlowRemove_Handler,
- },
- {
- MethodName: "HeartbeatCheck",
- Handler: _Openolt_HeartbeatCheck_Handler,
- },
- {
- MethodName: "EnablePonIf",
- Handler: _Openolt_EnablePonIf_Handler,
- },
- {
- MethodName: "GetPonIf",
- Handler: _Openolt_GetPonIf_Handler,
- },
- {
- MethodName: "DisablePonIf",
- Handler: _Openolt_DisablePonIf_Handler,
- },
- {
- MethodName: "GetDeviceInfo",
- Handler: _Openolt_GetDeviceInfo_Handler,
- },
- {
- MethodName: "Reboot",
- Handler: _Openolt_Reboot_Handler,
- },
- {
- MethodName: "CollectStatistics",
- Handler: _Openolt_CollectStatistics_Handler,
- },
- {
- MethodName: "CreateTconts",
- Handler: _Openolt_CreateTconts_Handler,
- },
- {
- MethodName: "RemoveTconts",
- Handler: _Openolt_RemoveTconts_Handler,
- },
- },
- Streams: []grpc.StreamDesc{
- {
- StreamName: "EnableIndication",
- Handler: _Openolt_EnableIndication_Handler,
- ServerStreams: true,
- },
- },
- Metadata: "api/openolt.proto",
-}
diff --git a/api/openolt.proto b/api/openolt/openolt.proto
similarity index 100%
rename from api/openolt.proto
rename to api/openolt/openolt.proto
diff --git a/build/package/Dockerfile b/build/package/Dockerfile
index b40783f..5af257d 100644
--- a/build/package/Dockerfile
+++ b/build/package/Dockerfile
@@ -46,7 +46,13 @@
# copy and build
COPY . ./
-RUN GO111MODULE=on go build -o ./cmd/bbsim ./internal/bbsim
+ARG GIT_STATUS=Clean
+RUN GO111MODULE=on go build \
+ -ldflags "-X main.buildTime=$(date +”%Y/%m/%d-%H:%M:%S”) \
+ -X main.commitHash=$(git log --pretty=format:%H -n 1) \
+ -X main.gitStatus=${GIT_STATUS}\
+ -X main.version=$(cat VERSION)" \
+ -o ./cmd/bbsim ./internal/bbsim
# runtime parent
FROM golang:1.12-stretch
@@ -68,4 +74,4 @@
WORKDIR /app
COPY --from=builder /go/src/gerrit.opencord.org/bbsim/cmd/bbsim /app/bbsim
RUN chmod a+x /app/bbsim
-CMD [ '/app/bbsim' ]
+ENTRYPOINT [ '/app/bbsim' ]
diff --git a/deployments/README.md b/deployments/README.md
deleted file mode 100644
index fe4d5d3..0000000
--- a/deployments/README.md
+++ /dev/null
@@ -1 +0,0 @@
-Coming soon
\ No newline at end of file
diff --git a/deployments/helm-chart/bbsim/templates/service.yaml b/deployments/helm-chart/bbsim/templates/service.yaml
index d63c129..6771da7 100644
--- a/deployments/helm-chart/bbsim/templates/service.yaml
+++ b/deployments/helm-chart/bbsim/templates/service.yaml
@@ -16,7 +16,7 @@
apiVersion: v1
kind: Service
metadata:
- name: {{ template "bbsim.fullname" . }}
+ name: bbsim-olt-id-{{ .Values.olt_id }}
namespace: {{ .Values.namespace }}
labels:
app: {{ template "bbsim.name" . }}
@@ -29,6 +29,9 @@
- name: "bbsim-olt-id-{{ .Values.olt_id }}"
port: {{ .Values.olt_tcp_port }}
protocol: TCP
+ - name: "bbsim-olt-id-{{ .Values.olt_id }}-api"
+ port: {{ .Values.bbsim_api_port }}
+ protocol: TCP
selector:
app: {{ template "bbsim.name" . }}
- release: {{ .Release.Name }}
+ release: {{ .Release.Name }}
\ No newline at end of file
diff --git a/deployments/helm-chart/bbsim/values.yaml b/deployments/helm-chart/bbsim/values.yaml
index 9d37587..5c0161c 100644
--- a/deployments/helm-chart/bbsim/values.yaml
+++ b/deployments/helm-chart/bbsim/values.yaml
@@ -21,8 +21,9 @@
pon: 1
onu: 1
-# TODO read this value in the config
+# TODO read this values in the config
olt_tcp_port: 50060
+bbsim_api_port: 50070
images:
bbsim:
diff --git a/internal/bbsim/bbsim.go b/internal/bbsim/bbsim.go
index d0acc14..589d557 100644
--- a/internal/bbsim/bbsim.go
+++ b/internal/bbsim/bbsim.go
@@ -2,8 +2,12 @@
import (
"flag"
+ "gerrit.opencord.org/bbsim/api/bbsim"
"gerrit.opencord.org/bbsim/internal/bbsim/devices"
log "github.com/sirupsen/logrus"
+ "google.golang.org/grpc"
+ "google.golang.org/grpc/reflection"
+ "net"
"sync"
)
@@ -25,6 +29,22 @@
return o
}
+func startApiServer() {
+ // TODO make configurable
+ address := "0.0.0.0:50070"
+ log.Debugf("APIServer Listening on: %v", address)
+ lis, err := net.Listen("tcp", address)
+ if err != nil {
+ log.Fatalf("APIServer failed to listen: %v", err)
+ }
+ grpcServer := grpc.NewServer()
+ bbsim.RegisterBBSimServer(grpcServer, BBSimServer{})
+
+ reflection.Register(grpcServer)
+
+ go grpcServer.Serve(lis)
+}
+
func init() {
log.SetLevel(log.DebugLevel)
//log.SetReportCaller(true)
@@ -42,11 +62,13 @@
}).Info("BroadBand Simulator is on")
wg := sync.WaitGroup{}
- wg.Add(1)
+ wg.Add(2)
go devices.CreateOLT(options.OltID, options.NumNniPerOlt, options.NumPonPerOlt, options.NumOnuPerPon)
log.Debugf("Created OLT with id: %d", options.OltID)
+ go startApiServer()
+ log.Debugf("Started APIService")
wg.Wait()
diff --git a/internal/bbsim/devices/olt.go b/internal/bbsim/devices/olt.go
index 8435af1..2c3486e 100644
--- a/internal/bbsim/devices/olt.go
+++ b/internal/bbsim/devices/olt.go
@@ -4,7 +4,7 @@
"context"
"errors"
"fmt"
- "gerrit.opencord.org/bbsim/api"
+ "gerrit.opencord.org/bbsim/api/openolt"
"github.com/looplab/fsm"
log "github.com/sirupsen/logrus"
"google.golang.org/grpc"
@@ -12,20 +12,30 @@
"sync"
)
+var logger = log.WithFields(log.Fields{
+ "module": "OLT",
+})
+
func init() {
//log.SetReportCaller(true)
log.SetLevel(log.DebugLevel)
}
+var olt = OltDevice{}
+
+func GetOLT() OltDevice {
+ return olt
+}
+
func CreateOLT(seq int, nni int, pon int, onuPerPon int) OltDevice {
- log.WithFields(log.Fields{
+ logger.WithFields(log.Fields{
"ID": seq,
"NumNni":nni,
"NumPon":pon,
"NumOnuPerPon":onuPerPon,
}).Debug("CreateOLT")
- olt := OltDevice{
+ olt = OltDevice{
ID: seq,
NumNni:nni,
NumPon:pon,
@@ -86,15 +96,15 @@
func newOltServer(o OltDevice) error {
// TODO make configurable
address := "0.0.0.0:50060"
- log.Debugf("OLT Listening on: %v", address)
lis, err := net.Listen("tcp", address)
if err != nil {
- log.Fatalf("failed to listen: %v", err)
+ logger.Fatalf("OLT failed to listen: %v", err)
}
grpcServer := grpc.NewServer()
openolt.RegisterOpenoltServer(grpcServer, o)
go grpcServer.Serve(lis)
+ logger.Debugf("OLT Listening on: %v", address)
return nil
}
@@ -103,6 +113,8 @@
func (o OltDevice) Enable (stream openolt.Openolt_EnableIndicationServer) error {
+ logger.Debug("Enable OLT called")
+
wg := sync.WaitGroup{}
wg.Add(1)
@@ -178,7 +190,7 @@
}
func (o OltDevice) stateChange(e *fsm.Event) {
- log.WithFields(log.Fields{
+ logger.WithFields(log.Fields{
"oltId": o.ID,
"dstState": e.Dst,
"srcState": e.Src,
@@ -188,10 +200,10 @@
func (o OltDevice) sendOltIndication(msg OltIndicationMessage, stream openolt.Openolt_EnableIndicationServer) {
data := &openolt.Indication_OltInd{OltInd: &openolt.OltIndication{OperState: msg.OperState.String()}}
if err := stream.Send(&openolt.Indication{Data: data}); err != nil {
- log.Error("Failed to send Indication_OltInd: %v", err)
+ logger.Error("Failed to send Indication_OltInd: %v", err)
}
- log.WithFields(log.Fields{
+ logger.WithFields(log.Fields{
"OperState": msg.OperState,
}).Debug("Sent Indication_OltInd")
}
@@ -206,10 +218,10 @@
}}
if err := stream.Send(&openolt.Indication{Data: operData}); err != nil {
- log.Error("Failed to send Indication_IntfOperInd for NNI: %v", err)
+ logger.Error("Failed to send Indication_IntfOperInd for NNI: %v", err)
}
- log.WithFields(log.Fields{
+ logger.WithFields(log.Fields{
"Type": nni.Type,
"IntfId": nni.ID,
"OperState": nni.OperState.String(),
@@ -225,10 +237,10 @@
}}
if err := stream.Send(&openolt.Indication{Data: discoverData}); err != nil {
- log.Error("Failed to send Indication_IntfInd: %v", err)
+ logger.Error("Failed to send Indication_IntfInd: %v", err)
}
- log.WithFields(log.Fields{
+ logger.WithFields(log.Fields{
"IntfId": pon.ID,
"OperState": pon.OperState.String(),
}).Debug("Sent Indication_IntfInd")
@@ -240,10 +252,10 @@
}}
if err := stream.Send(&openolt.Indication{Data: operData}); err != nil {
- log.Error("Failed to send Indication_IntfOperInd for PON: %v", err)
+ logger.Error("Failed to send Indication_IntfOperInd for PON: %v", err)
}
- log.WithFields(log.Fields{
+ logger.WithFields(log.Fields{
"Type": pon.Type,
"IntfId": pon.ID,
"OperState": pon.OperState.String(),
@@ -251,12 +263,12 @@
}
func (o OltDevice) oltChannels(stream openolt.Openolt_EnableIndicationServer) {
-
+ logger.Debug("Started OLT Indication Channel")
for message := range o.channel {
_msg, _ok := message.(Message)
if _ok {
- log.WithFields(log.Fields{
+ logger.WithFields(log.Fields{
"oltId": o.ID,
"messageType": _msg.Type,
}).Debug("Received message")
@@ -283,10 +295,10 @@
onu.InternalState.Event("enable")
onu.sendOnuIndication(msg, stream)
default:
- log.Warnf("Received unkown message data %v for type %v", _msg.Data, _msg.Type)
+ logger.Warnf("Received unkown message data %v for type %v", _msg.Data, _msg.Type)
}
} else {
- log.Warnf("Received unkown message %v", message)
+ logger.Warnf("Received unkown message %v", message)
}
}
@@ -295,7 +307,7 @@
// GRPC Endpoints
func (o OltDevice) ActivateOnu(context context.Context, onu *openolt.Onu) (*openolt.Empty, error) {
- log.WithFields(log.Fields{
+ logger.WithFields(log.Fields{
"onuSerialNumber": onu.SerialNumber,
}).Info("Received ActivateOnu call from VOLTHA")
msg := Message{
@@ -311,58 +323,58 @@
}
func (o OltDevice) DeactivateOnu(context.Context, *openolt.Onu) (*openolt.Empty, error) {
- log.Error("DeactivateOnu not implemented")
+ logger.Error("DeactivateOnu not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) DeleteOnu(context.Context, *openolt.Onu) (*openolt.Empty, error) {
- log.Error("DeleteOnu not implemented")
+ logger.Error("DeleteOnu not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) DisableOlt(context.Context, *openolt.Empty) (*openolt.Empty, error) {
- log.Error("DisableOlt not implemented")
+ logger.Error("DisableOlt not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) DisablePonIf(context.Context, *openolt.Interface) (*openolt.Empty, error) {
- log.Error("DisablePonIf not implemented")
+ logger.Error("DisablePonIf not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) EnableIndication(_ *openolt.Empty, stream openolt.Openolt_EnableIndicationServer) error {
- log.WithField("oltId", o.ID).Info("OLT receives EnableIndication call from VOLTHA")
+ logger.WithField("oltId", o.ID).Info("OLT receives EnableIndication call from VOLTHA")
o.Enable(stream)
return nil
}
func (o OltDevice) EnablePonIf(context.Context, *openolt.Interface) (*openolt.Empty, error) {
- log.Error("EnablePonIf not implemented")
+ logger.Error("EnablePonIf not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) FlowAdd(context.Context, *openolt.Flow) (*openolt.Empty, error) {
- log.Error("FlowAdd not implemented")
+ logger.Error("FlowAdd not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) FlowRemove(context.Context, *openolt.Flow) (*openolt.Empty, error) {
- log.Error("FlowRemove not implemented")
+ logger.Error("FlowRemove not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) HeartbeatCheck(context.Context, *openolt.Empty) (*openolt.Heartbeat, error) {
- log.Error("HeartbeatCheck not implemented")
+ logger.Error("HeartbeatCheck not implemented")
return new(openolt.Heartbeat) , nil
}
func (o OltDevice) GetDeviceInfo(context.Context, *openolt.Empty) (*openolt.DeviceInfo, error) {
- log.WithField("oltId", o.ID).Info("OLT receives GetDeviceInfo call from VOLTHA")
+ logger.WithField("oltId", o.ID).Info("OLT receives GetDeviceInfo call from VOLTHA")
devinfo := new(openolt.DeviceInfo)
devinfo.Vendor = "BBSim"
devinfo.Model = "asfvolt16"
- devinfo.HardwareVersion = ""
+ devinfo.HardwareVersion = "emulated"
devinfo.FirmwareVersion = ""
devinfo.Technology = "xgspon"
devinfo.PonPorts = 1
@@ -374,56 +386,57 @@
devinfo.GemportIdEnd = 65535
devinfo.FlowIdStart = 1
devinfo.FlowIdEnd = 16383
+ devinfo.DeviceSerialNumber = fmt.Sprintf("BBSIM_OLT_%d", o.ID)
return devinfo, nil
}
func (o OltDevice) OmciMsgOut(context.Context, *openolt.OmciMsg) (*openolt.Empty, error) {
- log.Error("OmciMsgOut not implemented")
+ logger.Error("OmciMsgOut not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) OnuPacketOut(context.Context, *openolt.OnuPacket) (*openolt.Empty, error) {
- log.Error("OnuPacketOut not implemented")
+ logger.Error("OnuPacketOut not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) Reboot(context.Context, *openolt.Empty) (*openolt.Empty, error) {
- log.Error("Reboot not implemented")
+ logger.Error("Reboot not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) ReenableOlt(context.Context, *openolt.Empty) (*openolt.Empty, error) {
- log.Error("ReenableOlt not implemented")
+ logger.Error("ReenableOlt not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) UplinkPacketOut(context context.Context, packet *openolt.UplinkPacket) (*openolt.Empty, error) {
- log.Error("UplinkPacketOut not implemented")
+ logger.Error("UplinkPacketOut not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) CollectStatistics(context.Context, *openolt.Empty) (*openolt.Empty, error) {
- log.Error("CollectStatistics not implemented")
+ logger.Error("CollectStatistics not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) CreateTconts(context context.Context, packet *openolt.Tconts) (*openolt.Empty, error) {
- log.Error("CreateTconts not implemented")
+ logger.Error("CreateTconts not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) RemoveTconts(context context.Context, packet *openolt.Tconts) (*openolt.Empty, error) {
- log.Error("RemoveTconts not implemented")
+ logger.Error("RemoveTconts not implemented")
return new(openolt.Empty) , nil
}
func (o OltDevice) GetOnuInfo(context context.Context, packet *openolt.Onu) (*openolt.OnuIndication, error) {
- log.Error("GetOnuInfo not implemented")
+ logger.Error("GetOnuInfo not implemented")
return new(openolt.OnuIndication) , nil
}
func (o OltDevice) GetPonIf(context context.Context, packet *openolt.Interface) (*openolt.IntfIndication, error) {
- log.Error("GetPonIf not implemented")
+ logger.Error("GetPonIf not implemented")
return new(openolt.IntfIndication) , nil
}
\ No newline at end of file
diff --git a/internal/bbsim/devices/onu.go b/internal/bbsim/devices/onu.go
index 2b7ee07..1569127 100644
--- a/internal/bbsim/devices/onu.go
+++ b/internal/bbsim/devices/onu.go
@@ -1,7 +1,7 @@
package devices
import (
- "gerrit.opencord.org/bbsim/api"
+ "gerrit.opencord.org/bbsim/api/openolt"
"github.com/looplab/fsm"
log "github.com/sirupsen/logrus"
)
diff --git a/internal/bbsim/devices/types.go b/internal/bbsim/devices/types.go
index bb1be32..5edabd7 100644
--- a/internal/bbsim/devices/types.go
+++ b/internal/bbsim/devices/types.go
@@ -5,7 +5,7 @@
"errors"
"fmt"
"github.com/looplab/fsm"
- "gerrit.opencord.org/bbsim/api"
+ "gerrit.opencord.org/bbsim/api/openolt"
)
// Devices
@@ -65,8 +65,7 @@
Nnis []NniPort
// OLT Attributes
- OperState int
- AdminState int
+ OperState OperState
}
// BBSim Internals
@@ -128,10 +127,8 @@
type OperState int
const (
- UP OperState = 0
-
- // The device has been discovered, but not yet activated
- DOWN OperState = 1
+ UP OperState = iota
+ DOWN // The device has been discovered, but not yet activated
)
func (m OperState) String() string {
diff --git a/internal/bbsim/grpc_api_server.go b/internal/bbsim/grpc_api_server.go
new file mode 100644
index 0000000..f47dc03
--- /dev/null
+++ b/internal/bbsim/grpc_api_server.go
@@ -0,0 +1,63 @@
+package main
+
+import (
+ "context"
+ "fmt"
+ "gerrit.opencord.org/bbsim/api/bbsim"
+ "gerrit.opencord.org/bbsim/internal/bbsim/devices"
+ log "github.com/sirupsen/logrus"
+)
+
+var logger = log.WithFields(log.Fields{
+ "module": "GrpcApiServer",
+})
+
+var (
+ version string
+ buildTime string
+ commitHash string
+ gitStatus string
+)
+
+type BBSimServer struct {
+}
+
+func (s BBSimServer) Version(ctx context.Context, req *bbsim.Empty) (*bbsim.VersionNumber, error) {
+ // TODO add a flag to specofy whether the tree was clean at this commit or not
+ return &bbsim.VersionNumber{
+ Version: version,
+ BuildTime: buildTime,
+ CommitHash: commitHash,
+ GitStatus: gitStatus,
+ }, nil
+}
+
+func (s BBSimServer) GetOlt(ctx context.Context, req *bbsim.Empty) (*bbsim.Olt, error) {
+ olt := devices.GetOLT()
+ nnis := []*bbsim.NNIPort{}
+ pons := []*bbsim.PONPort{}
+
+ for _, nni := range olt.Nnis {
+ n := bbsim.NNIPort{
+ ID: int32(nni.ID),
+ OperState: fmt.Sprintf("%s", nni.OperState),
+ }
+ nnis = append(nnis, &n)
+ }
+
+ for _, pon := range olt.Pons {
+ p := bbsim.PONPort{
+ ID: int32(pon.ID),
+ OperState: fmt.Sprintf("%s", pon.OperState),
+ }
+ pons = append(pons, &p)
+ }
+
+ res := bbsim.Olt{
+ ID: int32(olt.ID),
+ OperState: fmt.Sprintf("%s", olt.OperState),
+ NNIPorts: nnis,
+ PONPorts: pons,
+ }
+ return &res, nil
+}
\ No newline at end of file