omci

package module
v0.13.0 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2020 License: Apache-2.0 Imports: 9 Imported by: 7

README

Attention: OMCI LIBRARY MOVED

This library has been moved under the ONF opencord github in order for the ONF community to work on it. Please find the most up to date code here: https://github.com/opencord/omci-lib-go

**Any contribution to this codebase should be done at this new location.

OMCI

OMCI gopacket library supports the encoding and decoding of ITU G.988 OMCI messages.

Message Types supported and under unit test

The following OMCI message types currently have been coded and are covered satisfactory by unit tests.

  • CreateRequest
  • CreateResponse
  • DeleteRequest
  • DeleteResponse
  • SetRequest
  • GetRequest
  • GetAllAlarmsRequest
  • GetAllAlarmsResponse
  • GetAllAlarmsNextRequest
  • MibUploadRequest
  • MibUploadResponse
  • MibUploadNextRequest
  • MibResetRequest
  • MibResetResponse
  • SynchronizeTimeRequest

Message Types supported but lacking full unit test

The following OMCI message types currently have been coded and are partially covered by unit tests, but work still remains for sufficient/better unit test coverage.

  • SetResponse
  • GetResponse
  • GetAllAlarmsNextResponse
  • MibUploadNextResponse
  • SynchronizeTimeResponse
  • AttributeValueChange
  • RebootRequest
  • RebootResponse
  • StartSoftwareDownloadRequest
  • GetNextRequest
  • GetNextResponse

Message Types supported but lacking any unit test

The following OMCI message types currently have been coded but do not have any unit test coverage.

  • StartSoftwareDownloadResponse
  • DownloadSectionRequest
  • DownloadSectionResponse
  • EndSoftwareDownloadRequest
  • EndSoftwareDownloadResponse
  • ActivateSoftwareRequest
  • ActivateSoftwareResponse
  • CommitSoftwareRequest
  • CommitSoftwareResponse
  • GetCurrentDataRequest
  • GetCurrentDataResponse
  • AlarmNotification

Message Types not yet supported

The following OMCI message types currently have not been coded.

  • TestResult
  • TestRequest
  • TestResponse
  • SetTableRequest
  • SetTableResponse

Current user-test coverage

The coverage.sh and coverage.cmd scripts can be used to create code coverage support for the library. The current coverage (as of 2/11/2020) is:

File Statement Coverage
layers.go 100%
mebase.go 87.5%
meframe.go 54.8%
messagetypes.go 48.1%
omci.go 81.6%

Other outstanding items

Besides OMCI Message decode/serialization, and associated unit tests, the following items would be needed or useful in a first official release of this library. Some changes are to be done in the generated OMCI ME code as well.

  • Specific examples of how to use this library (expand upon DecodeEncode.go examples) Include unknown ME examples and how to catch various common or expected errors. Until this is available, please take a look at how this library is used in my onumock. There is a utilities subdirectory in the onumock project that has some examples. One is a very crude OLT simulator that I wrote to help test the ONU Mock.
  • Support optional msg-types. (This was very recently fixed in the code generator).
  • Constraint checking (these are not yet fully parsed/provided by the OMCI code generated structs). This feature will hopefully be available in the near future.
  • Add Alarm Table Support (generated MEs also)
  • Add AVC flag for appropriate attributes
  • Support of the extended message format
  • For serialization, check early for message size exceeded
  • Add some type of logging support

The following would be 'nice' to have but are not necessary for initial code release

  • Extended message support
  • MIC Encode/Decode support

Also searching through the code for TODO statements will also yeild additional areas of work to be performed.

What is not provided by this library

This library is not a full OMCI stack for either an OLT or an ONU. It is focused primarily on packet decode/serialization and a variety of structs and functions that are useful for handling the creation of OMCI frames and handling decoded frames from the PON.

For an OLT-side OMCI stack, you would still need to write:

  • OMCI CC sender & receiver with appropriate timeout support
  • OLT State machines to support
    • MIB Uploads/Audits/Resynchronization (and a MIB database implemention),
    • More sophisticated get & get-next support to make handle of MEs with lots of attributes or table attributes easy to handle and code,
    • Alarm Table support,
    • OMCI ME/Msg-Type capabilities inquiry,
    • Performance Monitoring collection (and initial time synchronization),
    • Service implementation

For an ONU-side OMCI stack, you would still need to write:

  • OMCC implementation,
  • MIB Database,
  • Get-Next cache for table attributes,
  • MIB upload next cache for MIB uploads,
  • Generation of any alarms/AVC notifications,
  • Actually acting on the create/delete/get/set/... requests from an OLT

Documentation

Overview

Package omci provides a library of routines to create, manipulate, serialize, and decode ITU-T G.988 OMCI messages/packets

Index

Constants

View Source 
const (
	CreateRequestType                 = MessageType(byte(me.Create) | me.AR)
	CreateResponseType                = MessageType(byte(me.Create) | me.AK)
	DeleteRequestType                 = MessageType(byte(me.Delete) | me.AR)
	DeleteResponseType                = MessageType(byte(me.Delete) | me.AK)
	SetRequestType                    = MessageType(byte(me.Set) | me.AR)
	SetResponseType                   = MessageType(byte(me.Set) | me.AK)
	GetRequestType                    = MessageType(byte(me.Get) | me.AR)
	GetResponseType                   = MessageType(byte(me.Get) | me.AK)
	GetAllAlarmsRequestType           = MessageType(byte(me.GetAllAlarms) | me.AR)
	GetAllAlarmsResponseType          = MessageType(byte(me.GetAllAlarms) | me.AK)
	GetAllAlarmsNextRequestType       = MessageType(byte(me.GetAllAlarmsNext) | me.AR)
	GetAllAlarmsNextResponseType      = MessageType(byte(me.GetAllAlarmsNext) | me.AK)
	MibUploadRequestType              = MessageType(byte(me.MibUpload) | me.AR)
	MibUploadResponseType             = MessageType(byte(me.MibUpload) | me.AK)
	MibUploadNextRequestType          = MessageType(byte(me.MibUploadNext) | me.AR)
	MibUploadNextResponseType         = MessageType(byte(me.MibUploadNext) | me.AK)
	MibResetRequestType               = MessageType(byte(me.MibReset) | me.AR)
	MibResetResponseType              = MessageType(byte(me.MibReset) | me.AK)
	TestRequestType                   = MessageType(byte(me.Test) | me.AR)
	TestResponseType                  = MessageType(byte(me.Test) | me.AK)
	StartSoftwareDownloadRequestType  = MessageType(byte(me.StartSoftwareDownload) | me.AR)
	StartSoftwareDownloadResponseType = MessageType(byte(me.StartSoftwareDownload) | me.AK)
	DownloadSectionRequestType        = MessageType(byte(me.DownloadSection) | me.AR)
	DownloadSectionResponseType       = MessageType(byte(me.DownloadSection) | me.AK)
	EndSoftwareDownloadRequestType    = MessageType(byte(me.EndSoftwareDownload) | me.AR)
	EndSoftwareDownloadResponseType   = MessageType(byte(me.EndSoftwareDownload) | me.AK)
	ActivateSoftwareRequestType       = MessageType(byte(me.ActivateSoftware) | me.AR)
	ActivateSoftwareResponseType      = MessageType(byte(me.ActivateSoftware) | me.AK)
	CommitSoftwareRequestType         = MessageType(byte(me.CommitSoftware) | me.AR)
	CommitSoftwareResponseType        = MessageType(byte(me.CommitSoftware) | me.AK)
	SynchronizeTimeRequestType        = MessageType(byte(me.SynchronizeTime) | me.AR)
	SynchronizeTimeResponseType       = MessageType(byte(me.SynchronizeTime) | me.AK)
	RebootRequestType                 = MessageType(byte(me.Reboot) | me.AR)
	RebootResponseType                = MessageType(byte(me.Reboot) | me.AK)
	GetNextRequestType                = MessageType(byte(me.GetNext) | me.AR)
	GetNextResponseType               = MessageType(byte(me.GetNext) | me.AK)
	GetCurrentDataRequestType         = MessageType(byte(me.GetCurrentData) | me.AR)
	GetCurrentDataResponseType        = MessageType(byte(me.GetCurrentData) | me.AK)
	SetTableRequestType               = MessageType(byte(me.SetTable) | me.AR)
	SetTableResponseType              = MessageType(byte(me.SetTable) | me.AK)
	// Autonomous ONU messages
	AlarmNotificationType    = MessageType(byte(me.AlarmNotification))
	AttributeValueChangeType = MessageType(byte(me.AttributeValueChange))
	TestResultType           = MessageType(byte(me.TestResult))
)
View Source 
const AlarmBitmapSize = 224

/////////////////////////////////////////////////////////////////////////// AlarmNotificationMsg

View Source 
const MaxAttributeGetNextBaselineLength = MaxBaselineLength - 11 - 8

MaxAttributeGetNextBaselineLength is the maximum payload size for attributes for a Baseline MIB Get Next message. This is just the attribute portion of the message contents and does not include the Result Code & Attribute Mask.

View Source 
const MaxAttributeGetNextExtendedLength = MaxExtendedLength - 13 - 4

MaxAttributeGetNextExtendedLength is the maximum payload size for attributes for a Extended MIB Get Next message. This is just the attribute portion of the message contents and does not include the Result Code & Attribute Mask.

View Source 
const MaxAttributeMibUploadNextBaselineLength = MaxBaselineLength - 14 - 8

MaxAttributeMibUploadNextBaselineLength is the maximum payload size for attributes for a Baseline MIB Upload Next message.29

View Source 
const MaxBaselineLength = 48

MaxBaselineLength is the maximum number of octets allowed in an OMCI Baseline message. Depending on the adapter, it may or may not include the

View Source 
const MaxExtendedLength = 1980

MaxExtendedLength is the maximum number of octets allowed in an OMCI Extended message (including header).

View Source 
const MaxManagedEntityMibUploadNextExtendedLength = MaxExtendedLength - 10 - 4

MaxManagedEntityMibUploadNextExtendedLength is the maximum payload size for ME entries for an Extended MIB Upload Next message. Extended messages differ from the baseline as multiple MEs can be reported in a single frame, just not multiple attributes.

View Source 
const NullEntityID = uint16(0xffff)

NullEntityID is often used as the Null/void Managed Entity ID for attributes that are used to refer to other Managed Entities but are currently not provisioned.

Variables

View Source 
var (
	LayerTypeCreateRequest                gopacket.LayerType
	LayerTypeDeleteRequest                gopacket.LayerType
	LayerTypeSetRequest                   gopacket.LayerType
	LayerTypeGetRequest                   gopacket.LayerType
	LayerTypeGetAllAlarmsRequest          gopacket.LayerType
	LayerTypeGetAllAlarmsNextRequest      gopacket.LayerType
	LayerTypeMibUploadRequest             gopacket.LayerType
	LayerTypeMibUploadNextRequest         gopacket.LayerType
	LayerTypeMibResetRequest              gopacket.LayerType
	LayerTypeTestRequest                  gopacket.LayerType
	LayerTypeStartSoftwareDownloadRequest gopacket.LayerType
	LayerTypeDownloadSectionRequest       gopacket.LayerType
	LayerTypeDownloadSectionLastRequest   gopacket.LayerType
	LayerTypeEndSoftwareDownloadRequest   gopacket.LayerType
	LayerTypeActivateSoftwareRequest      gopacket.LayerType
	LayerTypeCommitSoftwareRequest        gopacket.LayerType
	LayerTypeSynchronizeTimeRequest       gopacket.LayerType
	LayerTypeRebootRequest                gopacket.LayerType
	LayerTypeGetNextRequest               gopacket.LayerType
	LayerTypeGetCurrentDataRequest        gopacket.LayerType
	LayerTypeSetTableRequest              gopacket.LayerType
)
View Source 
var (
	LayerTypeCreateResponse                gopacket.LayerType
	LayerTypeDeleteResponse                gopacket.LayerType
	LayerTypeSetResponse                   gopacket.LayerType
	LayerTypeGetResponse                   gopacket.LayerType
	LayerTypeGetAllAlarmsResponse          gopacket.LayerType
	LayerTypeGetAllAlarmsNextResponse      gopacket.LayerType
	LayerTypeMibUploadResponse             gopacket.LayerType
	LayerTypeMibUploadNextResponse         gopacket.LayerType
	LayerTypeMibResetResponse              gopacket.LayerType
	LayerTypeAlarmNotification             gopacket.LayerType
	LayerTypeAttributeValueChange          gopacket.LayerType
	LayerTypeTestResponse                  gopacket.LayerType
	LayerTypeStartSoftwareDownloadResponse gopacket.LayerType
	LayerTypeDownloadSectionResponse       gopacket.LayerType
	LayerTypeEndSoftwareDownloadResponse   gopacket.LayerType
	LayerTypeActivateSoftwareResponse      gopacket.LayerType
	LayerTypeCommitSoftwareResponse        gopacket.LayerType
	LayerTypeSynchronizeTimeResponse       gopacket.LayerType
	LayerTypeRebootResponse                gopacket.LayerType
	LayerTypeGetNextResponse               gopacket.LayerType
	LayerTypeTestResult                    gopacket.LayerType
	LayerTypeGetCurrentDataResponse        gopacket.LayerType
	LayerTypeSetTableResponse              gopacket.LayerType
)
View Source 
var (
	LayerTypeOMCI gopacket.LayerType
)

LayerTypeOmci provide a gopacket LayerType for OMCI messages

Functions

func ActivateSoftwareRequestFrame added in v0.0.7 

func ActivateSoftwareRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func ActivateSoftwareResponseFrame added in v0.0.7 

func ActivateSoftwareResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func AlarmNotificationFrame added in v0.0.7 

func AlarmNotificationFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func AttributeValueChangeFrame added in v0.0.7 

func AttributeValueChangeFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func CommitSoftwareRequestFrame added in v0.0.7 

func CommitSoftwareRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func CommitSoftwareResponseFrame added in v0.0.7 

func CommitSoftwareResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func CreateRequestFrame added in v0.0.7 

func CreateRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func CreateResponseFrame added in v0.0.7 

func CreateResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func DeleteRequestFrame added in v0.0.7 

func DeleteRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func DeleteResponseFrame added in v0.0.7 

func DeleteResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func DownloadSectionRequestFrame added in v0.0.7 

func DownloadSectionRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func DownloadSectionResponseFrame added in v0.0.7 

func DownloadSectionResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func EndSoftwareDownloadRequestFrame added in v0.0.7 

func EndSoftwareDownloadRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func EndSoftwareDownloadResponseFrame added in v0.0.7 

func EndSoftwareDownloadResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func GenFrame added in v0.1.0 

func GenFrame(meInstance *me.ManagedEntity, messageType MessageType, options ...FrameOption) ([]byte, error)

GenFrame is a helper function to make tests a little easier to read. For a real application, use the .../omci/generated/class.go 'New' functions to create your Managed Entity and then use it to call the EncodeFrame method.

func GetAllAlarmsNextRequestFrame added in v0.0.7 

func GetAllAlarmsNextRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func GetAllAlarmsNextResponseFrame added in v0.0.7 

func GetAllAlarmsNextResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func GetAllAlarmsRequestFrame added in v0.0.7 

func GetAllAlarmsRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func GetAllAlarmsResponseFrame added in v0.0.7 

func GetAllAlarmsResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func GetCurrentDataRequestFrame added in v0.0.7 

func GetCurrentDataRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func GetCurrentDataResponseFrame added in v0.0.7 

func GetCurrentDataResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func GetNextRequestFrame added in v0.0.7 

func GetNextRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func GetNextResponseFrame added in v0.0.7 

func GetNextResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func GetRequestFrame added in v0.0.7 

func GetRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func GetResponseFrame added in v0.0.7 

func GetResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func MibResetRequestFrame added in v0.0.7 

func MibResetRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func MibResetResponseFrame added in v0.0.7 

func MibResetResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func MibUploadNextRequestFrame added in v0.0.7 

func MibUploadNextRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func MibUploadNextResponseFrame added in v0.0.7 

func MibUploadNextResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func MibUploadRequestFrame added in v0.0.7 

func MibUploadRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func MibUploadResponseFrame added in v0.0.7 

func MibUploadResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func MsgTypeToNextLayer 

func MsgTypeToNextLayer(mt MessageType) (gopacket.LayerType, error)

func RebootRequestFrame added in v0.0.7 

func RebootRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func RebootResponseFrame added in v0.0.7 

func RebootResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func SetRequestFrame added in v0.0.7 

func SetRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func SetResponseFrame added in v0.0.7 

func SetResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func SetTableRequestFrame added in v0.0.7 

func SetTableRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func SetTableResponseFrame added in v0.0.7 

func SetTableResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func StartSoftwareDownloadRequestFrame added in v0.0.7 

func StartSoftwareDownloadRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func StartSoftwareDownloadResponseFrame added in v0.0.7 

func StartSoftwareDownloadResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func SynchronizeTimeRequestFrame added in v0.0.7 

func SynchronizeTimeRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func SynchronizeTimeResponseFrame added in v0.0.7 

func SynchronizeTimeResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func TestRequestFrame added in v0.0.7 

func TestRequestFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func TestResponseFrame added in v0.0.7 

func TestResponseFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

func TestResultFrame added in v0.0.7 

func TestResultFrame(m *me.ManagedEntity, opt options) (gopacket.SerializableLayer, error)

Types

type ActivateSoftwareRequest 

type ActivateSoftwareRequest struct {
	MeBasePacket  // Note: EntityInstance for software download is two specific values
	ActivateFlags byte
}

///////////////////////////////////////////////////////////////////////////

func (*ActivateSoftwareRequest) DecodeFromBytes 

func (omci *ActivateSoftwareRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of an Activate Software Request into this layer

func (*ActivateSoftwareRequest) SerializeTo 

func (omci *ActivateSoftwareRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Activate Software message

func (*ActivateSoftwareRequest) String added in v0.0.7 

func (omci *ActivateSoftwareRequest) String() string

type ActivateSoftwareResponse 

type ActivateSoftwareResponse struct {
	MeBasePacket
	Result me.Results
}

///////////////////////////////////////////////////////////////////////////

func (*ActivateSoftwareResponse) DecodeFromBytes 

func (omci *ActivateSoftwareResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of an Activate Softwre Response into this layer

func (*ActivateSoftwareResponse) SerializeTo 

func (omci *ActivateSoftwareResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Activate Software Response message

func (*ActivateSoftwareResponse) String added in v0.0.7 

func (omci *ActivateSoftwareResponse) String() string

type AlarmNotificationMsg 

type AlarmNotificationMsg struct {
	MeBasePacket
	AlarmBitmap [AlarmBitmapSize / 8]byte

	AlarmSequenceNumber byte
	// contains filtered or unexported fields
}

func (*AlarmNotificationMsg) ActivateAlarm 

func (omci *AlarmNotificationMsg) ActivateAlarm(alarmNumber uint8) error

func (*AlarmNotificationMsg) ClearAlarm 

func (omci *AlarmNotificationMsg) ClearAlarm(alarmNumber uint8) error

func (*AlarmNotificationMsg) DecodeFromBytes 

func (omci *AlarmNotificationMsg) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of an Alarm Notification into this layer

func (*AlarmNotificationMsg) IsAlarmActive 

func (omci *AlarmNotificationMsg) IsAlarmActive(alarmNumber uint8) (bool, error)

func (*AlarmNotificationMsg) IsAlarmClear 

func (omci *AlarmNotificationMsg) IsAlarmClear(alarmNumber uint8) (bool, error)

func (*AlarmNotificationMsg) SerializeTo 

func (omci *AlarmNotificationMsg) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Alarm Notification message

func (*AlarmNotificationMsg) String 

func (omci *AlarmNotificationMsg) String() string

type AlarmOptions added in v0.0.7 

type AlarmOptions struct {
	AlarmClassID  me.ClassID
	AlarmInstance uint16
	AlarmBitmap   []byte // Should be up to 58 octets
}

Alarm related frames have a wide variety of settable values. Placing them in a separate struct is mainly to keep the base options simple

type AttributeValueChangeMsg 

type AttributeValueChangeMsg struct {
	MeBasePacket
	AttributeMask uint16
	Attributes    me.AttributeValueMap
}

/////////////////////////////////////////////////////////////////////////// AttributeValueChangeMsg

func (*AttributeValueChangeMsg) DecodeFromBytes 

func (omci *AttributeValueChangeMsg) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of an Attribute Value Change notification into this layer

func (*AttributeValueChangeMsg) SerializeTo 

func (omci *AttributeValueChangeMsg) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Attribute Value Change Notification message

func (*AttributeValueChangeMsg) String 

func (omci *AttributeValueChangeMsg) String() string

type CommitSoftwareRequest 

type CommitSoftwareRequest struct {
	MeBasePacket
}

///////////////////////////////////////////////////////////////////////////

func (*CommitSoftwareRequest) DecodeFromBytes 

func (omci *CommitSoftwareRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Commit Software Request into this layer

func (*CommitSoftwareRequest) SerializeTo 

func (omci *CommitSoftwareRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Commit Software Request message

func (*CommitSoftwareRequest) String added in v0.0.7 

func (omci *CommitSoftwareRequest) String() string

type CommitSoftwareResponse 

type CommitSoftwareResponse struct {
	MeBasePacket
}

///////////////////////////////////////////////////////////////////////////

func (*CommitSoftwareResponse) DecodeFromBytes 

func (omci *CommitSoftwareResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Commit Softwar Response into this layer

func (*CommitSoftwareResponse) SerializeTo 

func (omci *CommitSoftwareResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Commit Software Response message

func (*CommitSoftwareResponse) String added in v0.0.7 

func (omci *CommitSoftwareResponse) String() string

type CreateRequest 

type CreateRequest struct {
	MeBasePacket
	Attributes me.AttributeValueMap
}

/////////////////////////////////////////////////////////////////////////// CreateRequest

func (*CreateRequest) DecodeFromBytes 

func (omci *CreateRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Create Request into this layer

func (*CreateRequest) SerializeTo 

func (omci *CreateRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Create Request Message

func (*CreateRequest) String 

func (omci *CreateRequest) String() string

type CreateResponse 

type CreateResponse struct {
	MeBasePacket
	Result                 me.Results
	AttributeExecutionMask uint16 // Used when Result == ParameterError
}

/////////////////////////////////////////////////////////////////////////// CreateResponse

func (*CreateResponse) DecodeFromBytes 

func (omci *CreateResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Create Response into this layer

func (*CreateResponse) SerializeTo 

func (omci *CreateResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Create Response message

func (*CreateResponse) String 

func (omci *CreateResponse) String() string

type DeleteRequest 

type DeleteRequest struct {
	MeBasePacket
}

/////////////////////////////////////////////////////////////////////////// DeleteRequest

func (*DeleteRequest) DecodeFromBytes 

func (omci *DeleteRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Delete Request into this layer

func (*DeleteRequest) SerializeTo 

func (omci *DeleteRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Delete Request message

func (*DeleteRequest) String 

func (omci *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	MeBasePacket
	Result me.Results
}

/////////////////////////////////////////////////////////////////////////// DeleteResponse

func (*DeleteResponse) DecodeFromBytes 

func (omci *DeleteResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Delete Response into this layer

func (*DeleteResponse) SerializeTo 

func (omci *DeleteResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Delete Response message

func (*DeleteResponse) String 

func (omci *DeleteResponse) String() string

type DeviceIdent 

type DeviceIdent byte

DeviceIdent identifies the OMCI message format. Currently either baseline or extended. 

const (

	// BaselineIdent message are composed of a fixed 40 octet packet + 8-octet trailer. All
	// G-PON OLTs and ONUs support the baseline message set
	BaselineIdent DeviceIdent = 0x0A

	// ExtendedIdent messager are up to 1920 octets but may not be supported by all ONUs or OLTs.
	ExtendedIdent DeviceIdent = 0x0B
)

func (DeviceIdent) String 

func (di DeviceIdent) String() string

type DownloadSectionRequest 

type DownloadSectionRequest struct {
	MeBasePacket  // Note: EntityInstance for software download is two specific values
	SectionNumber byte
	SectionData   [29]byte // 0 padding if final transfer requires only a partial block
}

///////////////////////////////////////////////////////////////////////////

func (*DownloadSectionRequest) DecodeFromBytes 

func (omci *DownloadSectionRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Download Section Request into this layer

func (*DownloadSectionRequest) SerializeTo 

func (omci *DownloadSectionRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Download Section Request message

func (*DownloadSectionRequest) String added in v0.0.7 

func (omci *DownloadSectionRequest) String() string

type DownloadSectionResponse 

type DownloadSectionResponse struct {
	MeBasePacket  // Note: EntityInstance for software download is two specific values
	Result        me.Results
	SectionNumber byte
}

///////////////////////////////////////////////////////////////////////////

func (*DownloadSectionResponse) DecodeFromBytes 

func (omci *DownloadSectionResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Download Section Response into this layer

func (*DownloadSectionResponse) SerializeTo 

func (omci *DownloadSectionResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Download Section Response message

func (*DownloadSectionResponse) String added in v0.0.7 

func (omci *DownloadSectionResponse) String() string

type EndSoftwareDownloadRequest 

type EndSoftwareDownloadRequest struct {
	MeBasePacket      // Note: EntityInstance for software download is two specific values
	CRC32             uint32
	ImageSize         uint32
	NumberOfInstances byte
	ImageInstances    []uint16
}

///////////////////////////////////////////////////////////////////////////

func (*EndSoftwareDownloadRequest) DecodeFromBytes 

func (omci *EndSoftwareDownloadRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of an End Software Download Request into this layer

func (*EndSoftwareDownloadRequest) SerializeTo 

func (omci *EndSoftwareDownloadRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an End Software Download Request message

func (*EndSoftwareDownloadRequest) String added in v0.0.7 

func (omci *EndSoftwareDownloadRequest) String() string

type EndSoftwareDownloadResponse 

type EndSoftwareDownloadResponse struct {
	MeBasePacket      // Note: EntityInstance for software download is two specific values
	Result            me.Results
	NumberOfInstances byte
	MeResults         []downloadResults
}

///////////////////////////////////////////////////////////////////////////

func (*EndSoftwareDownloadResponse) DecodeFromBytes 

func (omci *EndSoftwareDownloadResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of an End Software Download Response into this layer

func (*EndSoftwareDownloadResponse) SerializeTo 

func (omci *EndSoftwareDownloadResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an End Software Download Response message

func (*EndSoftwareDownloadResponse) String added in v0.0.7 

func (omci *EndSoftwareDownloadResponse) String() string

type FrameOption 

type FrameOption func(*options)

FrameOption sets options such as frame format, etc.

func AddDefaults added in v0.13.0 

func AddDefaults(add bool) FrameOption

AddDefaults is used to specify that if a SetByCreate attribute is not specified in the list of attributes for a Create Request, use the attribute defined default

func Alarm added in v0.0.7 

func Alarm(ao AlarmOptions) FrameOption

Alarm is used to specify a collection of options related to Alarm notifications

func AttributeExecutionMask 

func AttributeExecutionMask(m uint16) FrameOption

AttributeExecutionMask is used by the Create and Set Response frames to indicate attributes that failed to be created/set.

func AttributeMask 

func AttributeMask(m uint16) FrameOption

attributeMask determines the attributes to encode into the frame. The default value is 0xFFFF which specifies all available attributes in the frame

func FailIfTruncated 

func FailIfTruncated(f bool) FrameOption

FailIfTruncated determines whether a request to encode a frame that does not have enough room for all requested options should fail and return an error.

If set to 'false', the behaviour depends on the message type/operation requested. The table below provides more information: 

  Request Type	Behavour
	 ------------------------------------------------------------------------
	 CreateRequest  A single CreateRequest struct is always returned as the
                 CreateRequest message does not have an attributes Mask
                 field and a Baseline OMCI message is large enough to
                 support all Set-By-Create attributes.

  GetResponse	If multiple OMCI response frames are needed to return
					all requested attributes, only the attributes that can
					fit will be returned and the FailedAttributeMask field
					set to the attributes that could not be returned

					If this is an ME with an attribute that is a table, the
					first GetResponse struct will return the size of the
					attribute and the following GetNextResponse structs will
					contain the attribute data. The ONU application is
					responsible for stashing these extra struct(s) away in
					anticipation of possible GetNext Requests occurring for
					the attribute.  See the discussion on Table attributes
					in the GetResponse section of ITU G.988 for more
					information.

If set to 'true', no struct(s) are returned and an error is provided.

The default value is 'false'

func FrameFormat 

func FrameFormat(ff DeviceIdent) FrameOption

FrameFormat determines determines the OMCI message format used on the fiber. The default value is BaselineIdent

func Payload added in v0.0.7 

func Payload(p interface{}) FrameOption

Payload is used to specify ME payload options that are not simple types. This include the ME (list of MEs) to encode into a GetNextMibUpload response, the alarm bitmap for alarm relates responses/notifications, alarm bitmaps, and for specifying the download section data when performing Software Download.

func RebootCondition added in v0.0.7 

func RebootCondition(m uint8) FrameOption

RebootCondition is to specify the the Reboot Condition for a ONU Reboot request

func Result added in v0.0.7 

func Result(r me.Results) FrameOption

Result is used to set returned results in responses that have that field

func RetrievalMode added in v0.0.7 

func RetrievalMode(m uint8) FrameOption

RetrievalMode is to specify the the Alarm Retrieval Mode in a GetAllAlarms Request

func SequenceNumberCountOrSize added in v0.0.7 

func SequenceNumberCountOrSize(m uint16) FrameOption

SequenceNumberCountOrSize is used by the GetNext and MibUploadGetNext request frames and for frames that return number of commands or length such as Get (table attribute) or MibUpload/GetAllAlarms/...

func Software added in v0.0.7 

func Software(so SoftwareOptions) FrameOption

Software is used to specify a collection of options related to Software image manipulation

func SuccessResult added in v0.0.7 

func SuccessResult(m uint8) FrameOption

SuccessResult is to specify the the SuccessResult for a SynchronizeTime Response

func TransactionID added in v0.0.7 

func TransactionID(tid uint16) FrameOption

TransactionID is to specify the TID in the OMCI header. The default is zero which requires the caller to set it to the appropriate value if this is not an autonomous ONU notification frame

func UnsupportedAttributeMask added in v0.0.7 

func UnsupportedAttributeMask(m uint16) FrameOption

UnsupportedAttributeMask is used by the Set Response frames to indicate attributes are not supported on this ONU

type GetAllAlarmsNextRequest 

type GetAllAlarmsNextRequest struct {
	MeBasePacket
	CommandSequenceNumber uint16
}

/////////////////////////////////////////////////////////////////////////// GetAllAlarms

func (*GetAllAlarmsNextRequest) DecodeFromBytes 

func (omci *GetAllAlarmsNextRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Get All Alarms Next Request into this layer

func (*GetAllAlarmsNextRequest) SerializeTo 

func (omci *GetAllAlarmsNextRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Get All Alarms Next Request message

func (*GetAllAlarmsNextRequest) String 

func (omci *GetAllAlarmsNextRequest) String() string

type GetAllAlarmsNextResponse 

type GetAllAlarmsNextResponse struct {
	MeBasePacket
	AlarmEntityClass    me.ClassID
	AlarmEntityInstance uint16
	AlarmBitMap         [28]byte // 224 bits
}

/////////////////////////////////////////////////////////////////////////// GetAllAlarms

func (*GetAllAlarmsNextResponse) DecodeFromBytes 

func (omci *GetAllAlarmsNextResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Get All Alarms Next Response into this layer

func (*GetAllAlarmsNextResponse) SerializeTo 

func (omci *GetAllAlarmsNextResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Get All Alarms Next Response message

func (*GetAllAlarmsNextResponse) String 

func (omci *GetAllAlarmsNextResponse) String() string

type GetAllAlarmsRequest 

type GetAllAlarmsRequest struct {
	MeBasePacket
	AlarmRetrievalMode byte
}

/////////////////////////////////////////////////////////////////////////// GetAllAlarms

func (*GetAllAlarmsRequest) DecodeFromBytes 

func (omci *GetAllAlarmsRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Get All Alarms Request into this layer

func (*GetAllAlarmsRequest) SerializeTo 

func (omci *GetAllAlarmsRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Get All Alarms Request message

func (*GetAllAlarmsRequest) String 

func (omci *GetAllAlarmsRequest) String() string

type GetAllAlarmsResponse 

type GetAllAlarmsResponse struct {
	MeBasePacket
	NumberOfCommands uint16
}

/////////////////////////////////////////////////////////////////////////// GetAllAlarms

func (*GetAllAlarmsResponse) DecodeFromBytes 

func (omci *GetAllAlarmsResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Get All Alarms Response into this layer

func (*GetAllAlarmsResponse) SerializeTo 

func (omci *GetAllAlarmsResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Get All Alarms Response message

func (*GetAllAlarmsResponse) String 

func (omci *GetAllAlarmsResponse) String() string

type GetCurrentDataRequest 

type GetCurrentDataRequest struct {
	MeBasePacket
	AttributeMask uint16
}

///////////////////////////////////////////////////////////////////////////

func (*GetCurrentDataRequest) DecodeFromBytes 

func (omci *GetCurrentDataRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Get Current Data Request into this layer

func (*GetCurrentDataRequest) SerializeTo 

func (omci *GetCurrentDataRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Get Current Data Request message

func (*GetCurrentDataRequest) String added in v0.0.7 

func (omci *GetCurrentDataRequest) String() string

type GetCurrentDataResponse 

type GetCurrentDataResponse struct {
	MeBasePacket
	Result        me.Results
	AttributeMask uint16
	Attributes    me.AttributeValueMap
}

///////////////////////////////////////////////////////////////////////////

func (*GetCurrentDataResponse) DecodeFromBytes 

func (omci *GetCurrentDataResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Get Current Data Respnse into this layer

func (*GetCurrentDataResponse) SerializeTo 

func (omci *GetCurrentDataResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Get Current Data Message Type Response

func (*GetCurrentDataResponse) String added in v0.0.7 

func (omci *GetCurrentDataResponse) String() string

type GetNextRequest 

type GetNextRequest struct {
	MeBasePacket
	AttributeMask  uint16
	SequenceNumber uint16
}

///////////////////////////////////////////////////////////////////////////

func (*GetNextRequest) DecodeFromBytes 

func (omci *GetNextRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Get Next Request into this layer

func (*GetNextRequest) SerializeTo 

func (omci *GetNextRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Get Next Message Type Request

func (*GetNextRequest) String added in v0.0.7 

func (omci *GetNextRequest) String() string

type GetNextResponse 

type GetNextResponse struct {
	MeBasePacket
	Result        me.Results
	AttributeMask uint16
	Attributes    me.AttributeValueMap
}

///////////////////////////////////////////////////////////////////////////

func (*GetNextResponse) DecodeFromBytes 

func (omci *GetNextResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Get Next Response into this layer

func (*GetNextResponse) SerializeTo 

func (omci *GetNextResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Get Next Message Type Response

func (*GetNextResponse) String added in v0.0.7 

func (omci *GetNextResponse) String() string

SerializeTo provides serialization of an Get Next Message Type Response

type GetRequest 

type GetRequest struct {
	MeBasePacket
	AttributeMask uint16
}

/////////////////////////////////////////////////////////////////////////// GetRequest

func (*GetRequest) DecodeFromBytes 

func (omci *GetRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Get Request into this layer

func (*GetRequest) SerializeTo 

func (omci *GetRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Get Request message

func (*GetRequest) String 

func (omci *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	MeBasePacket
	Result                   me.Results
	AttributeMask            uint16
	Attributes               me.AttributeValueMap
	UnsupportedAttributeMask uint16
	FailedAttributeMask      uint16
}

/////////////////////////////////////////////////////////////////////////// GetResponse

func (*GetResponse) DecodeFromBytes 

func (omci *GetResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Get Response into this layer

func (*GetResponse) SerializeTo 

func (omci *GetResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Get Response message

func (*GetResponse) String 

func (omci *GetResponse) String() string

type MeBasePacket 

type MeBasePacket struct {
	EntityClass    me.ClassID
	EntityInstance uint16

	gopacket.Layer
	layers.BaseLayer
	MsgLayerType gopacket.LayerType
}

func (*MeBasePacket) CanDecode 

func (msg *MeBasePacket) CanDecode() gopacket.LayerClass

CanDecode returns the set of layer types that this DecodingLayer can decode

func (*MeBasePacket) DecodeFromBytes 

func (msg *MeBasePacket) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes into this layer

func (*MeBasePacket) LayerContents 

func (msg *MeBasePacket) LayerContents() []byte

LayerContents returns the bytes of the packet layer.

func (*MeBasePacket) LayerPayload 

func (msg *MeBasePacket) LayerPayload() []byte

LayerPayload returns the bytes contained within the packet layer

func (*MeBasePacket) LayerType 

func (msg *MeBasePacket) LayerType() gopacket.LayerType

LayerType returns MsgLayerType. It partially satisfies Layer and SerializableLayer

func (*MeBasePacket) NextLayerType 

func (msg *MeBasePacket) NextLayerType() gopacket.LayerType

NextLayerType returns the layer type contained by this DecodingLayer

func (*MeBasePacket) SerializeTo 

func (msg *MeBasePacket) SerializeTo(b gopacket.SerializeBuffer) error

SerializeTo provides serialization of this message layer

func (*MeBasePacket) String 

func (msg *MeBasePacket) String() string

type MessageType added in v0.0.2 

type MessageType byte

MessageType is the OMCI Message Type or'ed with the AR/AK flags as appropriate.

func (MessageType) String added in v0.0.7 

func (mt MessageType) String() string

type MibResetRequest 

type MibResetRequest struct {
	MeBasePacket
}

/////////////////////////////////////////////////////////////////////////// MibResetRequest

func (*MibResetRequest) DecodeFromBytes 

func (omci *MibResetRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a MIB Reset Request into this layer

func (*MibResetRequest) SerializeTo 

func (omci *MibResetRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an MIB Reset Request message

func (*MibResetRequest) String 

func (omci *MibResetRequest) String() string

type MibResetResponse 

type MibResetResponse struct {
	MeBasePacket
	Result me.Results
}

/////////////////////////////////////////////////////////////////////////// MibResetResponse

func (*MibResetResponse) DecodeFromBytes 

func (omci *MibResetResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a MIB Reset Response into this layer

func (*MibResetResponse) SerializeTo 

func (omci *MibResetResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an MIB Reset Response message

func (*MibResetResponse) String 

func (omci *MibResetResponse) String() string

type MibUploadNextRequest 

type MibUploadNextRequest struct {
	MeBasePacket
	CommandSequenceNumber uint16
}

///////////////////////////////////////////////////////////////////////////

func (*MibUploadNextRequest) DecodeFromBytes 

func (omci *MibUploadNextRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a MIB Upload Next Request into this layer

func (*MibUploadNextRequest) SerializeTo 

func (omci *MibUploadNextRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an MIB Upload Next Request message

func (*MibUploadNextRequest) String 

func (omci *MibUploadNextRequest) String() string

type MibUploadNextResponse 

type MibUploadNextResponse struct {
	MeBasePacket
	ReportedME me.ManagedEntity
}

///////////////////////////////////////////////////////////////////////////

func (*MibUploadNextResponse) DecodeFromBytes 

func (omci *MibUploadNextResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a MIB Upload Next Response into this layer

func (*MibUploadNextResponse) SerializeTo 

func (omci *MibUploadNextResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an MIB Upload Next Response message

func (*MibUploadNextResponse) String 

func (omci *MibUploadNextResponse) String() string

type MibUploadRequest 

type MibUploadRequest struct {
	MeBasePacket
}

/////////////////////////////////////////////////////////////////////////// MibUploadRequest

func (*MibUploadRequest) DecodeFromBytes 

func (omci *MibUploadRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a MIB Upload Request into this layer

func (*MibUploadRequest) SerializeTo 

func (omci *MibUploadRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an MIB Upload Request message

func (*MibUploadRequest) String 

func (omci *MibUploadRequest) String() string

type MibUploadResponse 

type MibUploadResponse struct {
	MeBasePacket
	NumberOfCommands uint16
}

/////////////////////////////////////////////////////////////////////////// MibUploadResponse

func (*MibUploadResponse) DecodeFromBytes 

func (omci *MibUploadResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a MIB Upload Response into this layer

func (*MibUploadResponse) SerializeTo 

func (omci *MibUploadResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an MIB Upload Response message

func (*MibUploadResponse) String 

func (omci *MibUploadResponse) String() string

type OMCI 

type OMCI struct {
	layers.BaseLayer
	TransactionID    uint16
	MessageType      MessageType
	DeviceIdentifier DeviceIdent
	Payload          []byte

	Length uint16
	MIC    uint32
	// contains filtered or unexported fields
}

OMCI defines the common protocol. Extended will be added once I can get basic working (and layered properly). See ITU-T G.988 11/2017 section A.3 for more information

func EncodeFrame added in v0.0.7 

func EncodeFrame(m *me.ManagedEntity, messageType MessageType, opt ...FrameOption) (*OMCI, gopacket.SerializableLayer, error)

EncodeFrame will encode the Managed Entity specific protocol struct and an OMCILayer struct. This struct can be provided to the gopacket.SerializeLayers() function to be serialized into a buffer for transmission.

func (*OMCI) CanDecode 

func (omci *OMCI) CanDecode() gopacket.LayerClass

CanDecode returns the layers that this class can decode

func (*OMCI) DecodeFromBytes 

func (omci *OMCI) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes will decode the OMCI layer of a packet/message

func (*OMCI) LayerContents 

func (omci *OMCI) LayerContents() []byte

LayerContents returns the OMCI specific layer information

func (*OMCI) LayerType 

func (omci *OMCI) LayerType() gopacket.LayerType

LayerType returns LayerTypeOMCI

func (*OMCI) NextLayerType 

func (omci *OMCI) NextLayerType() gopacket.LayerType

NextLayerType returns the layer type contained by this DecodingLayer.

func (*OMCI) SerializeTo 

func (omci *OMCI) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo writes the serialized form of this layer into the SerializationBuffer, implementing gopacket.SerializableLayer. See the docs for gopacket.SerializableLayer for more info.

func (*OMCI) String 

func (omci *OMCI) String() string

type RebootRequest 

type RebootRequest struct {
	MeBasePacket
	RebootCondition byte
}

///////////////////////////////////////////////////////////////////////////

func (*RebootRequest) DecodeFromBytes 

func (omci *RebootRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Reboot Request into this layer

func (*RebootRequest) SerializeTo 

func (omci *RebootRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Reboot Request message

func (*RebootRequest) String added in v0.0.7 

func (omci *RebootRequest) String() string

type RebootResponse 

type RebootResponse struct {
	MeBasePacket
	Result me.Results
}

///////////////////////////////////////////////////////////////////////////

func (*RebootResponse) DecodeFromBytes 

func (omci *RebootResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Reboot Response into this layer

func (*RebootResponse) SerializeTo 

func (omci *RebootResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Reboot Response message

func (*RebootResponse) String added in v0.0.7 

func (omci *RebootResponse) String() string

DecodeFromBytes decodes the given bytes of a Reboot Response into this layer

type SetRequest 

type SetRequest struct {
	MeBasePacket
	AttributeMask uint16
	Attributes    me.AttributeValueMap
}

/////////////////////////////////////////////////////////////////////////// SetRequest

func (*SetRequest) DecodeFromBytes 

func (omci *SetRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Set Request into this layer

func (*SetRequest) SerializeTo 

func (omci *SetRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Set Request message

func (*SetRequest) String 

func (omci *SetRequest) String() string

type SetResponse 

type SetResponse struct {
	MeBasePacket
	Result                   me.Results
	UnsupportedAttributeMask uint16
	FailedAttributeMask      uint16
}

/////////////////////////////////////////////////////////////////////////// SetResponse

func (*SetResponse) DecodeFromBytes 

func (omci *SetResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Set Response into this layer

func (*SetResponse) SerializeTo 

func (omci *SetResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Set Response message

func (*SetResponse) String 

func (omci *SetResponse) String() string

type SetTableRequest 

type SetTableRequest struct {
	MeBasePacket
}

///////////////////////////////////////////////////////////////////////////

func (*SetTableRequest) DecodeFromBytes 

func (omci *SetTableRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Set Table Request into this layer

func (*SetTableRequest) SerializeTo 

func (omci *SetTableRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Set Table Message Type Request

func (*SetTableRequest) String added in v0.0.7 

func (omci *SetTableRequest) String() string

type SetTableResponse 

type SetTableResponse struct {
	MeBasePacket
}

///////////////////////////////////////////////////////////////////////////

func (*SetTableResponse) DecodeFromBytes 

func (omci *SetTableResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Set Table Response into this layer

func (*SetTableResponse) SerializeTo 

func (omci *SetTableResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Set Table Message Type Response

func (*SetTableResponse) String added in v0.0.7 

func (omci *SetTableResponse) String() string

type SoftwareOptions added in v0.0.7 

type SoftwareOptions struct {
	WindowSize   uint8 // Window size - 1
	ImageSize    uint32
	CircuitPacks []uint16 // slot (upper 8 bits) and instance (lower 8 bits)
	Results      []downloadResults
}

Software related frames have a wide variety of settable values. Placing them in a separate struct is mainly to keep the base options simple

type StartSoftwareDownloadRequest 

type StartSoftwareDownloadRequest struct {
	MeBasePacket                // Note: EntityInstance for software download is two specific values
	WindowSize           byte   // Window Size -1
	ImageSize            uint32 // Octets
	NumberOfCircuitPacks byte
	CircuitPacks         []uint16 // MSB & LSB of software image instance
}

///////////////////////////////////////////////////////////////////////////

func (*StartSoftwareDownloadRequest) DecodeFromBytes 

func (omci *StartSoftwareDownloadRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Start Software Download Request into this layer

func (*StartSoftwareDownloadRequest) SerializeTo 

func (omci *StartSoftwareDownloadRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Start Software Download Request message

func (*StartSoftwareDownloadRequest) String added in v0.0.7 

func (omci *StartSoftwareDownloadRequest) String() string

type StartSoftwareDownloadResponse 

type StartSoftwareDownloadResponse struct {
	MeBasePacket      // Note: EntityInstance for software download is two specific values
	Result            me.Results
	WindowSize        byte // Window Size -1
	NumberOfInstances byte
	MeResults         []downloadResults
}

func (*StartSoftwareDownloadResponse) DecodeFromBytes 

func (omci *StartSoftwareDownloadResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Start Software Download Response into this layer

func (*StartSoftwareDownloadResponse) SerializeTo 

func (omci *StartSoftwareDownloadResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Start Software Download Response message

func (*StartSoftwareDownloadResponse) String added in v0.0.7 

func (omci *StartSoftwareDownloadResponse) String() string

type SynchronizeTimeRequest 

type SynchronizeTimeRequest struct {
	MeBasePacket
	Year   uint16
	Month  uint8
	Day    uint8
	Hour   uint8
	Minute uint8
	Second uint8
}

///////////////////////////////////////////////////////////////////////////

func (*SynchronizeTimeRequest) DecodeFromBytes 

func (omci *SynchronizeTimeRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Synchronize Time Request into this layer

func (*SynchronizeTimeRequest) SerializeTo 

func (omci *SynchronizeTimeRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Synchronize Time Request message

func (*SynchronizeTimeRequest) String added in v0.0.7 

func (omci *SynchronizeTimeRequest) String() string

type SynchronizeTimeResponse 

type SynchronizeTimeResponse struct {
	MeBasePacket
	Result         me.Results
	SuccessResults uint8 // Only if 'Result' is 0 -> success
}

///////////////////////////////////////////////////////////////////////////

func (*SynchronizeTimeResponse) DecodeFromBytes 

func (omci *SynchronizeTimeResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Synchronize Time Response into this layer

func (*SynchronizeTimeResponse) SerializeTo 

func (omci *SynchronizeTimeResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Synchronize Time Response message

func (*SynchronizeTimeResponse) String added in v0.0.7 

func (omci *SynchronizeTimeResponse) String() string

type TestRequest 

type TestRequest struct {
	MeBasePacket
}

/////////////////////////////////////////////////////////////////////////// TestRequest: TODO: Not yet implemented

func (*TestRequest) DecodeFromBytes 

func (omci *TestRequest) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Test Request into this layer

func (*TestRequest) SerializeTo 

func (omci *TestRequest) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Test Request message

func (*TestRequest) String 

func (omci *TestRequest) String() string

type TestResponse 

type TestResponse struct {
	MeBasePacket
}

/////////////////////////////////////////////////////////////////////////// TestResponse: TODO: Not yet implemented

func (*TestResponse) DecodeFromBytes 

func (omci *TestResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Test Response into this layer

func (*TestResponse) SerializeTo 

func (omci *TestResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Test Response message

func (*TestResponse) String added in v0.0.7 

func (omci *TestResponse) String() string

type TestResultMsg 

type TestResultMsg struct {
	MeBasePacket
}

///////////////////////////////////////////////////////////////////////////

func (*TestResultMsg) DecodeFromBytes 

func (omci *TestResultMsg) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of a Test Result Notification into this layer

func (*TestResultMsg) SerializeTo 

func (omci *TestResultMsg) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Test Result notification message

func (*TestResultMsg) String added in v0.0.7 

func (omci *TestResultMsg) String() string

type UnsupportedMessageTypeResponse 

type UnsupportedMessageTypeResponse struct {
	MeBasePacket
	Result me.Results
}

///////////////////////////////////////////////////////////////////////////

func (*UnsupportedMessageTypeResponse) DecodeFromBytes 

func (omci *UnsupportedMessageTypeResponse) DecodeFromBytes(data []byte, p gopacket.PacketBuilder) error

DecodeFromBytes decodes the given bytes of an Unsupported Message Type Response into this layer

func (*UnsupportedMessageTypeResponse) SerializeTo 

func (omci *UnsupportedMessageTypeResponse) SerializeTo(b gopacket.SerializeBuffer, opts gopacket.SerializeOptions) error

SerializeTo provides serialization of an Unsupported Message Type Response

Source Files

View all Source files

Directories

Path Synopsis
examples
misc
sequences
Package generated provides code-generated OMCI types
 Package generated provides code-generated OMCI types

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.