middleware

Documentation

Index

• func NewRequestTelemetry(svcLogger svc1log.Logger, evtLogger evt2log.Logger, ...) wrouter.RequestHandlerMiddleware
• func NewRouteTelemetry(mr metrics.Registry, endpoint500s *EndpointFiveHundredsHealthCheck) wrouter.RouteHandlerMiddleware
• type EndpointFiveHundredsHealthCheck
  • func NewEndpointFiveHundredsHealthCheck(ctx context.Context, alwaysHealthy bool) *EndpointFiveHundredsHealthCheck
  • func (e *EndpointFiveHundredsHealthCheck) HealthStatus(context.Context) health.HealthStatus
  • func (e *EndpointFiveHundredsHealthCheck) MarkResponse(route wrouter.RouteSpec, code int)

Functions

func NewRequestTelemetry

func NewRequestTelemetry(
	svcLogger svc1log.Logger,
	evtLogger evt2log.Logger,
	auditLogger audit2log.Logger,
	metricLogger metric1log.Logger,
	diagLogger diag1log.Logger,
	reqLogger req2log.Logger,
	trcLogger trc1log.Logger,
	tracerOptions []wtracing.TracerOption,
	idsExtractor extractor.IDsFromRequest,
	metricsRegistry metrics.Registry,
) wrouter.RequestHandlerMiddleware

NewRequestTelemetry is request middleware that configures instrumentation and emits telemetry that applies to all requests.

* Set loggers, metrics registry, and tracer on context * Extract IDs from request and set on context * Create outer trace span for request * Set HSTS headers

func NewRouteTelemetry

func NewRouteTelemetry(mr metrics.Registry, endpoint500s *EndpointFiveHundredsHealthCheck) wrouter.RouteHandlerMiddleware

Types

type EndpointFiveHundredsHealthCheck

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

func NewEndpointFiveHundredsHealthCheck

func NewEndpointFiveHundredsHealthCheck(ctx context.Context, alwaysHealthy bool) *EndpointFiveHundredsHealthCheck

NewEndpointFiveHundredsHealthCheck creates a new EndpointFiveHundredsHealthCheck and starts its internal goroutine. If alwaysHealthy is true, the health check will always return HEALTHY but any failing/broken endpoints will still be included in the results params map as information.

func (*EndpointFiveHundredsHealthCheck) HealthStatus

func (e *EndpointFiveHundredsHealthCheck) HealthStatus(context.Context) health.HealthStatus

func (*EndpointFiveHundredsHealthCheck) MarkResponse

func (e *EndpointFiveHundredsHealthCheck) MarkResponse(route wrouter.RouteSpec, code int)