interfaces

type ErrorCode common.ErrorCode

type IBridge interface {
	GetExtendedStatistics(me.ClassID, uint16) *Statistics
	SetExtendedStatistics(me.ClassID, *Statistics) me.OmciErrors
}

type IBridgeManager interface {
	GetBridgeService(uint16) IBridge
	GetBridgePort(uint16) IBridgePort
}

type IBridgePort interface {
	GetExtendedStatistics(me.ClassID, uint16) *Statistics
	SetExtendedStatistics(me.ClassID, *Statistics) me.OmciErrors
}

type ICommon interface {
	// Parent returns the next higher layer ICommon entity
	Parent() ICommon

	// ID returns the unique ID for this entity. This ID is only unique
	// among common types
	ID() uint

	// Name or serial number of entity
	Name() string

	IsEnabled() bool

	Configuration() interface{}

	AddTimers(timer *time.Timer)

	Input() chan<- interface{}

	State() fsm.State
}

type IMib interface {
	Set(me.ClassID, uint16, me.AttributeValueMap, ...bool) me.OmciErrors
	// TODO: Move back to just errors returned or 'nil' on no error to make processing simpler
	SetAttribute(me.ClassID, uint16, string, interface{}) error
	Delete(me.ClassID, uint16) error
	QueryClass(me.ClassID) (map[uint16]MeDbInstance, error)
	QueryInstance(me.ClassID, uint16) (*MeDbEntry, error)

	// Special Allocation routines
	AllocateTCont() (uint16, error)
	ReleaseTCont(uint16) error
	GetFreeTContAllocID() uint16
}

type IOltOmciEndpoint interface {
	RxOmci() chan *omci_pb.OmciResponse
	RxPloam() chan *omci_pb.PloamDiscoveryResponse
}

type IOnu interface {
	ICommon
	GetMIB() IMib
	GetCurrentIntervalEndTime() uint8
	GetMibCache() OnuReadOnlyInfo

	AddManagedEntity(item interface{}, attr me.AttributeValueMap) me.OmciErrors
	DeleteManagedEntity(cid me.ClassID, eid uint16) interface{}
	GetNextMacAddress() []byte
	GetHandler(*me.ManagedEntity, me.AttributeValueMap) gopacket.SerializableLayer
	SetHandler(*me.ManagedEntity, me.AttributeValueMap, me.Results, uint16, uint16) gopacket.SerializableLayer

	GetBridgeManager() IBridgeManager
}

type IOnuOmciEndpoint interface {
	RxOmci() chan *OmciRequest
	RxPloam() chan *PloamRequest
}

type IPMCounterGroup interface {
	Name() string
	GetAttributeValues([]int) me.AttributeValueMap
	Increment(uint, uint64) error
	Set(uint, uint64) error

	Reset()
	On15MinuteIntervalEnd()
}

type IPMCounterOrGauge interface {
	Name() string
	Increment(uint64)
	Set(uint64)
	Get() interface{}
	Reset()
}

type IPacket interface {
	RxFrame(gopacket.Packet, interface{})
}

type MeDbClass struct {
	ClassId   me.ClassID              `yaml:"classId"   json:"classId"`
	Instances map[uint16]MeDbInstance `yaml:"instances" json:"instances"`
}

type MeDbEntry struct {
	ClassId    me.ClassID
	InstanceId uint16
	Attributes me.AttributeValueMap
}

type MeDbInstance struct {
	InstanceId uint16               `yaml:"instanceId" json:"instanceId"`
	Attributes me.AttributeValueMap `yaml:"attributes" json:"attributes"`
	// contains filtered or unexported fields
}

type MeHandler func(*me.ManagedEntity, *MeDbEntry, omci.MessageType) gopacket.SerializableLayer

type OmciOltServiceEndpoint struct {
	OmciServiceEndpoint // Common elements

	// Client (OLT side specific fields)
	Olt IOltOmciEndpoint

	OmciTxChannel  chan *omci_pb.OmciRequest
	PloamTxChannel chan *omci_pb.PloamRequest
	// contains filtered or unexported fields
}

type OmciOnuServiceEndpoint struct {
	OmciServiceEndpoint // Common elements

	// Server (ONU side specific fields)
	OnuMockService IOnuOmciEndpoint
	// contains filtered or unexported fields
}

type OmciRequest struct {
	Request *omci_pb.OmciRequest
	Stream  omci_pb.OMCI_OmciChannelServer
	// contains filtered or unexported fields
}

type OmciServiceEndpoint struct {
	// Common elements
	//mutex     sync.Mutex
	Done chan struct{}
	// contains filtered or unexported fields
}

type OnuReadOnlyInfo struct {
	// ONU-G
	TrafficManagementOption byte

	// ONU-2G
	OmccVersion            byte
	SecurityCapability     byte
	PriorityQueueCount     uint16
	TrafficSchedulerCount  byte
	GemPortCount           uint16
	ConnectivityCapability uint16

	// QOS Flexibility values
	PriorityQueuePortReadWrite     bool
	PriorityQueueSchedulerFlexible bool
	PriorityQueuePriorityReadWrite bool
	SchedulerTContReadWrite        bool
	SchedulerPolicyReadWrite       bool
	TContPolicyReadWrite           bool
}

type PMControlBlock struct {
	ThresholdDataID     uint16
	ParentMEClass       me.ClassID
	ParentMEInstance    uint16
	AccumulationDisable uint16
	TCADisable          uint16
	TCI                 uint16

	// Following from control fields
	ContinuousCollection bool
	DownstreamTraffic    bool
	TCIEnabled           bool
	VIDEnabled           bool

	// Following dictates if extended or not
	Extended bool
}

type PMCounter struct {
	// contains filtered or unexported fields
}

type PMGauge struct {
	// contains filtered or unexported fields
}

type PloamRequest struct {
	Request *omci_pb.PloamRequest
	Stream  omci_pb.OMCI_PloamChannelServer
}

type ReferenceLink struct {
	ClassID    me.ClassID
	InstanceID uint16
}

type Statistics struct {
	ClassID  me.ClassID
	EntityID uint16

	// This attribute identifies the most recently finished 15 min interval
	IntervalEndTime uint8

	// This attribute points to an instance of the threshold data 1/2 ME that contains PM
	// threshold values for regular PM or the Control Block for extended PM
	ControlBlock PMControlBlock

	// Data/counters for current interval
	CurrentInterval map[uint]IPMCounterOrGauge
	// contains filtered or unexported fields
}