ingest

Documentation

Index

• func Serve(addr string, srv *Server) (*grpc.Server, net.Listener, error)
• type Server
  • func NewServer(g *graph.Graph, p *persist.Persister, s *schema.Schema) *Server
  • func (s *Server) Export(ctx context.Context, req *collogspb.ExportLogsServiceRequest) (*collogspb.ExportLogsServiceResponse, error)

Functions

func Serve

func Serve(addr string, srv *Server) (*grpc.Server, net.Listener, error)

Serve starts the OTLP gRPC server on the given address.

Types

type Server

type Server struct {
	collogspb.UnimplementedLogsServiceServer
	// contains filtered or unexported fields
}

Server receives OTLP log records and applies them as graph mutations.

func NewServer

func NewServer(g *graph.Graph, p *persist.Persister, s *schema.Schema) *Server

NewServer creates an OTLP ingestion server.

func (*Server) Export

func (s *Server) Export(ctx context.Context, req *collogspb.ExportLogsServiceRequest) (*collogspb.ExportLogsServiceResponse, error)

Export handles OTLP ExportLogsServiceRequest.