http

Documentation

Index

• Constants
• func CreateAuthMiddleware(authInterceptor pkgHttpJwt.Interceptor, ...) func(next http.Handler) http.Handler
• func CreateLoggingMiddleware(opts ...LogOpt) func(next http.Handler) http.Handler
• func CreateMakeQueryCaseInsensitiveMiddleware(queryCaseInsensitive map[string]string, opts ...LogOpt) func(next http.Handler) http.Handler
• func CreateTrailSlashSuffixMiddleware(opts ...LogOpt) func(next http.Handler) http.Handler
• func DefaultCodeToLevel(code int, logger log.Logger) func(args ...interface{})
• func ErrToStatus(err error) int
• func ErrToStatusWithDef(err error, def int) int
• func GetToken(auth string) (string, error)
• func NewDefaultAuthorizationRules(apiPath string) map[string][]pkgHttpJwt.AuthArgs
• func OpenTelemetryNewHandler(handler http.Handler, serviceName string, tracerProvider trace.TracerProvider) http.Handler
• func WantToLog(code int, logger log.Logger) bool
• type LogOpt
  • func WithLogger(logger log.Logger) LogOpt
• type LogOptions
  • func NewLogOptions() *LogOptions
• type OnUnauthorizedAccessFunc
• type OpenTelemetryCollectorConfig
  • func (c *OpenTelemetryCollectorConfig) Validate() error

Constants

const (
	ApplicationProtoJsonContentType = "application/protojson"

	AcceptHeaderKey             = "Accept"
	AuthorizationHeaderKey      = "Authorization"
	ConnectionHeaderKey         = "Connection"
	ContentLengthHeaderKey      = "Content-Length"
	ContentTypeHeaderKey        = "Content-Type"
	ContentTypeOptionsHeaderKey = "X-Content-Type-Options"
	CorrelationIDHeaderKey      = "Correlation-Id"
	ETagHeaderKey               = "ETag"

	AuthorizationBearerPrefix = "Bearer "
)

const (
	AnyPathSuffixRegex = `\/.*`
)

Functions

func CreateAuthMiddleware

func CreateAuthMiddleware(authInterceptor pkgHttpJwt.Interceptor, onUnauthorizedAccessFunc OnUnauthorizedAccessFunc) func(next http.Handler) http.Handler

CreateAuthMiddleware creates middleware for authorization

func CreateLoggingMiddleware

func CreateLoggingMiddleware(opts ...LogOpt) func(next http.Handler) http.Handler

func CreateMakeQueryCaseInsensitiveMiddleware

func CreateMakeQueryCaseInsensitiveMiddleware(queryCaseInsensitive map[string]string, opts ...LogOpt) func(next http.Handler) http.Handler

func CreateTrailSlashSuffixMiddleware

func CreateTrailSlashSuffixMiddleware(opts ...LogOpt) func(next http.Handler) http.Handler

func DefaultCodeToLevel

func DefaultCodeToLevel(code int, logger log.Logger) func(args ...interface{})

DefaultCodeToLevel is the default implementation of gRPC return codes and interceptor log level for server side.

func ErrToStatus

func ErrToStatus(err error) int

ErrToStatus converts err to http.Status.

func ErrToStatusWithDef

func ErrToStatusWithDef(err error, def int) int

ErrToStatusWithDef converts err with default http.Status(for unknown conversion) to http.Status.

func GetToken

func GetToken(auth string) (string, error)

func NewDefaultAuthorizationRules

func NewDefaultAuthorizationRules(apiPath string) map[string][]pkgHttpJwt.AuthArgs

NewDefaultAuthorizationRules returns a map of HTTP methods to a slice of AuthArgs. The AuthArgs contain a URI field that is a regular expression matching the given apiPath with any path suffix. This function is used to create default authorization rules for HTTP methods GET, POST, DELETE, and PUT.

func OpenTelemetryNewHandler

func OpenTelemetryNewHandler(handler http.Handler, serviceName string, tracerProvider trace.TracerProvider) http.Handler

func WantToLog

func WantToLog(code int, logger log.Logger) bool

DefaultCodeToLevel is the default implementation of gRPC return codes and interceptor log level for server side.

Types

type LogOpt

type LogOpt = func(*LogOptions)

func WithLogger

func WithLogger(logger log.Logger) LogOpt

type LogOptions

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

func NewLogOptions

func NewLogOptions() *LogOptions

type OnUnauthorizedAccessFunc

type OnUnauthorizedAccessFunc = func(ctx context.Context, w http.ResponseWriter, r *http.Request, err error)

type OpenTelemetryCollectorConfig

type OpenTelemetryCollectorConfig struct {
	otelClient.Config `yaml:",inline"`
}

func (*OpenTelemetryCollectorConfig) Validate

func (c *OpenTelemetryCollectorConfig) Validate() error