server

package
v0.0.0-...-2119b44 Latest Latest
Warning

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

Go to latest
Published: Apr 17, 2024 License: MPL-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type NodeEventServer

type NodeEventServer struct {
	epb.UnimplementedEventNotificationServiceServer
	// contains filtered or unexported fields
}

func NewNodeEventServer

func NewNodeEventServer(orgName string, s *NodeServer) *NodeEventServer

func (*NodeEventServer) EventNotification

func (n *NodeEventServer) EventNotification(ctx context.Context, e *epb.Event) (*epb.EventResponse, error)

type NodeServer

type NodeServer struct {
	pb.UnimplementedNodeServiceServer
	// contains filtered or unexported fields
}

func NewNodeServer

func NewNodeServer(orgName string, nodeRepo db.NodeRepo, siteRepo db.SiteRepo, nodeStatusRepo db.NodeStatusRepo,
	pushGateway string, msgBus mb.MsgBusServiceClient, siteService providers.SiteClientProvider, org uuid.UUID) *NodeServer

func (*NodeServer) AddNode

func (n *NodeServer) AddNode(ctx context.Context, req *pb.AddNodeRequest) (*pb.AddNodeResponse, error)

func (*NodeServer) AddNodeToSite

func (*NodeServer) AttachNodes

func (*NodeServer) DeleteNode

func (*NodeServer) DetachNode

func (*NodeServer) GetNode

func (n *NodeServer) GetNode(ctx context.Context, req *pb.GetNodeRequest) (*pb.GetNodeResponse, error)

func (*NodeServer) GetNodes

func (n *NodeServer) GetNodes(ctx context.Context, req *pb.GetNodesRequest) (*pb.GetNodesResponse, error)

func (*NodeServer) GetNodesForNetwork

func (n *NodeServer) GetNodesForNetwork(ctx context.Context, req *pb.GetByNetworkRequest) (*pb.GetByNetworkResponse, error)

func (*NodeServer) GetNodesForOrg

func (n *NodeServer) GetNodesForOrg(ctx context.Context, req *pb.GetByOrgRequest) (*pb.GetByOrgResponse, error)

func (*NodeServer) GetNodesForSite

func (n *NodeServer) GetNodesForSite(ctx context.Context, req *pb.GetBySiteRequest) (*pb.GetBySiteResponse, error)

func (*NodeServer) PushMetrics

func (n *NodeServer) PushMetrics()

func (*NodeServer) ReleaseNodeFromSite

func (*NodeServer) UpdateNode

func (*NodeServer) UpdateNodeStatus

func (n *NodeServer) UpdateNodeStatus(ctx context.Context, req *pb.UpdateNodeStateRequest) (*pb.UpdateNodeResponse, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL