Documentation
¶
Index ¶
- Constants
- type MetadataService
- func (s *MetadataService) GetMetadataForNode(ctx context.Context, ...) (*api.NodeMetadataMessage, error)
- func (s *MetadataService) GetMetadataForPort(ctx context.Context, ...) (*api.PortMetadataMessage, error)
- func (s *MetadataService) GetMetadataForScanner(ctx context.Context, _ *empty.Empty) (*api.ScannerMetadataMessage, error)
- func (s *MetadataService) Open() error
- type NodeAndPortScanPortService
- func (s *NodeAndPortScanPortService) Open() error
- func (s *NodeAndPortScanPortService) StartNodeScan(ctx context.Context, nodeScanStartMessage *api.NodeScanStartMessage) (*api.NodeScanMessage, error)
- func (s *NodeAndPortScanPortService) SubscribeToNodeScans(_ *empty.Empty, stream api.NodeAndPortScanService_SubscribeToNodeScansServer) error
- func (s *NodeAndPortScanPortService) SubscribeToNodes(nodeScanMessage *api.NodeScanMessage, ...) error
- func (s *NodeAndPortScanPortService) SubscribeToPortScans(nodeMessage *api.NodeMessage, ...) error
- func (s *NodeAndPortScanPortService) SubscribeToPorts(portScanMessage *api.PortScanMessage, ...) error
- type NodeWakeService
Constants ¶
View Source
const (
AUTHORIZATION_METADATA_KEY = "X-Liwasc-Authorization"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetadataService ¶
type MetadataService struct {
api.UnimplementedMetadataServiceServer
// contains filtered or unexported fields
}
func NewMetadataService ¶
func NewMetadataService( interfaceInspector *networking.InterfaceInspector, mac2vendorPersister *persisters.MAC2VendorPersister, serviceNamesPortNumbersPersister *persisters.ServiceNamesPortNumbersPersister, contextValidator *validators.ContextValidator, ) *MetadataService
func (*MetadataService) GetMetadataForNode ¶
func (s *MetadataService) GetMetadataForNode(ctx context.Context, nodeMetadataReferenceMessage *api.NodeMetadataReferenceMessage) (*api.NodeMetadataMessage, error)
func (*MetadataService) GetMetadataForPort ¶
func (s *MetadataService) GetMetadataForPort(ctx context.Context, portMetadataReferenceMessage *api.PortMetadataReferenceMessage) (*api.PortMetadataMessage, error)
func (*MetadataService) GetMetadataForScanner ¶
func (s *MetadataService) GetMetadataForScanner(ctx context.Context, _ *empty.Empty) (*api.ScannerMetadataMessage, error)
func (*MetadataService) Open ¶
func (s *MetadataService) Open() error
type NodeAndPortScanPortService ¶
type NodeAndPortScanPortService struct {
api.UnimplementedNodeAndPortScanServiceServer
// contains filtered or unexported fields
}
func NewNodeAndPortScanPortService ¶
func NewNodeAndPortScanPortService( device string, ports2packetsPersister *persisters.Ports2PacketPersister, nodeAndPortScanPersister *persisters.NodeAndPortScanPersister, portScannerSemaphore *semaphore.Weighted, periodicScanCronExpression string, periodicNodeScanTimeout int, periodicPortScanTimeout int, contextValidator *validators.ContextValidator, ) *NodeAndPortScanPortService
func (*NodeAndPortScanPortService) Open ¶
func (s *NodeAndPortScanPortService) Open() error
func (*NodeAndPortScanPortService) StartNodeScan ¶
func (s *NodeAndPortScanPortService) StartNodeScan(ctx context.Context, nodeScanStartMessage *api.NodeScanStartMessage) (*api.NodeScanMessage, error)
func (*NodeAndPortScanPortService) SubscribeToNodeScans ¶
func (s *NodeAndPortScanPortService) SubscribeToNodeScans(_ *empty.Empty, stream api.NodeAndPortScanService_SubscribeToNodeScansServer) error
func (*NodeAndPortScanPortService) SubscribeToNodes ¶
func (s *NodeAndPortScanPortService) SubscribeToNodes(nodeScanMessage *api.NodeScanMessage, stream api.NodeAndPortScanService_SubscribeToNodesServer) error
func (*NodeAndPortScanPortService) SubscribeToPortScans ¶
func (s *NodeAndPortScanPortService) SubscribeToPortScans(nodeMessage *api.NodeMessage, stream api.NodeAndPortScanService_SubscribeToPortScansServer) error
func (*NodeAndPortScanPortService) SubscribeToPorts ¶
func (s *NodeAndPortScanPortService) SubscribeToPorts(portScanMessage *api.PortScanMessage, stream api.NodeAndPortScanService_SubscribeToPortsServer) error
type NodeWakeService ¶
type NodeWakeService struct {
api.UnimplementedNodeWakeServiceServer
// contains filtered or unexported fields
}
func NewNodeWakeService ¶
func NewNodeWakeService( device string, wakeOnLANWaker *wakers.WakeOnLANWaker, nodeWakePersister *persisters.NodeWakePersister, getIPAddress func(macAddress string) (ipAddress string, err error), contextValidator *validators.ContextValidator, ) *NodeWakeService
func (*NodeWakeService) StartNodeWake ¶
func (s *NodeWakeService) StartNodeWake(ctx context.Context, nodeWakeStartMessage *api.NodeWakeStartMessage) (*api.NodeWakeMessage, error)
func (*NodeWakeService) SubscribeToNodeWakes ¶
func (s *NodeWakeService) SubscribeToNodeWakes(_ *empty.Empty, stream api.NodeWakeService_SubscribeToNodeWakesServer) error
Source Files
Click to show internal directories.
Click to hide internal directories.