grpc

package

v0.0.1 Latest Latest Go to latest Published: Mar 17, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

Write implements the DataSourceService Write RPC

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

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

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 struct {
	// contains filtered or unexported fields
}

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

func (s *Server) Start(ctx context.Context, t *tracee.Tracee, e *engine.Engine)

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

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) GetEventDefinition(ctx context.Context, in *pb.GetEventDefinitionRequest) (*pb.GetEventDefinitionResponse, 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