legacy

package
v1.15.7 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package legacy is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterBBSimServiceHandler 

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

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

func RegisterBBSimServiceHandlerClient 

func RegisterBBSimServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BBSimServiceClient) error

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

func RegisterBBSimServiceHandlerFromEndpoint 

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

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

func RegisterBBSimServiceHandlerServer 

func RegisterBBSimServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BBSimServiceServer) error

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

func RegisterBBSimServiceServer 

func RegisterBBSimServiceServer(s *grpc.Server, srv BBSimServiceServer)

Types

type BBSimResponse 

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

BBSim response message

func (*BBSimResponse) Descriptor 

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

func (*BBSimResponse) GetStatusMsg 

func (m *BBSimResponse) GetStatusMsg() string

func (*BBSimResponse) ProtoMessage 

func (*BBSimResponse) ProtoMessage()

func (*BBSimResponse) Reset 

func (m *BBSimResponse) Reset()

func (*BBSimResponse) String 

func (m *BBSimResponse) String() string

func (*BBSimResponse) XXX_DiscardUnknown 

func (m *BBSimResponse) XXX_DiscardUnknown()

func (*BBSimResponse) XXX_Marshal 

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

func (*BBSimResponse) XXX_Merge 

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

func (*BBSimResponse) XXX_Size 

func (m *BBSimResponse) XXX_Size() int

func (*BBSimResponse) XXX_Unmarshal 

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

type BBSimServiceClient 

type BBSimServiceClient interface {
	// Get current status of OLT
	OLTStatus(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*OLTStatusResponse, error)
	// Get status of a PON/NNI port
	PortStatus(ctx context.Context, in *PortInfo, opts ...grpc.CallOption) (*Ports, error)
	// Get status of all or specific ONUs
	ONUStatus(ctx context.Context, in *ONURequest, opts ...grpc.CallOption) (*ONUs, error)
	// Single/bulk activate ONU(s) for specific PON port(s)
	ONUActivate(ctx context.Context, in *ONURequest, opts ...grpc.CallOption) (*BBSimResponse, error)
	// Deactivate ONU(s) for specific PON port(s) specified by
	// a given onu_serial, onu_id, or pon_port_id
	ONUDeactivate(ctx context.Context, in *ONURequest, opts ...grpc.CallOption) (*BBSimResponse, error)
	// Generate ONU related alarms
	GenerateONUAlarm(ctx context.Context, in *ONUAlarmRequest, opts ...grpc.CallOption) (*BBSimResponse, error)
	// Generate OLT related alarms
	GenerateOLTAlarm(ctx context.Context, in *OLTAlarmRequest, opts ...grpc.CallOption) (*BBSimResponse, error)
	// Perform actions on OLT/ONU devices (e.g. reboot)
	PerformDeviceAction(ctx context.Context, in *DeviceAction, opts ...grpc.CallOption) (*BBSimResponse, error)
	// Get flows
	GetFlows(ctx context.Context, in *ONUInfo, opts ...grpc.CallOption) (*Flows, error)
}

BBSimServiceClient is the client API for BBSimService service.

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

func NewBBSimServiceClient 

func NewBBSimServiceClient(cc *grpc.ClientConn) BBSimServiceClient

type BBSimServiceServer 

type BBSimServiceServer interface {
	// Get current status of OLT
	OLTStatus(context.Context, *Empty) (*OLTStatusResponse, error)
	// Get status of a PON/NNI port
	PortStatus(context.Context, *PortInfo) (*Ports, error)
	// Get status of all or specific ONUs
	ONUStatus(context.Context, *ONURequest) (*ONUs, error)
	// Single/bulk activate ONU(s) for specific PON port(s)
	ONUActivate(context.Context, *ONURequest) (*BBSimResponse, error)
	// Deactivate ONU(s) for specific PON port(s) specified by
	// a given onu_serial, onu_id, or pon_port_id
	ONUDeactivate(context.Context, *ONURequest) (*BBSimResponse, error)
	// Generate ONU related alarms
	GenerateONUAlarm(context.Context, *ONUAlarmRequest) (*BBSimResponse, error)
	// Generate OLT related alarms
	GenerateOLTAlarm(context.Context, *OLTAlarmRequest) (*BBSimResponse, error)
	// Perform actions on OLT/ONU devices (e.g. reboot)
	PerformDeviceAction(context.Context, *DeviceAction) (*BBSimResponse, error)
	// Get flows
	GetFlows(context.Context, *ONUInfo) (*Flows, error)
}

BBSimServiceServer is the server API for BBSimService service.

type DeviceAction 

type DeviceAction struct {
	DeviceType           string   `protobuf:"bytes,1,opt,name=device_type,json=deviceType,proto3" json:"device_type,omitempty"`
	SerialNumber         string   `protobuf:"bytes,2,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"`
	Action               string   `protobuf:"bytes,3,opt,name=action,proto3" json:"action,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Device action

func (*DeviceAction) Descriptor 

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

func (*DeviceAction) GetAction 

func (m *DeviceAction) GetAction() string

func (*DeviceAction) GetDeviceType 

func (m *DeviceAction) GetDeviceType() string

func (*DeviceAction) GetSerialNumber 

func (m *DeviceAction) GetSerialNumber() string

func (*DeviceAction) ProtoMessage 

func (*DeviceAction) ProtoMessage()

func (*DeviceAction) Reset 

func (m *DeviceAction) Reset()

func (*DeviceAction) String 

func (m *DeviceAction) String() string

func (*DeviceAction) XXX_DiscardUnknown 

func (m *DeviceAction) XXX_DiscardUnknown()

func (*DeviceAction) XXX_Marshal 

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

func (*DeviceAction) XXX_Merge 

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

func (*DeviceAction) XXX_Size 

func (m *DeviceAction) XXX_Size() int

func (*DeviceAction) XXX_Unmarshal 

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

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 

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

func (*Flows) Descriptor 

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

func (*Flows) GetFlows 

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

func (*Flows) ProtoMessage 

func (*Flows) ProtoMessage()

func (*Flows) Reset 

func (m *Flows) Reset()

func (*Flows) String 

func (m *Flows) String() string

func (*Flows) XXX_DiscardUnknown 

func (m *Flows) XXX_DiscardUnknown()

func (*Flows) XXX_Marshal 

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

func (*Flows) XXX_Merge 

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

func (*Flows) XXX_Size 

func (m *Flows) XXX_Size() int

func (*Flows) XXX_Unmarshal 

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

type OLTAlarmRequest 

type OLTAlarmRequest struct {
	PortId               uint32   `protobuf:"varint,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
	PortType             string   `protobuf:"bytes,2,opt,name=port_type,json=portType,proto3" json:"port_type,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 

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

func (*OLTAlarmRequest) GetPortId 

func (m *OLTAlarmRequest) GetPortId() uint32

func (*OLTAlarmRequest) GetPortType 

func (m *OLTAlarmRequest) GetPortType() string

func (*OLTAlarmRequest) GetStatus 

func (m *OLTAlarmRequest) GetStatus() string

func (*OLTAlarmRequest) ProtoMessage 

func (*OLTAlarmRequest) ProtoMessage()

func (*OLTAlarmRequest) Reset 

func (m *OLTAlarmRequest) Reset()

func (*OLTAlarmRequest) String 

func (m *OLTAlarmRequest) String() string

func (*OLTAlarmRequest) XXX_DiscardUnknown 

func (m *OLTAlarmRequest) XXX_DiscardUnknown()

func (*OLTAlarmRequest) XXX_Marshal 

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

func (*OLTAlarmRequest) XXX_Merge 

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

func (*OLTAlarmRequest) XXX_Size 

func (m *OLTAlarmRequest) XXX_Size() int

func (*OLTAlarmRequest) XXX_Unmarshal 

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

type OLTInfo 

type OLTInfo struct {
	OltId                int64    `protobuf:"varint,1,opt,name=olt_id,json=oltId,proto3" json:"olt_id,omitempty"`
	OltSerial            string   `protobuf:"bytes,2,opt,name=olt_serial,json=oltSerial,proto3" json:"olt_serial,omitempty"`
	OltIp                string   `protobuf:"bytes,3,opt,name=olt_ip,json=oltIp,proto3" json:"olt_ip,omitempty"`
	OltState             string   `protobuf:"bytes,4,opt,name=olt_state,json=oltState,proto3" json:"olt_state,omitempty"`
	OltVendor            string   `protobuf:"bytes,5,opt,name=olt_vendor,json=oltVendor,proto3" json:"olt_vendor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

OLT information This supports the older format of the REST APIs (still used from some clients) Please refer to the protos in api/bbsim/bbsim.proto for the latest available version

func (*OLTInfo) Descriptor 

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

func (*OLTInfo) GetOltId 

func (m *OLTInfo) GetOltId() int64

func (*OLTInfo) GetOltIp 

func (m *OLTInfo) GetOltIp() string

func (*OLTInfo) GetOltSerial 

func (m *OLTInfo) GetOltSerial() string

func (*OLTInfo) GetOltState 

func (m *OLTInfo) GetOltState() string

func (*OLTInfo) GetOltVendor 

func (m *OLTInfo) GetOltVendor() string

func (*OLTInfo) ProtoMessage 

func (*OLTInfo) ProtoMessage()

func (*OLTInfo) Reset 

func (m *OLTInfo) Reset()

func (*OLTInfo) String 

func (m *OLTInfo) String() string

func (*OLTInfo) XXX_DiscardUnknown 

func (m *OLTInfo) XXX_DiscardUnknown()

func (*OLTInfo) XXX_Marshal 

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

func (*OLTInfo) XXX_Merge 

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

func (*OLTInfo) XXX_Size 

func (m *OLTInfo) XXX_Size() int

func (*OLTInfo) XXX_Unmarshal 

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

type OLTStatusResponse 

type OLTStatusResponse struct {
	Olt                  *OLTInfo    `protobuf:"bytes,1,opt,name=olt,proto3" json:"olt,omitempty"`
	Ports                []*PortInfo `protobuf:"bytes,2,rep,name=ports,proto3" json:"ports,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

BBSim status

func (*OLTStatusResponse) Descriptor 

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

func (*OLTStatusResponse) GetOlt 

func (m *OLTStatusResponse) GetOlt() *OLTInfo

func (*OLTStatusResponse) GetPorts 

func (m *OLTStatusResponse) GetPorts() []*PortInfo

func (*OLTStatusResponse) ProtoMessage 

func (*OLTStatusResponse) ProtoMessage()

func (*OLTStatusResponse) Reset 

func (m *OLTStatusResponse) Reset()

func (*OLTStatusResponse) String 

func (m *OLTStatusResponse) String() string

func (*OLTStatusResponse) XXX_DiscardUnknown 

func (m *OLTStatusResponse) XXX_DiscardUnknown()

func (*OLTStatusResponse) XXX_Marshal 

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

func (*OLTStatusResponse) XXX_Merge 

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

func (*OLTStatusResponse) XXX_Size 

func (m *OLTStatusResponse) XXX_Size() int

func (*OLTStatusResponse) XXX_Unmarshal 

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

type ONUAlarmRequest 

type ONUAlarmRequest struct {
	// ONU serial number
	OnuSerial string `protobuf:"bytes,1,opt,name=onu_serial,json=onuSerial,proto3" json:"onu_serial,omitempty"`
	// Alarm types are:
	//   "signaldegrade"
	//   "lossofomcichannel"
	//   "lossofploam"
	AlarmType string `protobuf:"bytes,2,opt,name=alarm_type,json=alarmType,proto3" json:"alarm_type,omitempty"`
	// "on"/"off" indicates raised or cleared alarm
	Status               string   `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ONU alarm request

func (*ONUAlarmRequest) Descriptor 

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

func (*ONUAlarmRequest) GetAlarmType 

func (m *ONUAlarmRequest) GetAlarmType() string

func (*ONUAlarmRequest) GetOnuSerial 

func (m *ONUAlarmRequest) GetOnuSerial() string

func (*ONUAlarmRequest) GetStatus 

func (m *ONUAlarmRequest) GetStatus() string

func (*ONUAlarmRequest) ProtoMessage 

func (*ONUAlarmRequest) ProtoMessage()

func (*ONUAlarmRequest) Reset 

func (m *ONUAlarmRequest) Reset()

func (*ONUAlarmRequest) String 

func (m *ONUAlarmRequest) String() string

func (*ONUAlarmRequest) XXX_DiscardUnknown 

func (m *ONUAlarmRequest) XXX_DiscardUnknown()

func (*ONUAlarmRequest) XXX_Marshal 

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

func (*ONUAlarmRequest) XXX_Merge 

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

func (*ONUAlarmRequest) XXX_Size 

func (m *ONUAlarmRequest) XXX_Size() int

func (*ONUAlarmRequest) XXX_Unmarshal 

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

type ONUInfo 

type ONUInfo struct {
	OnuId     uint32 `protobuf:"varint,1,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
	PonPortId uint32 `protobuf:"varint,2,opt,name=pon_port_id,json=ponPortId,proto3" json:"pon_port_id,omitempty"`
	// ONU serial number
	OnuSerial string `protobuf:"bytes,3,opt,name=onu_serial,json=onuSerial,proto3" json:"onu_serial,omitempty"`
	// ONU oper state
	OperState string `protobuf:"bytes,4,opt,name=oper_state,json=operState,proto3" json:"oper_state,omitempty"`
	// ONU internal state
	OnuState             string   `protobuf:"bytes,5,opt,name=onu_state,json=onuState,proto3" json:"onu_state,omitempty"`
	Gemports             []uint32 `protobuf:"varint,6,rep,packed,name=gemports,proto3" json:"gemports,omitempty"`
	Tconts               *Tconts  `protobuf:"bytes,7,opt,name=tconts,proto3" json:"tconts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ONU information

func (*ONUInfo) Descriptor 

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

func (*ONUInfo) GetGemports 

func (m *ONUInfo) GetGemports() []uint32

func (*ONUInfo) GetOnuId 

func (m *ONUInfo) GetOnuId() uint32

func (*ONUInfo) GetOnuSerial 

func (m *ONUInfo) GetOnuSerial() string

func (*ONUInfo) GetOnuState 

func (m *ONUInfo) GetOnuState() string

func (*ONUInfo) GetOperState 

func (m *ONUInfo) GetOperState() string

func (*ONUInfo) GetPonPortId 

func (m *ONUInfo) GetPonPortId() uint32

func (*ONUInfo) GetTconts 

func (m *ONUInfo) GetTconts() *Tconts

func (*ONUInfo) ProtoMessage 

func (*ONUInfo) ProtoMessage()

func (*ONUInfo) Reset 

func (m *ONUInfo) Reset()

func (*ONUInfo) String 

func (m *ONUInfo) String() string

func (*ONUInfo) XXX_DiscardUnknown 

func (m *ONUInfo) XXX_DiscardUnknown()

func (*ONUInfo) XXX_Marshal 

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

func (*ONUInfo) XXX_Merge 

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

func (*ONUInfo) XXX_Size 

func (m *ONUInfo) XXX_Size() int

func (*ONUInfo) XXX_Unmarshal 

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

type ONURequest 

type ONURequest struct {
	Onu                  *ONUInfo `protobuf:"bytes,1,opt,name=onu,proto3" json:"onu,omitempty"`
	OnusBatch            *ONUs    `protobuf:"bytes,2,opt,name=onus_batch,json=onusBatch,proto3" json:"onus_batch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ONURequest) Descriptor 

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

func (*ONURequest) GetOnu 

func (m *ONURequest) GetOnu() *ONUInfo

func (*ONURequest) GetOnusBatch 

func (m *ONURequest) GetOnusBatch() *ONUs

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 ONUs 

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

Bulk ONU operations

func (*ONUs) Descriptor 

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

func (*ONUs) GetOnus 

func (m *ONUs) GetOnus() []*ONUInfo

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 PortInfo 

type PortInfo struct {
	PortType             string   `protobuf:"bytes,1,opt,name=port_type,json=portType,proto3" json:"port_type,omitempty"`
	PortId               uint32   `protobuf:"varint,2,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
	PonPortMaxOnus       uint32   `protobuf:"varint,3,opt,name=pon_port_max_onus,json=ponPortMaxOnus,proto3" json:"pon_port_max_onus,omitempty"`
	PonPortActiveOnus    uint32   `protobuf:"varint,4,opt,name=pon_port_active_onus,json=ponPortActiveOnus,proto3" json:"pon_port_active_onus,omitempty"`
	PortState            string   `protobuf:"bytes,5,opt,name=port_state,json=portState,proto3" json:"port_state,omitempty"`
	AlarmState           string   `protobuf:"bytes,6,opt,name=alarm_state,json=alarmState,proto3" json:"alarm_state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Port information

func (*PortInfo) Descriptor 

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

func (*PortInfo) GetAlarmState 

func (m *PortInfo) GetAlarmState() string

func (*PortInfo) GetPonPortActiveOnus 

func (m *PortInfo) GetPonPortActiveOnus() uint32

func (*PortInfo) GetPonPortMaxOnus 

func (m *PortInfo) GetPonPortMaxOnus() uint32

func (*PortInfo) GetPortId 

func (m *PortInfo) GetPortId() uint32

func (*PortInfo) GetPortState 

func (m *PortInfo) GetPortState() string

func (*PortInfo) GetPortType 

func (m *PortInfo) GetPortType() string

func (*PortInfo) ProtoMessage 

func (*PortInfo) ProtoMessage()

func (*PortInfo) Reset 

func (m *PortInfo) Reset()

func (*PortInfo) String 

func (m *PortInfo) String() string

func (*PortInfo) XXX_DiscardUnknown 

func (m *PortInfo) XXX_DiscardUnknown()

func (*PortInfo) XXX_Marshal 

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

func (*PortInfo) XXX_Merge 

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

func (*PortInfo) XXX_Size 

func (m *PortInfo) XXX_Size() int

func (*PortInfo) XXX_Unmarshal 

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

type Ports 

type Ports struct {
	Ports                []*PortInfo `protobuf:"bytes,1,rep,name=ports,proto3" json:"ports,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Bulk port information

func (*Ports) Descriptor 

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

func (*Ports) GetPorts 

func (m *Ports) GetPorts() []*PortInfo

func (*Ports) ProtoMessage 

func (*Ports) ProtoMessage()

func (*Ports) Reset 

func (m *Ports) Reset()

func (*Ports) String 

func (m *Ports) String() string

func (*Ports) XXX_DiscardUnknown 

func (m *Ports) XXX_DiscardUnknown()

func (*Ports) XXX_Marshal 

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

func (*Ports) XXX_Merge 

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

func (*Ports) XXX_Size 

func (m *Ports) XXX_Size() int

func (*Ports) XXX_Unmarshal 

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

type Tconts 

type Tconts struct {
	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               []*tech_profile.TrafficScheduler `protobuf:"bytes,3,rep,name=tconts,proto3" json:"tconts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*Tconts) Descriptor 

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

func (*Tconts) GetPortNo 

func (m *Tconts) GetPortNo() uint32

func (*Tconts) GetTconts 

func (m *Tconts) GetTconts() []*tech_profile.TrafficScheduler

func (*Tconts) GetUniId 

func (m *Tconts) GetUniId() uint32

func (*Tconts) ProtoMessage 

func (*Tconts) ProtoMessage()

func (*Tconts) Reset 

func (m *Tconts) Reset()

func (*Tconts) String 

func (m *Tconts) String() string

func (*Tconts) XXX_DiscardUnknown 

func (m *Tconts) XXX_DiscardUnknown()

func (*Tconts) XXX_Marshal 

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

func (*Tconts) XXX_Merge 

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

func (*Tconts) XXX_Size 

func (m *Tconts) XXX_Size() int

func (*Tconts) XXX_Unmarshal 

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

type UnimplementedBBSimServiceServer 

type UnimplementedBBSimServiceServer struct {
}

UnimplementedBBSimServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBBSimServiceServer) GenerateOLTAlarm 

func (*UnimplementedBBSimServiceServer) GenerateOLTAlarm(ctx context.Context, req *OLTAlarmRequest) (*BBSimResponse, error)

func (*UnimplementedBBSimServiceServer) GenerateONUAlarm 

func (*UnimplementedBBSimServiceServer) GenerateONUAlarm(ctx context.Context, req *ONUAlarmRequest) (*BBSimResponse, error)

func (*UnimplementedBBSimServiceServer) GetFlows 

func (*UnimplementedBBSimServiceServer) GetFlows(ctx context.Context, req *ONUInfo) (*Flows, error)

func (*UnimplementedBBSimServiceServer) OLTStatus 

func (*UnimplementedBBSimServiceServer) OLTStatus(ctx context.Context, req *Empty) (*OLTStatusResponse, error)

func (*UnimplementedBBSimServiceServer) ONUActivate 

func (*UnimplementedBBSimServiceServer) ONUActivate(ctx context.Context, req *ONURequest) (*BBSimResponse, error)

func (*UnimplementedBBSimServiceServer) ONUDeactivate 

func (*UnimplementedBBSimServiceServer) ONUDeactivate(ctx context.Context, req *ONURequest) (*BBSimResponse, error)

func (*UnimplementedBBSimServiceServer) ONUStatus 

func (*UnimplementedBBSimServiceServer) ONUStatus(ctx context.Context, req *ONURequest) (*ONUs, error)

func (*UnimplementedBBSimServiceServer) PerformDeviceAction 

func (*UnimplementedBBSimServiceServer) PerformDeviceAction(ctx context.Context, req *DeviceAction) (*BBSimResponse, error)

func (*UnimplementedBBSimServiceServer) PortStatus 

func (*UnimplementedBBSimServiceServer) PortStatus(ctx context.Context, req *PortInfo) (*Ports, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.