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)
Click to show internal directories.
Click to hide internal directories.