metrics

Documentation

Index

• func RunGRPC(port int)
• type Server
  • func NewServer() *Server
  • func (s *Server) Connections(ctx context.Context, req *pb.MetricsRequest) (*pb.MetricsResponse, error)
  • func (s *Server) EventsCount(ctx context.Context, req *pb.MetricsRequest) (*pb.MetricsResponse, error)
  • func (s *Server) EventsSize(ctx context.Context, req *pb.MetricsRequest) (*pb.MetricsResponse, error)

Functions

func RunGRPC

func RunGRPC(port int)

RunGRPC starts the grpc endpoint

Types

type Server

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

Server core struct

func NewServer

func NewServer() *Server

NewServer creates a new struct to interface the streams server

func (*Server) Connections

func (s *Server) Connections(ctx context.Context, req *pb.MetricsRequest) (*pb.MetricsResponse, error)

Connections fetches metrics relating to socket count from timeseries services

func (*Server) EventsCount

func (s *Server) EventsCount(ctx context.Context, req *pb.MetricsRequest) (*pb.MetricsResponse, error)

EventsCount fetches metrics relating to event count from timeseries services

func (*Server) EventsSize

func (s *Server) EventsSize(ctx context.Context, req *pb.MetricsRequest) (*pb.MetricsResponse, error)

EventsSize fetches metrics relating to event byte size from timeseries services