transport

Documentation

Overview

Copyright (c) 2024 ESET See LICENSE file for redistribution.

Copyright (c) 2024 ESET See LICENSE file for redistribution.

Index

• func NewHandler(reloader *EndpointReloader) http.Handler
• type Config
• type ConfigHTTP
• type EndpointReloader
  • func NewEndpointReloader(handler http.Handler) *EndpointReloader
  • func (e *EndpointReloader) Endpoint() http.Handler
  • func (e *EndpointReloader) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (e *EndpointReloader) Set(endpoint *ProxyEndpoint)
• type Logger
• type ProxyEndpoint
  • func NewProxyEndpoint(logger Logger, router *routerPkg.Router, client grpcClient.ClientInterface, ...) *ProxyEndpoint
  • func (e *ProxyEndpoint) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func NewHandler

func NewHandler(reloader *EndpointReloader) http.Handler

Types

type Config

type Config struct {
	HTTP *ConfigHTTP `mapstructure:"http" validate:"required"`
}

type ConfigHTTP

type ConfigHTTP struct {
	MaxRequestSizeKB uint               `mapstructure:"maxRequestSizeKB"`
	RequestTimeout   time.Duration      `mapstructure:"requestTimeout" validate:"gte=0"`
	Server           *http.ServerConfig `mapstructure:"server" validate:"required"`
}

type EndpointReloader

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

EndpointReloader is wrapper for Handle method to allow dynamic endpoint reloading

func NewEndpointReloader

func NewEndpointReloader(handler http.Handler) *EndpointReloader

func (*EndpointReloader) Endpoint

func (e *EndpointReloader) Endpoint() http.Handler

func (*EndpointReloader) ServeHTTP

func (e *EndpointReloader) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*EndpointReloader) Set

func (e *EndpointReloader) Set(endpoint *ProxyEndpoint)

type Logger

type Logger interface {
	// Log error during request processing
	ErrorContext(ctx context.Context, msg string, args ...any)
}

type ProxyEndpoint

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

func NewProxyEndpoint

func NewProxyEndpoint(
	logger Logger,
	router *routerPkg.Router,
	client grpcClient.ClientInterface,
	jsonEncoder jsonencoder.Encoder,
) *ProxyEndpoint

func (*ProxyEndpoint) ServeHTTP

func (e *ProxyEndpoint) ServeHTTP(w http.ResponseWriter, r *http.Request)