server

package

v0.1.0 Latest Latest Go to latest Published: Feb 19, 2026 License: MIT Imports: 32 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Server struct {
	pb.UnimplementedTelemetryServiceServer
	// contains filtered or unexported fields
}

func New(cfg config.ServerConfig, logger zerolog.Logger) *Server

func (s *Server) Run(ctx context.Context) error

func (s *Server) StreamTelemetry(stream pb.TelemetryService_StreamTelemetryServer) error

type Store struct {
	// contains filtered or unexported fields
}

func NewStore() *Store

func (s *Store) GetNodeSnapshot(nodeID string) (api.NodeSnapshot, error)

func (s *Store) ListNodeSnapshots() []api.NodeSnapshot

func (s *Store) SetNodeConnected(nodeID string, connected bool)

func (s *Store) SetNodeRegistration(reg *api.Registration)

func (s *Store) SetNodeSourceIP(nodeID, sourceIP string)

func (s *Store) TouchNode(nodeID string, at int64)