server

Documentation

Index

• type Server
  • 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
  • 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)

Types

type Server

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

func New

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

func (*Server) Run

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

func (*Server) StreamTelemetry

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

type Store

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

func NewStore

func NewStore() *Store

func (*Store) GetNodeSnapshot

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

func (*Store) ListNodeSnapshots

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

func (*Store) SetNodeConnected

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

func (*Store) SetNodeRegistration

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

func (*Store) SetNodeSourceIP

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

func (*Store) TouchNode

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