receiver

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 28, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GRPCReceiver

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

func NewGRPCReceiver

func NewGRPCReceiver(pipeline *ingestion.Pipeline) *GRPCReceiver

func (*GRPCReceiver) ListenAndServe

func (r *GRPCReceiver) ListenAndServe(addr string) error

func (*GRPCReceiver) Stop

func (r *GRPCReceiver) Stop()

type HTTPReceiver

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

func NewHTTPReceiver

func NewHTTPReceiver(pipeline *ingestion.Pipeline) *HTTPReceiver

func (*HTTPReceiver) HandleLogs

func (h *HTTPReceiver) HandleLogs(w http.ResponseWriter, r *http.Request)

func (*HTTPReceiver) HandleMetrics

func (h *HTTPReceiver) HandleMetrics(w http.ResponseWriter, r *http.Request)

func (*HTTPReceiver) HandleTraces

func (h *HTTPReceiver) HandleTraces(w http.ResponseWriter, r *http.Request)

func (*HTTPReceiver) SetForwarder

func (h *HTTPReceiver) SetForwarder(f *forwarder.Forwarder)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL