common

Documentation

Index

• Constants
• Variables
• func GetIPAddr(ifname string) (string, error)
• func InitializePublisher(oltID int) error
• func KafkaPublisher(eventChannel chan Event)
• func OnuSnToString(sn *openolt.SerialNumber) string
• func SetLogLevel(logger *log.Logger, level string, caller bool)
• type BBRCliOptions
  • func GetBBROpts() BBRCliOptions
• type BBRConfig
• type BBSimConfig
• type BBSimYamlConfig
  • func GetBBSimOpts() *BBSimYamlConfig
  • func LoadBBSimConf(filename string) (*BBSimYamlConfig, error)
• type Event
• type OltConfig
• type SadisFormat
  • func (s SadisFormat) String() string
• type TagAllocation
  • func (t TagAllocation) String() string

Constants

const OltNniLos = "OLT_NNI_LOS"

const OltPonLos = "OLT_PON_LOS"

Variables

var OLTAlarms = map[string]bbsim.AlarmType_Types{
	OltNniLos: bbsim.AlarmType_LOS,
	OltPonLos: bbsim.AlarmType_LOS,
}

var ONUAlarms = make(map[string]bbsim.AlarmType_Types)

Functions

func GetIPAddr

func GetIPAddr(ifname string) (string, error)

GetIPAddr returns the IPv4 address of an interface. 0.0.0.0 is returned if the IP cannot be determined.

func InitializePublisher

func InitializePublisher(oltID int) error

InitializePublisher initalizes kafka publisher

func KafkaPublisher

func KafkaPublisher(eventChannel chan Event)

KafkaPublisher receives messages on eventChannel and publish them to kafka

func OnuSnToString

func OnuSnToString(sn *openolt.SerialNumber) string

func SetLogLevel

func SetLogLevel(logger *log.Logger, level string, caller bool)

Types

type BBRCliOptions

type BBRCliOptions struct {
	*BBSimYamlConfig
	BBSimIp      string
	BBSimPort    string
	BBSimApiPort string
	LogFile      string
}

func GetBBROpts

func GetBBROpts() BBRCliOptions

type BBRConfig

type BBRConfig struct {
	Log       string `yaml:"log"`
	LogLevel  string `yaml:"log_level"`
	LogCaller bool   `yaml:"log_caller"`
}

type BBSimConfig

type BBSimConfig struct {
	EnableDhcp           bool          `yaml:"enable_dhcp"`
	EnableAuth           bool          `yaml:"enable_auth"`
	LogLevel             string        `yaml:"log_level"`
	LogCaller            bool          `yaml:"log_caller"`
	Delay                int           `yaml:"delay"`
	CpuProfile           *string       `yaml:"cpu_profile"`
	CTagAllocation       TagAllocation `yaml:"c_tag_allocation"`
	CTag                 int           `yaml:"c_tag"`
	STagAllocation       TagAllocation `yaml:"s_tag_allocation"`
	STag                 int           `yaml:"s_tag"`
	OpenOltAddress       string        `yaml:"openolt_address"`
	ApiAddress           string        `yaml:"api_address"`
	RestApiAddress       string        `yaml:"rest_api_address"`
	LegacyApiAddress     string        `yaml:"legacy_api_address"`
	LegacyRestApiAddress string        `yaml:"legacy_rest_api_address"`
	SadisRestAddress     string        `yaml:"sadis_rest_address"`
	SadisServer          bool          `yaml:"sadis_server"`
	SadisFormat          SadisFormat   `yaml:"sadis_format"`
	KafkaAddress         string        `yaml:"kafka_address"`
	Events               bool          `yaml:"enable_events"`
	ControlledActivation string        `yaml:"controlled_activation"`
	EnablePerf           bool          `yaml:"enable_perf"`
}

type BBSimYamlConfig

type BBSimYamlConfig struct {
	BBSim BBSimConfig
	Olt   OltConfig
	BBR   BBRConfig
}

var Options *BBSimYamlConfig

func GetBBSimOpts

func GetBBSimOpts() *BBSimYamlConfig

GetBBSimOpts loads the BBSim configuration file and over-rides options with corresponding CLI flags if set

func LoadBBSimConf

func LoadBBSimConf(filename string) (*BBSimYamlConfig, error)

LoadBBSimConf loads the BBSim configuration from a YAML file

type Event

type Event struct {
	EventType string
	OnuSerial string
	OltID     int
	IntfID    int32
	OnuID     int32
	EpochTime int64
	Timestamp string
}

Event defines structure for bbsim events

type OltConfig

type OltConfig struct {
	Model              string `yaml:"model"`
	Vendor             string `yaml:"vendor"`
	HardwareVersion    string `yaml:"hardware_version"`
	FirmwareVersion    string `yaml:"firmware_version"`
	DeviceId           string `yaml:"device_id"`
	DeviceSerialNumber string `yaml:"device_serial_number"`
	PonPorts           uint32 `yaml:"pon_ports"`
	NniPorts           uint32 `yaml:"nni_ports"`
	OnusPonPort        uint32 `yaml:"onus_per_port"`
	Technology         string `yaml:"technology"`
	ID                 int    `yaml:"id"`
	OltRebootDelay     int    `yaml:"reboot_delay"`
	PortStatsInterval  int    `yaml: "port_stats_interval"`
}

type SadisFormat

type SadisFormat int

const (
	SadisFormatAtt SadisFormat
	SadisFormatDt
	SadisFormatTt
)

func (SadisFormat) String

func (s SadisFormat) String() string

type TagAllocation

type TagAllocation int

const (
	TagAllocationShared TagAllocation
	TagAllocationUnique
)

func (TagAllocation) String

func (t TagAllocation) String() string