grpc

Documentation

Index

• type Server
  • func NewServer(logg sysmon.Logger, collector sysmon.Collector, bufSize int) *Server
  • func (s *Server) ListStatistics(req *stat.SubscriptionRequest, stream stat.Statistics_ListStatisticsServer) error
  • func (s *Server) Start(ctx context.Context, addr string) error
  • func (s *Server) Stop(ctx context.Context) error

Types

type Server

type Server struct {
	stat.UnimplementedStatisticsServer
	// contains filtered or unexported fields
}

Server структура сервера.

func NewServer

func NewServer(logg sysmon.Logger, collector sysmon.Collector, bufSize int) *Server

NewServer конструктор.

func (*Server) ListStatistics

func (s *Server) ListStatistics(req *stat.SubscriptionRequest, stream stat.Statistics_ListStatisticsServer) error

ListStatistics стримминг данных клиенту.

func (*Server) Start

func (s *Server) Start(ctx context.Context, addr string) error

Start запуск сервера gRPC.

func (*Server) Stop

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

Stop останов сервера gRPC.