internal

type EndpointRequestResult struct {
	// Error is the error that occurred when sending the payload to the endpoint. This is nil if the payload was sent successfully.
	Error error
	// PayloadByteSize is the number of bytes that were sent to the endpoint, zero if the payload was not sent.
	PayloadByteSize int
	// CallDuration is the duration of the call to the endpoint if the call was successful
	CallDuration time.Duration
	// StatusCode is the status code of the response from the endpoint even if the call failed but only with an actual HTTP error
	StatusCode int
}

type Range[T cmp.Ordered] struct {
	Min T
	Max T
}

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

type Recorder[T any] struct {
	// contains filtered or unexported fields
}

type RingQueue[T any] struct {

	// BufferSizes is the range of buffer sizes that the ring queue can have.
	BufferSizes Range[int]
	// contains filtered or unexported fields
}

type SumReaderCloser struct {
	io.ReadCloser
	// contains filtered or unexported fields
}

type SyncPool[T any] struct {
	// contains filtered or unexported fields
}

type TickFunc func()

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

type TracerConfig struct {
	// Service is the name of the service being traced.
	Service string
	// Env is the environment the service is running in.
	Env string
	// Version is the version of the service.
	Version string
}

type Writer interface {
	// Flush does a synchronous call to the telemetry endpoint with the given payload. Thread-safe.
	// It returns a non-empty [EndpointRequestResult] slice and a nil error if the payload was sent successfully.
	// Otherwise, the error is a call to [errors.Join] on all errors that occurred.
	Flush(transport.Payload) ([]EndpointRequestResult, error)
}

type WriterConfig struct {
	// TracerConfig is the configuration the tracer sent when the telemetry client was created (required)
	TracerConfig
	// Endpoints is a list of requests that will be used alongside the body of the telemetry data to create the requests to the telemetry endpoint (required to not be empty)
	// The writer will try each endpoint in order until it gets a 2XX HTTP response from the server
	Endpoints []*http.Request
	// HTTPClient is the http client that will be used to send the telemetry data (defaults to a copy of [http.DefaultClient])
	HTTPClient *http.Client
	// Debug is a flag that indicates whether the telemetry client is in debug mode (defaults to false)
	Debug bool
}

type WriterStatusCodeError struct {
	Status string
	Body   string
}