Documentation ¶
Index ¶
- func RegisterCoreServiceServer(s *grpc.Server, srv CoreServiceServer)
- type CoreServiceClient
- type CoreServiceServer
- type CoreService_GetHealthStatusClient
- type CoreService_GetHealthStatusServer
- type UnimplementedCoreServiceServer
- func (*UnimplementedCoreServiceServer) ChildDeviceDetected(ctx context.Context, req *core_adapter.DeviceDiscovery) (*voltha.Device, error)
- func (*UnimplementedCoreServiceServer) ChildDevicesDetected(ctx context.Context, req *common.ID) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) ChildDevicesLost(ctx context.Context, req *common.ID) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) ChildrenStateUpdate(ctx context.Context, req *core_adapter.DeviceStateFilter) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) DeleteAllPorts(ctx context.Context, req *common.ID) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) DevicePMConfigUpdate(ctx context.Context, req *voltha.PmConfigs) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) DeviceReasonUpdate(ctx context.Context, req *core_adapter.DeviceReason) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) DeviceStateUpdate(ctx context.Context, req *core_adapter.DeviceStateFilter) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) DeviceUpdate(ctx context.Context, req *voltha.Device) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) GetChildDevice(ctx context.Context, req *core_adapter.ChildDeviceFilter) (*voltha.Device, error)
- func (*UnimplementedCoreServiceServer) GetChildDeviceWithProxyAddress(ctx context.Context, req *voltha.Device_ProxyAddress) (*voltha.Device, error)
- func (*UnimplementedCoreServiceServer) GetChildDevices(ctx context.Context, req *common.ID) (*voltha.Devices, error)
- func (*UnimplementedCoreServiceServer) GetDevice(ctx context.Context, req *common.ID) (*voltha.Device, error)
- func (*UnimplementedCoreServiceServer) GetDevicePort(ctx context.Context, req *core_adapter.PortFilter) (*voltha.Port, error)
- func (*UnimplementedCoreServiceServer) GetHealthStatus(srv CoreService_GetHealthStatusServer) error
- func (*UnimplementedCoreServiceServer) GetPorts(ctx context.Context, req *core_adapter.PortFilter) (*voltha.Ports, error)
- func (*UnimplementedCoreServiceServer) ListDevicePorts(ctx context.Context, req *common.ID) (*voltha.Ports, error)
- func (*UnimplementedCoreServiceServer) PortCreated(ctx context.Context, req *voltha.Port) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) PortStateUpdate(ctx context.Context, req *core_adapter.PortState) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) PortsStateUpdate(ctx context.Context, req *core_adapter.PortStateFilter) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) ReconcileChildDevices(ctx context.Context, req *common.ID) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) RegisterAdapter(ctx context.Context, req *core_adapter.AdapterRegistration) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) SendPacketIn(ctx context.Context, req *core_adapter.PacketIn) (*empty.Empty, error)
- func (*UnimplementedCoreServiceServer) UpdateImageDownload(ctx context.Context, req *voltha.ImageDownload) (*empty.Empty, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterCoreServiceServer ¶
func RegisterCoreServiceServer(s *grpc.Server, srv CoreServiceServer)
Types ¶
type CoreServiceClient ¶
type CoreServiceClient interface { // GetHealthStatus is used by a CoreService client to verify connectivity // to the gRPC server hosting the CoreService service GetHealthStatus(ctx context.Context, opts ...grpc.CallOption) (CoreService_GetHealthStatusClient, error) RegisterAdapter(ctx context.Context, in *core_adapter.AdapterRegistration, opts ...grpc.CallOption) (*empty.Empty, error) DeviceUpdate(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) PortCreated(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error) PortsStateUpdate(ctx context.Context, in *core_adapter.PortStateFilter, opts ...grpc.CallOption) (*empty.Empty, error) DeleteAllPorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) GetDevicePort(ctx context.Context, in *core_adapter.PortFilter, opts ...grpc.CallOption) (*voltha.Port, error) ListDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.Ports, error) DeviceStateUpdate(ctx context.Context, in *core_adapter.DeviceStateFilter, opts ...grpc.CallOption) (*empty.Empty, error) DevicePMConfigUpdate(ctx context.Context, in *voltha.PmConfigs, opts ...grpc.CallOption) (*empty.Empty, error) ChildDeviceDetected(ctx context.Context, in *core_adapter.DeviceDiscovery, opts ...grpc.CallOption) (*voltha.Device, error) ChildDevicesLost(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) ChildDevicesDetected(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) GetDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.Device, error) GetChildDevice(ctx context.Context, in *core_adapter.ChildDeviceFilter, opts ...grpc.CallOption) (*voltha.Device, error) GetChildDevices(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.Devices, error) SendPacketIn(ctx context.Context, in *core_adapter.PacketIn, opts ...grpc.CallOption) (*empty.Empty, error) DeviceReasonUpdate(ctx context.Context, in *core_adapter.DeviceReason, opts ...grpc.CallOption) (*empty.Empty, error) PortStateUpdate(ctx context.Context, in *core_adapter.PortState, opts ...grpc.CallOption) (*empty.Empty, error) // Additional API found in the Core - unused? ReconcileChildDevices(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) GetChildDeviceWithProxyAddress(ctx context.Context, in *voltha.Device_ProxyAddress, opts ...grpc.CallOption) (*voltha.Device, error) GetPorts(ctx context.Context, in *core_adapter.PortFilter, opts ...grpc.CallOption) (*voltha.Ports, error) ChildrenStateUpdate(ctx context.Context, in *core_adapter.DeviceStateFilter, opts ...grpc.CallOption) (*empty.Empty, error) UpdateImageDownload(ctx context.Context, in *voltha.ImageDownload, opts ...grpc.CallOption) (*empty.Empty, error) }
CoreServiceClient is the client API for CoreService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCoreServiceClient ¶
func NewCoreServiceClient(cc *grpc.ClientConn) CoreServiceClient
type CoreServiceServer ¶
type CoreServiceServer interface { // GetHealthStatus is used by a CoreService client to verify connectivity // to the gRPC server hosting the CoreService service GetHealthStatus(CoreService_GetHealthStatusServer) error RegisterAdapter(context.Context, *core_adapter.AdapterRegistration) (*empty.Empty, error) DeviceUpdate(context.Context, *voltha.Device) (*empty.Empty, error) PortCreated(context.Context, *voltha.Port) (*empty.Empty, error) PortsStateUpdate(context.Context, *core_adapter.PortStateFilter) (*empty.Empty, error) DeleteAllPorts(context.Context, *common.ID) (*empty.Empty, error) GetDevicePort(context.Context, *core_adapter.PortFilter) (*voltha.Port, error) ListDevicePorts(context.Context, *common.ID) (*voltha.Ports, error) DeviceStateUpdate(context.Context, *core_adapter.DeviceStateFilter) (*empty.Empty, error) DevicePMConfigUpdate(context.Context, *voltha.PmConfigs) (*empty.Empty, error) ChildDeviceDetected(context.Context, *core_adapter.DeviceDiscovery) (*voltha.Device, error) ChildDevicesLost(context.Context, *common.ID) (*empty.Empty, error) ChildDevicesDetected(context.Context, *common.ID) (*empty.Empty, error) GetDevice(context.Context, *common.ID) (*voltha.Device, error) GetChildDevice(context.Context, *core_adapter.ChildDeviceFilter) (*voltha.Device, error) GetChildDevices(context.Context, *common.ID) (*voltha.Devices, error) SendPacketIn(context.Context, *core_adapter.PacketIn) (*empty.Empty, error) DeviceReasonUpdate(context.Context, *core_adapter.DeviceReason) (*empty.Empty, error) PortStateUpdate(context.Context, *core_adapter.PortState) (*empty.Empty, error) // Additional API found in the Core - unused? ReconcileChildDevices(context.Context, *common.ID) (*empty.Empty, error) GetChildDeviceWithProxyAddress(context.Context, *voltha.Device_ProxyAddress) (*voltha.Device, error) GetPorts(context.Context, *core_adapter.PortFilter) (*voltha.Ports, error) ChildrenStateUpdate(context.Context, *core_adapter.DeviceStateFilter) (*empty.Empty, error) UpdateImageDownload(context.Context, *voltha.ImageDownload) (*empty.Empty, error) }
CoreServiceServer is the server API for CoreService service.
type CoreService_GetHealthStatusClient ¶
type CoreService_GetHealthStatusClient interface { Send(*common.Connection) error Recv() (*health.HealthStatus, error) grpc.ClientStream }
type CoreService_GetHealthStatusServer ¶
type CoreService_GetHealthStatusServer interface { Send(*health.HealthStatus) error Recv() (*common.Connection, error) grpc.ServerStream }
type UnimplementedCoreServiceServer ¶
type UnimplementedCoreServiceServer struct { }
UnimplementedCoreServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedCoreServiceServer) ChildDeviceDetected ¶
func (*UnimplementedCoreServiceServer) ChildDeviceDetected(ctx context.Context, req *core_adapter.DeviceDiscovery) (*voltha.Device, error)
func (*UnimplementedCoreServiceServer) ChildDevicesDetected ¶
func (*UnimplementedCoreServiceServer) ChildDevicesLost ¶
func (*UnimplementedCoreServiceServer) ChildrenStateUpdate ¶
func (*UnimplementedCoreServiceServer) ChildrenStateUpdate(ctx context.Context, req *core_adapter.DeviceStateFilter) (*empty.Empty, error)
func (*UnimplementedCoreServiceServer) DeleteAllPorts ¶
func (*UnimplementedCoreServiceServer) DevicePMConfigUpdate ¶
func (*UnimplementedCoreServiceServer) DeviceReasonUpdate ¶
func (*UnimplementedCoreServiceServer) DeviceReasonUpdate(ctx context.Context, req *core_adapter.DeviceReason) (*empty.Empty, error)
func (*UnimplementedCoreServiceServer) DeviceStateUpdate ¶
func (*UnimplementedCoreServiceServer) DeviceStateUpdate(ctx context.Context, req *core_adapter.DeviceStateFilter) (*empty.Empty, error)
func (*UnimplementedCoreServiceServer) DeviceUpdate ¶
func (*UnimplementedCoreServiceServer) GetChildDevice ¶
func (*UnimplementedCoreServiceServer) GetChildDevice(ctx context.Context, req *core_adapter.ChildDeviceFilter) (*voltha.Device, error)
func (*UnimplementedCoreServiceServer) GetChildDeviceWithProxyAddress ¶
func (*UnimplementedCoreServiceServer) GetChildDeviceWithProxyAddress(ctx context.Context, req *voltha.Device_ProxyAddress) (*voltha.Device, error)
func (*UnimplementedCoreServiceServer) GetChildDevices ¶
func (*UnimplementedCoreServiceServer) GetDevicePort ¶
func (*UnimplementedCoreServiceServer) GetDevicePort(ctx context.Context, req *core_adapter.PortFilter) (*voltha.Port, error)
func (*UnimplementedCoreServiceServer) GetHealthStatus ¶
func (*UnimplementedCoreServiceServer) GetHealthStatus(srv CoreService_GetHealthStatusServer) error
func (*UnimplementedCoreServiceServer) GetPorts ¶
func (*UnimplementedCoreServiceServer) GetPorts(ctx context.Context, req *core_adapter.PortFilter) (*voltha.Ports, error)
func (*UnimplementedCoreServiceServer) ListDevicePorts ¶
func (*UnimplementedCoreServiceServer) PortCreated ¶
func (*UnimplementedCoreServiceServer) PortStateUpdate ¶
func (*UnimplementedCoreServiceServer) PortStateUpdate(ctx context.Context, req *core_adapter.PortState) (*empty.Empty, error)
func (*UnimplementedCoreServiceServer) PortsStateUpdate ¶
func (*UnimplementedCoreServiceServer) PortsStateUpdate(ctx context.Context, req *core_adapter.PortStateFilter) (*empty.Empty, error)
func (*UnimplementedCoreServiceServer) ReconcileChildDevices ¶
func (*UnimplementedCoreServiceServer) RegisterAdapter ¶
func (*UnimplementedCoreServiceServer) RegisterAdapter(ctx context.Context, req *core_adapter.AdapterRegistration) (*empty.Empty, error)
func (*UnimplementedCoreServiceServer) SendPacketIn ¶
func (*UnimplementedCoreServiceServer) SendPacketIn(ctx context.Context, req *core_adapter.PacketIn) (*empty.Empty, error)
func (*UnimplementedCoreServiceServer) UpdateImageDownload ¶
func (*UnimplementedCoreServiceServer) UpdateImageDownload(ctx context.Context, req *voltha.ImageDownload) (*empty.Empty, error)
Click to show internal directories.
Click to hide internal directories.