types

Documentation

Index

• type ByteMsg
• type IgmpMessage
• type Message
• type MessageType
  • func (m MessageType) String() string
• type NniIndicationMessage
• type OltIndicationMessage
• type OmciIndicationMessage
• type OmciMessage
• type OnuDiscIndicationMessage
• type OnuFlowUpdateMessage
• type OnuIndicationMessage
• type OnuPacketMessage
• type OperState
  • func (m OperState) String() string
• type PacketMessage
• type PacketMsg
• type PonIndicationMessage
• type Stream
• type UniStatusAlarmMessage

Types

type ByteMsg

type ByteMsg struct {
	IntfId uint32
	OnuId  uint32
	Bytes  []byte
}

deprecated, use OnuPacketOutMessage instead

type IgmpMessage

type IgmpMessage struct {
	GroupAddress string
}

type Message

type Message struct {
	Type MessageType
	Data interface{}
}

type MessageType

type MessageType int

const (
	OltIndication     MessageType = 0
	NniIndication     MessageType = 1
	PonIndication     MessageType = 2
	OnuDiscIndication MessageType = 3
	OnuIndication     MessageType = 4
	OMCI              MessageType = 5
	FlowAdd           MessageType = 6
	FlowRemoved       MessageType = 18
	StartEAPOL        MessageType = 7
	StartDHCP         MessageType = 8
	OnuPacketOut      MessageType = 9

	// BBR messages
	OmciIndication MessageType = 10 // this are OMCI messages going from the OLT to VOLTHA
	SendEapolFlow  MessageType = 11
	SendDhcpFlow   MessageType = 12
	OnuPacketIn    MessageType = 13

	//IGMP
	IGMPMembershipReportV2 MessageType = 14 // Version 2 Membership Report (JOIN)
	IGMPLeaveGroup         MessageType = 15 // Leave Group

	AlarmIndication        MessageType = 16 // message data is an openolt.AlarmIndication
	IGMPMembershipReportV3 MessageType = 17 // Version 3 Membership Report
	UniStatusAlarm         MessageType = 19
)

func (MessageType) String

func (m MessageType) String() string

type NniIndicationMessage

type NniIndicationMessage struct {
	OperState OperState
	NniPortID uint32
}

type OltIndicationMessage

type OltIndicationMessage struct {
	OperState OperState
}

type OmciIndicationMessage

type OmciIndicationMessage struct {
	OnuSN   *openolt.SerialNumber
	OnuID   uint32
	OmciInd *openolt.OmciIndication
}

these are OMCI messages going from the OLT to VOLTHA these messages are received by BBR

type OmciMessage

type OmciMessage struct {
	OnuSN   *openolt.SerialNumber
	OnuID   uint32
	OmciMsg *omci.OMCI
	OmciPkt gopacket.Packet
}

these are OMCI messages going from VOLTHA to the OLT used by BBSim

type OnuDiscIndicationMessage

type OnuDiscIndicationMessage struct {
	OperState OperState
}

type OnuFlowUpdateMessage

type OnuFlowUpdateMessage struct {
	PonPortID uint32
	OnuID     uint32
	Flow      *openolt.Flow
}

type OnuIndicationMessage

type OnuIndicationMessage struct {
	OperState OperState
	PonPortID uint32
	OnuID     uint32
	OnuSN     *openolt.SerialNumber
}

type OnuPacketMessage

type OnuPacketMessage struct {
	IntfId     uint32
	OnuId      uint32
	PortNo     uint32
	Packet     gopacket.Packet
	Type       packetHandlers.PacketType
	MacAddress net.HardwareAddr
	GemPortId  uint32 // this is used by BBR
}

type OperState

type OperState int

const (
	UP   OperState = iota
	DOWN           // The device has been discovered, but not yet activated
)

func (OperState) String

func (m OperState) String() string

type PacketMessage

type PacketMessage struct {
	PonPortID uint32
	OnuID     uint32
}

type PacketMsg

type PacketMsg struct {
	Pkt gopacket.Packet
}

type PonIndicationMessage

type PonIndicationMessage struct {
	OperState OperState
	PonPortID uint32
}

type Stream

type Stream interface {
	Send(*openolt.Indication) error
	grpc.ServerStream
}

represent a gRPC stream

type UniStatusAlarmMessage

type UniStatusAlarmMessage struct {
	OnuSN          *openolt.SerialNumber
	OnuID          uint32
	AdminState     uint8
	EntityID       uint16
	RaiseOMCIAlarm bool
}