http

Documentation

Index

• type Multiplexer
  • func NewMultiplexer(logger *zap.Logger, ingestFn ingestFunc, ...) (*Multiplexer, error)
  • func (m *Multiplexer) ServeHTTP(resp http.ResponseWriter, req *http.Request)
• type PushRequest
  • func DecodeJSONPushRequest(b io.Reader) (*PushRequest, error)
  • func DecodeProtoPushRequest(r io.Reader) (*PushRequest, error)
• type Stream

Types

type Multiplexer

type Multiplexer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Multiplexer implements `http.Handler`.

func NewMultiplexer

func NewMultiplexer(logger *zap.Logger, ingestFn ingestFunc, lokiEndpoint, defaultDataset, datasetKey string) (*Multiplexer, error)

NewMultiplexer creates a new Multiplexer which uses the passed Axiom client to send logs to Axiom.

func (*Multiplexer) ServeHTTP

func (m *Multiplexer) ServeHTTP(resp http.ResponseWriter, req *http.Request)

ServeHTTP implements `http.Handler`.

type PushRequest

type PushRequest struct {
	Streams []Stream
}

func DecodeJSONPushRequest

func DecodeJSONPushRequest(b io.Reader) (*PushRequest, error)

func DecodeProtoPushRequest

func DecodeProtoPushRequest(r io.Reader) (*PushRequest, error)

type Stream

type Stream struct {
	Entries []pb.Entry
	Labels  loghttp.LabelSet
}