grpc

Documentation

Index

• Variables
• type DataSourceService
  • func (s *DataSourceService) Write(ctx context.Context, req *pb.WriteDataSourceRequest) (*pb.WriteDataSourceResponse, error)
  • func (s *DataSourceService) WriteStream(stream pb.DataSourceService_WriteStreamServer) error
• 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 *tracee.Tracee, e *engine.Engine)
• type TraceeService
  • func (s *TraceeService) DisableEvent(ctx context.Context, in *pb.DisableEventRequest) (*pb.DisableEventResponse, error)
  • func (s *TraceeService) EnableEvent(ctx context.Context, in *pb.EnableEventRequest) (*pb.EnableEventResponse, error)
  • func (s *TraceeService) GetEventDefinitions(ctx context.Context, in *pb.GetEventDefinitionsRequest) (*pb.GetEventDefinitionsResponse, error)
  • func (s *TraceeService) GetVersion(ctx context.Context, in *pb.GetVersionRequest) (*pb.GetVersionResponse, error)
  • func (s *TraceeService) StreamEvents(in *pb.StreamEventsRequest, grpcStream pb.TraceeService_StreamEventsServer) error

Variables

var EventTranslationTable = [events.MaxBuiltinID]pb.EventId{}/* 559 elements not displayed */

EventTranslationTable translates internal to external protobuf Event Id

Types

type DataSourceService

type DataSourceService struct {
	pb.UnimplementedDataSourceServiceServer
	// contains filtered or unexported fields
}

func (*DataSourceService) Write

func (s *DataSourceService) Write(ctx context.Context, req *pb.WriteDataSourceRequest) (*pb.WriteDataSourceResponse, error)

Write implements the DataSourceService Write RPC

func (*DataSourceService) WriteStream

func (s *DataSourceService) WriteStream(stream pb.DataSourceService_WriteStreamServer) error

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 *tracee.Tracee, e *engine.Engine)

type TraceeService

type TraceeService struct {
	pb.UnimplementedTraceeServiceServer
	// contains filtered or unexported fields
}

func (*TraceeService) DisableEvent

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

func (*TraceeService) EnableEvent

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

func (*TraceeService) GetEventDefinitions

func (s *TraceeService) GetEventDefinitions(ctx context.Context, in *pb.GetEventDefinitionsRequest) (*pb.GetEventDefinitionsResponse, error)

func (*TraceeService) GetVersion

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

func (*TraceeService) StreamEvents

func (s *TraceeService) StreamEvents(in *pb.StreamEventsRequest, grpcStream pb.TraceeService_StreamEventsServer) error