grpc

Documentation

Index

• type DiagnosticService
  • func (s *DiagnosticService) ChangeLogLevel(ctx context.Context, in *pb.ChangeLogLevelRequest) (*pb.ChangeLogLevelResponse, error)
  • func (s *DiagnosticService) GetMetrics(ctx context.Context, in *pb.GetMetricsRequest) (*pb.GetMetricsResponse, error)
  • func (s *DiagnosticService) GetStacktrace(ctx context.Context, in *pb.GetStacktraceRequest) (*pb.GetStacktraceResponse, error)
• type Server
  • func New(protocol, listenAddr string) (*Server, error)
  • func (s *Server) Start(ctx context.Context, t *tracker.Tracker)
• type TrackerService
  • func (s *TrackerService) DisableEvent(ctx context.Context, in *pb.DisableEventRequest) (*pb.DisableEventResponse, error)
  • func (s *TrackerService) EnableEvent(ctx context.Context, in *pb.EnableEventRequest) (*pb.EnableEventResponse, error)
  • func (s *TrackerService) GetEventDefinition(ctx context.Context, in *pb.GetEventDefinitionRequest) (*pb.GetEventDefinitionResponse, error)
  • func (s *TrackerService) GetVersion(ctx context.Context, in *pb.GetVersionRequest) (*pb.GetVersionResponse, error)
  • func (s *TrackerService) StreamEvents(in *pb.StreamEventsRequest, grpcStream pb.TrackerService_StreamEventsServer) error

Types

type DiagnosticService

type DiagnosticService struct {
	pb.UnimplementedDiagnosticServiceServer
	// contains filtered or unexported fields
}

func (*DiagnosticService) ChangeLogLevel

func (s *DiagnosticService) ChangeLogLevel(ctx context.Context, in *pb.ChangeLogLevelRequest) (*pb.ChangeLogLevelResponse, error)

func (*DiagnosticService) GetMetrics

func (s *DiagnosticService) GetMetrics(ctx context.Context, in *pb.GetMetricsRequest) (*pb.GetMetricsResponse, error)

func (*DiagnosticService) GetStacktrace

func (s *DiagnosticService) GetStacktrace(ctx context.Context, in *pb.GetStacktraceRequest) (*pb.GetStacktraceResponse, error)

type Server

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

func New

func New(protocol, listenAddr string) (*Server, error)

func (*Server) Start

func (s *Server) Start(ctx context.Context, t *tracker.Tracker)

type TrackerService

type TrackerService struct {
	pb.UnimplementedTrackerServiceServer
	// contains filtered or unexported fields
}

func (*TrackerService) DisableEvent

func (s *TrackerService) DisableEvent(ctx context.Context, in *pb.DisableEventRequest) (*pb.DisableEventResponse, error)

func (*TrackerService) EnableEvent

func (s *TrackerService) EnableEvent(ctx context.Context, in *pb.EnableEventRequest) (*pb.EnableEventResponse, error)

func (*TrackerService) GetEventDefinition

func (s *TrackerService) GetEventDefinition(ctx context.Context, in *pb.GetEventDefinitionRequest) (*pb.GetEventDefinitionResponse, error)

func (*TrackerService) GetVersion

func (s *TrackerService) GetVersion(ctx context.Context, in *pb.GetVersionRequest) (*pb.GetVersionResponse, error)

func (*TrackerService) StreamEvents

func (s *TrackerService) StreamEvents(in *pb.StreamEventsRequest, grpcStream pb.TrackerService_StreamEventsServer) error