bbsim

package
v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 12, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package bbsim is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var AlarmType_Types_name = map[int32]string{
	0:  "LOS",
	1:  "DYING_GASP",
	2:  "ONU_ALARM",
	3:  "ONU_STARTUP_FAILURE",
	4:  "ONU_SIGNAL_DEGRADE",
	5:  "ONU_DRIFT_OF_WINDOW",
	6:  "ONU_LOSS_OF_OMCI_CHANNEL",
	7:  "ONU_SIGNALS_FAILURE",
	8:  "ONU_TRANSMISSION_INTERFERENCE_WARNING",
	9:  "ONU_ACTIVATION_FAILURE",
	10: "ONU_PROCESSING_ERROR",
	11: "ONU_LOSS_OF_KEY_SYNC_FAILURE",
	12: "ONU_ITU_PON_STATS",
	13: "ONU_ALARM_LOS",
	14: "ONU_ALARM_LOB",
	15: "ONU_ALARM_LOPC_MISS",
	16: "ONU_ALARM_LOPC_MIC_ERROR",
	17: "ONU_ALARM_LOFI",
	18: "ONU_ALARM_LOAMI",
}
View Source
var AlarmType_Types_value = map[string]int32{
	"LOS":                                   0,
	"DYING_GASP":                            1,
	"ONU_ALARM":                             2,
	"ONU_STARTUP_FAILURE":                   3,
	"ONU_SIGNAL_DEGRADE":                    4,
	"ONU_DRIFT_OF_WINDOW":                   5,
	"ONU_LOSS_OF_OMCI_CHANNEL":              6,
	"ONU_SIGNALS_FAILURE":                   7,
	"ONU_TRANSMISSION_INTERFERENCE_WARNING": 8,
	"ONU_ACTIVATION_FAILURE":                9,
	"ONU_PROCESSING_ERROR":                  10,
	"ONU_LOSS_OF_KEY_SYNC_FAILURE":          11,
	"ONU_ITU_PON_STATS":                     12,
	"ONU_ALARM_LOS":                         13,
	"ONU_ALARM_LOB":                         14,
	"ONU_ALARM_LOPC_MISS":                   15,
	"ONU_ALARM_LOPC_MIC_ERROR":              16,
	"ONU_ALARM_LOFI":                        17,
	"ONU_ALARM_LOAMI":                       18,
}
View Source
var SubActionTypes_name = map[int32]string{
	0: "JOIN",
	1: "LEAVE",
	2: "JOINV3",
}
View Source
var SubActionTypes_value = map[string]int32{
	"JOIN":   0,
	"LEAVE":  1,
	"JOINV3": 2,
}

Functions

func RegisterBBSimHandler

func RegisterBBSimHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBBSimHandler registers the http handlers for service BBSim to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBBSimHandlerClient

func RegisterBBSimHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BBSimClient) error

RegisterBBSimHandlerClient registers the http handlers for service BBSim to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BBSimClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BBSimClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BBSimClient" to call the correct interceptors.

func RegisterBBSimHandlerFromEndpoint

func RegisterBBSimHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBBSimHandlerFromEndpoint is same as RegisterBBSimHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBBSimHandlerServer

func RegisterBBSimHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BBSimServer) error

RegisterBBSimHandlerServer registers the http handlers for service BBSim to "mux". UnaryRPC :call BBSimServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterBBSimServer

func RegisterBBSimServer(s *grpc.Server, srv BBSimServer)

Types

type AlarmParameter added in v0.0.12

type AlarmParameter struct {
	Key                  string   `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlarmParameter) Descriptor added in v0.0.12

func (*AlarmParameter) Descriptor() ([]byte, []int)

func (*AlarmParameter) GetKey added in v0.0.12

func (m *AlarmParameter) GetKey() string

func (*AlarmParameter) GetValue added in v0.0.12

func (m *AlarmParameter) GetValue() string

func (*AlarmParameter) ProtoMessage added in v0.0.12

func (*AlarmParameter) ProtoMessage()

func (*AlarmParameter) Reset added in v0.0.12

func (m *AlarmParameter) Reset()

func (*AlarmParameter) String added in v0.0.12

func (m *AlarmParameter) String() string

func (*AlarmParameter) XXX_DiscardUnknown added in v0.0.12

func (m *AlarmParameter) XXX_DiscardUnknown()

func (*AlarmParameter) XXX_Marshal added in v0.0.12

func (m *AlarmParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlarmParameter) XXX_Merge added in v0.0.12

func (m *AlarmParameter) XXX_Merge(src proto.Message)

func (*AlarmParameter) XXX_Size added in v0.0.12

func (m *AlarmParameter) XXX_Size() int

func (*AlarmParameter) XXX_Unmarshal added in v0.0.12

func (m *AlarmParameter) XXX_Unmarshal(b []byte) error

type AlarmType added in v0.0.12

type AlarmType struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlarmType) Descriptor added in v0.0.12

func (*AlarmType) Descriptor() ([]byte, []int)

func (*AlarmType) ProtoMessage added in v0.0.12

func (*AlarmType) ProtoMessage()

func (*AlarmType) Reset added in v0.0.12

func (m *AlarmType) Reset()

func (*AlarmType) String added in v0.0.12

func (m *AlarmType) String() string

func (*AlarmType) XXX_DiscardUnknown added in v0.0.12

func (m *AlarmType) XXX_DiscardUnknown()

func (*AlarmType) XXX_Marshal added in v0.0.12

func (m *AlarmType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlarmType) XXX_Merge added in v0.0.12

func (m *AlarmType) XXX_Merge(src proto.Message)

func (*AlarmType) XXX_Size added in v0.0.12

func (m *AlarmType) XXX_Size() int

func (*AlarmType) XXX_Unmarshal added in v0.0.12

func (m *AlarmType) XXX_Unmarshal(b []byte) error

type AlarmType_Types added in v0.0.12

type AlarmType_Types int32

These types correspond to the messages permitted in the oneof in AlarmIndication in the openolt protos

const (
	AlarmType_LOS                                   AlarmType_Types = 0
	AlarmType_DYING_GASP                            AlarmType_Types = 1
	AlarmType_ONU_ALARM                             AlarmType_Types = 2
	AlarmType_ONU_STARTUP_FAILURE                   AlarmType_Types = 3
	AlarmType_ONU_SIGNAL_DEGRADE                    AlarmType_Types = 4
	AlarmType_ONU_DRIFT_OF_WINDOW                   AlarmType_Types = 5
	AlarmType_ONU_LOSS_OF_OMCI_CHANNEL              AlarmType_Types = 6
	AlarmType_ONU_SIGNALS_FAILURE                   AlarmType_Types = 7
	AlarmType_ONU_TRANSMISSION_INTERFERENCE_WARNING AlarmType_Types = 8
	AlarmType_ONU_ACTIVATION_FAILURE                AlarmType_Types = 9
	AlarmType_ONU_PROCESSING_ERROR                  AlarmType_Types = 10
	AlarmType_ONU_LOSS_OF_KEY_SYNC_FAILURE          AlarmType_Types = 11
	AlarmType_ONU_ITU_PON_STATS                     AlarmType_Types = 12
	// These break out ONU_ALARM, which is a single message, but
	// includes statuses for these six alarms.
	AlarmType_ONU_ALARM_LOS            AlarmType_Types = 13
	AlarmType_ONU_ALARM_LOB            AlarmType_Types = 14
	AlarmType_ONU_ALARM_LOPC_MISS      AlarmType_Types = 15
	AlarmType_ONU_ALARM_LOPC_MIC_ERROR AlarmType_Types = 16
	AlarmType_ONU_ALARM_LOFI           AlarmType_Types = 17
	AlarmType_ONU_ALARM_LOAMI          AlarmType_Types = 18
)

func (AlarmType_Types) EnumDescriptor added in v0.0.12

func (AlarmType_Types) EnumDescriptor() ([]byte, []int)

func (AlarmType_Types) String added in v0.0.12

func (x AlarmType_Types) String() string

type BBSimClient

type BBSimClient interface {
	// Get BBSim version
	Version(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionNumber, error)
	// Set BBSim log level
	SetLogLevel(ctx context.Context, in *LogLevel, opts ...grpc.CallOption) (*LogLevel, error)
	// Get current status of OLT
	GetOlt(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Olt, error)
	// Poweron OLT
	PoweronOlt(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Response, error)
	// Shutdown OLT
	ShutdownOlt(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Response, error)
	// Reboot OLT
	RebootOlt(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Response, error)
	// Get status of an ONU by serial number
	GetONU(ctx context.Context, in *ONURequest, opts ...grpc.CallOption) (*ONU, error)
	// Get status of all ONUs
	GetONUs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ONUs, error)
	// Shutdown an ONU by serial number
	ShutdownONU(ctx context.Context, in *ONURequest, opts ...grpc.CallOption) (*Response, error)
	// Shutdown all ONUs in OLT
	ShutdownAllONUs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Response, error)
	// Shutdown all ONUs under a PON by pon-port-ID
	ShutdownONUsOnPON(ctx context.Context, in *PONRequest, opts ...grpc.CallOption) (*Response, error)
	// Poweron an ONU by serial number
	PoweronONU(ctx context.Context, in *ONURequest, opts ...grpc.CallOption) (*Response, error)
	// Poweron all ONUs in OLT
	PoweronAllONUs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Response, error)
	// Poweron all ONUs under a PON by pon-port-ID
	PoweronONUsOnPON(ctx context.Context, in *PONRequest, opts ...grpc.CallOption) (*Response, error)
	// Restart EAPOL for ONU
	RestartEapol(ctx context.Context, in *ONURequest, opts ...grpc.CallOption) (*Response, error)
	// Resatrt DHCP for ONU
	RestartDhcp(ctx context.Context, in *ONURequest, opts ...grpc.CallOption) (*Response, error)
	// Send ONU alarm indication
	SetOnuAlarmIndication(ctx context.Context, in *ONUAlarmRequest, opts ...grpc.CallOption) (*Response, error)
	// Send OLT alarm indication for Interface type NNI or PON
	SetOltAlarmIndication(ctx context.Context, in *OLTAlarmRequest, opts ...grpc.CallOption) (*Response, error)
	// Get all flows or ONU specific flows
	GetFlows(ctx context.Context, in *ONURequest, opts ...grpc.CallOption) (*Flows, error)
	// Chnage IGMP state
	ChangeIgmpState(ctx context.Context, in *IgmpRequest, opts ...grpc.CallOption) (*Response, error)
	// Get Traffic scheduler information for ONU
	GetOnuTrafficSchedulers(ctx context.Context, in *ONURequest, opts ...grpc.CallOption) (*ONUTrafficSchedulers, error)
}

BBSimClient is the client API for BBSim service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBBSimClient

func NewBBSimClient(cc *grpc.ClientConn) BBSimClient

type BBSimServer

type BBSimServer interface {
	// Get BBSim version
	Version(context.Context, *Empty) (*VersionNumber, error)
	// Set BBSim log level
	SetLogLevel(context.Context, *LogLevel) (*LogLevel, error)
	// Get current status of OLT
	GetOlt(context.Context, *Empty) (*Olt, error)
	// Poweron OLT
	PoweronOlt(context.Context, *Empty) (*Response, error)
	// Shutdown OLT
	ShutdownOlt(context.Context, *Empty) (*Response, error)
	// Reboot OLT
	RebootOlt(context.Context, *Empty) (*Response, error)
	// Get status of an ONU by serial number
	GetONU(context.Context, *ONURequest) (*ONU, error)
	// Get status of all ONUs
	GetONUs(context.Context, *Empty) (*ONUs, error)
	// Shutdown an ONU by serial number
	ShutdownONU(context.Context, *ONURequest) (*Response, error)
	// Shutdown all ONUs in OLT
	ShutdownAllONUs(context.Context, *Empty) (*Response, error)
	// Shutdown all ONUs under a PON by pon-port-ID
	ShutdownONUsOnPON(context.Context, *PONRequest) (*Response, error)
	// Poweron an ONU by serial number
	PoweronONU(context.Context, *ONURequest) (*Response, error)
	// Poweron all ONUs in OLT
	PoweronAllONUs(context.Context, *Empty) (*Response, error)
	// Poweron all ONUs under a PON by pon-port-ID
	PoweronONUsOnPON(context.Context, *PONRequest) (*Response, error)
	// Restart EAPOL for ONU
	RestartEapol(context.Context, *ONURequest) (*Response, error)
	// Resatrt DHCP for ONU
	RestartDhcp(context.Context, *ONURequest) (*Response, error)
	// Send ONU alarm indication
	SetOnuAlarmIndication(context.Context, *ONUAlarmRequest) (*Response, error)
	// Send OLT alarm indication for Interface type NNI or PON
	SetOltAlarmIndication(context.Context, *OLTAlarmRequest) (*Response, error)
	// Get all flows or ONU specific flows
	GetFlows(context.Context, *ONURequest) (*Flows, error)
	// Chnage IGMP state
	ChangeIgmpState(context.Context, *IgmpRequest) (*Response, error)
	// Get Traffic scheduler information for ONU
	GetOnuTrafficSchedulers(context.Context, *ONURequest) (*ONUTrafficSchedulers, error)
}

BBSimServer is the server API for BBSim service.

type Empty

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor

func (*Empty) Descriptor() ([]byte, []int)

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) String

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal

func (m *Empty) XXX_Unmarshal(b []byte) error

type Flows added in v0.0.18

type Flows struct {
	FlowCount            uint32          `protobuf:"varint,1,opt,name=flow_count,json=flowCount,proto3" json:"flow_count,omitempty"`
	Flows                []*openolt.Flow `protobuf:"bytes,2,rep,name=flows,proto3" json:"flows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Flows) Descriptor added in v0.0.18

func (*Flows) Descriptor() ([]byte, []int)

func (*Flows) GetFlowCount added in v0.0.18

func (m *Flows) GetFlowCount() uint32

func (*Flows) GetFlows added in v0.0.18

func (m *Flows) GetFlows() []*openolt.Flow

func (*Flows) ProtoMessage added in v0.0.18

func (*Flows) ProtoMessage()

func (*Flows) Reset added in v0.0.18

func (m *Flows) Reset()

func (*Flows) String added in v0.0.18

func (m *Flows) String() string

func (*Flows) XXX_DiscardUnknown added in v0.0.18

func (m *Flows) XXX_DiscardUnknown()

func (*Flows) XXX_Marshal added in v0.0.18

func (m *Flows) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Flows) XXX_Merge added in v0.0.18

func (m *Flows) XXX_Merge(src proto.Message)

func (*Flows) XXX_Size added in v0.0.18

func (m *Flows) XXX_Size() int

func (*Flows) XXX_Unmarshal added in v0.0.18

func (m *Flows) XXX_Unmarshal(b []byte) error

type IgmpRequest added in v0.0.15

type IgmpRequest struct {
	OnuReq               *ONURequest    `protobuf:"bytes,1,opt,name=OnuReq,proto3" json:"OnuReq,omitempty"`
	SubActionVal         SubActionTypes `protobuf:"varint,2,opt,name=SubActionVal,proto3,enum=bbsim.SubActionTypes" json:"SubActionVal,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*IgmpRequest) Descriptor added in v0.0.15

func (*IgmpRequest) Descriptor() ([]byte, []int)

func (*IgmpRequest) GetOnuReq added in v0.0.15

func (m *IgmpRequest) GetOnuReq() *ONURequest

func (*IgmpRequest) GetSubActionVal added in v0.0.15

func (m *IgmpRequest) GetSubActionVal() SubActionTypes

func (*IgmpRequest) ProtoMessage added in v0.0.15

func (*IgmpRequest) ProtoMessage()

func (*IgmpRequest) Reset added in v0.0.15

func (m *IgmpRequest) Reset()

func (*IgmpRequest) String added in v0.0.15

func (m *IgmpRequest) String() string

func (*IgmpRequest) XXX_DiscardUnknown added in v0.0.15

func (m *IgmpRequest) XXX_DiscardUnknown()

func (*IgmpRequest) XXX_Marshal added in v0.0.15

func (m *IgmpRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IgmpRequest) XXX_Merge added in v0.0.15

func (m *IgmpRequest) XXX_Merge(src proto.Message)

func (*IgmpRequest) XXX_Size added in v0.0.15

func (m *IgmpRequest) XXX_Size() int

func (*IgmpRequest) XXX_Unmarshal added in v0.0.15

func (m *IgmpRequest) XXX_Unmarshal(b []byte) error

type LogLevel

type LogLevel struct {
	Level                string   `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`
	Caller               bool     `protobuf:"varint,2,opt,name=caller,proto3" json:"caller,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogLevel) Descriptor

func (*LogLevel) Descriptor() ([]byte, []int)

func (*LogLevel) GetCaller

func (m *LogLevel) GetCaller() bool

func (*LogLevel) GetLevel

func (m *LogLevel) GetLevel() string

func (*LogLevel) ProtoMessage

func (*LogLevel) ProtoMessage()

func (*LogLevel) Reset

func (m *LogLevel) Reset()

func (*LogLevel) String

func (m *LogLevel) String() string

func (*LogLevel) XXX_DiscardUnknown

func (m *LogLevel) XXX_DiscardUnknown()

func (*LogLevel) XXX_Marshal

func (m *LogLevel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogLevel) XXX_Merge

func (m *LogLevel) XXX_Merge(src proto.Message)

func (*LogLevel) XXX_Size

func (m *LogLevel) XXX_Size() int

func (*LogLevel) XXX_Unmarshal

func (m *LogLevel) XXX_Unmarshal(b []byte) error

type NNIPort

type NNIPort struct {
	ID                   int32    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	OperState            string   `protobuf:"bytes,2,opt,name=OperState,proto3" json:"OperState,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NNIPort) Descriptor

func (*NNIPort) Descriptor() ([]byte, []int)

func (*NNIPort) GetID

func (m *NNIPort) GetID() int32

func (*NNIPort) GetOperState

func (m *NNIPort) GetOperState() string

func (*NNIPort) ProtoMessage

func (*NNIPort) ProtoMessage()

func (*NNIPort) Reset

func (m *NNIPort) Reset()

func (*NNIPort) String

func (m *NNIPort) String() string

func (*NNIPort) XXX_DiscardUnknown

func (m *NNIPort) XXX_DiscardUnknown()

func (*NNIPort) XXX_Marshal

func (m *NNIPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NNIPort) XXX_Merge

func (m *NNIPort) XXX_Merge(src proto.Message)

func (*NNIPort) XXX_Size

func (m *NNIPort) XXX_Size() int

func (*NNIPort) XXX_Unmarshal

func (m *NNIPort) XXX_Unmarshal(b []byte) error

type OLTAlarmRequest added in v0.0.18

type OLTAlarmRequest struct {
	InterfaceID          uint32   `protobuf:"varint,1,opt,name=InterfaceID,proto3" json:"InterfaceID,omitempty"`
	InterfaceType        string   `protobuf:"bytes,2,opt,name=InterfaceType,proto3" json:"InterfaceType,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:"-"`
}

OLT alarm request

func (*OLTAlarmRequest) Descriptor added in v0.0.18

func (*OLTAlarmRequest) Descriptor() ([]byte, []int)

func (*OLTAlarmRequest) GetInterfaceID added in v0.0.18

func (m *OLTAlarmRequest) GetInterfaceID() uint32

func (*OLTAlarmRequest) GetInterfaceType added in v0.0.18

func (m *OLTAlarmRequest) GetInterfaceType() string

func (*OLTAlarmRequest) GetStatus added in v0.0.18

func (m *OLTAlarmRequest) GetStatus() string

func (*OLTAlarmRequest) ProtoMessage added in v0.0.18

func (*OLTAlarmRequest) ProtoMessage()

func (*OLTAlarmRequest) Reset added in v0.0.18

func (m *OLTAlarmRequest) Reset()

func (*OLTAlarmRequest) String added in v0.0.18

func (m *OLTAlarmRequest) String() string

func (*OLTAlarmRequest) XXX_DiscardUnknown added in v0.0.18

func (m *OLTAlarmRequest) XXX_DiscardUnknown()

func (*OLTAlarmRequest) XXX_Marshal added in v0.0.18

func (m *OLTAlarmRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OLTAlarmRequest) XXX_Merge added in v0.0.18

func (m *OLTAlarmRequest) XXX_Merge(src proto.Message)

func (*OLTAlarmRequest) XXX_Size added in v0.0.18

func (m *OLTAlarmRequest) XXX_Size() int

func (*OLTAlarmRequest) XXX_Unmarshal added in v0.0.18

func (m *OLTAlarmRequest) XXX_Unmarshal(b []byte) error

type ONU

type ONU struct {
	ID                   int32    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	SerialNumber         string   `protobuf:"bytes,2,opt,name=SerialNumber,proto3" json:"SerialNumber,omitempty"`
	OperState            string   `protobuf:"bytes,3,opt,name=OperState,proto3" json:"OperState,omitempty"`
	InternalState        string   `protobuf:"bytes,4,opt,name=InternalState,proto3" json:"InternalState,omitempty"`
	PonPortID            int32    `protobuf:"varint,5,opt,name=PonPortID,proto3" json:"PonPortID,omitempty"`
	STag                 int32    `protobuf:"varint,6,opt,name=STag,proto3" json:"STag,omitempty"`
	CTag                 int32    `protobuf:"varint,7,opt,name=CTag,proto3" json:"CTag,omitempty"`
	HwAddress            string   `protobuf:"bytes,8,opt,name=HwAddress,proto3" json:"HwAddress,omitempty"`
	PortNo               int32    `protobuf:"varint,9,opt,name=PortNo,proto3" json:"PortNo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ONU) Descriptor

func (*ONU) Descriptor() ([]byte, []int)

func (*ONU) GetCTag

func (m *ONU) GetCTag() int32

func (*ONU) GetHwAddress

func (m *ONU) GetHwAddress() string

func (*ONU) GetID

func (m *ONU) GetID() int32

func (*ONU) GetInternalState

func (m *ONU) GetInternalState() string

func (*ONU) GetOperState

func (m *ONU) GetOperState() string

func (*ONU) GetPonPortID

func (m *ONU) GetPonPortID() int32

func (*ONU) GetPortNo

func (m *ONU) GetPortNo() int32

func (*ONU) GetSTag

func (m *ONU) GetSTag() int32

func (*ONU) GetSerialNumber

func (m *ONU) GetSerialNumber() string

func (*ONU) ProtoMessage

func (*ONU) ProtoMessage()

func (*ONU) Reset

func (m *ONU) Reset()

func (*ONU) String

func (m *ONU) String() string

func (*ONU) XXX_DiscardUnknown

func (m *ONU) XXX_DiscardUnknown()

func (*ONU) XXX_Marshal

func (m *ONU) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ONU) XXX_Merge

func (m *ONU) XXX_Merge(src proto.Message)

func (*ONU) XXX_Size

func (m *ONU) XXX_Size() int

func (*ONU) XXX_Unmarshal

func (m *ONU) XXX_Unmarshal(b []byte) error

type ONUAlarmRequest added in v0.0.18

type ONUAlarmRequest struct {
	AlarmType            string            `protobuf:"bytes,1,opt,name=AlarmType,proto3" json:"AlarmType,omitempty"`
	SerialNumber         string            `protobuf:"bytes,2,opt,name=SerialNumber,proto3" json:"SerialNumber,omitempty"`
	Status               string            `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"`
	Parameters           []*AlarmParameter `protobuf:"bytes,4,rep,name=Parameters,proto3" json:"Parameters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

ONUAlarmRequest includes fields common to every Onu alarm, plus an optional list of AlarmParameter list that can be used to set additional fields in alarms that support them.

func (*ONUAlarmRequest) Descriptor added in v0.0.18

func (*ONUAlarmRequest) Descriptor() ([]byte, []int)

func (*ONUAlarmRequest) GetAlarmType added in v0.0.18

func (m *ONUAlarmRequest) GetAlarmType() string

func (*ONUAlarmRequest) GetParameters added in v0.0.18

func (m *ONUAlarmRequest) GetParameters() []*AlarmParameter

func (*ONUAlarmRequest) GetSerialNumber added in v0.0.18

func (m *ONUAlarmRequest) GetSerialNumber() string

func (*ONUAlarmRequest) GetStatus added in v0.0.18

func (m *ONUAlarmRequest) GetStatus() string

func (*ONUAlarmRequest) ProtoMessage added in v0.0.18

func (*ONUAlarmRequest) ProtoMessage()

func (*ONUAlarmRequest) Reset added in v0.0.18

func (m *ONUAlarmRequest) Reset()

func (*ONUAlarmRequest) String added in v0.0.18

func (m *ONUAlarmRequest) String() string

func (*ONUAlarmRequest) XXX_DiscardUnknown added in v0.0.18

func (m *ONUAlarmRequest) XXX_DiscardUnknown()

func (*ONUAlarmRequest) XXX_Marshal added in v0.0.18

func (m *ONUAlarmRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ONUAlarmRequest) XXX_Merge added in v0.0.18

func (m *ONUAlarmRequest) XXX_Merge(src proto.Message)

func (*ONUAlarmRequest) XXX_Size added in v0.0.18

func (m *ONUAlarmRequest) XXX_Size() int

func (*ONUAlarmRequest) XXX_Unmarshal added in v0.0.18

func (m *ONUAlarmRequest) XXX_Unmarshal(b []byte) error

type ONURequest

type ONURequest struct {
	SerialNumber         string   `protobuf:"bytes,1,opt,name=SerialNumber,proto3" json:"SerialNumber,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ONURequest) Descriptor

func (*ONURequest) Descriptor() ([]byte, []int)

func (*ONURequest) GetSerialNumber

func (m *ONURequest) GetSerialNumber() string

func (*ONURequest) ProtoMessage

func (*ONURequest) ProtoMessage()

func (*ONURequest) Reset

func (m *ONURequest) Reset()

func (*ONURequest) String

func (m *ONURequest) String() string

func (*ONURequest) XXX_DiscardUnknown

func (m *ONURequest) XXX_DiscardUnknown()

func (*ONURequest) XXX_Marshal

func (m *ONURequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ONURequest) XXX_Merge

func (m *ONURequest) XXX_Merge(src proto.Message)

func (*ONURequest) XXX_Size

func (m *ONURequest) XXX_Size() int

func (*ONURequest) XXX_Unmarshal

func (m *ONURequest) XXX_Unmarshal(b []byte) error

type ONUTrafficSchedulers added in v0.0.18

type ONUTrafficSchedulers struct {
	TraffSchedulers      *tech_profile.TrafficSchedulers `protobuf:"bytes,1,opt,name=traffSchedulers,proto3" json:"traffSchedulers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*ONUTrafficSchedulers) Descriptor added in v0.0.18

func (*ONUTrafficSchedulers) Descriptor() ([]byte, []int)

func (*ONUTrafficSchedulers) GetTraffSchedulers added in v0.0.18

func (m *ONUTrafficSchedulers) GetTraffSchedulers() *tech_profile.TrafficSchedulers

func (*ONUTrafficSchedulers) ProtoMessage added in v0.0.18

func (*ONUTrafficSchedulers) ProtoMessage()

func (*ONUTrafficSchedulers) Reset added in v0.0.18

func (m *ONUTrafficSchedulers) Reset()

func (*ONUTrafficSchedulers) String added in v0.0.18

func (m *ONUTrafficSchedulers) String() string

func (*ONUTrafficSchedulers) XXX_DiscardUnknown added in v0.0.18

func (m *ONUTrafficSchedulers) XXX_DiscardUnknown()

func (*ONUTrafficSchedulers) XXX_Marshal added in v0.0.18

func (m *ONUTrafficSchedulers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ONUTrafficSchedulers) XXX_Merge added in v0.0.18

func (m *ONUTrafficSchedulers) XXX_Merge(src proto.Message)

func (*ONUTrafficSchedulers) XXX_Size added in v0.0.18

func (m *ONUTrafficSchedulers) XXX_Size() int

func (*ONUTrafficSchedulers) XXX_Unmarshal added in v0.0.18

func (m *ONUTrafficSchedulers) XXX_Unmarshal(b []byte) error

type ONUs

type ONUs struct {
	Items                []*ONU   `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ONUs) Descriptor

func (*ONUs) Descriptor() ([]byte, []int)

func (*ONUs) GetItems

func (m *ONUs) GetItems() []*ONU

func (*ONUs) ProtoMessage

func (*ONUs) ProtoMessage()

func (*ONUs) Reset

func (m *ONUs) Reset()

func (*ONUs) String

func (m *ONUs) String() string

func (*ONUs) XXX_DiscardUnknown

func (m *ONUs) XXX_DiscardUnknown()

func (*ONUs) XXX_Marshal

func (m *ONUs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ONUs) XXX_Merge

func (m *ONUs) XXX_Merge(src proto.Message)

func (*ONUs) XXX_Size

func (m *ONUs) XXX_Size() int

func (*ONUs) XXX_Unmarshal

func (m *ONUs) XXX_Unmarshal(b []byte) error

type Olt

type Olt struct {
	ID                   int32      `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	SerialNumber         string     `protobuf:"bytes,2,opt,name=SerialNumber,proto3" json:"SerialNumber,omitempty"`
	OperState            string     `protobuf:"bytes,3,opt,name=OperState,proto3" json:"OperState,omitempty"`
	InternalState        string     `protobuf:"bytes,4,opt,name=InternalState,proto3" json:"InternalState,omitempty"`
	IP                   string     `protobuf:"bytes,7,opt,name=IP,proto3" json:"IP,omitempty"`
	NNIPorts             []*NNIPort `protobuf:"bytes,5,rep,name=NNIPorts,proto3" json:"NNIPorts,omitempty"`
	PONPorts             []*PONPort `protobuf:"bytes,6,rep,name=PONPorts,proto3" json:"PONPorts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Olt) Descriptor

func (*Olt) Descriptor() ([]byte, []int)

func (*Olt) GetID

func (m *Olt) GetID() int32

func (*Olt) GetIP added in v0.0.19

func (m *Olt) GetIP() string

func (*Olt) GetInternalState

func (m *Olt) GetInternalState() string

func (*Olt) GetNNIPorts

func (m *Olt) GetNNIPorts() []*NNIPort

func (*Olt) GetOperState

func (m *Olt) GetOperState() string

func (*Olt) GetPONPorts

func (m *Olt) GetPONPorts() []*PONPort

func (*Olt) GetSerialNumber

func (m *Olt) GetSerialNumber() string

func (*Olt) ProtoMessage

func (*Olt) ProtoMessage()

func (*Olt) Reset

func (m *Olt) Reset()

func (*Olt) String

func (m *Olt) String() string

func (*Olt) XXX_DiscardUnknown

func (m *Olt) XXX_DiscardUnknown()

func (*Olt) XXX_Marshal

func (m *Olt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Olt) XXX_Merge

func (m *Olt) XXX_Merge(src proto.Message)

func (*Olt) XXX_Size

func (m *Olt) XXX_Size() int

func (*Olt) XXX_Unmarshal

func (m *Olt) XXX_Unmarshal(b []byte) error

type PONPort

type PONPort struct {
	ID                   int32    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	OperState            string   `protobuf:"bytes,2,opt,name=OperState,proto3" json:"OperState,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PONPort) Descriptor

func (*PONPort) Descriptor() ([]byte, []int)

func (*PONPort) GetID

func (m *PONPort) GetID() int32

func (*PONPort) GetOperState

func (m *PONPort) GetOperState() string

func (*PONPort) ProtoMessage

func (*PONPort) ProtoMessage()

func (*PONPort) Reset

func (m *PONPort) Reset()

func (*PONPort) String

func (m *PONPort) String() string

func (*PONPort) XXX_DiscardUnknown

func (m *PONPort) XXX_DiscardUnknown()

func (*PONPort) XXX_Marshal

func (m *PONPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PONPort) XXX_Merge

func (m *PONPort) XXX_Merge(src proto.Message)

func (*PONPort) XXX_Size

func (m *PONPort) XXX_Size() int

func (*PONPort) XXX_Unmarshal

func (m *PONPort) XXX_Unmarshal(b []byte) error

type PONRequest added in v0.0.19

type PONRequest struct {
	PonPortId            uint32   `protobuf:"varint,1,opt,name=PonPortId,proto3" json:"PonPortId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PONRequest) Descriptor added in v0.0.19

func (*PONRequest) Descriptor() ([]byte, []int)

func (*PONRequest) GetPonPortId added in v0.0.19

func (m *PONRequest) GetPonPortId() uint32

func (*PONRequest) ProtoMessage added in v0.0.19

func (*PONRequest) ProtoMessage()

func (*PONRequest) Reset added in v0.0.19

func (m *PONRequest) Reset()

func (*PONRequest) String added in v0.0.19

func (m *PONRequest) String() string

func (*PONRequest) XXX_DiscardUnknown added in v0.0.19

func (m *PONRequest) XXX_DiscardUnknown()

func (*PONRequest) XXX_Marshal added in v0.0.19

func (m *PONRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PONRequest) XXX_Merge added in v0.0.19

func (m *PONRequest) XXX_Merge(src proto.Message)

func (*PONRequest) XXX_Size added in v0.0.19

func (m *PONRequest) XXX_Size() int

func (*PONRequest) XXX_Unmarshal added in v0.0.19

func (m *PONRequest) XXX_Unmarshal(b []byte) error

type Response

type Response struct {
	StatusCode           int32    `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Response) Descriptor

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetMessage

func (m *Response) GetMessage() string

func (*Response) GetStatusCode

func (m *Response) GetStatusCode() int32

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) String

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal

func (m *Response) XXX_Unmarshal(b []byte) error

type SubActionTypes added in v0.0.15

type SubActionTypes int32
const (
	SubActionTypes_JOIN   SubActionTypes = 0
	SubActionTypes_LEAVE  SubActionTypes = 1
	SubActionTypes_JOINV3 SubActionTypes = 2
)

func (SubActionTypes) EnumDescriptor added in v0.0.15

func (SubActionTypes) EnumDescriptor() ([]byte, []int)

func (SubActionTypes) String added in v0.0.15

func (x SubActionTypes) String() string

type UnimplementedBBSimServer

type UnimplementedBBSimServer struct {
}

UnimplementedBBSimServer can be embedded to have forward compatible implementations.

func (*UnimplementedBBSimServer) ChangeIgmpState added in v0.0.15

func (*UnimplementedBBSimServer) ChangeIgmpState(ctx context.Context, req *IgmpRequest) (*Response, error)

func (*UnimplementedBBSimServer) GetFlows added in v0.0.18

func (*UnimplementedBBSimServer) GetFlows(ctx context.Context, req *ONURequest) (*Flows, error)

func (*UnimplementedBBSimServer) GetONU

func (*UnimplementedBBSimServer) GetONUs

func (*UnimplementedBBSimServer) GetONUs(ctx context.Context, req *Empty) (*ONUs, error)

func (*UnimplementedBBSimServer) GetOlt

func (*UnimplementedBBSimServer) GetOlt(ctx context.Context, req *Empty) (*Olt, error)

func (*UnimplementedBBSimServer) GetOnuTrafficSchedulers added in v0.0.18

func (*UnimplementedBBSimServer) GetOnuTrafficSchedulers(ctx context.Context, req *ONURequest) (*ONUTrafficSchedulers, error)

func (*UnimplementedBBSimServer) PoweronAllONUs added in v0.0.19

func (*UnimplementedBBSimServer) PoweronAllONUs(ctx context.Context, req *Empty) (*Response, error)

func (*UnimplementedBBSimServer) PoweronONU

func (*UnimplementedBBSimServer) PoweronONU(ctx context.Context, req *ONURequest) (*Response, error)

func (*UnimplementedBBSimServer) PoweronONUsOnPON added in v0.0.19

func (*UnimplementedBBSimServer) PoweronONUsOnPON(ctx context.Context, req *PONRequest) (*Response, error)

func (*UnimplementedBBSimServer) PoweronOlt

func (*UnimplementedBBSimServer) PoweronOlt(ctx context.Context, req *Empty) (*Response, error)

func (*UnimplementedBBSimServer) RebootOlt

func (*UnimplementedBBSimServer) RebootOlt(ctx context.Context, req *Empty) (*Response, error)

func (*UnimplementedBBSimServer) RestartDhcp

func (*UnimplementedBBSimServer) RestartDhcp(ctx context.Context, req *ONURequest) (*Response, error)

func (*UnimplementedBBSimServer) RestartEapol

func (*UnimplementedBBSimServer) RestartEapol(ctx context.Context, req *ONURequest) (*Response, error)

func (*UnimplementedBBSimServer) SetLogLevel

func (*UnimplementedBBSimServer) SetLogLevel(ctx context.Context, req *LogLevel) (*LogLevel, error)

func (*UnimplementedBBSimServer) SetOltAlarmIndication added in v0.0.18

func (*UnimplementedBBSimServer) SetOltAlarmIndication(ctx context.Context, req *OLTAlarmRequest) (*Response, error)

func (*UnimplementedBBSimServer) SetOnuAlarmIndication added in v0.0.18

func (*UnimplementedBBSimServer) SetOnuAlarmIndication(ctx context.Context, req *ONUAlarmRequest) (*Response, error)

func (*UnimplementedBBSimServer) ShutdownAllONUs added in v0.0.19

func (*UnimplementedBBSimServer) ShutdownAllONUs(ctx context.Context, req *Empty) (*Response, error)

func (*UnimplementedBBSimServer) ShutdownONU

func (*UnimplementedBBSimServer) ShutdownONU(ctx context.Context, req *ONURequest) (*Response, error)

func (*UnimplementedBBSimServer) ShutdownONUsOnPON added in v0.0.19

func (*UnimplementedBBSimServer) ShutdownONUsOnPON(ctx context.Context, req *PONRequest) (*Response, error)

func (*UnimplementedBBSimServer) ShutdownOlt

func (*UnimplementedBBSimServer) ShutdownOlt(ctx context.Context, req *Empty) (*Response, error)

func (*UnimplementedBBSimServer) Version

type VersionNumber

type VersionNumber struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	BuildTime            string   `protobuf:"bytes,2,opt,name=buildTime,proto3" json:"buildTime,omitempty"`
	CommitHash           string   `protobuf:"bytes,3,opt,name=commitHash,proto3" json:"commitHash,omitempty"`
	GitStatus            string   `protobuf:"bytes,4,opt,name=gitStatus,proto3" json:"gitStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionNumber) Descriptor

func (*VersionNumber) Descriptor() ([]byte, []int)

func (*VersionNumber) GetBuildTime

func (m *VersionNumber) GetBuildTime() string

func (*VersionNumber) GetCommitHash

func (m *VersionNumber) GetCommitHash() string

func (*VersionNumber) GetGitStatus

func (m *VersionNumber) GetGitStatus() string

func (*VersionNumber) GetVersion

func (m *VersionNumber) GetVersion() string

func (*VersionNumber) ProtoMessage

func (*VersionNumber) ProtoMessage()

func (*VersionNumber) Reset

func (m *VersionNumber) Reset()

func (*VersionNumber) String

func (m *VersionNumber) String() string

func (*VersionNumber) XXX_DiscardUnknown

func (m *VersionNumber) XXX_DiscardUnknown()

func (*VersionNumber) XXX_Marshal

func (m *VersionNumber) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionNumber) XXX_Merge

func (m *VersionNumber) XXX_Merge(src proto.Message)

func (*VersionNumber) XXX_Size

func (m *VersionNumber) XXX_Size() int

func (*VersionNumber) XXX_Unmarshal

func (m *VersionNumber) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL