voltha

package
v5.5.0 Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2024 License: Apache-2.0 Imports: 18 Imported by: 7

Documentation

Index

Constants

View Source 
const AdminState_DISABLED = AdminState_Types(common.AdminState_DISABLED)
View Source 
const AdminState_DOWNLOADING_IMAGE = AdminState_Types(common.AdminState_DOWNLOADING_IMAGE)
View Source 
const AdminState_ENABLED = AdminState_Types(common.AdminState_ENABLED)
View Source 
const AdminState_PREPROVISIONED = AdminState_Types(common.AdminState_PREPROVISIONED)
View Source 
const AdminState_UNKNOWN = AdminState_Types(common.AdminState_UNKNOWN)
View Source 
const ConnectStatus_REACHABLE = ConnectStatus_Types(common.ConnectStatus_REACHABLE)
View Source 
const ConnectStatus_UNKNOWN = ConnectStatus_Types(common.ConnectStatus_UNKNOWN)
View Source 
const ConnectStatus_UNREACHABLE = ConnectStatus_Types(common.ConnectStatus_UNREACHABLE)
View Source 
const OperStatus_ACTIVATING = OperStatus_Types(common.OperStatus_ACTIVATING)
View Source 
const OperStatus_ACTIVE = OperStatus_Types(common.OperStatus_ACTIVE)
View Source 
const OperStatus_DISCOVERED = OperStatus_Types(common.OperStatus_DISCOVERED)
View Source 
const OperStatus_FAILED = OperStatus_Types(common.OperStatus_FAILED)
View Source 
const OperStatus_REBOOTED = OperStatus_Types(common.OperStatus_REBOOTED)
View Source 
const OperStatus_RECONCILING = OperStatus_Types(common.OperStatus_RECONCILING)
View Source 
const OperStatus_RECONCILING_FAILED = OperStatus_Types(common.OperStatus_RECONCILING_FAILED)
View Source 
const OperStatus_TESTING = OperStatus_Types(common.OperStatus_TESTING)
View Source 
const OperStatus_UNKNOWN = OperStatus_Types(common.OperStatus_UNKNOWN)
View Source 
const OperationResp_OPERATION_FAILURE = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_FAILURE)
View Source 
const OperationResp_OPERATION_IN_PROGRESS = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_IN_PROGRESS)
View Source 
const OperationResp_OPERATION_SUCCESS = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_SUCCESS)
View Source 
const OperationResp_OPERATION_UNSUPPORTED = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_UNSUPPORTED)
View Source 
const TestModeKeys_api_test = TestModeKeys(common.TestModeKeys_api_test)

Variables

View Source 
var AdminState_Types_name = common.AdminState_Types_name
View Source 
var AdminState_Types_value = common.AdminState_Types_value
View Source 
var ConfigEventType_Types_name = map[int32]string{
	0: "add",
	1: "remove",
	2: "update",
}
View Source 
var ConfigEventType_Types_value = map[string]int32{
	"add":    0,
	"remove": 1,
	"update": 2,
}
View Source 
var ConnectStatus_Types_name = common.ConnectStatus_Types_name
View Source 
var ConnectStatus_Types_value = common.ConnectStatus_Types_value
View Source 
var EventCategory_Types_name = map[int32]string{
	0: "COMMUNICATION",
	1: "ENVIRONMENT",
	2: "EQUIPMENT",
	3: "SERVICE",
	4: "PROCESSING",
	5: "SECURITY",
}
View Source 
var EventCategory_Types_value = map[string]int32{
	"COMMUNICATION": 0,
	"ENVIRONMENT":   1,
	"EQUIPMENT":     2,
	"SERVICE":       3,
	"PROCESSING":    4,
	"SECURITY":      5,
}
View Source 
var EventFilterRuleKey_EventFilterRuleType_name = map[int32]string{
	0: "filter_all",
	1: "category",
	2: "sub_category",
	3: "kpi_event_type",
	4: "config_event_type",
	5: "device_event_type",
}
View Source 
var EventFilterRuleKey_EventFilterRuleType_value = map[string]int32{
	"filter_all":        0,
	"category":          1,
	"sub_category":      2,
	"kpi_event_type":    3,
	"config_event_type": 4,
	"device_event_type": 5,
}
View Source 
var EventSubCategory_Types_name = map[int32]string{
	0: "PON",
	1: "OLT",
	2: "ONT",
	3: "ONU",
	4: "NNI",
	5: "NONE",
}
View Source 
var EventSubCategory_Types_value = map[string]int32{
	"PON":  0,
	"OLT":  1,
	"ONT":  2,
	"ONU":  3,
	"NNI":  4,
	"NONE": 5,
}
View Source 
var EventType_Types_name = map[int32]string{
	0: "CONFIG_EVENT",
	1: "KPI_EVENT",
	2: "KPI_EVENT2",
	3: "DEVICE_EVENT",
	4: "RPC_EVENT",
}
View Source 
var EventType_Types_value = map[string]int32{
	"CONFIG_EVENT": 0,
	"KPI_EVENT":    1,
	"KPI_EVENT2":   2,
	"DEVICE_EVENT": 3,
	"RPC_EVENT":    4,
}
View Source 
var ImageDownload_ImageActivateState_name = map[int32]string{
	0: "IMAGE_UNKNOWN",
	1: "IMAGE_INACTIVE",
	2: "IMAGE_ACTIVATING",
	3: "IMAGE_ACTIVE",
	4: "IMAGE_REVERTING",
	5: "IMAGE_REVERTED",
}
View Source 
var ImageDownload_ImageActivateState_value = map[string]int32{
	"IMAGE_UNKNOWN":    0,
	"IMAGE_INACTIVE":   1,
	"IMAGE_ACTIVATING": 2,
	"IMAGE_ACTIVE":     3,
	"IMAGE_REVERTING":  4,
	"IMAGE_REVERTED":   5,
}
View Source 
var ImageDownload_ImageDownloadFailureReason_name = map[int32]string{
	0: "NO_ERROR",
	1: "INVALID_URL",
	2: "DEVICE_BUSY",
	3: "INSUFFICIENT_SPACE",
	4: "UNKNOWN_ERROR",
	5: "CANCELLED",
}
View Source 
var ImageDownload_ImageDownloadFailureReason_value = map[string]int32{
	"NO_ERROR":           0,
	"INVALID_URL":        1,
	"DEVICE_BUSY":        2,
	"INSUFFICIENT_SPACE": 3,
	"UNKNOWN_ERROR":      4,
	"CANCELLED":          5,
}
View Source 
var ImageDownload_ImageDownloadState_name = map[int32]string{
	0: "DOWNLOAD_UNKNOWN",
	1: "DOWNLOAD_SUCCEEDED",
	2: "DOWNLOAD_REQUESTED",
	3: "DOWNLOAD_STARTED",
	4: "DOWNLOAD_FAILED",
	5: "DOWNLOAD_UNSUPPORTED",
	6: "DOWNLOAD_CANCELLED",
}
View Source 
var ImageDownload_ImageDownloadState_value = map[string]int32{
	"DOWNLOAD_UNKNOWN":     0,
	"DOWNLOAD_SUCCEEDED":   1,
	"DOWNLOAD_REQUESTED":   2,
	"DOWNLOAD_STARTED":     3,
	"DOWNLOAD_FAILED":      4,
	"DOWNLOAD_UNSUPPORTED": 5,
	"DOWNLOAD_CANCELLED":   6,
}
View Source 
var ImageState_ImageActivationState_name = map[int32]string{
	0:  "IMAGE_UNKNOWN",
	1:  "IMAGE_INACTIVE",
	2:  "IMAGE_ACTIVATING",
	3:  "IMAGE_ACTIVE",
	4:  "IMAGE_COMMITTING",
	5:  "IMAGE_COMMITTED",
	6:  "IMAGE_ACTIVATION_ABORTING",
	7:  "IMAGE_ACTIVATION_ABORTED",
	8:  "IMAGE_COMMIT_ABORTING",
	9:  "IMAGE_COMMIT_ABORTED",
	10: "IMAGE_DOWNLOADING",
}
View Source 
var ImageState_ImageActivationState_value = map[string]int32{
	"IMAGE_UNKNOWN":             0,
	"IMAGE_INACTIVE":            1,
	"IMAGE_ACTIVATING":          2,
	"IMAGE_ACTIVE":              3,
	"IMAGE_COMMITTING":          4,
	"IMAGE_COMMITTED":           5,
	"IMAGE_ACTIVATION_ABORTING": 6,
	"IMAGE_ACTIVATION_ABORTED":  7,
	"IMAGE_COMMIT_ABORTING":     8,
	"IMAGE_COMMIT_ABORTED":      9,
	"IMAGE_DOWNLOADING":         10,
}
View Source 
var ImageState_ImageDownloadState_name = map[int32]string{
	0: "DOWNLOAD_UNKNOWN",
	1: "DOWNLOAD_SUCCEEDED",
	2: "DOWNLOAD_REQUESTED",
	3: "DOWNLOAD_STARTED",
	4: "DOWNLOAD_FAILED",
	5: "DOWNLOAD_UNSUPPORTED",
	6: "DOWNLOAD_CANCELLING",
	7: "DOWNLOAD_CANCELLED",
}
View Source 
var ImageState_ImageDownloadState_value = map[string]int32{
	"DOWNLOAD_UNKNOWN":     0,
	"DOWNLOAD_SUCCEEDED":   1,
	"DOWNLOAD_REQUESTED":   2,
	"DOWNLOAD_STARTED":     3,
	"DOWNLOAD_FAILED":      4,
	"DOWNLOAD_UNSUPPORTED": 5,
	"DOWNLOAD_CANCELLING":  6,
	"DOWNLOAD_CANCELLED":   7,
}
View Source 
var ImageState_ImageFailureReason_name = map[int32]string{
	0: "NO_ERROR",
	1: "INVALID_URL",
	2: "DEVICE_BUSY",
	3: "INSUFFICIENT_SPACE",
	4: "UNKNOWN_ERROR",
	5: "CANCELLED_ON_REQUEST",
	6: "CANCELLED_ON_ONU_STATE",
	7: "VENDOR_DEVICE_MISMATCH",
	8: "OMCI_TRANSFER_ERROR",
	9: "IMAGE_REFUSED_BY_ONU",
}
View Source 
var ImageState_ImageFailureReason_value = map[string]int32{
	"NO_ERROR":               0,
	"INVALID_URL":            1,
	"DEVICE_BUSY":            2,
	"INSUFFICIENT_SPACE":     3,
	"UNKNOWN_ERROR":          4,
	"CANCELLED_ON_REQUEST":   5,
	"CANCELLED_ON_ONU_STATE": 6,
	"VENDOR_DEVICE_MISMATCH": 7,
	"OMCI_TRANSFER_ERROR":    8,
	"IMAGE_REFUSED_BY_ONU":   9,
}
View Source 
var KpiEventType_Types_name = map[int32]string{
	0: "slice",
	1: "ts",
}
View Source 
var KpiEventType_Types_value = map[string]int32{
	"slice": 0,
	"ts":    1,
}
View Source 
var OperStatus_Types_name = common.OperStatus_Types_name
View Source 
var OperStatus_Types_value = common.OperStatus_Types_value
View Source 
var OperationResp_OperationReturnCode_name = common.OperationResp_OperationReturnCode_name
View Source 
var OperationResp_OperationReturnCode_value = common.OperationResp_OperationReturnCode_value
View Source 
var PmConfig_PmType_name = map[int32]string{
	0: "COUNTER",
	1: "GAUGE",
	2: "STATE",
	3: "CONTEXT",
}
View Source 
var PmConfig_PmType_value = map[string]int32{
	"COUNTER": 0,
	"GAUGE":   1,
	"STATE":   2,
	"CONTEXT": 3,
}
View Source 
var Port_PortType_name = map[int32]string{
	0: "UNKNOWN",
	1: "ETHERNET_NNI",
	2: "ETHERNET_UNI",
	3: "PON_OLT",
	4: "PON_ONU",
	5: "VENET_OLT",
	6: "VENET_ONU",
}
View Source 
var Port_PortType_value = map[string]int32{
	"UNKNOWN":      0,
	"ETHERNET_NNI": 1,
	"ETHERNET_UNI": 2,
	"PON_OLT":      3,
	"PON_ONU":      4,
	"VENET_OLT":    5,
	"VENET_ONU":    6,
}
View Source 
var SelfTestResponse_SelfTestResult_name = map[int32]string{
	0: "SUCCESS",
	1: "FAILURE",
	2: "NOT_SUPPORTED",
	3: "UNKNOWN_ERROR",
}
View Source 
var SelfTestResponse_SelfTestResult_value = map[string]int32{
	"SUCCESS":       0,
	"FAILURE":       1,
	"NOT_SUPPORTED": 2,
	"UNKNOWN_ERROR": 3,
}
View Source 
var SimulateAlarmRequest_OperationType_name = map[int32]string{
	0: "RAISE",
	1: "CLEAR",
}
View Source 
var SimulateAlarmRequest_OperationType_value = map[string]int32{
	"RAISE": 0,
	"CLEAR": 1,
}
View Source 
var TestModeKeys_name = common.TestModeKeys_name
View Source 
var TestModeKeys_value = common.TestModeKeys_value

Functions

func RegisterVolthaServiceServer 

func RegisterVolthaServiceServer(s *grpc.Server, srv VolthaServiceServer)

Types

type Adapter 

type Adapter struct {
	// the adapter ID has to be unique,
	// it will be generated as Type + CurrentReplica
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Vendor  string `protobuf:"bytes,2,opt,name=vendor,proto3" json:"vendor,omitempty"`
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// Adapter configuration
	Config *AdapterConfig `protobuf:"bytes,16,opt,name=config,proto3" json:"config,omitempty"`
	// Custom descriptors and custom configuration
	AdditionalDescription *any.Any `protobuf:"bytes,64,opt,name=additional_description,json=additionalDescription,proto3" json:"additional_description,omitempty"`
	LogicalDeviceIds      []string `protobuf:"bytes,4,rep,name=logical_device_ids,json=logicalDeviceIds,proto3" json:"logical_device_ids,omitempty"`
	// timestamp when the adapter last sent a message to the core
	LastCommunication int64  `protobuf:"varint,5,opt,name=last_communication,json=lastCommunication,proto3" json:"last_communication,omitempty"`
	CurrentReplica    int32  `protobuf:"varint,6,opt,name=currentReplica,proto3" json:"currentReplica,omitempty"`
	TotalReplicas     int32  `protobuf:"varint,7,opt,name=totalReplicas,proto3" json:"totalReplicas,omitempty"`
	Endpoint          string `protobuf:"bytes,8,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// all replicas of the same adapter will have the same type
	// it is used to associate a device to an adapter
	Type                 string   `protobuf:"bytes,9,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Adapter (software plugin)

func (*Adapter) Descriptor 

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

func (*Adapter) GetAdditionalDescription 

func (m *Adapter) GetAdditionalDescription() *any.Any

func (*Adapter) GetConfig 

func (m *Adapter) GetConfig() *AdapterConfig

func (*Adapter) GetCurrentReplica 

func (m *Adapter) GetCurrentReplica() int32

func (*Adapter) GetEndpoint 

func (m *Adapter) GetEndpoint() string

func (*Adapter) GetId 

func (m *Adapter) GetId() string

func (*Adapter) GetLastCommunication 

func (m *Adapter) GetLastCommunication() int64

func (*Adapter) GetLogicalDeviceIds 

func (m *Adapter) GetLogicalDeviceIds() []string

func (*Adapter) GetTotalReplicas 

func (m *Adapter) GetTotalReplicas() int32

func (*Adapter) GetType 

func (m *Adapter) GetType() string

func (*Adapter) GetVendor 

func (m *Adapter) GetVendor() string

func (*Adapter) GetVersion 

func (m *Adapter) GetVersion() string

func (*Adapter) ProtoMessage 

func (*Adapter) ProtoMessage()

func (*Adapter) Reset 

func (m *Adapter) Reset()

func (*Adapter) String 

func (m *Adapter) String() string

func (*Adapter) XXX_DiscardUnknown 

func (m *Adapter) XXX_DiscardUnknown()

func (*Adapter) XXX_Marshal 

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

func (*Adapter) XXX_Merge 

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

func (*Adapter) XXX_Size 

func (m *Adapter) XXX_Size() int

func (*Adapter) XXX_Unmarshal 

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

type AdapterConfig 

type AdapterConfig struct {
	// Custom (vendor-specific) configuration attributes
	AdditionalConfig     *any.Any `protobuf:"bytes,64,opt,name=additional_config,json=additionalConfig,proto3" json:"additional_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AdapterConfig) Descriptor 

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

func (*AdapterConfig) GetAdditionalConfig 

func (m *AdapterConfig) GetAdditionalConfig() *any.Any

func (*AdapterConfig) ProtoMessage 

func (*AdapterConfig) ProtoMessage()

func (*AdapterConfig) Reset 

func (m *AdapterConfig) Reset()

func (*AdapterConfig) String 

func (m *AdapterConfig) String() string

func (*AdapterConfig) XXX_DiscardUnknown 

func (m *AdapterConfig) XXX_DiscardUnknown()

func (*AdapterConfig) XXX_Marshal 

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

func (*AdapterConfig) XXX_Merge 

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

func (*AdapterConfig) XXX_Size 

func (m *AdapterConfig) XXX_Size() int

func (*AdapterConfig) XXX_Unmarshal 

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

type Adapters 

type Adapters struct {
	Items                []*Adapter `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Adapters) Descriptor 

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

func (*Adapters) GetItems 

func (m *Adapters) GetItems() []*Adapter

func (*Adapters) ProtoMessage 

func (*Adapters) ProtoMessage()

func (*Adapters) Reset 

func (m *Adapters) Reset()

func (*Adapters) String 

func (m *Adapters) String() string

func (*Adapters) XXX_DiscardUnknown 

func (m *Adapters) XXX_DiscardUnknown()

func (*Adapters) XXX_Marshal 

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

func (*Adapters) XXX_Merge 

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

func (*Adapters) XXX_Size 

func (m *Adapters) XXX_Size() int

func (*Adapters) XXX_Unmarshal 

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

type AdminState 

type AdminState = common.AdminState

AdminState from public import voltha_protos/common.proto

type AdminState_Types 

type AdminState_Types = common.AdminState_Types

AdminState_Types from public import voltha_protos/common.proto

type ConfigEvent 

type ConfigEvent struct {
	Type                 ConfigEventType_Types `protobuf:"varint,1,opt,name=type,proto3,enum=event.ConfigEventType_Types" json:"type,omitempty"`
	Hash                 string                `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	Data                 string                `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConfigEvent) Descriptor 

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

func (*ConfigEvent) GetData 

func (m *ConfigEvent) GetData() string

func (*ConfigEvent) GetHash 

func (m *ConfigEvent) GetHash() string

func (*ConfigEvent) GetType 

func (m *ConfigEvent) GetType() ConfigEventType_Types

func (*ConfigEvent) ProtoMessage 

func (*ConfigEvent) ProtoMessage()

func (*ConfigEvent) Reset 

func (m *ConfigEvent) Reset()

func (*ConfigEvent) String 

func (m *ConfigEvent) String() string

func (*ConfigEvent) XXX_DiscardUnknown 

func (m *ConfigEvent) XXX_DiscardUnknown()

func (*ConfigEvent) XXX_Marshal 

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

func (*ConfigEvent) XXX_Merge 

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

func (*ConfigEvent) XXX_Size 

func (m *ConfigEvent) XXX_Size() int

func (*ConfigEvent) XXX_Unmarshal 

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

type ConfigEventType 

type ConfigEventType struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigEventType) Descriptor 

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

func (*ConfigEventType) ProtoMessage 

func (*ConfigEventType) ProtoMessage()

func (*ConfigEventType) Reset 

func (m *ConfigEventType) Reset()

func (*ConfigEventType) String 

func (m *ConfigEventType) String() string

func (*ConfigEventType) XXX_DiscardUnknown 

func (m *ConfigEventType) XXX_DiscardUnknown()

func (*ConfigEventType) XXX_Marshal 

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

func (*ConfigEventType) XXX_Merge 

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

func (*ConfigEventType) XXX_Size 

func (m *ConfigEventType) XXX_Size() int

func (*ConfigEventType) XXX_Unmarshal 

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

type ConfigEventType_Types 

type ConfigEventType_Types int32
const (
	ConfigEventType_add    ConfigEventType_Types = 0
	ConfigEventType_remove ConfigEventType_Types = 1
	ConfigEventType_update ConfigEventType_Types = 2
)

func (ConfigEventType_Types) EnumDescriptor 

func (ConfigEventType_Types) EnumDescriptor() ([]byte, []int)

func (ConfigEventType_Types) String 

func (x ConfigEventType_Types) String() string

type ConnectStatus 

type ConnectStatus = common.ConnectStatus

ConnectStatus from public import voltha_protos/common.proto

type ConnectStatus_Types 

type ConnectStatus_Types = common.ConnectStatus_Types

ConnectStatus_Types from public import voltha_protos/common.proto

type Connection 

type Connection = common.Connection

Connection from public import voltha_protos/common.proto

type CoreInstance 

type CoreInstance struct {
	InstanceId           string               `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Health               *health.HealthStatus `protobuf:"bytes,2,opt,name=health,proto3" json:"health,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

CoreInstance represents a core instance. It is data held in memory when a core is running. This data is not persistent.

func (*CoreInstance) Descriptor 

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

func (*CoreInstance) GetHealth 

func (m *CoreInstance) GetHealth() *health.HealthStatus

func (*CoreInstance) GetInstanceId 

func (m *CoreInstance) GetInstanceId() string

func (*CoreInstance) ProtoMessage 

func (*CoreInstance) ProtoMessage()

func (*CoreInstance) Reset 

func (m *CoreInstance) Reset()

func (*CoreInstance) String 

func (m *CoreInstance) String() string

func (*CoreInstance) XXX_DiscardUnknown 

func (m *CoreInstance) XXX_DiscardUnknown()

func (*CoreInstance) XXX_Marshal 

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

func (*CoreInstance) XXX_Merge 

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

func (*CoreInstance) XXX_Size 

func (m *CoreInstance) XXX_Size() int

func (*CoreInstance) XXX_Unmarshal 

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

type CoreInstances 

type CoreInstances struct {
	Items                []*CoreInstance `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CoreInstances) Descriptor 

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

func (*CoreInstances) GetItems 

func (m *CoreInstances) GetItems() []*CoreInstance

func (*CoreInstances) ProtoMessage 

func (*CoreInstances) ProtoMessage()

func (*CoreInstances) Reset 

func (m *CoreInstances) Reset()

func (*CoreInstances) String 

func (m *CoreInstances) String() string

func (*CoreInstances) XXX_DiscardUnknown 

func (m *CoreInstances) XXX_DiscardUnknown()

func (*CoreInstances) XXX_Marshal 

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

func (*CoreInstances) XXX_Merge 

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

func (*CoreInstances) XXX_Size 

func (m *CoreInstances) XXX_Size() int

func (*CoreInstances) XXX_Unmarshal 

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

type Device 

type Device struct {
	// Voltha's device identifier
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Device type, refers to one of the registered device types
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Is this device a root device. Each logical switch has one root
	// device that is associated with the logical flow switch.
	Root bool `protobuf:"varint,3,opt,name=root,proto3" json:"root,omitempty"`
	// Parent device id, in the device tree (for a root device, the parent_id
	// is the logical_device.id)
	ParentId     string `protobuf:"bytes,4,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	ParentPortNo uint32 `protobuf:"varint,20,opt,name=parent_port_no,json=parentPortNo,proto3" json:"parent_port_no,omitempty"`
	// Vendor, version, serial number, etc.
	Vendor          string `protobuf:"bytes,5,opt,name=vendor,proto3" json:"vendor,omitempty"`
	Model           string `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	HardwareVersion string `protobuf:"bytes,7,opt,name=hardware_version,json=hardwareVersion,proto3" json:"hardware_version,omitempty"`
	FirmwareVersion string `protobuf:"bytes,8,opt,name=firmware_version,json=firmwareVersion,proto3" json:"firmware_version,omitempty"`
	// List of software on the device
	Images       *Images `protobuf:"bytes,9,opt,name=images,proto3" json:"images,omitempty"`
	SerialNumber string  `protobuf:"bytes,10,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"`
	VendorId     string  `protobuf:"bytes,24,opt,name=vendor_id,json=vendorId,proto3" json:"vendor_id,omitempty"`
	// Indicates how to reach the adapter instance that manages this device
	AdapterEndpoint string `protobuf:"bytes,25,opt,name=adapter_endpoint,json=adapterEndpoint,proto3" json:"adapter_endpoint,omitempty"`
	// Device contact on vlan (if 0, no vlan)
	Vlan uint32 `protobuf:"varint,12,opt,name=vlan,proto3" json:"vlan,omitempty"`
	// Device contact MAC address (format: "xx:xx:xx:xx:xx:xx")
	MacAddress string `protobuf:"bytes,13,opt,name=mac_address,json=macAddress,proto3" json:"mac_address,omitempty"`
	// Types that are valid to be assigned to Address:
	//	*Device_Ipv4Address
	//	*Device_Ipv6Address
	//	*Device_HostAndPort
	Address       isDevice_Address           `protobuf_oneof:"address"`
	ExtraArgs     string                     `protobuf:"bytes,23,opt,name=extra_args,json=extraArgs,proto3" json:"extra_args,omitempty"`
	ProxyAddress  *Device_ProxyAddress       `protobuf:"bytes,19,opt,name=proxy_address,json=proxyAddress,proto3" json:"proxy_address,omitempty"`
	AdminState    common.AdminState_Types    `protobuf:"varint,16,opt,name=admin_state,json=adminState,proto3,enum=common.AdminState_Types" json:"admin_state,omitempty"`
	OperStatus    common.OperStatus_Types    `protobuf:"varint,17,opt,name=oper_status,json=operStatus,proto3,enum=common.OperStatus_Types" json:"oper_status,omitempty"`
	Reason        string                     `protobuf:"bytes,22,opt,name=reason,proto3" json:"reason,omitempty"`
	ConnectStatus common.ConnectStatus_Types `` /* 134-byte string literal not displayed */
	// Device type specific attributes
	Custom *any.Any `protobuf:"bytes,64,opt,name=custom,proto3" json:"custom,omitempty"`
	// PmConfigs type
	PmConfigs            *PmConfigs       `protobuf:"bytes,131,opt,name=pm_configs,json=pmConfigs,proto3" json:"pm_configs,omitempty"`
	ImageDownloads       []*ImageDownload `protobuf:"bytes,133,rep,name=image_downloads,json=imageDownloads,proto3" json:"image_downloads,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

A Physical Device instance

func (*Device) Descriptor 

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

func (*Device) GetAdapterEndpoint 

func (m *Device) GetAdapterEndpoint() string

func (*Device) GetAddress 

func (m *Device) GetAddress() isDevice_Address

func (*Device) GetAdminState 

func (m *Device) GetAdminState() common.AdminState_Types

func (*Device) GetConnectStatus 

func (m *Device) GetConnectStatus() common.ConnectStatus_Types

func (*Device) GetCustom 

func (m *Device) GetCustom() *any.Any

func (*Device) GetExtraArgs 

func (m *Device) GetExtraArgs() string

func (*Device) GetFirmwareVersion 

func (m *Device) GetFirmwareVersion() string

func (*Device) GetHardwareVersion 

func (m *Device) GetHardwareVersion() string

func (*Device) GetHostAndPort 

func (m *Device) GetHostAndPort() string

func (*Device) GetId 

func (m *Device) GetId() string

func (*Device) GetImageDownloads 

func (m *Device) GetImageDownloads() []*ImageDownload

func (*Device) GetImages 

func (m *Device) GetImages() *Images

func (*Device) GetIpv4Address 

func (m *Device) GetIpv4Address() string

func (*Device) GetIpv6Address 

func (m *Device) GetIpv6Address() string

func (*Device) GetMacAddress 

func (m *Device) GetMacAddress() string

func (*Device) GetModel 

func (m *Device) GetModel() string

func (*Device) GetOperStatus 

func (m *Device) GetOperStatus() common.OperStatus_Types

func (*Device) GetParentId 

func (m *Device) GetParentId() string

func (*Device) GetParentPortNo 

func (m *Device) GetParentPortNo() uint32

func (*Device) GetPmConfigs 

func (m *Device) GetPmConfigs() *PmConfigs

func (*Device) GetProxyAddress 

func (m *Device) GetProxyAddress() *Device_ProxyAddress

func (*Device) GetReason 

func (m *Device) GetReason() string

func (*Device) GetRoot 

func (m *Device) GetRoot() bool

func (*Device) GetSerialNumber 

func (m *Device) GetSerialNumber() string

func (*Device) GetType 

func (m *Device) GetType() string

func (*Device) GetVendor 

func (m *Device) GetVendor() string

func (*Device) GetVendorId 

func (m *Device) GetVendorId() string

func (*Device) GetVlan 

func (m *Device) GetVlan() uint32

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) Reset 

func (m *Device) Reset()

func (*Device) String 

func (m *Device) String() string

func (*Device) XXX_DiscardUnknown 

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal 

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

func (*Device) XXX_Merge 

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

func (*Device) XXX_OneofWrappers 

func (*Device) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Device) XXX_Size 

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal 

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

type DeviceEvent 

type DeviceEvent struct {
	// Identifier of the originating resource of the event, for ex: device_id
	ResourceId string `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// device_event_name indicates clearly the name of the device event
	DeviceEventName string `protobuf:"bytes,2,opt,name=device_event_name,json=deviceEventName,proto3" json:"device_event_name,omitempty"`
	// Textual explanation of the device event
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Key/Value storage for extra information that may give context to the event
	Context              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Describes the events specific to device

func (*DeviceEvent) Descriptor 

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

func (*DeviceEvent) GetContext 

func (m *DeviceEvent) GetContext() map[string]string

func (*DeviceEvent) GetDescription 

func (m *DeviceEvent) GetDescription() string

func (*DeviceEvent) GetDeviceEventName 

func (m *DeviceEvent) GetDeviceEventName() string

func (*DeviceEvent) GetResourceId 

func (m *DeviceEvent) GetResourceId() string

func (*DeviceEvent) ProtoMessage 

func (*DeviceEvent) ProtoMessage()

func (*DeviceEvent) Reset 

func (m *DeviceEvent) Reset()

func (*DeviceEvent) String 

func (m *DeviceEvent) String() string

func (*DeviceEvent) XXX_DiscardUnknown 

func (m *DeviceEvent) XXX_DiscardUnknown()

func (*DeviceEvent) XXX_Marshal 

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

func (*DeviceEvent) XXX_Merge 

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

func (*DeviceEvent) XXX_Size 

func (m *DeviceEvent) XXX_Size() int

func (*DeviceEvent) XXX_Unmarshal 

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

type DeviceImageDownloadRequest 

type DeviceImageDownloadRequest struct {
	// Device Id
	// allows for operations on multiple devices.
	DeviceId []*common.ID `protobuf:"bytes,1,rep,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	//The image for the device containing all the information
	Image *Image `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	//Activate the image if the download to the device is successful
	ActivateOnSuccess bool `protobuf:"varint,3,opt,name=activateOnSuccess,proto3" json:"activateOnSuccess,omitempty"`
	//Automatically commit the image if the activation on the device is successful
	CommitOnSuccess      bool     `protobuf:"varint,4,opt,name=commitOnSuccess,proto3" json:"commitOnSuccess,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeviceImageDownloadRequest) Descriptor 

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

func (*DeviceImageDownloadRequest) GetActivateOnSuccess 

func (m *DeviceImageDownloadRequest) GetActivateOnSuccess() bool

func (*DeviceImageDownloadRequest) GetCommitOnSuccess 

func (m *DeviceImageDownloadRequest) GetCommitOnSuccess() bool

func (*DeviceImageDownloadRequest) GetDeviceId 

func (m *DeviceImageDownloadRequest) GetDeviceId() []*common.ID

func (*DeviceImageDownloadRequest) GetImage 

func (m *DeviceImageDownloadRequest) GetImage() *Image

func (*DeviceImageDownloadRequest) ProtoMessage 

func (*DeviceImageDownloadRequest) ProtoMessage()

func (*DeviceImageDownloadRequest) Reset 

func (m *DeviceImageDownloadRequest) Reset()

func (*DeviceImageDownloadRequest) String 

func (m *DeviceImageDownloadRequest) String() string

func (*DeviceImageDownloadRequest) XXX_DiscardUnknown 

func (m *DeviceImageDownloadRequest) XXX_DiscardUnknown()

func (*DeviceImageDownloadRequest) XXX_Marshal 

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

func (*DeviceImageDownloadRequest) XXX_Merge 

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

func (*DeviceImageDownloadRequest) XXX_Size 

func (m *DeviceImageDownloadRequest) XXX_Size() int

func (*DeviceImageDownloadRequest) XXX_Unmarshal 

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

type DeviceImageRequest 

type DeviceImageRequest struct {
	//Device Id
	//allows for operations on multiple adapters.
	DeviceId []*common.ID `protobuf:"bytes,1,rep,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// Image Version, this is the sole identifier of the image. it's the vendor specified OMCI version
	// must be known at the time of initiating a download, activate, commit image on an onu.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	//Automatically commit the image if the activation on the device is successful
	CommitOnSuccess      bool     `protobuf:"varint,3,opt,name=commitOnSuccess,proto3" json:"commitOnSuccess,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeviceImageRequest) Descriptor 

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

func (*DeviceImageRequest) GetCommitOnSuccess 

func (m *DeviceImageRequest) GetCommitOnSuccess() bool

func (*DeviceImageRequest) GetDeviceId 

func (m *DeviceImageRequest) GetDeviceId() []*common.ID

func (*DeviceImageRequest) GetVersion 

func (m *DeviceImageRequest) GetVersion() string

func (*DeviceImageRequest) ProtoMessage 

func (*DeviceImageRequest) ProtoMessage()

func (*DeviceImageRequest) Reset 

func (m *DeviceImageRequest) Reset()

func (*DeviceImageRequest) String 

func (m *DeviceImageRequest) String() string

func (*DeviceImageRequest) XXX_DiscardUnknown 

func (m *DeviceImageRequest) XXX_DiscardUnknown()

func (*DeviceImageRequest) XXX_Marshal 

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

func (*DeviceImageRequest) XXX_Merge 

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

func (*DeviceImageRequest) XXX_Size 

func (m *DeviceImageRequest) XXX_Size() int

func (*DeviceImageRequest) XXX_Unmarshal 

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

type DeviceImageResponse 

type DeviceImageResponse struct {
	//Image state for the different devices
	DeviceImageStates    []*DeviceImageState `protobuf:"bytes,1,rep,name=device_image_states,json=deviceImageStates,proto3" json:"device_image_states,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*DeviceImageResponse) Descriptor 

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

func (*DeviceImageResponse) GetDeviceImageStates 

func (m *DeviceImageResponse) GetDeviceImageStates() []*DeviceImageState

func (*DeviceImageResponse) ProtoMessage 

func (*DeviceImageResponse) ProtoMessage()

func (*DeviceImageResponse) Reset 

func (m *DeviceImageResponse) Reset()

func (*DeviceImageResponse) String 

func (m *DeviceImageResponse) String() string

func (*DeviceImageResponse) XXX_DiscardUnknown 

func (m *DeviceImageResponse) XXX_DiscardUnknown()

func (*DeviceImageResponse) XXX_Marshal 

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

func (*DeviceImageResponse) XXX_Merge 

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

func (*DeviceImageResponse) XXX_Size 

func (m *DeviceImageResponse) XXX_Size() int

func (*DeviceImageResponse) XXX_Unmarshal 

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

type DeviceImageState 

type DeviceImageState struct {
	DeviceId             string      `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	ImageState           *ImageState `protobuf:"bytes,2,opt,name=imageState,proto3" json:"imageState,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*DeviceImageState) Descriptor 

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

func (*DeviceImageState) GetDeviceId 

func (m *DeviceImageState) GetDeviceId() string

func (*DeviceImageState) GetImageState 

func (m *DeviceImageState) GetImageState() *ImageState

func (*DeviceImageState) ProtoMessage 

func (*DeviceImageState) ProtoMessage()

func (*DeviceImageState) Reset 

func (m *DeviceImageState) Reset()

func (*DeviceImageState) String 

func (m *DeviceImageState) String() string

func (*DeviceImageState) XXX_DiscardUnknown 

func (m *DeviceImageState) XXX_DiscardUnknown()

func (*DeviceImageState) XXX_Marshal 

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

func (*DeviceImageState) XXX_Merge 

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

func (*DeviceImageState) XXX_Size 

func (m *DeviceImageState) XXX_Size() int

func (*DeviceImageState) XXX_Unmarshal 

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

type DeviceType 

type DeviceType struct {
	// Unique name for the device type
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Unique vendor id for the device type applicable to ONU
	// 4 bytes of vendor id from ONU serial number
	VendorId  string   `protobuf:"bytes,5,opt,name=vendor_id,json=vendorId,proto3" json:"vendor_id,omitempty"`
	VendorIds []string `protobuf:"bytes,6,rep,name=vendor_ids,json=vendorIds,proto3" json:"vendor_ids,omitempty"`
	// Name of the adapter that handles device type
	// Deprecated and replaced by adapterType
	Adapter string `protobuf:"bytes,2,opt,name=adapter,proto3" json:"adapter,omitempty"`
	// Capabilities
	AcceptsBulkFlowUpdate           bool `` /* 129-byte string literal not displayed */
	AcceptsAddRemoveFlowUpdates     bool `` /* 149-byte string literal not displayed */
	AcceptsDirectLogicalFlowsUpdate bool `` /* 161-byte string literal not displayed */
	// Type of adapter that can handle this device type
	AdapterType          string   `protobuf:"bytes,8,opt,name=adapter_type,json=adapterType,proto3" json:"adapter_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A Device Type

func (*DeviceType) Descriptor 

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

func (*DeviceType) GetAcceptsAddRemoveFlowUpdates 

func (m *DeviceType) GetAcceptsAddRemoveFlowUpdates() bool

func (*DeviceType) GetAcceptsBulkFlowUpdate 

func (m *DeviceType) GetAcceptsBulkFlowUpdate() bool

func (*DeviceType) GetAcceptsDirectLogicalFlowsUpdate 

func (m *DeviceType) GetAcceptsDirectLogicalFlowsUpdate() bool

func (*DeviceType) GetAdapter 

func (m *DeviceType) GetAdapter() string

func (*DeviceType) GetAdapterType 

func (m *DeviceType) GetAdapterType() string

func (*DeviceType) GetId 

func (m *DeviceType) GetId() string

func (*DeviceType) GetVendorId 

func (m *DeviceType) GetVendorId() string

func (*DeviceType) GetVendorIds 

func (m *DeviceType) GetVendorIds() []string

func (*DeviceType) ProtoMessage 

func (*DeviceType) ProtoMessage()

func (*DeviceType) Reset 

func (m *DeviceType) Reset()

func (*DeviceType) String 

func (m *DeviceType) String() string

func (*DeviceType) XXX_DiscardUnknown 

func (m *DeviceType) XXX_DiscardUnknown()

func (*DeviceType) XXX_Marshal 

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

func (*DeviceType) XXX_Merge 

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

func (*DeviceType) XXX_Size 

func (m *DeviceType) XXX_Size() int

func (*DeviceType) XXX_Unmarshal 

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

type DeviceTypes 

type DeviceTypes struct {
	Items                []*DeviceType `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

A plurality of device types

func (*DeviceTypes) Descriptor 

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

func (*DeviceTypes) GetItems 

func (m *DeviceTypes) GetItems() []*DeviceType

func (*DeviceTypes) ProtoMessage 

func (*DeviceTypes) ProtoMessage()

func (*DeviceTypes) Reset 

func (m *DeviceTypes) Reset()

func (*DeviceTypes) String 

func (m *DeviceTypes) String() string

func (*DeviceTypes) XXX_DiscardUnknown 

func (m *DeviceTypes) XXX_DiscardUnknown()

func (*DeviceTypes) XXX_Marshal 

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

func (*DeviceTypes) XXX_Merge 

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

func (*DeviceTypes) XXX_Size 

func (m *DeviceTypes) XXX_Size() int

func (*DeviceTypes) XXX_Unmarshal 

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

type Device_HostAndPort 

type Device_HostAndPort struct {
	HostAndPort string `protobuf:"bytes,21,opt,name=host_and_port,json=hostAndPort,proto3,oneof"`
}

type Device_Ipv4Address 

type Device_Ipv4Address struct {
	Ipv4Address string `protobuf:"bytes,14,opt,name=ipv4_address,json=ipv4Address,proto3,oneof"`
}

type Device_Ipv6Address 

type Device_Ipv6Address struct {
	Ipv6Address string `protobuf:"bytes,15,opt,name=ipv6_address,json=ipv6Address,proto3,oneof"`
}

type Device_ProxyAddress 

type Device_ProxyAddress struct {
	DeviceId             string   `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	DeviceType           string   `protobuf:"bytes,2,opt,name=device_type,json=deviceType,proto3" json:"device_type,omitempty"`
	ChannelId            uint32   `protobuf:"varint,3,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	ChannelGroupId       uint32   `protobuf:"varint,4,opt,name=channel_group_id,json=channelGroupId,proto3" json:"channel_group_id,omitempty"`
	ChannelTermination   string   `protobuf:"bytes,5,opt,name=channel_termination,json=channelTermination,proto3" json:"channel_termination,omitempty"`
	OnuId                uint32   `protobuf:"varint,6,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
	OnuSessionId         uint32   `protobuf:"varint,7,opt,name=onu_session_id,json=onuSessionId,proto3" json:"onu_session_id,omitempty"`
	AdapterEndpoint      string   `protobuf:"bytes,8,opt,name=adapter_endpoint,json=adapterEndpoint,proto3" json:"adapter_endpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Device_ProxyAddress) Descriptor 

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

func (*Device_ProxyAddress) GetAdapterEndpoint 

func (m *Device_ProxyAddress) GetAdapterEndpoint() string

func (*Device_ProxyAddress) GetChannelGroupId 

func (m *Device_ProxyAddress) GetChannelGroupId() uint32

func (*Device_ProxyAddress) GetChannelId 

func (m *Device_ProxyAddress) GetChannelId() uint32

func (*Device_ProxyAddress) GetChannelTermination 

func (m *Device_ProxyAddress) GetChannelTermination() string

func (*Device_ProxyAddress) GetDeviceId 

func (m *Device_ProxyAddress) GetDeviceId() string

func (*Device_ProxyAddress) GetDeviceType 

func (m *Device_ProxyAddress) GetDeviceType() string

func (*Device_ProxyAddress) GetOnuId 

func (m *Device_ProxyAddress) GetOnuId() uint32

func (*Device_ProxyAddress) GetOnuSessionId 

func (m *Device_ProxyAddress) GetOnuSessionId() uint32

func (*Device_ProxyAddress) ProtoMessage 

func (*Device_ProxyAddress) ProtoMessage()

func (*Device_ProxyAddress) Reset 

func (m *Device_ProxyAddress) Reset()

func (*Device_ProxyAddress) String 

func (m *Device_ProxyAddress) String() string

func (*Device_ProxyAddress) XXX_DiscardUnknown 

func (m *Device_ProxyAddress) XXX_DiscardUnknown()

func (*Device_ProxyAddress) XXX_Marshal 

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

func (*Device_ProxyAddress) XXX_Merge 

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

func (*Device_ProxyAddress) XXX_Size 

func (m *Device_ProxyAddress) XXX_Size() int

func (*Device_ProxyAddress) XXX_Unmarshal 

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

type Devices 

type Devices struct {
	Items                []*Device `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Devices) Descriptor 

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

func (*Devices) GetItems 

func (m *Devices) GetItems() []*Device

func (*Devices) ProtoMessage 

func (*Devices) ProtoMessage()

func (*Devices) Reset 

func (m *Devices) Reset()

func (*Devices) String 

func (m *Devices) String() string

func (*Devices) XXX_DiscardUnknown 

func (m *Devices) XXX_DiscardUnknown()

func (*Devices) XXX_Marshal 

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

func (*Devices) XXX_Merge 

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

func (*Devices) XXX_Size 

func (m *Devices) XXX_Size() int

func (*Devices) XXX_Unmarshal 

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

type Event 

type Event struct {
	// event header
	Header *EventHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// oneof event types referred by EventType.
	//
	// Types that are valid to be assigned to EventType:
	//	*Event_ConfigEvent
	//	*Event_KpiEvent
	//	*Event_KpiEvent2
	//	*Event_DeviceEvent
	//	*Event_RpcEvent
	EventType            isEvent_EventType `protobuf_oneof:"event_type"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Event Structure

func (*Event) Descriptor 

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

func (*Event) GetConfigEvent 

func (m *Event) GetConfigEvent() *ConfigEvent

func (*Event) GetDeviceEvent 

func (m *Event) GetDeviceEvent() *DeviceEvent

func (*Event) GetEventType 

func (m *Event) GetEventType() isEvent_EventType

func (*Event) GetHeader 

func (m *Event) GetHeader() *EventHeader

func (*Event) GetKpiEvent 

func (m *Event) GetKpiEvent() *KpiEvent

func (*Event) GetKpiEvent2 

func (m *Event) GetKpiEvent2() *KpiEvent2

func (*Event) GetRpcEvent 

func (m *Event) GetRpcEvent() *RPCEvent

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_OneofWrappers 

func (*Event) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type EventCategory 

type EventCategory struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identify the area of the system impacted by the event.

func (*EventCategory) Descriptor 

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

func (*EventCategory) ProtoMessage 

func (*EventCategory) ProtoMessage()

func (*EventCategory) Reset 

func (m *EventCategory) Reset()

func (*EventCategory) String 

func (m *EventCategory) String() string

func (*EventCategory) XXX_DiscardUnknown 

func (m *EventCategory) XXX_DiscardUnknown()

func (*EventCategory) XXX_Marshal 

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

func (*EventCategory) XXX_Merge 

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

func (*EventCategory) XXX_Size 

func (m *EventCategory) XXX_Size() int

func (*EventCategory) XXX_Unmarshal 

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

type EventCategory_Types 

type EventCategory_Types int32
const (
	EventCategory_COMMUNICATION EventCategory_Types = 0
	EventCategory_ENVIRONMENT   EventCategory_Types = 1
	EventCategory_EQUIPMENT     EventCategory_Types = 2
	EventCategory_SERVICE       EventCategory_Types = 3
	EventCategory_PROCESSING    EventCategory_Types = 4
	EventCategory_SECURITY      EventCategory_Types = 5
)

func (EventCategory_Types) EnumDescriptor 

func (EventCategory_Types) EnumDescriptor() ([]byte, []int)

func (EventCategory_Types) String 

func (x EventCategory_Types) String() string

type EventFilter 

type EventFilter struct {
	Id                   string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Enable               bool               `protobuf:"varint,2,opt,name=enable,proto3" json:"enable,omitempty"`
	DeviceId             string             `protobuf:"bytes,3,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	EventType            string             `protobuf:"bytes,4,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Rules                []*EventFilterRule `protobuf:"bytes,5,rep,name=rules,proto3" json:"rules,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*EventFilter) Descriptor 

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

func (*EventFilter) GetDeviceId 

func (m *EventFilter) GetDeviceId() string

func (*EventFilter) GetEnable 

func (m *EventFilter) GetEnable() bool

func (*EventFilter) GetEventType 

func (m *EventFilter) GetEventType() string

func (*EventFilter) GetId 

func (m *EventFilter) GetId() string

func (*EventFilter) GetRules 

func (m *EventFilter) GetRules() []*EventFilterRule

func (*EventFilter) ProtoMessage 

func (*EventFilter) ProtoMessage()

func (*EventFilter) Reset 

func (m *EventFilter) Reset()

func (*EventFilter) String 

func (m *EventFilter) String() string

func (*EventFilter) XXX_DiscardUnknown 

func (m *EventFilter) XXX_DiscardUnknown()

func (*EventFilter) XXX_Marshal 

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

func (*EventFilter) XXX_Merge 

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

func (*EventFilter) XXX_Size 

func (m *EventFilter) XXX_Size() int

func (*EventFilter) XXX_Unmarshal 

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

type EventFilterRule 

type EventFilterRule struct {
	Key                  EventFilterRuleKey_EventFilterRuleType `protobuf:"varint,1,opt,name=key,proto3,enum=event.EventFilterRuleKey_EventFilterRuleType" json:"key,omitempty"`
	Value                string                                 `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

func (*EventFilterRule) Descriptor 

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

func (*EventFilterRule) GetKey 

func (m *EventFilterRule) GetKey() EventFilterRuleKey_EventFilterRuleType

func (*EventFilterRule) GetValue 

func (m *EventFilterRule) GetValue() string

func (*EventFilterRule) ProtoMessage 

func (*EventFilterRule) ProtoMessage()

func (*EventFilterRule) Reset 

func (m *EventFilterRule) Reset()

func (*EventFilterRule) String 

func (m *EventFilterRule) String() string

func (*EventFilterRule) XXX_DiscardUnknown 

func (m *EventFilterRule) XXX_DiscardUnknown()

func (*EventFilterRule) XXX_Marshal 

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

func (*EventFilterRule) XXX_Merge 

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

func (*EventFilterRule) XXX_Size 

func (m *EventFilterRule) XXX_Size() int

func (*EventFilterRule) XXX_Unmarshal 

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

type EventFilterRuleKey 

type EventFilterRuleKey struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventFilterRuleKey) Descriptor 

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

func (*EventFilterRuleKey) ProtoMessage 

func (*EventFilterRuleKey) ProtoMessage()

func (*EventFilterRuleKey) Reset 

func (m *EventFilterRuleKey) Reset()

func (*EventFilterRuleKey) String 

func (m *EventFilterRuleKey) String() string

func (*EventFilterRuleKey) XXX_DiscardUnknown 

func (m *EventFilterRuleKey) XXX_DiscardUnknown()

func (*EventFilterRuleKey) XXX_Marshal 

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

func (*EventFilterRuleKey) XXX_Merge 

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

func (*EventFilterRuleKey) XXX_Size 

func (m *EventFilterRuleKey) XXX_Size() int

func (*EventFilterRuleKey) XXX_Unmarshal 

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

type EventFilterRuleKey_EventFilterRuleType 

type EventFilterRuleKey_EventFilterRuleType int32
const (
	EventFilterRuleKey_filter_all        EventFilterRuleKey_EventFilterRuleType = 0
	EventFilterRuleKey_category          EventFilterRuleKey_EventFilterRuleType = 1
	EventFilterRuleKey_sub_category      EventFilterRuleKey_EventFilterRuleType = 2
	EventFilterRuleKey_kpi_event_type    EventFilterRuleKey_EventFilterRuleType = 3
	EventFilterRuleKey_config_event_type EventFilterRuleKey_EventFilterRuleType = 4
	EventFilterRuleKey_device_event_type EventFilterRuleKey_EventFilterRuleType = 5
)

func (EventFilterRuleKey_EventFilterRuleType) EnumDescriptor 

func (EventFilterRuleKey_EventFilterRuleType) EnumDescriptor() ([]byte, []int)

func (EventFilterRuleKey_EventFilterRuleType) String 

func (x EventFilterRuleKey_EventFilterRuleType) String() string

type EventFilters 

type EventFilters struct {
	Filters              []*EventFilter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*EventFilters) Descriptor 

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

func (*EventFilters) GetFilters 

func (m *EventFilters) GetFilters() []*EventFilter

func (*EventFilters) ProtoMessage 

func (*EventFilters) ProtoMessage()

func (*EventFilters) Reset 

func (m *EventFilters) Reset()

func (*EventFilters) String 

func (m *EventFilters) String() string

func (*EventFilters) XXX_DiscardUnknown 

func (m *EventFilters) XXX_DiscardUnknown()

func (*EventFilters) XXX_Marshal 

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

func (*EventFilters) XXX_Merge 

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

func (*EventFilters) XXX_Size 

func (m *EventFilters) XXX_Size() int

func (*EventFilters) XXX_Unmarshal 

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

type EventHeader 

type EventHeader struct {
	// Unique ID for this event.  e.g. voltha.some_olt.1234
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Refers to the functional area affect by the event
	Category EventCategory_Types `protobuf:"varint,2,opt,name=category,proto3,enum=event.EventCategory_Types" json:"category,omitempty"`
	// Refers to functional category of the event
	SubCategory EventSubCategory_Types `` /* 129-byte string literal not displayed */
	// Refers to the type of the event
	Type EventType_Types `protobuf:"varint,4,opt,name=type,proto3,enum=event.EventType_Types" json:"type,omitempty"`
	// The version identifier for this event type, thus allowing each
	// event type to evolve independently. The version should be in the
	// format “MAJOR.MINOR” format and minor changes must only be additive
	// and non-breaking.
	TypeVersion string `protobuf:"bytes,5,opt,name=type_version,json=typeVersion,proto3" json:"type_version,omitempty"`
	// Timestamp at which the event was first raised.
	// This represents the UTC time stamp since epoch (in seconds) when the
	// the event was first raised from the source entity.
	// If the source entity doesn't send the raised_ts, this shall be set
	// to timestamp when the event was received.
	RaisedTs *timestamp.Timestamp `protobuf:"bytes,6,opt,name=raised_ts,json=raisedTs,proto3" json:"raised_ts,omitempty"`
	// Timestamp at which the event was reported.
	// This represents the UTC time stamp since epoch (in seconds) when the
	// the event was reported (this time stamp is >= raised_ts).
	// If the source entity that reported this event doesn't send the
	// reported_ts, this shall be set to the same value as raised_ts.
	ReportedTs           *timestamp.Timestamp `protobuf:"bytes,7,opt,name=reported_ts,json=reportedTs,proto3" json:"reported_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Identify the functional category originating the event

func (*EventHeader) Descriptor 

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

func (*EventHeader) GetCategory 

func (m *EventHeader) GetCategory() EventCategory_Types

func (*EventHeader) GetId 

func (m *EventHeader) GetId() string

func (*EventHeader) GetRaisedTs 

func (m *EventHeader) GetRaisedTs() *timestamp.Timestamp

func (*EventHeader) GetReportedTs 

func (m *EventHeader) GetReportedTs() *timestamp.Timestamp

func (*EventHeader) GetSubCategory 

func (m *EventHeader) GetSubCategory() EventSubCategory_Types

func (*EventHeader) GetType 

func (m *EventHeader) GetType() EventType_Types

func (*EventHeader) GetTypeVersion 

func (m *EventHeader) GetTypeVersion() string

func (*EventHeader) ProtoMessage 

func (*EventHeader) ProtoMessage()

func (*EventHeader) Reset 

func (m *EventHeader) Reset()

func (*EventHeader) String 

func (m *EventHeader) String() string

func (*EventHeader) XXX_DiscardUnknown 

func (m *EventHeader) XXX_DiscardUnknown()

func (*EventHeader) XXX_Marshal 

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

func (*EventHeader) XXX_Merge 

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

func (*EventHeader) XXX_Size 

func (m *EventHeader) XXX_Size() int

func (*EventHeader) XXX_Unmarshal 

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

type EventSubCategory 

type EventSubCategory struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identify the functional category originating the event

func (*EventSubCategory) Descriptor 

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

func (*EventSubCategory) ProtoMessage 

func (*EventSubCategory) ProtoMessage()

func (*EventSubCategory) Reset 

func (m *EventSubCategory) Reset()

func (*EventSubCategory) String 

func (m *EventSubCategory) String() string

func (*EventSubCategory) XXX_DiscardUnknown 

func (m *EventSubCategory) XXX_DiscardUnknown()

func (*EventSubCategory) XXX_Marshal 

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

func (*EventSubCategory) XXX_Merge 

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

func (*EventSubCategory) XXX_Size 

func (m *EventSubCategory) XXX_Size() int

func (*EventSubCategory) XXX_Unmarshal 

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

type EventSubCategory_Types 

type EventSubCategory_Types int32
const (
	EventSubCategory_PON  EventSubCategory_Types = 0
	EventSubCategory_OLT  EventSubCategory_Types = 1
	EventSubCategory_ONT  EventSubCategory_Types = 2
	EventSubCategory_ONU  EventSubCategory_Types = 3
	EventSubCategory_NNI  EventSubCategory_Types = 4
	EventSubCategory_NONE EventSubCategory_Types = 5
)

func (EventSubCategory_Types) EnumDescriptor 

func (EventSubCategory_Types) EnumDescriptor() ([]byte, []int)

func (EventSubCategory_Types) String 

func (x EventSubCategory_Types) String() string

type EventType 

type EventType struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identify the type of event

func (*EventType) Descriptor 

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

func (*EventType) ProtoMessage 

func (*EventType) ProtoMessage()

func (*EventType) Reset 

func (m *EventType) Reset()

func (*EventType) String 

func (m *EventType) String() string

func (*EventType) XXX_DiscardUnknown 

func (m *EventType) XXX_DiscardUnknown()

func (*EventType) XXX_Marshal 

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

func (*EventType) XXX_Merge 

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

func (*EventType) XXX_Size 

func (m *EventType) XXX_Size() int

func (*EventType) XXX_Unmarshal 

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

type EventType_Types 

type EventType_Types int32
const (
	EventType_CONFIG_EVENT EventType_Types = 0
	EventType_KPI_EVENT    EventType_Types = 1
	EventType_KPI_EVENT2   EventType_Types = 2
	EventType_DEVICE_EVENT EventType_Types = 3
	EventType_RPC_EVENT    EventType_Types = 4
)

func (EventType_Types) EnumDescriptor 

func (EventType_Types) EnumDescriptor() ([]byte, []int)

func (EventType_Types) String 

func (x EventType_Types) String() string

type Event_ConfigEvent 

type Event_ConfigEvent struct {
	ConfigEvent *ConfigEvent `protobuf:"bytes,2,opt,name=config_event,json=configEvent,proto3,oneof"`
}

type Event_DeviceEvent 

type Event_DeviceEvent struct {
	DeviceEvent *DeviceEvent `protobuf:"bytes,5,opt,name=device_event,json=deviceEvent,proto3,oneof"`
}

type Event_KpiEvent 

type Event_KpiEvent struct {
	KpiEvent *KpiEvent `protobuf:"bytes,3,opt,name=kpi_event,json=kpiEvent,proto3,oneof"`
}

type Event_KpiEvent2 

type Event_KpiEvent2 struct {
	KpiEvent2 *KpiEvent2 `protobuf:"bytes,4,opt,name=kpi_event2,json=kpiEvent2,proto3,oneof"`
}

type Event_RpcEvent 

type Event_RpcEvent struct {
	RpcEvent *RPCEvent `protobuf:"bytes,6,opt,name=rpc_event,json=rpcEvent,proto3,oneof"`
}

type ID 

type ID = common.ID

ID from public import voltha_protos/common.proto

type IDs 

type IDs = common.IDs

IDs from public import voltha_protos/common.proto

type Image 

type Image struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Version, this is the sole identifier of the image. it's the vendor specified OMCI version
	// must be known at the time of initiating a download, activate, commit image on an onu.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// hash of the image to be verified against
	// Deprecated in voltha 2.8, will be removed
	Hash uint32 `protobuf:"varint,3,opt,name=hash,proto3" json:"hash,omitempty"`
	// Deprecated in voltha 2.8, will be removed
	InstallDatetime string `protobuf:"bytes,4,opt,name=install_datetime,json=installDatetime,proto3" json:"install_datetime,omitempty"`
	// The active software image is one that is currently loaded and executing
	// in the ONU or circuit pack. Under normal operation, one software image
	// is always active while the other is inactive. Under no circumstances are
	// both software images allowed to be active at the same time
	// Deprecated in voltha 2.8, will be removed
	IsActive bool `protobuf:"varint,5,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	// The committed software image is loaded and executed upon reboot of the
	// ONU and/or circuit pack. During normal operation, one software image is
	// always committed, while the other is uncommitted.
	// Deprecated in voltha 2.8, will be removed
	IsCommitted bool `protobuf:"varint,6,opt,name=is_committed,json=isCommitted,proto3" json:"is_committed,omitempty"`
	// A software image is valid if it has been verified to be an executable
	// code image. The verification mechanism is not subject to standardization;
	// however, it should include at least a data integrity (e.g., CRC) check of
	// the entire code image.
	// Deprecated in voltha 2.8, will be removed
	IsValid bool `protobuf:"varint,7,opt,name=is_valid,json=isValid,proto3" json:"is_valid,omitempty"`
	// URL where the image is available
	// URL MUST be fully qualified,
	// including filename, username and password
	Url string `protobuf:"bytes,8,opt,name=url,proto3" json:"url,omitempty"`
	// Represents the vendor/device mfr
	// Needs to match the vendor of the device the image will be installed on
	// optional, if not matched no check will be performed
	Vendor string `protobuf:"bytes,9,opt,name=vendor,proto3" json:"vendor,omitempty"`
	// Represents the ONU Image CRC value.
	// Default to value 0 if not specified.
	// If different then 0 it's used to verify the image retrieved from outside before sending it to the ONU.
	// Calculation of this needs to be done according to ITU-T I.363.5 as per OMCI spec (section A.2.27)
	Crc32                uint32   `protobuf:"varint,10,opt,name=crc32,proto3" json:"crc32,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Object representing an image

func (*Image) Descriptor 

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

func (*Image) GetCrc32 

func (m *Image) GetCrc32() uint32

func (*Image) GetHash 

func (m *Image) GetHash() uint32

func (*Image) GetInstallDatetime 

func (m *Image) GetInstallDatetime() string

func (*Image) GetIsActive 

func (m *Image) GetIsActive() bool

func (*Image) GetIsCommitted 

func (m *Image) GetIsCommitted() bool

func (*Image) GetIsValid 

func (m *Image) GetIsValid() bool

func (*Image) GetName 

func (m *Image) GetName() string

func (*Image) GetUrl 

func (m *Image) GetUrl() string

func (*Image) GetVendor 

func (m *Image) GetVendor() string

func (*Image) GetVersion 

func (m *Image) GetVersion() string

func (*Image) ProtoMessage 

func (*Image) ProtoMessage()

func (*Image) Reset 

func (m *Image) Reset()

func (*Image) String 

func (m *Image) String() string

func (*Image) XXX_DiscardUnknown 

func (m *Image) XXX_DiscardUnknown()

func (*Image) XXX_Marshal 

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

func (*Image) XXX_Merge 

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

func (*Image) XXX_Size 

func (m *Image) XXX_Size() int

func (*Image) XXX_Unmarshal 

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

type ImageDownload deprecated 

type ImageDownload struct {
	// Device Identifier
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Image unique identifier
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// URL where the image is available
	// should include username password
	Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// CRC of the image to be verified aginst
	Crc uint32 `protobuf:"varint,4,opt,name=crc,proto3" json:"crc,omitempty"`
	// Download state
	DownloadState ImageDownload_ImageDownloadState `` /* 146-byte string literal not displayed */
	// Downloaded version
	ImageVersion string `protobuf:"bytes,6,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"`
	// Bytes downloaded
	DownloadedBytes uint32 `protobuf:"varint,7,opt,name=downloaded_bytes,json=downloadedBytes,proto3" json:"downloaded_bytes,omitempty"`
	// Download failure reason
	Reason ImageDownload_ImageDownloadFailureReason `protobuf:"varint,8,opt,name=reason,proto3,enum=device.ImageDownload_ImageDownloadFailureReason" json:"reason,omitempty"`
	// Additional info
	AdditionalInfo string `protobuf:"bytes,9,opt,name=additional_info,json=additionalInfo,proto3" json:"additional_info,omitempty"`
	// Save current configuration
	SaveConfig bool `protobuf:"varint,10,opt,name=save_config,json=saveConfig,proto3" json:"save_config,omitempty"`
	// Image local location
	LocalDir string `protobuf:"bytes,11,opt,name=local_dir,json=localDir,proto3" json:"local_dir,omitempty"`
	// Image activation state
	ImageState ImageDownload_ImageActivateState `` /* 138-byte string literal not displayed */
	// Image file size
	FileSize             uint32   `protobuf:"varint,13,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Older version of the API please see DeviceImageDownloadRequest Deprecated in voltha 2.8, will be removed

Deprecated: Do not use.

func (*ImageDownload) Descriptor 

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

func (*ImageDownload) GetAdditionalInfo 

func (m *ImageDownload) GetAdditionalInfo() string

func (*ImageDownload) GetCrc 

func (m *ImageDownload) GetCrc() uint32

func (*ImageDownload) GetDownloadState 

func (m *ImageDownload) GetDownloadState() ImageDownload_ImageDownloadState

func (*ImageDownload) GetDownloadedBytes 

func (m *ImageDownload) GetDownloadedBytes() uint32

func (*ImageDownload) GetFileSize 

func (m *ImageDownload) GetFileSize() uint32

func (*ImageDownload) GetId 

func (m *ImageDownload) GetId() string

func (*ImageDownload) GetImageState 

func (m *ImageDownload) GetImageState() ImageDownload_ImageActivateState

func (*ImageDownload) GetImageVersion 

func (m *ImageDownload) GetImageVersion() string

func (*ImageDownload) GetLocalDir 

func (m *ImageDownload) GetLocalDir() string

func (*ImageDownload) GetName 

func (m *ImageDownload) GetName() string

func (*ImageDownload) GetReason 

func (m *ImageDownload) GetReason() ImageDownload_ImageDownloadFailureReason

func (*ImageDownload) GetSaveConfig 

func (m *ImageDownload) GetSaveConfig() bool

func (*ImageDownload) GetUrl 

func (m *ImageDownload) GetUrl() string

func (*ImageDownload) ProtoMessage 

func (*ImageDownload) ProtoMessage()

func (*ImageDownload) Reset 

func (m *ImageDownload) Reset()

func (*ImageDownload) String 

func (m *ImageDownload) String() string

func (*ImageDownload) XXX_DiscardUnknown 

func (m *ImageDownload) XXX_DiscardUnknown()

func (*ImageDownload) XXX_Marshal 

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

func (*ImageDownload) XXX_Merge 

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

func (*ImageDownload) XXX_Size 

func (m *ImageDownload) XXX_Size() int

func (*ImageDownload) XXX_Unmarshal 

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

type ImageDownload_ImageActivateState 

type ImageDownload_ImageActivateState int32
const (
	ImageDownload_IMAGE_UNKNOWN    ImageDownload_ImageActivateState = 0
	ImageDownload_IMAGE_INACTIVE   ImageDownload_ImageActivateState = 1
	ImageDownload_IMAGE_ACTIVATING ImageDownload_ImageActivateState = 2
	ImageDownload_IMAGE_ACTIVE     ImageDownload_ImageActivateState = 3
	ImageDownload_IMAGE_REVERTING  ImageDownload_ImageActivateState = 4
	ImageDownload_IMAGE_REVERTED   ImageDownload_ImageActivateState = 5
)

func (ImageDownload_ImageActivateState) EnumDescriptor 

func (ImageDownload_ImageActivateState) EnumDescriptor() ([]byte, []int)

func (ImageDownload_ImageActivateState) String 

func (x ImageDownload_ImageActivateState) String() string

type ImageDownload_ImageDownloadFailureReason 

type ImageDownload_ImageDownloadFailureReason int32
const (
	ImageDownload_NO_ERROR           ImageDownload_ImageDownloadFailureReason = 0
	ImageDownload_INVALID_URL        ImageDownload_ImageDownloadFailureReason = 1
	ImageDownload_DEVICE_BUSY        ImageDownload_ImageDownloadFailureReason = 2
	ImageDownload_INSUFFICIENT_SPACE ImageDownload_ImageDownloadFailureReason = 3
	ImageDownload_UNKNOWN_ERROR      ImageDownload_ImageDownloadFailureReason = 4
	ImageDownload_CANCELLED          ImageDownload_ImageDownloadFailureReason = 5
)

func (ImageDownload_ImageDownloadFailureReason) EnumDescriptor 

func (ImageDownload_ImageDownloadFailureReason) EnumDescriptor() ([]byte, []int)

func (ImageDownload_ImageDownloadFailureReason) String 

func (x ImageDownload_ImageDownloadFailureReason) String() string

type ImageDownload_ImageDownloadState 

type ImageDownload_ImageDownloadState int32
const (
	ImageDownload_DOWNLOAD_UNKNOWN     ImageDownload_ImageDownloadState = 0
	ImageDownload_DOWNLOAD_SUCCEEDED   ImageDownload_ImageDownloadState = 1
	ImageDownload_DOWNLOAD_REQUESTED   ImageDownload_ImageDownloadState = 2
	ImageDownload_DOWNLOAD_STARTED     ImageDownload_ImageDownloadState = 3
	ImageDownload_DOWNLOAD_FAILED      ImageDownload_ImageDownloadState = 4
	ImageDownload_DOWNLOAD_UNSUPPORTED ImageDownload_ImageDownloadState = 5
	ImageDownload_DOWNLOAD_CANCELLED   ImageDownload_ImageDownloadState = 6
)

func (ImageDownload_ImageDownloadState) EnumDescriptor 

func (ImageDownload_ImageDownloadState) EnumDescriptor() ([]byte, []int)

func (ImageDownload_ImageDownloadState) String 

func (x ImageDownload_ImageDownloadState) String() string

type ImageDownloads deprecated 

type ImageDownloads struct {
	Items                []*ImageDownload `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Deprecated in voltha 2.8, will be removed

Deprecated: Do not use.

func (*ImageDownloads) Descriptor 

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

func (*ImageDownloads) GetItems 

func (m *ImageDownloads) GetItems() []*ImageDownload

func (*ImageDownloads) ProtoMessage 

func (*ImageDownloads) ProtoMessage()

func (*ImageDownloads) Reset 

func (m *ImageDownloads) Reset()

func (*ImageDownloads) String 

func (m *ImageDownloads) String() string

func (*ImageDownloads) XXX_DiscardUnknown 

func (m *ImageDownloads) XXX_DiscardUnknown()

func (*ImageDownloads) XXX_Marshal 

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

func (*ImageDownloads) XXX_Merge 

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

func (*ImageDownloads) XXX_Size 

func (m *ImageDownloads) XXX_Size() int

func (*ImageDownloads) XXX_Unmarshal 

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

type ImageState 

type ImageState struct {
	// image version
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Download state
	DownloadState ImageState_ImageDownloadState `` /* 143-byte string literal not displayed */
	// Image Operation Failure reason (use for both Download and Activate)
	Reason ImageState_ImageFailureReason `protobuf:"varint,3,opt,name=reason,proto3,enum=device.ImageState_ImageFailureReason" json:"reason,omitempty"`
	// Image activation state
	ImageState           ImageState_ImageActivationState `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*ImageState) Descriptor 

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

func (*ImageState) GetDownloadState 

func (m *ImageState) GetDownloadState() ImageState_ImageDownloadState

func (*ImageState) GetImageState 

func (m *ImageState) GetImageState() ImageState_ImageActivationState

func (*ImageState) GetReason 

func (m *ImageState) GetReason() ImageState_ImageFailureReason

func (*ImageState) GetVersion 

func (m *ImageState) GetVersion() string

func (*ImageState) ProtoMessage 

func (*ImageState) ProtoMessage()

func (*ImageState) Reset 

func (m *ImageState) Reset()

func (*ImageState) String 

func (m *ImageState) String() string

func (*ImageState) XXX_DiscardUnknown 

func (m *ImageState) XXX_DiscardUnknown()

func (*ImageState) XXX_Marshal 

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

func (*ImageState) XXX_Merge 

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

func (*ImageState) XXX_Size 

func (m *ImageState) XXX_Size() int

func (*ImageState) XXX_Unmarshal 

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

type ImageState_ImageActivationState 

type ImageState_ImageActivationState int32
const (
	ImageState_IMAGE_UNKNOWN             ImageState_ImageActivationState = 0
	ImageState_IMAGE_INACTIVE            ImageState_ImageActivationState = 1
	ImageState_IMAGE_ACTIVATING          ImageState_ImageActivationState = 2
	ImageState_IMAGE_ACTIVE              ImageState_ImageActivationState = 3
	ImageState_IMAGE_COMMITTING          ImageState_ImageActivationState = 4
	ImageState_IMAGE_COMMITTED           ImageState_ImageActivationState = 5
	ImageState_IMAGE_ACTIVATION_ABORTING ImageState_ImageActivationState = 6
	ImageState_IMAGE_ACTIVATION_ABORTED  ImageState_ImageActivationState = 7
	ImageState_IMAGE_COMMIT_ABORTING     ImageState_ImageActivationState = 8
	ImageState_IMAGE_COMMIT_ABORTED      ImageState_ImageActivationState = 9
	ImageState_IMAGE_DOWNLOADING         ImageState_ImageActivationState = 10
)

func (ImageState_ImageActivationState) EnumDescriptor 

func (ImageState_ImageActivationState) EnumDescriptor() ([]byte, []int)

func (ImageState_ImageActivationState) String 

func (x ImageState_ImageActivationState) String() string

type ImageState_ImageDownloadState 

type ImageState_ImageDownloadState int32
const (
	ImageState_DOWNLOAD_UNKNOWN     ImageState_ImageDownloadState = 0
	ImageState_DOWNLOAD_SUCCEEDED   ImageState_ImageDownloadState = 1
	ImageState_DOWNLOAD_REQUESTED   ImageState_ImageDownloadState = 2
	ImageState_DOWNLOAD_STARTED     ImageState_ImageDownloadState = 3
	ImageState_DOWNLOAD_FAILED      ImageState_ImageDownloadState = 4
	ImageState_DOWNLOAD_UNSUPPORTED ImageState_ImageDownloadState = 5
	ImageState_DOWNLOAD_CANCELLING  ImageState_ImageDownloadState = 6
	ImageState_DOWNLOAD_CANCELLED   ImageState_ImageDownloadState = 7
)

func (ImageState_ImageDownloadState) EnumDescriptor 

func (ImageState_ImageDownloadState) EnumDescriptor() ([]byte, []int)

func (ImageState_ImageDownloadState) String 

func (x ImageState_ImageDownloadState) String() string

type ImageState_ImageFailureReason 

type ImageState_ImageFailureReason int32
const (
	ImageState_NO_ERROR               ImageState_ImageFailureReason = 0
	ImageState_INVALID_URL            ImageState_ImageFailureReason = 1
	ImageState_DEVICE_BUSY            ImageState_ImageFailureReason = 2
	ImageState_INSUFFICIENT_SPACE     ImageState_ImageFailureReason = 3
	ImageState_UNKNOWN_ERROR          ImageState_ImageFailureReason = 4
	ImageState_CANCELLED_ON_REQUEST   ImageState_ImageFailureReason = 5
	ImageState_CANCELLED_ON_ONU_STATE ImageState_ImageFailureReason = 6
	ImageState_VENDOR_DEVICE_MISMATCH ImageState_ImageFailureReason = 7
	ImageState_OMCI_TRANSFER_ERROR    ImageState_ImageFailureReason = 8
	ImageState_IMAGE_REFUSED_BY_ONU   ImageState_ImageFailureReason = 9
)

func (ImageState_ImageFailureReason) EnumDescriptor 

func (ImageState_ImageFailureReason) EnumDescriptor() ([]byte, []int)

func (ImageState_ImageFailureReason) String 

func (x ImageState_ImageFailureReason) String() string

type Images 

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

func (*Images) Descriptor 

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

func (*Images) GetImage 

func (m *Images) GetImage() []*Image

func (*Images) ProtoMessage 

func (*Images) ProtoMessage()

func (*Images) Reset 

func (m *Images) Reset()

func (*Images) String 

func (m *Images) String() string

func (*Images) XXX_DiscardUnknown 

func (m *Images) XXX_DiscardUnknown()

func (*Images) XXX_Marshal 

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

func (*Images) XXX_Merge 

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

func (*Images) XXX_Size 

func (m *Images) XXX_Size() int

func (*Images) XXX_Unmarshal 

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

type Key 

type Key = common.Key

Key from public import voltha_protos/common.proto

type KpiEvent 

type KpiEvent struct {
	Type                 KpiEventType_Types           `protobuf:"varint,1,opt,name=type,proto3,enum=event.KpiEventType_Types" json:"type,omitempty"`
	Ts                   float32                      `protobuf:"fixed32,2,opt,name=ts,proto3" json:"ts,omitempty"`
	Prefixes             map[string]*MetricValuePairs `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

Legacy KPI Event structured. In mid-August, the KPI event format was updated 

to a more easily parsable format. See VOL-1140
for more information.

func (*KpiEvent) Descriptor 

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

func (*KpiEvent) GetPrefixes 

func (m *KpiEvent) GetPrefixes() map[string]*MetricValuePairs

func (*KpiEvent) GetTs 

func (m *KpiEvent) GetTs() float32

func (*KpiEvent) GetType 

func (m *KpiEvent) GetType() KpiEventType_Types

func (*KpiEvent) ProtoMessage 

func (*KpiEvent) ProtoMessage()

func (*KpiEvent) Reset 

func (m *KpiEvent) Reset()

func (*KpiEvent) String 

func (m *KpiEvent) String() string

func (*KpiEvent) XXX_DiscardUnknown 

func (m *KpiEvent) XXX_DiscardUnknown()

func (*KpiEvent) XXX_Marshal 

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

func (*KpiEvent) XXX_Merge 

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

func (*KpiEvent) XXX_Size 

func (m *KpiEvent) XXX_Size() int

func (*KpiEvent) XXX_Unmarshal 

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

type KpiEvent2 

type KpiEvent2 struct {
	// Type of KPI Event
	Type KpiEventType_Types `protobuf:"varint,1,opt,name=type,proto3,enum=event.KpiEventType_Types" json:"type,omitempty"`
	// Fields used when for slice:
	Ts                   float64              `protobuf:"fixed64,2,opt,name=ts,proto3" json:"ts,omitempty"`
	SliceData            []*MetricInformation `protobuf:"bytes,3,rep,name=slice_data,json=sliceData,proto3" json:"slice_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*KpiEvent2) Descriptor 

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

func (*KpiEvent2) GetSliceData 

func (m *KpiEvent2) GetSliceData() []*MetricInformation

func (*KpiEvent2) GetTs 

func (m *KpiEvent2) GetTs() float64

func (*KpiEvent2) GetType 

func (m *KpiEvent2) GetType() KpiEventType_Types

func (*KpiEvent2) ProtoMessage 

func (*KpiEvent2) ProtoMessage()

func (*KpiEvent2) Reset 

func (m *KpiEvent2) Reset()

func (*KpiEvent2) String 

func (m *KpiEvent2) String() string

func (*KpiEvent2) XXX_DiscardUnknown 

func (m *KpiEvent2) XXX_DiscardUnknown()

func (*KpiEvent2) XXX_Marshal 

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

func (*KpiEvent2) XXX_Merge 

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

func (*KpiEvent2) XXX_Size 

func (m *KpiEvent2) XXX_Size() int

func (*KpiEvent2) XXX_Unmarshal 

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

type KpiEventType 

type KpiEventType struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KpiEventType) Descriptor 

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

func (*KpiEventType) ProtoMessage 

func (*KpiEventType) ProtoMessage()

func (*KpiEventType) Reset 

func (m *KpiEventType) Reset()

func (*KpiEventType) String 

func (m *KpiEventType) String() string

func (*KpiEventType) XXX_DiscardUnknown 

func (m *KpiEventType) XXX_DiscardUnknown()

func (*KpiEventType) XXX_Marshal 

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

func (*KpiEventType) XXX_Merge 

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

func (*KpiEventType) XXX_Size 

func (m *KpiEventType) XXX_Size() int

func (*KpiEventType) XXX_Unmarshal 

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

type KpiEventType_Types 

type KpiEventType_Types int32
const (
	KpiEventType_slice KpiEventType_Types = 0
	KpiEventType_ts    KpiEventType_Types = 1
)

func (KpiEventType_Types) EnumDescriptor 

func (KpiEventType_Types) EnumDescriptor() ([]byte, []int)

func (KpiEventType_Types) String 

func (x KpiEventType_Types) String() string

type LogicalDevice 

type LogicalDevice struct {
	// unique id of logical device
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// unique datapath id for the logical device (used by the SDN controller)
	DatapathId uint64 `protobuf:"varint,2,opt,name=datapath_id,json=datapathId,proto3" json:"datapath_id,omitempty"`
	// device description
	Desc *openflow_13.OfpDesc `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	// device features
	SwitchFeatures *openflow_13.OfpSwitchFeatures `protobuf:"bytes,4,opt,name=switch_features,json=switchFeatures,proto3" json:"switch_features,omitempty"`
	// name of the root device anchoring logical device
	RootDeviceId         string   `protobuf:"bytes,5,opt,name=root_device_id,json=rootDeviceId,proto3" json:"root_device_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogicalDevice) Descriptor 

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

func (*LogicalDevice) GetDatapathId 

func (m *LogicalDevice) GetDatapathId() uint64

func (*LogicalDevice) GetDesc 

func (m *LogicalDevice) GetDesc() *openflow_13.OfpDesc

func (*LogicalDevice) GetId 

func (m *LogicalDevice) GetId() string

func (*LogicalDevice) GetRootDeviceId 

func (m *LogicalDevice) GetRootDeviceId() string

func (*LogicalDevice) GetSwitchFeatures 

func (m *LogicalDevice) GetSwitchFeatures() *openflow_13.OfpSwitchFeatures

func (*LogicalDevice) ProtoMessage 

func (*LogicalDevice) ProtoMessage()

func (*LogicalDevice) Reset 

func (m *LogicalDevice) Reset()

func (*LogicalDevice) String 

func (m *LogicalDevice) String() string

func (*LogicalDevice) XXX_DiscardUnknown 

func (m *LogicalDevice) XXX_DiscardUnknown()

func (*LogicalDevice) XXX_Marshal 

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

func (*LogicalDevice) XXX_Merge 

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

func (*LogicalDevice) XXX_Size 

func (m *LogicalDevice) XXX_Size() int

func (*LogicalDevice) XXX_Unmarshal 

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

type LogicalDevices 

type LogicalDevices struct {
	Items                []*LogicalDevice `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*LogicalDevices) Descriptor 

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

func (*LogicalDevices) GetItems 

func (m *LogicalDevices) GetItems() []*LogicalDevice

func (*LogicalDevices) ProtoMessage 

func (*LogicalDevices) ProtoMessage()

func (*LogicalDevices) Reset 

func (m *LogicalDevices) Reset()

func (*LogicalDevices) String 

func (m *LogicalDevices) String() string

func (*LogicalDevices) XXX_DiscardUnknown 

func (m *LogicalDevices) XXX_DiscardUnknown()

func (*LogicalDevices) XXX_Marshal 

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

func (*LogicalDevices) XXX_Merge 

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

func (*LogicalDevices) XXX_Size 

func (m *LogicalDevices) XXX_Size() int

func (*LogicalDevices) XXX_Unmarshal 

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

type LogicalPort 

type LogicalPort struct {
	Id                   string                    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	OfpPort              *openflow_13.OfpPort      `protobuf:"bytes,2,opt,name=ofp_port,json=ofpPort,proto3" json:"ofp_port,omitempty"`
	DeviceId             string                    `protobuf:"bytes,3,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	DevicePortNo         uint32                    `protobuf:"varint,4,opt,name=device_port_no,json=devicePortNo,proto3" json:"device_port_no,omitempty"`
	RootPort             bool                      `protobuf:"varint,5,opt,name=root_port,json=rootPort,proto3" json:"root_port,omitempty"`
	OfpPortStats         *openflow_13.OfpPortStats `protobuf:"bytes,6,opt,name=ofp_port_stats,json=ofpPortStats,proto3" json:"ofp_port_stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*LogicalPort) Descriptor 

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

func (*LogicalPort) GetDeviceId 

func (m *LogicalPort) GetDeviceId() string

func (*LogicalPort) GetDevicePortNo 

func (m *LogicalPort) GetDevicePortNo() uint32

func (*LogicalPort) GetId 

func (m *LogicalPort) GetId() string

func (*LogicalPort) GetOfpPort 

func (m *LogicalPort) GetOfpPort() *openflow_13.OfpPort

func (*LogicalPort) GetOfpPortStats 

func (m *LogicalPort) GetOfpPortStats() *openflow_13.OfpPortStats

func (*LogicalPort) GetRootPort 

func (m *LogicalPort) GetRootPort() bool

func (*LogicalPort) ProtoMessage 

func (*LogicalPort) ProtoMessage()

func (*LogicalPort) Reset 

func (m *LogicalPort) Reset()

func (*LogicalPort) String 

func (m *LogicalPort) String() string

func (*LogicalPort) XXX_DiscardUnknown 

func (m *LogicalPort) XXX_DiscardUnknown()

func (*LogicalPort) XXX_Marshal 

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

func (*LogicalPort) XXX_Merge 

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

func (*LogicalPort) XXX_Size 

func (m *LogicalPort) XXX_Size() int

func (*LogicalPort) XXX_Unmarshal 

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

type LogicalPortId 

type LogicalPortId struct {
	// unique id of logical device
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// id of the port on the logical device
	PortId               string   `protobuf:"bytes,2,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogicalPortId) Descriptor 

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

func (*LogicalPortId) GetId 

func (m *LogicalPortId) GetId() string

func (*LogicalPortId) GetPortId 

func (m *LogicalPortId) GetPortId() string

func (*LogicalPortId) ProtoMessage 

func (*LogicalPortId) ProtoMessage()

func (*LogicalPortId) Reset 

func (m *LogicalPortId) Reset()

func (*LogicalPortId) String 

func (m *LogicalPortId) String() string

func (*LogicalPortId) XXX_DiscardUnknown 

func (m *LogicalPortId) XXX_DiscardUnknown()

func (*LogicalPortId) XXX_Marshal 

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

func (*LogicalPortId) XXX_Merge 

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

func (*LogicalPortId) XXX_Size 

func (m *LogicalPortId) XXX_Size() int

func (*LogicalPortId) XXX_Unmarshal 

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

type LogicalPorts 

type LogicalPorts struct {
	Items                []*LogicalPort `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*LogicalPorts) Descriptor 

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

func (*LogicalPorts) GetItems 

func (m *LogicalPorts) GetItems() []*LogicalPort

func (*LogicalPorts) ProtoMessage 

func (*LogicalPorts) ProtoMessage()

func (*LogicalPorts) Reset 

func (m *LogicalPorts) Reset()

func (*LogicalPorts) String 

func (m *LogicalPorts) String() string

func (*LogicalPorts) XXX_DiscardUnknown 

func (m *LogicalPorts) XXX_DiscardUnknown()

func (*LogicalPorts) XXX_Marshal 

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

func (*LogicalPorts) XXX_Merge 

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

func (*LogicalPorts) XXX_Size 

func (m *LogicalPorts) XXX_Size() int

func (*LogicalPorts) XXX_Unmarshal 

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

type MetricInformation 

type MetricInformation struct {
	Metadata             *MetricMetaData    `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Metrics              map[string]float32 `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Struct to group metadata for a metric (or group of metrics) with the key-value pairs of collected metrics

func (*MetricInformation) Descriptor 

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

func (*MetricInformation) GetMetadata 

func (m *MetricInformation) GetMetadata() *MetricMetaData

func (*MetricInformation) GetMetrics 

func (m *MetricInformation) GetMetrics() map[string]float32

func (*MetricInformation) ProtoMessage 

func (*MetricInformation) ProtoMessage()

func (*MetricInformation) Reset 

func (m *MetricInformation) Reset()

func (*MetricInformation) String 

func (m *MetricInformation) String() string

func (*MetricInformation) XXX_DiscardUnknown 

func (m *MetricInformation) XXX_DiscardUnknown()

func (*MetricInformation) XXX_Marshal 

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

func (*MetricInformation) XXX_Merge 

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

func (*MetricInformation) XXX_Size 

func (m *MetricInformation) XXX_Size() int

func (*MetricInformation) XXX_Unmarshal 

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

type MetricMetaData 

type MetricMetaData struct {
	Title           string  `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Ts              float64 `protobuf:"fixed64,2,opt,name=ts,proto3" json:"ts,omitempty"`
	LogicalDeviceId string  `protobuf:"bytes,3,opt,name=logical_device_id,json=logicalDeviceId,proto3" json:"logical_device_id,omitempty"`
	// (equivalent to the DPID that ONOS has
	// for the VOLTHA device without the
	//  'of:' prefix
	SerialNo             string            `protobuf:"bytes,4,opt,name=serial_no,json=serialNo,proto3" json:"serial_no,omitempty"`
	DeviceId             string            `protobuf:"bytes,5,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Context              map[string]string `` /* 155-byte string literal not displayed */
	Uuid                 string            `protobuf:"bytes,7,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Struct to convey a dictionary of metric metadata.

func (*MetricMetaData) Descriptor 

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

func (*MetricMetaData) GetContext 

func (m *MetricMetaData) GetContext() map[string]string

func (*MetricMetaData) GetDeviceId 

func (m *MetricMetaData) GetDeviceId() string

func (*MetricMetaData) GetLogicalDeviceId 

func (m *MetricMetaData) GetLogicalDeviceId() string

func (*MetricMetaData) GetSerialNo 

func (m *MetricMetaData) GetSerialNo() string

func (*MetricMetaData) GetTitle 

func (m *MetricMetaData) GetTitle() string

func (*MetricMetaData) GetTs 

func (m *MetricMetaData) GetTs() float64

func (*MetricMetaData) GetUuid 

func (m *MetricMetaData) GetUuid() string

func (*MetricMetaData) ProtoMessage 

func (*MetricMetaData) ProtoMessage()

func (*MetricMetaData) Reset 

func (m *MetricMetaData) Reset()

func (*MetricMetaData) String 

func (m *MetricMetaData) String() string

func (*MetricMetaData) XXX_DiscardUnknown 

func (m *MetricMetaData) XXX_DiscardUnknown()

func (*MetricMetaData) XXX_Marshal 

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

func (*MetricMetaData) XXX_Merge 

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

func (*MetricMetaData) XXX_Size 

func (m *MetricMetaData) XXX_Size() int

func (*MetricMetaData) XXX_Unmarshal 

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

type MetricValuePairs 

type MetricValuePairs struct {
	// Metric / value pairs.
	Metrics              map[string]float32 `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Struct to convey a dictionary of metric->value pairs. Typically used in pure shared-timestamp or shared-timestamp + shared object prefix situations.

func (*MetricValuePairs) Descriptor 

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

func (*MetricValuePairs) GetMetrics 

func (m *MetricValuePairs) GetMetrics() map[string]float32

func (*MetricValuePairs) ProtoMessage 

func (*MetricValuePairs) ProtoMessage()

func (*MetricValuePairs) Reset 

func (m *MetricValuePairs) Reset()

func (*MetricValuePairs) String 

func (m *MetricValuePairs) String() string

func (*MetricValuePairs) XXX_DiscardUnknown 

func (m *MetricValuePairs) XXX_DiscardUnknown()

func (*MetricValuePairs) XXX_Marshal 

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

func (*MetricValuePairs) XXX_Merge 

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

func (*MetricValuePairs) XXX_Size 

func (m *MetricValuePairs) XXX_Size() int

func (*MetricValuePairs) XXX_Unmarshal 

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

type OnuImage 

type OnuImage struct {
	//image version
	Version     string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	IsCommited  bool   `protobuf:"varint,2,opt,name=isCommited,proto3" json:"isCommited,omitempty"`
	IsActive    bool   `protobuf:"varint,3,opt,name=isActive,proto3" json:"isActive,omitempty"`
	IsValid     bool   `protobuf:"varint,4,opt,name=isValid,proto3" json:"isValid,omitempty"`
	ProductCode string `protobuf:"bytes,5,opt,name=productCode,proto3" json:"productCode,omitempty"`
	// Hash is computed by the ONU and is optional as per OMCI spec (paragraph 9.1.4)
	// No assumption should be made on the existence of this attribute at any time.
	Hash                 string   `protobuf:"bytes,6,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

OnuImage represents the OMCI information as per OMCI spec the information will be populates exactly as extracted from the device.

func (*OnuImage) Descriptor 

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

func (*OnuImage) GetHash 

func (m *OnuImage) GetHash() string

func (*OnuImage) GetIsActive 

func (m *OnuImage) GetIsActive() bool

func (*OnuImage) GetIsCommited 

func (m *OnuImage) GetIsCommited() bool

func (*OnuImage) GetIsValid 

func (m *OnuImage) GetIsValid() bool

func (*OnuImage) GetProductCode 

func (m *OnuImage) GetProductCode() string

func (*OnuImage) GetVersion 

func (m *OnuImage) GetVersion() string

func (*OnuImage) ProtoMessage 

func (*OnuImage) ProtoMessage()

func (*OnuImage) Reset 

func (m *OnuImage) Reset()

func (*OnuImage) String 

func (m *OnuImage) String() string

func (*OnuImage) XXX_DiscardUnknown 

func (m *OnuImage) XXX_DiscardUnknown()

func (*OnuImage) XXX_Marshal 

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

func (*OnuImage) XXX_Merge 

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

func (*OnuImage) XXX_Size 

func (m *OnuImage) XXX_Size() int

func (*OnuImage) XXX_Unmarshal 

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

type OnuImages 

type OnuImages struct {
	Items                []*OnuImage `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*OnuImages) Descriptor 

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

func (*OnuImages) GetItems 

func (m *OnuImages) GetItems() []*OnuImage

func (*OnuImages) ProtoMessage 

func (*OnuImages) ProtoMessage()

func (*OnuImages) Reset 

func (m *OnuImages) Reset()

func (*OnuImages) String 

func (m *OnuImages) String() string

func (*OnuImages) XXX_DiscardUnknown 

func (m *OnuImages) XXX_DiscardUnknown()

func (*OnuImages) XXX_Marshal 

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

func (*OnuImages) XXX_Merge 

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

func (*OnuImages) XXX_Size 

func (m *OnuImages) XXX_Size() int

func (*OnuImages) XXX_Unmarshal 

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

type OperStatus 

type OperStatus = common.OperStatus

OperStatus from public import voltha_protos/common.proto

type OperStatus_Types 

type OperStatus_Types = common.OperStatus_Types

OperStatus_Types from public import voltha_protos/common.proto

type OperationResp 

type OperationResp = common.OperationResp

OperationResp from public import voltha_protos/common.proto

type OperationResp_OperationReturnCode 

type OperationResp_OperationReturnCode = common.OperationResp_OperationReturnCode

OperationResp_OperationReturnCode from public import voltha_protos/common.proto

type PmConfig 

type PmConfig struct {
	Name                 string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 PmConfig_PmType `protobuf:"varint,2,opt,name=type,proto3,enum=device.PmConfig_PmType" json:"type,omitempty"`
	Enabled              bool            `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
	SampleFreq           uint32          `protobuf:"varint,4,opt,name=sample_freq,json=sampleFreq,proto3" json:"sample_freq,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PmConfig) Descriptor 

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

func (*PmConfig) GetEnabled 

func (m *PmConfig) GetEnabled() bool

func (*PmConfig) GetName 

func (m *PmConfig) GetName() string

func (*PmConfig) GetSampleFreq 

func (m *PmConfig) GetSampleFreq() uint32

func (*PmConfig) GetType 

func (m *PmConfig) GetType() PmConfig_PmType

func (*PmConfig) ProtoMessage 

func (*PmConfig) ProtoMessage()

func (*PmConfig) Reset 

func (m *PmConfig) Reset()

func (*PmConfig) String 

func (m *PmConfig) String() string

func (*PmConfig) XXX_DiscardUnknown 

func (m *PmConfig) XXX_DiscardUnknown()

func (*PmConfig) XXX_Marshal 

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

func (*PmConfig) XXX_Merge 

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

func (*PmConfig) XXX_Size 

func (m *PmConfig) XXX_Size() int

func (*PmConfig) XXX_Unmarshal 

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

type PmConfig_PmType 

type PmConfig_PmType int32
const (
	PmConfig_COUNTER PmConfig_PmType = 0
	PmConfig_GAUGE   PmConfig_PmType = 1
	PmConfig_STATE   PmConfig_PmType = 2
	PmConfig_CONTEXT PmConfig_PmType = 3
)

func (PmConfig_PmType) EnumDescriptor 

func (PmConfig_PmType) EnumDescriptor() ([]byte, []int)

func (PmConfig_PmType) String 

func (x PmConfig_PmType) String() string

type PmConfigs 

type PmConfigs struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DefaultFreq uint32 `protobuf:"varint,2,opt,name=default_freq,json=defaultFreq,proto3" json:"default_freq,omitempty"`
	// Forces group names and group semantics
	Grouped bool `protobuf:"varint,3,opt,name=grouped,proto3" json:"grouped,omitempty"`
	// Allows Pm to set an individual sample frequency
	FreqOverride         bool             `protobuf:"varint,4,opt,name=freq_override,json=freqOverride,proto3" json:"freq_override,omitempty"`
	Groups               []*PmGroupConfig `protobuf:"bytes,5,rep,name=groups,proto3" json:"groups,omitempty"`
	Metrics              []*PmConfig      `protobuf:"bytes,6,rep,name=metrics,proto3" json:"metrics,omitempty"`
	MaxSkew              uint32           `protobuf:"varint,7,opt,name=max_skew,json=maxSkew,proto3" json:"max_skew,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*PmConfigs) Descriptor 

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

func (*PmConfigs) GetDefaultFreq 

func (m *PmConfigs) GetDefaultFreq() uint32

func (*PmConfigs) GetFreqOverride 

func (m *PmConfigs) GetFreqOverride() bool

func (*PmConfigs) GetGrouped 

func (m *PmConfigs) GetGrouped() bool

func (*PmConfigs) GetGroups 

func (m *PmConfigs) GetGroups() []*PmGroupConfig

func (*PmConfigs) GetId 

func (m *PmConfigs) GetId() string

func (*PmConfigs) GetMaxSkew 

func (m *PmConfigs) GetMaxSkew() uint32

func (*PmConfigs) GetMetrics 

func (m *PmConfigs) GetMetrics() []*PmConfig

func (*PmConfigs) ProtoMessage 

func (*PmConfigs) ProtoMessage()

func (*PmConfigs) Reset 

func (m *PmConfigs) Reset()

func (*PmConfigs) String 

func (m *PmConfigs) String() string

func (*PmConfigs) XXX_DiscardUnknown 

func (m *PmConfigs) XXX_DiscardUnknown()

func (*PmConfigs) XXX_Marshal 

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

func (*PmConfigs) XXX_Merge 

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

func (*PmConfigs) XXX_Size 

func (m *PmConfigs) XXX_Size() int

func (*PmConfigs) XXX_Unmarshal 

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

type PmGroupConfig 

type PmGroupConfig struct {
	GroupName            string      `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	GroupFreq            uint32      `protobuf:"varint,2,opt,name=group_freq,json=groupFreq,proto3" json:"group_freq,omitempty"`
	Enabled              bool        `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Metrics              []*PmConfig `protobuf:"bytes,4,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*PmGroupConfig) Descriptor 

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

func (*PmGroupConfig) GetEnabled 

func (m *PmGroupConfig) GetEnabled() bool

func (*PmGroupConfig) GetGroupFreq 

func (m *PmGroupConfig) GetGroupFreq() uint32

func (*PmGroupConfig) GetGroupName 

func (m *PmGroupConfig) GetGroupName() string

func (*PmGroupConfig) GetMetrics 

func (m *PmGroupConfig) GetMetrics() []*PmConfig

func (*PmGroupConfig) ProtoMessage 

func (*PmGroupConfig) ProtoMessage()

func (*PmGroupConfig) Reset 

func (m *PmGroupConfig) Reset()

func (*PmGroupConfig) String 

func (m *PmGroupConfig) String() string

func (*PmGroupConfig) XXX_DiscardUnknown 

func (m *PmGroupConfig) XXX_DiscardUnknown()

func (*PmGroupConfig) XXX_Marshal 

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

func (*PmGroupConfig) XXX_Merge 

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

func (*PmGroupConfig) XXX_Size 

func (m *PmGroupConfig) XXX_Size() int

func (*PmGroupConfig) XXX_Unmarshal 

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

type Port 

type Port struct {
	PortNo     uint32                  `protobuf:"varint,1,opt,name=port_no,json=portNo,proto3" json:"port_no,omitempty"`
	Label      string                  `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Type       Port_PortType           `protobuf:"varint,3,opt,name=type,proto3,enum=device.Port_PortType" json:"type,omitempty"`
	AdminState common.AdminState_Types `protobuf:"varint,5,opt,name=admin_state,json=adminState,proto3,enum=common.AdminState_Types" json:"admin_state,omitempty"`
	OperStatus common.OperStatus_Types `protobuf:"varint,6,opt,name=oper_status,json=operStatus,proto3,enum=common.OperStatus_Types" json:"oper_status,omitempty"`
	DeviceId   string                  `protobuf:"bytes,7,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Peers      []*Port_PeerPort        `protobuf:"bytes,8,rep,name=peers,proto3" json:"peers,omitempty"`
	RxPackets  uint64                  `protobuf:"fixed64,9,opt,name=rx_packets,json=rxPackets,proto3" json:"rx_packets,omitempty"`
	RxBytes    uint64                  `protobuf:"fixed64,10,opt,name=rx_bytes,json=rxBytes,proto3" json:"rx_bytes,omitempty"`
	RxErrors   uint64                  `protobuf:"fixed64,11,opt,name=rx_errors,json=rxErrors,proto3" json:"rx_errors,omitempty"`
	TxPackets  uint64                  `protobuf:"fixed64,12,opt,name=tx_packets,json=txPackets,proto3" json:"tx_packets,omitempty"`
	TxBytes    uint64                  `protobuf:"fixed64,13,opt,name=tx_bytes,json=txBytes,proto3" json:"tx_bytes,omitempty"`
	TxErrors   uint64                  `protobuf:"fixed64,14,opt,name=tx_errors,json=txErrors,proto3" json:"tx_errors,omitempty"`
	// ofp_port represents the characteristics of a port, e.g. hardware
	// address and supported features.  This field is relevant only for
	// UNI and NNI ports.   For PON ports, it can be left empty.
	OfpPort              *openflow_13.OfpPort `protobuf:"bytes,15,opt,name=ofp_port,json=ofpPort,proto3" json:"ofp_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Port) Descriptor 

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

func (*Port) GetAdminState 

func (m *Port) GetAdminState() common.AdminState_Types

func (*Port) GetDeviceId 

func (m *Port) GetDeviceId() string

func (*Port) GetLabel 

func (m *Port) GetLabel() string

func (*Port) GetOfpPort 

func (m *Port) GetOfpPort() *openflow_13.OfpPort

func (*Port) GetOperStatus 

func (m *Port) GetOperStatus() common.OperStatus_Types

func (*Port) GetPeers 

func (m *Port) GetPeers() []*Port_PeerPort

func (*Port) GetPortNo 

func (m *Port) GetPortNo() uint32

func (*Port) GetRxBytes 

func (m *Port) GetRxBytes() uint64

func (*Port) GetRxErrors 

func (m *Port) GetRxErrors() uint64

func (*Port) GetRxPackets 

func (m *Port) GetRxPackets() uint64

func (*Port) GetTxBytes 

func (m *Port) GetTxBytes() uint64

func (*Port) GetTxErrors 

func (m *Port) GetTxErrors() uint64

func (*Port) GetTxPackets 

func (m *Port) GetTxPackets() uint64

func (*Port) GetType 

func (m *Port) GetType() Port_PortType

func (*Port) ProtoMessage 

func (*Port) ProtoMessage()

func (*Port) Reset 

func (m *Port) Reset()

func (*Port) String 

func (m *Port) String() string

func (*Port) XXX_DiscardUnknown 

func (m *Port) XXX_DiscardUnknown()

func (*Port) XXX_Marshal 

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

func (*Port) XXX_Merge 

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

func (*Port) XXX_Size 

func (m *Port) XXX_Size() int

func (*Port) XXX_Unmarshal 

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

type Port_PeerPort 

type Port_PeerPort struct {
	DeviceId             string   `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	PortNo               uint32   `protobuf:"varint,2,opt,name=port_no,json=portNo,proto3" json:"port_no,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Port_PeerPort) Descriptor 

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

func (*Port_PeerPort) GetDeviceId 

func (m *Port_PeerPort) GetDeviceId() string

func (*Port_PeerPort) GetPortNo 

func (m *Port_PeerPort) GetPortNo() uint32

func (*Port_PeerPort) ProtoMessage 

func (*Port_PeerPort) ProtoMessage()

func (*Port_PeerPort) Reset 

func (m *Port_PeerPort) Reset()

func (*Port_PeerPort) String 

func (m *Port_PeerPort) String() string

func (*Port_PeerPort) XXX_DiscardUnknown 

func (m *Port_PeerPort) XXX_DiscardUnknown()

func (*Port_PeerPort) XXX_Marshal 

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

func (*Port_PeerPort) XXX_Merge 

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

func (*Port_PeerPort) XXX_Size 

func (m *Port_PeerPort) XXX_Size() int

func (*Port_PeerPort) XXX_Unmarshal 

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

type Port_PortType 

type Port_PortType int32
const (
	Port_UNKNOWN      Port_PortType = 0
	Port_ETHERNET_NNI Port_PortType = 1
	Port_ETHERNET_UNI Port_PortType = 2
	Port_PON_OLT      Port_PortType = 3
	Port_PON_ONU      Port_PortType = 4
	Port_VENET_OLT    Port_PortType = 5
	Port_VENET_ONU    Port_PortType = 6
)

func (Port_PortType) EnumDescriptor 

func (Port_PortType) EnumDescriptor() ([]byte, []int)

func (Port_PortType) String 

func (x Port_PortType) String() string

type Ports 

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

func (*Ports) Descriptor 

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

func (*Ports) GetItems 

func (m *Ports) GetItems() []*Port

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 RPCEvent 

type RPCEvent struct {
	// RPC name
	Rpc string `protobuf:"bytes,1,opt,name=rpc,proto3" json:"rpc,omitempty"`
	// The operation id of that request.  Can be a log correlation ID
	OperationId string `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// Identifies the service name originating the event
	Service string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	// Identifies the stack originating the event
	StackId string `protobuf:"bytes,4,opt,name=stack_id,json=stackId,proto3" json:"stack_id,omitempty"`
	// Identifies the resource upon which the action is taken, e.g. device_id
	ResourceId string `protobuf:"bytes,5,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// Textual explanation of the event
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// Key/Value storage for extra information that may give context to the event
	Context map[string]string `` /* 155-byte string literal not displayed */
	// Status of the RPC Event
	Status               *common.OperationResp `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Describes the events specific to an RPC request

func (*RPCEvent) Descriptor 

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

func (*RPCEvent) GetContext 

func (m *RPCEvent) GetContext() map[string]string

func (*RPCEvent) GetDescription 

func (m *RPCEvent) GetDescription() string

func (*RPCEvent) GetOperationId 

func (m *RPCEvent) GetOperationId() string

func (*RPCEvent) GetResourceId 

func (m *RPCEvent) GetResourceId() string

func (*RPCEvent) GetRpc 

func (m *RPCEvent) GetRpc() string

func (*RPCEvent) GetService 

func (m *RPCEvent) GetService() string

func (*RPCEvent) GetStackId 

func (m *RPCEvent) GetStackId() string

func (*RPCEvent) GetStatus 

func (m *RPCEvent) GetStatus() *common.OperationResp

func (*RPCEvent) ProtoMessage 

func (*RPCEvent) ProtoMessage()

func (*RPCEvent) Reset 

func (m *RPCEvent) Reset()

func (*RPCEvent) String 

func (m *RPCEvent) String() string

func (*RPCEvent) XXX_DiscardUnknown 

func (m *RPCEvent) XXX_DiscardUnknown()

func (*RPCEvent) XXX_Marshal 

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

func (*RPCEvent) XXX_Merge 

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

func (*RPCEvent) XXX_Size 

func (m *RPCEvent) XXX_Size() int

func (*RPCEvent) XXX_Unmarshal 

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

type SelfTestResponse 

type SelfTestResponse struct {
	Result               SelfTestResponse_SelfTestResult `protobuf:"varint,1,opt,name=result,proto3,enum=device.SelfTestResponse_SelfTestResult" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

Device Self Test Response

func (*SelfTestResponse) Descriptor 

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

func (*SelfTestResponse) GetResult 

func (m *SelfTestResponse) GetResult() SelfTestResponse_SelfTestResult

func (*SelfTestResponse) ProtoMessage 

func (*SelfTestResponse) ProtoMessage()

func (*SelfTestResponse) Reset 

func (m *SelfTestResponse) Reset()

func (*SelfTestResponse) String 

func (m *SelfTestResponse) String() string

func (*SelfTestResponse) XXX_DiscardUnknown 

func (m *SelfTestResponse) XXX_DiscardUnknown()

func (*SelfTestResponse) XXX_Marshal 

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

func (*SelfTestResponse) XXX_Merge 

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

func (*SelfTestResponse) XXX_Size 

func (m *SelfTestResponse) XXX_Size() int

func (*SelfTestResponse) XXX_Unmarshal 

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

type SelfTestResponse_SelfTestResult 

type SelfTestResponse_SelfTestResult int32
const (
	SelfTestResponse_SUCCESS       SelfTestResponse_SelfTestResult = 0
	SelfTestResponse_FAILURE       SelfTestResponse_SelfTestResult = 1
	SelfTestResponse_NOT_SUPPORTED SelfTestResponse_SelfTestResult = 2
	SelfTestResponse_UNKNOWN_ERROR SelfTestResponse_SelfTestResult = 3
)

func (SelfTestResponse_SelfTestResult) EnumDescriptor 

func (SelfTestResponse_SelfTestResult) EnumDescriptor() ([]byte, []int)

func (SelfTestResponse_SelfTestResult) String 

func (x SelfTestResponse_SelfTestResult) String() string

type SimulateAlarmRequest 

type SimulateAlarmRequest struct {
	// Device Identifier
	Id                   string                             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Indicator            string                             `protobuf:"bytes,2,opt,name=indicator,proto3" json:"indicator,omitempty"`
	IntfId               string                             `protobuf:"bytes,3,opt,name=intf_id,json=intfId,proto3" json:"intf_id,omitempty"`
	PortTypeName         string                             `protobuf:"bytes,4,opt,name=port_type_name,json=portTypeName,proto3" json:"port_type_name,omitempty"`
	OnuDeviceId          string                             `protobuf:"bytes,5,opt,name=onu_device_id,json=onuDeviceId,proto3" json:"onu_device_id,omitempty"`
	InverseBitErrorRate  int32                              `protobuf:"varint,6,opt,name=inverse_bit_error_rate,json=inverseBitErrorRate,proto3" json:"inverse_bit_error_rate,omitempty"`
	Drift                int32                              `protobuf:"varint,7,opt,name=drift,proto3" json:"drift,omitempty"`
	NewEqd               int32                              `protobuf:"varint,8,opt,name=new_eqd,json=newEqd,proto3" json:"new_eqd,omitempty"`
	OnuSerialNumber      string                             `protobuf:"bytes,9,opt,name=onu_serial_number,json=onuSerialNumber,proto3" json:"onu_serial_number,omitempty"`
	Operation            SimulateAlarmRequest_OperationType `protobuf:"varint,10,opt,name=operation,proto3,enum=device.SimulateAlarmRequest_OperationType" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*SimulateAlarmRequest) Descriptor 

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

func (*SimulateAlarmRequest) GetDrift 

func (m *SimulateAlarmRequest) GetDrift() int32

func (*SimulateAlarmRequest) GetId 

func (m *SimulateAlarmRequest) GetId() string

func (*SimulateAlarmRequest) GetIndicator 

func (m *SimulateAlarmRequest) GetIndicator() string

func (*SimulateAlarmRequest) GetIntfId 

func (m *SimulateAlarmRequest) GetIntfId() string

func (*SimulateAlarmRequest) GetInverseBitErrorRate 

func (m *SimulateAlarmRequest) GetInverseBitErrorRate() int32

func (*SimulateAlarmRequest) GetNewEqd 

func (m *SimulateAlarmRequest) GetNewEqd() int32

func (*SimulateAlarmRequest) GetOnuDeviceId 

func (m *SimulateAlarmRequest) GetOnuDeviceId() string

func (*SimulateAlarmRequest) GetOnuSerialNumber 

func (m *SimulateAlarmRequest) GetOnuSerialNumber() string

func (*SimulateAlarmRequest) GetOperation 

func (m *SimulateAlarmRequest) GetOperation() SimulateAlarmRequest_OperationType

func (*SimulateAlarmRequest) GetPortTypeName 

func (m *SimulateAlarmRequest) GetPortTypeName() string

func (*SimulateAlarmRequest) ProtoMessage 

func (*SimulateAlarmRequest) ProtoMessage()

func (*SimulateAlarmRequest) Reset 

func (m *SimulateAlarmRequest) Reset()

func (*SimulateAlarmRequest) String 

func (m *SimulateAlarmRequest) String() string

func (*SimulateAlarmRequest) XXX_DiscardUnknown 

func (m *SimulateAlarmRequest) XXX_DiscardUnknown()

func (*SimulateAlarmRequest) XXX_Marshal 

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

func (*SimulateAlarmRequest) XXX_Merge 

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

func (*SimulateAlarmRequest) XXX_Size 

func (m *SimulateAlarmRequest) XXX_Size() int

func (*SimulateAlarmRequest) XXX_Unmarshal 

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

type SimulateAlarmRequest_OperationType 

type SimulateAlarmRequest_OperationType int32
const (
	SimulateAlarmRequest_RAISE SimulateAlarmRequest_OperationType = 0
	SimulateAlarmRequest_CLEAR SimulateAlarmRequest_OperationType = 1
)

func (SimulateAlarmRequest_OperationType) EnumDescriptor 

func (SimulateAlarmRequest_OperationType) EnumDescriptor() ([]byte, []int)

func (SimulateAlarmRequest_OperationType) String 

func (x SimulateAlarmRequest_OperationType) String() string

type TestModeKeys 

type TestModeKeys = common.TestModeKeys

TestModeKeys from public import voltha_protos/common.proto

type UnimplementedVolthaServiceServer 

type UnimplementedVolthaServiceServer struct {
}

UnimplementedVolthaServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedVolthaServiceServer) AbortImageUpgradeToDevice 

func (*UnimplementedVolthaServiceServer) AbortImageUpgradeToDevice(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error)

func (*UnimplementedVolthaServiceServer) ActivateImage 

func (*UnimplementedVolthaServiceServer) ActivateImage(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error)

func (*UnimplementedVolthaServiceServer) ActivateImageUpdate 

func (*UnimplementedVolthaServiceServer) ActivateImageUpdate(ctx context.Context, req *ImageDownload) (*common.OperationResp, error)

func (*UnimplementedVolthaServiceServer) CancelImageDownload 

func (*UnimplementedVolthaServiceServer) CancelImageDownload(ctx context.Context, req *ImageDownload) (*common.OperationResp, error)

func (*UnimplementedVolthaServiceServer) CommitImage 

func (*UnimplementedVolthaServiceServer) CommitImage(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error)

func (*UnimplementedVolthaServiceServer) CreateDevice 

func (*UnimplementedVolthaServiceServer) CreateDevice(ctx context.Context, req *Device) (*Device, error)

func (*UnimplementedVolthaServiceServer) CreateEventFilter 

func (*UnimplementedVolthaServiceServer) CreateEventFilter(ctx context.Context, req *EventFilter) (*EventFilter, error)

func (*UnimplementedVolthaServiceServer) DeleteDevice 

func (*UnimplementedVolthaServiceServer) DeleteDevice(ctx context.Context, req *common.ID) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) DeleteEventFilter 

func (*UnimplementedVolthaServiceServer) DeleteEventFilter(ctx context.Context, req *EventFilter) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) DeleteVoipSystemProfile 

func (*UnimplementedVolthaServiceServer) DeleteVoipSystemProfile(ctx context.Context, req *common.Key) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) DeleteVoipUserProfile 

func (*UnimplementedVolthaServiceServer) DeleteVoipUserProfile(ctx context.Context, req *common.Key) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) DisableDevice 

func (*UnimplementedVolthaServiceServer) DisableDevice(ctx context.Context, req *common.ID) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) DisableLogicalDevicePort 

func (*UnimplementedVolthaServiceServer) DisableLogicalDevicePort(ctx context.Context, req *LogicalPortId) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) DisablePort 

func (*UnimplementedVolthaServiceServer) DisablePort(ctx context.Context, req *Port) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) DownloadImage 

func (*UnimplementedVolthaServiceServer) DownloadImage(ctx context.Context, req *ImageDownload) (*common.OperationResp, error)

func (*UnimplementedVolthaServiceServer) DownloadImageToDevice 

func (*UnimplementedVolthaServiceServer) DownloadImageToDevice(ctx context.Context, req *DeviceImageDownloadRequest) (*DeviceImageResponse, error)

func (*UnimplementedVolthaServiceServer) EnableDevice 

func (*UnimplementedVolthaServiceServer) EnableDevice(ctx context.Context, req *common.ID) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) EnableLogicalDevicePort 

func (*UnimplementedVolthaServiceServer) EnableLogicalDevicePort(ctx context.Context, req *LogicalPortId) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) EnablePort 

func (*UnimplementedVolthaServiceServer) EnablePort(ctx context.Context, req *Port) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) ForceDeleteDevice 

func (*UnimplementedVolthaServiceServer) ForceDeleteDevice(ctx context.Context, req *common.ID) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) GetAlarmDeviceData 

func (*UnimplementedVolthaServiceServer) GetAlarmDeviceData(ctx context.Context, req *common.ID) (*omci.AlarmDeviceData, error)

func (*UnimplementedVolthaServiceServer) GetCoreInstance 

func (*UnimplementedVolthaServiceServer) GetCoreInstance(ctx context.Context, req *common.ID) (*CoreInstance, error)

func (*UnimplementedVolthaServiceServer) GetDevice 

func (*UnimplementedVolthaServiceServer) GetDevice(ctx context.Context, req *common.ID) (*Device, error)

func (*UnimplementedVolthaServiceServer) GetDeviceType 

func (*UnimplementedVolthaServiceServer) GetDeviceType(ctx context.Context, req *common.ID) (*DeviceType, error)

func (*UnimplementedVolthaServiceServer) GetEventFilter 

func (*UnimplementedVolthaServiceServer) GetEventFilter(ctx context.Context, req *common.ID) (*EventFilters, error)

func (*UnimplementedVolthaServiceServer) GetExtValue 

func (*UnimplementedVolthaServiceServer) GetExtValue(ctx context.Context, req *extension.ValueSpecifier) (*extension.ReturnValues, error)

func (*UnimplementedVolthaServiceServer) GetImageDownload 

func (*UnimplementedVolthaServiceServer) GetImageDownload(ctx context.Context, req *ImageDownload) (*ImageDownload, error)

func (*UnimplementedVolthaServiceServer) GetImageDownloadStatus 

func (*UnimplementedVolthaServiceServer) GetImageDownloadStatus(ctx context.Context, req *ImageDownload) (*ImageDownload, error)

func (*UnimplementedVolthaServiceServer) GetImageStatus 

func (*UnimplementedVolthaServiceServer) GetImageStatus(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error)

func (*UnimplementedVolthaServiceServer) GetImages 

func (*UnimplementedVolthaServiceServer) GetImages(ctx context.Context, req *common.ID) (*Images, error)

func (*UnimplementedVolthaServiceServer) GetLogicalDevice 

func (*UnimplementedVolthaServiceServer) GetLogicalDevice(ctx context.Context, req *common.ID) (*LogicalDevice, error)

func (*UnimplementedVolthaServiceServer) GetLogicalDevicePort 

func (*UnimplementedVolthaServiceServer) GetLogicalDevicePort(ctx context.Context, req *LogicalPortId) (*LogicalPort, error)

func (*UnimplementedVolthaServiceServer) GetMibDeviceData 

func (*UnimplementedVolthaServiceServer) GetMibDeviceData(ctx context.Context, req *common.ID) (*omci.MibDeviceData, error)

func (*UnimplementedVolthaServiceServer) GetOnuImages 

func (*UnimplementedVolthaServiceServer) GetOnuImages(ctx context.Context, req *common.ID) (*OnuImages, error)

func (*UnimplementedVolthaServiceServer) GetVoltha 

func (*UnimplementedVolthaServiceServer) GetVoltha(ctx context.Context, req *empty.Empty) (*Voltha, error)

func (*UnimplementedVolthaServiceServer) ListAdapters 

func (*UnimplementedVolthaServiceServer) ListAdapters(ctx context.Context, req *empty.Empty) (*Adapters, error)

func (*UnimplementedVolthaServiceServer) ListCoreInstances 

func (*UnimplementedVolthaServiceServer) ListCoreInstances(ctx context.Context, req *empty.Empty) (*CoreInstances, error)

func (*UnimplementedVolthaServiceServer) ListDeviceFlowGroups 

func (*UnimplementedVolthaServiceServer) ListDeviceFlowGroups(ctx context.Context, req *common.ID) (*openflow_13.FlowGroups, error)

func (*UnimplementedVolthaServiceServer) ListDeviceFlows 

func (*UnimplementedVolthaServiceServer) ListDeviceFlows(ctx context.Context, req *common.ID) (*openflow_13.Flows, error)

func (*UnimplementedVolthaServiceServer) ListDeviceIds 

func (*UnimplementedVolthaServiceServer) ListDeviceIds(ctx context.Context, req *empty.Empty) (*common.IDs, error)

func (*UnimplementedVolthaServiceServer) ListDevicePmConfigs 

func (*UnimplementedVolthaServiceServer) ListDevicePmConfigs(ctx context.Context, req *common.ID) (*PmConfigs, error)

func (*UnimplementedVolthaServiceServer) ListDevicePorts 

func (*UnimplementedVolthaServiceServer) ListDevicePorts(ctx context.Context, req *common.ID) (*Ports, error)

func (*UnimplementedVolthaServiceServer) ListDeviceTypes 

func (*UnimplementedVolthaServiceServer) ListDeviceTypes(ctx context.Context, req *empty.Empty) (*DeviceTypes, error)

func (*UnimplementedVolthaServiceServer) ListDevices 

func (*UnimplementedVolthaServiceServer) ListDevices(ctx context.Context, req *empty.Empty) (*Devices, error)

func (*UnimplementedVolthaServiceServer) ListEventFilters 

func (*UnimplementedVolthaServiceServer) ListEventFilters(ctx context.Context, req *empty.Empty) (*EventFilters, error)

func (*UnimplementedVolthaServiceServer) ListImageDownloads 

func (*UnimplementedVolthaServiceServer) ListImageDownloads(ctx context.Context, req *common.ID) (*ImageDownloads, error)

func (*UnimplementedVolthaServiceServer) ListLogicalDeviceFlowGroups 

func (*UnimplementedVolthaServiceServer) ListLogicalDeviceFlowGroups(ctx context.Context, req *common.ID) (*openflow_13.FlowGroups, error)

func (*UnimplementedVolthaServiceServer) ListLogicalDeviceFlows 

func (*UnimplementedVolthaServiceServer) ListLogicalDeviceFlows(ctx context.Context, req *common.ID) (*openflow_13.Flows, error)

func (*UnimplementedVolthaServiceServer) ListLogicalDeviceMeters 

func (*UnimplementedVolthaServiceServer) ListLogicalDeviceMeters(ctx context.Context, req *common.ID) (*openflow_13.Meters, error)

func (*UnimplementedVolthaServiceServer) ListLogicalDevicePorts 

func (*UnimplementedVolthaServiceServer) ListLogicalDevicePorts(ctx context.Context, req *common.ID) (*LogicalPorts, error)

func (*UnimplementedVolthaServiceServer) ListLogicalDevices 

func (*UnimplementedVolthaServiceServer) ListLogicalDevices(ctx context.Context, req *empty.Empty) (*LogicalDevices, error)

func (*UnimplementedVolthaServiceServer) PutVoipSystemProfile 

func (*UnimplementedVolthaServiceServer) PutVoipSystemProfile(ctx context.Context, req *voip_system_profile.VoipSystemProfileRequest) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) PutVoipUserProfile 

func (*UnimplementedVolthaServiceServer) PutVoipUserProfile(ctx context.Context, req *voip_user_profile.VoipUserProfileRequest) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) RebootDevice 

func (*UnimplementedVolthaServiceServer) RebootDevice(ctx context.Context, req *common.ID) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) ReceiveChangeEvents 

func (*UnimplementedVolthaServiceServer) ReceiveChangeEvents(req *empty.Empty, srv VolthaService_ReceiveChangeEventsServer) error

func (*UnimplementedVolthaServiceServer) ReceivePacketsIn 

func (*UnimplementedVolthaServiceServer) ReceivePacketsIn(req *empty.Empty, srv VolthaService_ReceivePacketsInServer) error

func (*UnimplementedVolthaServiceServer) ReconcileDevices 

func (*UnimplementedVolthaServiceServer) ReconcileDevices(ctx context.Context, req *common.IDs) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) RevertImageUpdate 

func (*UnimplementedVolthaServiceServer) RevertImageUpdate(ctx context.Context, req *ImageDownload) (*common.OperationResp, error)

func (*UnimplementedVolthaServiceServer) SelfTest 

func (*UnimplementedVolthaServiceServer) SelfTest(ctx context.Context, req *common.ID) (*SelfTestResponse, error)

func (*UnimplementedVolthaServiceServer) SetExtValue 

func (*UnimplementedVolthaServiceServer) SetExtValue(ctx context.Context, req *extension.ValueSet) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) SimulateAlarm 

func (*UnimplementedVolthaServiceServer) SimulateAlarm(ctx context.Context, req *SimulateAlarmRequest) (*common.OperationResp, error)

func (*UnimplementedVolthaServiceServer) StartOmciTestAction 

func (*UnimplementedVolthaServiceServer) StartOmciTestAction(ctx context.Context, req *omci.OmciTestRequest) (*omci.TestResponse, error)

func (*UnimplementedVolthaServiceServer) StreamPacketsOut 

func (*UnimplementedVolthaServiceServer) StreamPacketsOut(srv VolthaService_StreamPacketsOutServer) error

func (*UnimplementedVolthaServiceServer) UpdateDevicePmConfigs 

func (*UnimplementedVolthaServiceServer) UpdateDevicePmConfigs(ctx context.Context, req *PmConfigs) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) UpdateEventFilter 

func (*UnimplementedVolthaServiceServer) UpdateEventFilter(ctx context.Context, req *EventFilter) (*EventFilter, error)

func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceFlowGroupTable 

func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceFlowGroupTable(ctx context.Context, req *openflow_13.FlowGroupTableUpdate) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceFlowTable 

func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceFlowTable(ctx context.Context, req *openflow_13.FlowTableUpdate) (*empty.Empty, error)

func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceMeterTable 

func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceMeterTable(ctx context.Context, req *openflow_13.MeterModUpdate) (*empty.Empty, error)

type Voltha 

type Voltha struct {
	Version              string                  `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Adapters             []*Adapter              `protobuf:"bytes,2,rep,name=adapters,proto3" json:"adapters,omitempty"`
	LogicalDevices       []*LogicalDevice        `protobuf:"bytes,3,rep,name=logical_devices,json=logicalDevices,proto3" json:"logical_devices,omitempty"`
	Devices              []*Device               `protobuf:"bytes,4,rep,name=devices,proto3" json:"devices,omitempty"`
	DeviceTypes          []*DeviceType           `protobuf:"bytes,5,rep,name=device_types,json=deviceTypes,proto3" json:"device_types,omitempty"`
	EventFilters         []*EventFilter          `protobuf:"bytes,7,rep,name=event_filters,json=eventFilters,proto3" json:"event_filters,omitempty"`
	OmciMibDatabase      []*omci.MibDeviceData   `protobuf:"bytes,28,rep,name=omci_mib_database,json=omciMibDatabase,proto3" json:"omci_mib_database,omitempty"`
	OmciAlarmDatabase    []*omci.AlarmDeviceData `protobuf:"bytes,29,rep,name=omci_alarm_database,json=omciAlarmDatabase,proto3" json:"omci_alarm_database,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Voltha represents the Voltha cluster data. Each Core instance will hold a subset of the entire cluster. However, some items (e.g. adapters) will be held by all cores for better performance

func (*Voltha) Descriptor 

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

func (*Voltha) GetAdapters 

func (m *Voltha) GetAdapters() []*Adapter

func (*Voltha) GetDeviceTypes 

func (m *Voltha) GetDeviceTypes() []*DeviceType

func (*Voltha) GetDevices 

func (m *Voltha) GetDevices() []*Device

func (*Voltha) GetEventFilters 

func (m *Voltha) GetEventFilters() []*EventFilter

func (*Voltha) GetLogicalDevices 

func (m *Voltha) GetLogicalDevices() []*LogicalDevice

func (*Voltha) GetOmciAlarmDatabase 

func (m *Voltha) GetOmciAlarmDatabase() []*omci.AlarmDeviceData

func (*Voltha) GetOmciMibDatabase 

func (m *Voltha) GetOmciMibDatabase() []*omci.MibDeviceData

func (*Voltha) GetVersion 

func (m *Voltha) GetVersion() string

func (*Voltha) ProtoMessage 

func (*Voltha) ProtoMessage()

func (*Voltha) Reset 

func (m *Voltha) Reset()

func (*Voltha) String 

func (m *Voltha) String() string

func (*Voltha) XXX_DiscardUnknown 

func (m *Voltha) XXX_DiscardUnknown()

func (*Voltha) XXX_Marshal 

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

func (*Voltha) XXX_Merge 

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

func (*Voltha) XXX_Size 

func (m *Voltha) XXX_Size() int

func (*Voltha) XXX_Unmarshal 

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

type VolthaServiceClient 

type VolthaServiceClient interface {
	// Get high level information on the Voltha cluster
	GetVoltha(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Voltha, error)
	// List all Voltha cluster core instances
	ListCoreInstances(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*CoreInstances, error)
	// Get details on a Voltha cluster instance
	GetCoreInstance(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*CoreInstance, error)
	// List all active adapters (plugins) in the Voltha cluster
	ListAdapters(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Adapters, error)
	// List all logical devices managed by the Voltha cluster
	ListLogicalDevices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*LogicalDevices, error)
	// Get additional information on a given logical device
	GetLogicalDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*LogicalDevice, error)
	// List ports of a logical device
	ListLogicalDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*LogicalPorts, error)
	// Gets a logical device port
	GetLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*LogicalPort, error)
	// Enables a logical device port
	EnableLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*empty.Empty, error)
	// Disables a logical device port
	DisableLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*empty.Empty, error)
	// List all flows of a logical device
	ListLogicalDeviceFlows(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Flows, error)
	// Update flow table for logical device
	UpdateLogicalDeviceFlowTable(ctx context.Context, in *openflow_13.FlowTableUpdate, opts ...grpc.CallOption) (*empty.Empty, error)
	// Update meter table for logical device
	UpdateLogicalDeviceMeterTable(ctx context.Context, in *openflow_13.MeterModUpdate, opts ...grpc.CallOption) (*empty.Empty, error)
	// List all meters of a logical device
	ListLogicalDeviceMeters(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Meters, error)
	// List all flow groups of a logical device
	ListLogicalDeviceFlowGroups(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.FlowGroups, error)
	// Update group table for device
	UpdateLogicalDeviceFlowGroupTable(ctx context.Context, in *openflow_13.FlowGroupTableUpdate, opts ...grpc.CallOption) (*empty.Empty, error)
	// List all physical devices controlled by the Voltha cluster
	ListDevices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Devices, error)
	// List all physical devices IDs controlled by the Voltha cluster
	ListDeviceIds(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*common.IDs, error)
	// Request to a voltha Core to reconcile a set of devices based on their IDs
	ReconcileDevices(ctx context.Context, in *common.IDs, opts ...grpc.CallOption) (*empty.Empty, error)
	// Get more information on a given physical device
	GetDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Device, error)
	// Pre-provision a new physical device
	CreateDevice(ctx context.Context, in *Device, opts ...grpc.CallOption) (*Device, error)
	// Enable a device.  If the device was in pre-provisioned state then it
	// will transition to ENABLED state.  If it was is DISABLED state then it
	// will transition to ENABLED state as well.
	EnableDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
	// Disable a device
	DisableDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
	// Reboot a device
	RebootDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
	// Delete a device
	DeleteDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
	// Forcefully delete a device
	ForceDeleteDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
	// Request an image download to the standby partition
	// of a device.
	// Note that the call is expected to be non-blocking.
	DownloadImage(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
	// Get image download status on a device
	// The request retrieves progress on device and updates db record
	// Deprecated in voltha 2.8, will be removed
	GetImageDownloadStatus(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*ImageDownload, error)
	// Get image download db record
	// Deprecated in voltha 2.8, will be removed
	GetImageDownload(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*ImageDownload, error)
	// List image download db records for a given device
	// Deprecated in voltha 2.8, will be removed
	ListImageDownloads(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*ImageDownloads, error)
	// Cancel an existing image download process on a device
	// Deprecated in voltha 2.8, will be removed
	CancelImageDownload(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
	// Activate the specified image at a standby partition
	// to active partition.
	// Depending on the device implementation, this call
	// may or may not cause device reboot.
	// If no reboot, then a reboot is required to make the
	// activated image running on device
	// Note that the call is expected to be non-blocking.
	// Deprecated in voltha 2.8, will be removed
	ActivateImageUpdate(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
	// Revert the specified image at standby partition
	// to active partition, and revert to previous image
	// Depending on the device implementation, this call
	// may or may not cause device reboot.
	// If no reboot, then a reboot is required to make the
	// previous image running on device
	// Note that the call is expected to be non-blocking.
	// Deprecated in voltha 2.8, will be removed
	RevertImageUpdate(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
	// Downloads a certain image to the standby partition of the devices
	// Note that the call is expected to be non-blocking.
	DownloadImageToDevice(ctx context.Context, in *DeviceImageDownloadRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
	// Get image status on a number of devices devices
	// Polled from northbound systems to get state of download/activate/commit
	GetImageStatus(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
	// Aborts the upgrade of an image on a device
	// To be used carefully, stops any further operations for the Image on the given devices
	// Might also stop if possible existing work, but no guarantees are given,
	// depends on implementation and procedure status.
	AbortImageUpgradeToDevice(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
	// Get Both Active and Standby image for a given device
	GetOnuImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*OnuImages, error)
	// Activate the specified image from a standby partition
	// to active partition.
	// Depending on the device implementation, this call
	// may or may not cause device reboot.
	// If no reboot, then a reboot is required to make the
	// activated image running on device
	// Note that the call is expected to be non-blocking.
	ActivateImage(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
	// Commit the specified image to be default.
	// Depending on the device implementation, this call
	// may or may not cause device reboot.
	// If no reboot, then a reboot is required to make the
	// activated image running on device upon next reboot
	// Note that the call is expected to be non-blocking.
	CommitImage(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
	// List ports of a device
	ListDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Ports, error)
	// List pm config of a device
	ListDevicePmConfigs(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*PmConfigs, error)
	// Update the pm config of a device
	UpdateDevicePmConfigs(ctx context.Context, in *PmConfigs, opts ...grpc.CallOption) (*empty.Empty, error)
	// List all flows of a device
	ListDeviceFlows(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Flows, error)
	// List all flow groups of a device
	ListDeviceFlowGroups(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.FlowGroups, error)
	// List device types known to Voltha
	ListDeviceTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DeviceTypes, error)
	// Get additional information on a device type
	GetDeviceType(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*DeviceType, error)
	// Stream control packets to the dataplane
	StreamPacketsOut(ctx context.Context, opts ...grpc.CallOption) (VolthaService_StreamPacketsOutClient, error)
	// Receive control packet stream
	ReceivePacketsIn(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (VolthaService_ReceivePacketsInClient, error)
	ReceiveChangeEvents(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (VolthaService_ReceiveChangeEventsClient, error)
	CreateEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*EventFilter, error)
	// Get all filters present for a device
	GetEventFilter(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*EventFilters, error)
	UpdateEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*EventFilter, error)
	DeleteEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*empty.Empty, error)
	// Get all the filters present
	ListEventFilters(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*EventFilters, error)
	GetImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Images, error)
	SelfTest(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*SelfTestResponse, error)
	// OpenOMCI MIB information
	GetMibDeviceData(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*omci.MibDeviceData, error)
	// OpenOMCI ALARM information
	GetAlarmDeviceData(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*omci.AlarmDeviceData, error)
	// Simulate an Alarm
	SimulateAlarm(ctx context.Context, in *SimulateAlarmRequest, opts ...grpc.CallOption) (*common.OperationResp, error)
	EnablePort(ctx context.Context, in *Port, opts ...grpc.CallOption) (*empty.Empty, error)
	DisablePort(ctx context.Context, in *Port, opts ...grpc.CallOption) (*empty.Empty, error)
	GetExtValue(ctx context.Context, in *extension.ValueSpecifier, opts ...grpc.CallOption) (*extension.ReturnValues, error)
	SetExtValue(ctx context.Context, in *extension.ValueSet, opts ...grpc.CallOption) (*empty.Empty, error)
	// omci start and stop cli implementation
	StartOmciTestAction(ctx context.Context, in *omci.OmciTestRequest, opts ...grpc.CallOption) (*omci.TestResponse, error)
	// Saves or updates system wide configuration into voltha KV
	PutVoipSystemProfile(ctx context.Context, in *voip_system_profile.VoipSystemProfileRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Deletes the given profile from voltha KV
	DeleteVoipSystemProfile(ctx context.Context, in *common.Key, opts ...grpc.CallOption) (*empty.Empty, error)
	// Saves or updates a profile (VOIP) into voltha KV
	PutVoipUserProfile(ctx context.Context, in *voip_user_profile.VoipUserProfileRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Deletes the given profile from voltha KV
	DeleteVoipUserProfile(ctx context.Context, in *common.Key, opts ...grpc.CallOption) (*empty.Empty, error)
}

VolthaServiceClient is the client API for VolthaService service.

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

func NewVolthaServiceClient 

func NewVolthaServiceClient(cc *grpc.ClientConn) VolthaServiceClient

type VolthaServiceServer 

type VolthaServiceServer interface {
	// Get high level information on the Voltha cluster
	GetVoltha(context.Context, *empty.Empty) (*Voltha, error)
	// List all Voltha cluster core instances
	ListCoreInstances(context.Context, *empty.Empty) (*CoreInstances, error)
	// Get details on a Voltha cluster instance
	GetCoreInstance(context.Context, *common.ID) (*CoreInstance, error)
	// List all active adapters (plugins) in the Voltha cluster
	ListAdapters(context.Context, *empty.Empty) (*Adapters, error)
	// List all logical devices managed by the Voltha cluster
	ListLogicalDevices(context.Context, *empty.Empty) (*LogicalDevices, error)
	// Get additional information on a given logical device
	GetLogicalDevice(context.Context, *common.ID) (*LogicalDevice, error)
	// List ports of a logical device
	ListLogicalDevicePorts(context.Context, *common.ID) (*LogicalPorts, error)
	// Gets a logical device port
	GetLogicalDevicePort(context.Context, *LogicalPortId) (*LogicalPort, error)
	// Enables a logical device port
	EnableLogicalDevicePort(context.Context, *LogicalPortId) (*empty.Empty, error)
	// Disables a logical device port
	DisableLogicalDevicePort(context.Context, *LogicalPortId) (*empty.Empty, error)
	// List all flows of a logical device
	ListLogicalDeviceFlows(context.Context, *common.ID) (*openflow_13.Flows, error)
	// Update flow table for logical device
	UpdateLogicalDeviceFlowTable(context.Context, *openflow_13.FlowTableUpdate) (*empty.Empty, error)
	// Update meter table for logical device
	UpdateLogicalDeviceMeterTable(context.Context, *openflow_13.MeterModUpdate) (*empty.Empty, error)
	// List all meters of a logical device
	ListLogicalDeviceMeters(context.Context, *common.ID) (*openflow_13.Meters, error)
	// List all flow groups of a logical device
	ListLogicalDeviceFlowGroups(context.Context, *common.ID) (*openflow_13.FlowGroups, error)
	// Update group table for device
	UpdateLogicalDeviceFlowGroupTable(context.Context, *openflow_13.FlowGroupTableUpdate) (*empty.Empty, error)
	// List all physical devices controlled by the Voltha cluster
	ListDevices(context.Context, *empty.Empty) (*Devices, error)
	// List all physical devices IDs controlled by the Voltha cluster
	ListDeviceIds(context.Context, *empty.Empty) (*common.IDs, error)
	// Request to a voltha Core to reconcile a set of devices based on their IDs
	ReconcileDevices(context.Context, *common.IDs) (*empty.Empty, error)
	// Get more information on a given physical device
	GetDevice(context.Context, *common.ID) (*Device, error)
	// Pre-provision a new physical device
	CreateDevice(context.Context, *Device) (*Device, error)
	// Enable a device.  If the device was in pre-provisioned state then it
	// will transition to ENABLED state.  If it was is DISABLED state then it
	// will transition to ENABLED state as well.
	EnableDevice(context.Context, *common.ID) (*empty.Empty, error)
	// Disable a device
	DisableDevice(context.Context, *common.ID) (*empty.Empty, error)
	// Reboot a device
	RebootDevice(context.Context, *common.ID) (*empty.Empty, error)
	// Delete a device
	DeleteDevice(context.Context, *common.ID) (*empty.Empty, error)
	// Forcefully delete a device
	ForceDeleteDevice(context.Context, *common.ID) (*empty.Empty, error)
	// Request an image download to the standby partition
	// of a device.
	// Note that the call is expected to be non-blocking.
	DownloadImage(context.Context, *ImageDownload) (*common.OperationResp, error)
	// Get image download status on a device
	// The request retrieves progress on device and updates db record
	// Deprecated in voltha 2.8, will be removed
	GetImageDownloadStatus(context.Context, *ImageDownload) (*ImageDownload, error)
	// Get image download db record
	// Deprecated in voltha 2.8, will be removed
	GetImageDownload(context.Context, *ImageDownload) (*ImageDownload, error)
	// List image download db records for a given device
	// Deprecated in voltha 2.8, will be removed
	ListImageDownloads(context.Context, *common.ID) (*ImageDownloads, error)
	// Cancel an existing image download process on a device
	// Deprecated in voltha 2.8, will be removed
	CancelImageDownload(context.Context, *ImageDownload) (*common.OperationResp, error)
	// Activate the specified image at a standby partition
	// to active partition.
	// Depending on the device implementation, this call
	// may or may not cause device reboot.
	// If no reboot, then a reboot is required to make the
	// activated image running on device
	// Note that the call is expected to be non-blocking.
	// Deprecated in voltha 2.8, will be removed
	ActivateImageUpdate(context.Context, *ImageDownload) (*common.OperationResp, error)
	// Revert the specified image at standby partition
	// to active partition, and revert to previous image
	// Depending on the device implementation, this call
	// may or may not cause device reboot.
	// If no reboot, then a reboot is required to make the
	// previous image running on device
	// Note that the call is expected to be non-blocking.
	// Deprecated in voltha 2.8, will be removed
	RevertImageUpdate(context.Context, *ImageDownload) (*common.OperationResp, error)
	// Downloads a certain image to the standby partition of the devices
	// Note that the call is expected to be non-blocking.
	DownloadImageToDevice(context.Context, *DeviceImageDownloadRequest) (*DeviceImageResponse, error)
	// Get image status on a number of devices devices
	// Polled from northbound systems to get state of download/activate/commit
	GetImageStatus(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
	// Aborts the upgrade of an image on a device
	// To be used carefully, stops any further operations for the Image on the given devices
	// Might also stop if possible existing work, but no guarantees are given,
	// depends on implementation and procedure status.
	AbortImageUpgradeToDevice(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
	// Get Both Active and Standby image for a given device
	GetOnuImages(context.Context, *common.ID) (*OnuImages, error)
	// Activate the specified image from a standby partition
	// to active partition.
	// Depending on the device implementation, this call
	// may or may not cause device reboot.
	// If no reboot, then a reboot is required to make the
	// activated image running on device
	// Note that the call is expected to be non-blocking.
	ActivateImage(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
	// Commit the specified image to be default.
	// Depending on the device implementation, this call
	// may or may not cause device reboot.
	// If no reboot, then a reboot is required to make the
	// activated image running on device upon next reboot
	// Note that the call is expected to be non-blocking.
	CommitImage(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
	// List ports of a device
	ListDevicePorts(context.Context, *common.ID) (*Ports, error)
	// List pm config of a device
	ListDevicePmConfigs(context.Context, *common.ID) (*PmConfigs, error)
	// Update the pm config of a device
	UpdateDevicePmConfigs(context.Context, *PmConfigs) (*empty.Empty, error)
	// List all flows of a device
	ListDeviceFlows(context.Context, *common.ID) (*openflow_13.Flows, error)
	// List all flow groups of a device
	ListDeviceFlowGroups(context.Context, *common.ID) (*openflow_13.FlowGroups, error)
	// List device types known to Voltha
	ListDeviceTypes(context.Context, *empty.Empty) (*DeviceTypes, error)
	// Get additional information on a device type
	GetDeviceType(context.Context, *common.ID) (*DeviceType, error)
	// Stream control packets to the dataplane
	StreamPacketsOut(VolthaService_StreamPacketsOutServer) error
	// Receive control packet stream
	ReceivePacketsIn(*empty.Empty, VolthaService_ReceivePacketsInServer) error
	ReceiveChangeEvents(*empty.Empty, VolthaService_ReceiveChangeEventsServer) error
	CreateEventFilter(context.Context, *EventFilter) (*EventFilter, error)
	// Get all filters present for a device
	GetEventFilter(context.Context, *common.ID) (*EventFilters, error)
	UpdateEventFilter(context.Context, *EventFilter) (*EventFilter, error)
	DeleteEventFilter(context.Context, *EventFilter) (*empty.Empty, error)
	// Get all the filters present
	ListEventFilters(context.Context, *empty.Empty) (*EventFilters, error)
	GetImages(context.Context, *common.ID) (*Images, error)
	SelfTest(context.Context, *common.ID) (*SelfTestResponse, error)
	// OpenOMCI MIB information
	GetMibDeviceData(context.Context, *common.ID) (*omci.MibDeviceData, error)
	// OpenOMCI ALARM information
	GetAlarmDeviceData(context.Context, *common.ID) (*omci.AlarmDeviceData, error)
	// Simulate an Alarm
	SimulateAlarm(context.Context, *SimulateAlarmRequest) (*common.OperationResp, error)
	EnablePort(context.Context, *Port) (*empty.Empty, error)
	DisablePort(context.Context, *Port) (*empty.Empty, error)
	GetExtValue(context.Context, *extension.ValueSpecifier) (*extension.ReturnValues, error)
	SetExtValue(context.Context, *extension.ValueSet) (*empty.Empty, error)
	// omci start and stop cli implementation
	StartOmciTestAction(context.Context, *omci.OmciTestRequest) (*omci.TestResponse, error)
	// Saves or updates system wide configuration into voltha KV
	PutVoipSystemProfile(context.Context, *voip_system_profile.VoipSystemProfileRequest) (*empty.Empty, error)
	// Deletes the given profile from voltha KV
	DeleteVoipSystemProfile(context.Context, *common.Key) (*empty.Empty, error)
	// Saves or updates a profile (VOIP) into voltha KV
	PutVoipUserProfile(context.Context, *voip_user_profile.VoipUserProfileRequest) (*empty.Empty, error)
	// Deletes the given profile from voltha KV
	DeleteVoipUserProfile(context.Context, *common.Key) (*empty.Empty, error)
}

VolthaServiceServer is the server API for VolthaService service.

type VolthaService_ReceiveChangeEventsClient 

type VolthaService_ReceiveChangeEventsClient interface {
	Recv() (*openflow_13.ChangeEvent, error)
	grpc.ClientStream
}

type VolthaService_ReceiveChangeEventsServer 

type VolthaService_ReceiveChangeEventsServer interface {
	Send(*openflow_13.ChangeEvent) error
	grpc.ServerStream
}

type VolthaService_ReceivePacketsInClient 

type VolthaService_ReceivePacketsInClient interface {
	Recv() (*openflow_13.PacketIn, error)
	grpc.ClientStream
}

type VolthaService_ReceivePacketsInServer 

type VolthaService_ReceivePacketsInServer interface {
	Send(*openflow_13.PacketIn) error
	grpc.ServerStream
}

type VolthaService_StreamPacketsOutClient 

type VolthaService_StreamPacketsOutClient interface {
	Send(*openflow_13.PacketOut) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type VolthaService_StreamPacketsOutServer 

type VolthaService_StreamPacketsOutServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*openflow_13.PacketOut, error)
	grpc.ServerStream
}

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.