nbi

package
v0.0.0-...-4bc4564 Latest Latest
Warning

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

 Go to latest Published: Feb 23, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ImpairmentRequest_ImpairmentType_name = map[int32]string{
	0: "TX_LOS",
	1: "RX_LOS",
	2: "POWER_LOSS",
}
View Source 
var ImpairmentRequest_ImpairmentType_value = map[string]int32{
	"TX_LOS":     0,
	"RX_LOS":     1,
	"POWER_LOSS": 2,
}

Functions

func RegisterNBIServer 

func RegisterNBIServer(s *grpc.Server, srv NBIServer)

Types

type ConfigResponse 

type ConfigResponse struct {
	NumPons              uint32   `protobuf:"varint,1,opt,name=num_pons,json=numPons,proto3" json:"num_pons,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigResponse) Descriptor 

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

func (*ConfigResponse) GetNumPons 

func (m *ConfigResponse) GetNumPons() uint32

func (*ConfigResponse) ProtoMessage 

func (*ConfigResponse) ProtoMessage()

func (*ConfigResponse) Reset 

func (m *ConfigResponse) Reset()

func (*ConfigResponse) String 

func (m *ConfigResponse) String() string

func (*ConfigResponse) XXX_DiscardUnknown 

func (m *ConfigResponse) XXX_DiscardUnknown()

func (*ConfigResponse) XXX_Marshal 

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

func (*ConfigResponse) XXX_Merge 

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

func (*ConfigResponse) XXX_Size 

func (m *ConfigResponse) XXX_Size() int

func (*ConfigResponse) XXX_Unmarshal 

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

type ImpairmentRequest 

type ImpairmentRequest struct {
	PonId                uint32                           `protobuf:"varint,1,opt,name=pon_id,json=ponId,proto3" json:"pon_id,omitempty"`
	OnuId                uint32                           `protobuf:"varint,2,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
	Impairment           ImpairmentRequest_ImpairmentType `protobuf:"varint,3,opt,name=impairment,proto3,enum=nbi.ImpairmentRequest_ImpairmentType" json:"impairment,omitempty"`
	Duration             uint32                           `protobuf:"varint,6,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

TODO: Add other impairments as needed

func (*ImpairmentRequest) Descriptor 

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

func (*ImpairmentRequest) GetDuration 

func (m *ImpairmentRequest) GetDuration() uint32

func (*ImpairmentRequest) GetImpairment 

func (m *ImpairmentRequest) GetImpairment() ImpairmentRequest_ImpairmentType

func (*ImpairmentRequest) GetOnuId 

func (m *ImpairmentRequest) GetOnuId() uint32

func (*ImpairmentRequest) GetPonId 

func (m *ImpairmentRequest) GetPonId() uint32

func (*ImpairmentRequest) ProtoMessage 

func (*ImpairmentRequest) ProtoMessage()

func (*ImpairmentRequest) Reset 

func (m *ImpairmentRequest) Reset()

func (*ImpairmentRequest) String 

func (m *ImpairmentRequest) String() string

func (*ImpairmentRequest) XXX_DiscardUnknown 

func (m *ImpairmentRequest) XXX_DiscardUnknown()

func (*ImpairmentRequest) XXX_Marshal 

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

func (*ImpairmentRequest) XXX_Merge 

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

func (*ImpairmentRequest) XXX_Size 

func (m *ImpairmentRequest) XXX_Size() int

func (*ImpairmentRequest) XXX_Unmarshal 

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

type ImpairmentRequest_ImpairmentType 

type ImpairmentRequest_ImpairmentType int32
const (
	ImpairmentRequest_TX_LOS     ImpairmentRequest_ImpairmentType = 0
	ImpairmentRequest_RX_LOS     ImpairmentRequest_ImpairmentType = 1
	ImpairmentRequest_POWER_LOSS ImpairmentRequest_ImpairmentType = 2
)

func (ImpairmentRequest_ImpairmentType) EnumDescriptor 

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

func (ImpairmentRequest_ImpairmentType) String 

func (x ImpairmentRequest_ImpairmentType) String() string

type NBIClient 

type NBIClient interface {
	GetConfiguration(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ConfigResponse, error)
	GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// Used to send impairment messages to the ONU Mock.
	Impairment(ctx context.Context, in *ImpairmentRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

NBIClient is the client API for NBI service.

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

func NewNBIClient 

func NewNBIClient(cc *grpc.ClientConn) NBIClient

type NBIServer 

type NBIServer interface {
	GetConfiguration(context.Context, *empty.Empty) (*ConfigResponse, error)
	GetStatus(context.Context, *StatusRequest) (*StatusResponse, error)
	// Used to send impairment messages to the ONU Mock.
	Impairment(context.Context, *ImpairmentRequest) (*empty.Empty, error)
}

NBIServer is the server API for NBI service.

type OnuStatus 

type OnuStatus struct {
	OnuId                uint32   `protobuf:"varint,1,opt,name=onu_id,json=onuId,proto3" json:"onu_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OnuStatus) Descriptor 

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

func (*OnuStatus) GetOnuId 

func (m *OnuStatus) GetOnuId() uint32

func (*OnuStatus) ProtoMessage 

func (*OnuStatus) ProtoMessage()

func (*OnuStatus) Reset 

func (m *OnuStatus) Reset()

func (*OnuStatus) String 

func (m *OnuStatus) String() string

func (*OnuStatus) XXX_DiscardUnknown 

func (m *OnuStatus) XXX_DiscardUnknown()

func (*OnuStatus) XXX_Marshal 

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

func (*OnuStatus) XXX_Merge 

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

func (*OnuStatus) XXX_Size 

func (m *OnuStatus) XXX_Size() int

func (*OnuStatus) XXX_Unmarshal 

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

type PloamDiscoveryResponse 

type PloamDiscoveryResponse struct {
	PonId                uint32   `protobuf:"varint,1,opt,name=pon_id,json=ponId,proto3" json:"pon_id,omitempty"`
	SerialNumber         string   `protobuf:"bytes,2,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"`
	Distance             uint32   `protobuf:"varint,3,opt,name=distance,proto3" json:"distance,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PloamDiscoveryResponse) Descriptor 

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

func (*PloamDiscoveryResponse) GetDistance 

func (m *PloamDiscoveryResponse) GetDistance() uint32

func (*PloamDiscoveryResponse) GetPonId 

func (m *PloamDiscoveryResponse) GetPonId() uint32

func (*PloamDiscoveryResponse) GetSerialNumber 

func (m *PloamDiscoveryResponse) GetSerialNumber() string

func (*PloamDiscoveryResponse) ProtoMessage 

func (*PloamDiscoveryResponse) ProtoMessage()

func (*PloamDiscoveryResponse) Reset 

func (m *PloamDiscoveryResponse) Reset()

func (*PloamDiscoveryResponse) String 

func (m *PloamDiscoveryResponse) String() string

func (*PloamDiscoveryResponse) XXX_DiscardUnknown 

func (m *PloamDiscoveryResponse) XXX_DiscardUnknown()

func (*PloamDiscoveryResponse) XXX_Marshal 

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

func (*PloamDiscoveryResponse) XXX_Merge 

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

func (*PloamDiscoveryResponse) XXX_Size 

func (m *PloamDiscoveryResponse) XXX_Size() int

func (*PloamDiscoveryResponse) XXX_Unmarshal 

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

type PonStatus 

type PonStatus struct {
	PonId                uint32       `protobuf:"varint,1,opt,name=pon_id,json=ponId,proto3" json:"pon_id,omitempty"`
	OnuStatus            []*OnuStatus `protobuf:"bytes,2,rep,name=onu_status,json=onuStatus,proto3" json:"onu_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PonStatus) Descriptor 

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

func (*PonStatus) GetOnuStatus 

func (m *PonStatus) GetOnuStatus() []*OnuStatus

func (*PonStatus) GetPonId 

func (m *PonStatus) GetPonId() uint32

func (*PonStatus) ProtoMessage 

func (*PonStatus) ProtoMessage()

func (*PonStatus) Reset 

func (m *PonStatus) Reset()

func (*PonStatus) String 

func (m *PonStatus) String() string

func (*PonStatus) XXX_DiscardUnknown 

func (m *PonStatus) XXX_DiscardUnknown()

func (*PonStatus) XXX_Marshal 

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

func (*PonStatus) XXX_Merge 

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

func (*PonStatus) XXX_Size 

func (m *PonStatus) XXX_Size() int

func (*PonStatus) XXX_Unmarshal 

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

type StatusRequest 

type StatusRequest struct {
	PonIds               []uint32 `protobuf:"varint,1,rep,packed,name=pon_ids,json=ponIds,proto3" json:"pon_ids,omitempty"`
	IncludeOnus          bool     `protobuf:"varint,2,opt,name=include_onus,json=includeOnus,proto3" json:"include_onus,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) GetIncludeOnus 

func (m *StatusRequest) GetIncludeOnus() bool

func (*StatusRequest) GetPonIds 

func (m *StatusRequest) GetPonIds() []uint32

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

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

func (*StatusRequest) XXX_Merge 

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

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

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

type StatusResponse 

type StatusResponse struct {
	PonStatus            []*PonStatus `protobuf:"bytes,1,rep,name=pon_status,json=ponStatus,proto3" json:"pon_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetPonStatus 

func (m *StatusResponse) GetPonStatus() []*PonStatus

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

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

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

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

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.