httptransport

type Config struct {
	transport.BaseConfig

	// URL is the endpoint logs are POSTed to. Required.
	//
	// The transport accepts any scheme; an http:// URL is allowed because
	// fluentd-over-loopback, Loki on a private network, and TLS-terminating
	// proxies are legitimate setups. Wrappers that ship a known credential
	// (transports/datadog ships DD-API-KEY) layer their own https-by-default
	// enforcement on top.
	URL string

	// Method is the HTTP method. Defaults to "POST".
	Method string

	// Headers are added to every request. Content-Type is set automatically
	// from the Encoder unless overridden here.
	//
	// Headers are transmitted in plaintext when URL is http://. If you
	// put credentials here (Authorization, X-API-Key, etc.), use an
	// https:// URL or a TLS-terminating proxy. The transport doesn't
	// enforce a scheme so internal endpoints (fluentd over the loopback,
	// Loki on a private network) keep working, but the contract is
	// caller-owned.
	//
	// Header injection (CRLF in a header value) is rejected by Go's
	// net/http at request-send time with an "invalid header field
	// value" error, which surfaces via OnError. The transport doesn't
	// pre-validate at Build time; the stdlib failure is enough.
	Headers map[string]string

	// Encoder serializes one or more entries into the request body. Defaults
	// to JSONArrayEncoder.
	Encoder Encoder

	// Client is the HTTP client used to send requests. Defaults to a client
	// with a 30-second timeout.
	Client *http.Client

	// BatchSize is the maximum number of entries per request. The worker
	// flushes whenever this is reached or BatchInterval elapses, whichever
	// comes first. Defaults to 100.
	BatchSize int

	// BatchInterval is the maximum wait before flushing a non-empty batch.
	// Defaults to 5 seconds.
	BatchInterval time.Duration

	// BufferSize is the size of the internal channel buffering entries before
	// the worker reads them. When full, new entries are dropped (oldest-out
	// is not implemented; the dispatch path stays non-blocking). Defaults to
	// 1024.
	BufferSize int

	// OnError is called when a batch fails to encode or send. The default
	// writes a one-line error to os.Stderr. Use this to plumb send errors
	// into a separate logger or metrics counter.
	OnError func(err error, entries []Entry)
}

type Encoder interface {
	Encode(entries []Entry) (body []byte, contentType string, err error)
}

type EncoderFunc func(entries []Entry) ([]byte, string, error)

type Entry struct {
	Level    loglayer.LogLevel
	Time     time.Time
	Messages []any
	// Data holds the assembled persistent fields and error map (may be nil).
	Data map[string]any
	// Metadata is the raw value the caller passed to WithMetadata. May be a
	// map, a struct, a scalar, or nil. Encoders decide how to render it.
	Metadata any
	// Groups mirrors [loglayer.TransportParams.Groups].
	Groups []string
	// Schema mirrors [loglayer.TransportParams.Schema].
	Schema loglayer.Schema
}

type HTTPError struct {
	StatusCode int
}

type Transport struct {
	transport.BaseTransport
	// contains filtered or unexported fields
}