internal

Feb 11, 2025

Changes in this version

type Config

+ GzipCompressionEnabled bool

Aug 6, 2024

Changes in this version

type Config

+ ForwardHeaders bool

+ func (c *Config) HasTLS() bool

Jul 9, 2024

Changes in this version

type Config

+ TLSDomains []string

Apr 26, 2024

Changes in this version

type Config

+ TLSDomain string

Mar 6, 2024

Changes in this version

+ const ENV_PREFIX

type Config

+ ACMEDirectoryURL string

+ EAB_HMACKey string

+ EAB_KID string

+ LogLevel slog.Level

Feb 28, 2024

Changes in this version

+ type CacheKey uint64

type CacheableResponse

+ VariantHeader http.Header

+ type Variant struct

+ func NewVariant(r *http.Request) *Variant

+ func (v *Variant) CacheKey() CacheKey

+ func (v *Variant) Matches(responseHeader http.Header) bool

+ func (v *Variant) SetResponseHeader(header http.Header)

+ func (v *Variant) VariantHeader() http.Header

Feb 14, 2024

Changes in this version

+ const KB

+ const MB

+ var ErrRequestBodyTooLarge = errors.New("request body too large")

+ func NewHandler(options HandlerOptions) http.Handler

+ func NewMaxRequestBodyHandler(maxBytes int, handler http.Handler) http.Handler

+ func NewProxyHandler(targetUrl *url.URL, badGatewayPage string) http.Handler

+ func NewStashingWriter(limit int, dest io.Writer) *stashingWriter

+ func ProxyErrorHandler(badGatewayPage string) func(w http.ResponseWriter, r *http.Request, err error)

+ type Cache interface

+ Get func(key uint64) ([]byte, bool)

+ Set func(key uint64, value []byte, expiresAt time.Time)

+ type CacheHandler struct

+ func NewCacheHandler(cache Cache, maxBodySize int, next http.Handler) *CacheHandler

+ func (h *CacheHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type CacheableResponse struct

+ Body []byte

+ HttpHeader http.Header

+ StatusCode int

+ func CacheableResponseFromBuffer(b []byte) (CacheableResponse, error)

+ func NewCacheableResponse(w http.ResponseWriter, maxBodyLength int) *CacheableResponse

+ func (c *CacheableResponse) CacheStatus() (bool, time.Time)

+ func (c *CacheableResponse) Header() http.Header

+ func (c *CacheableResponse) ToBuffer() ([]byte, error)

+ func (c *CacheableResponse) Write(bytes []byte) (int, error)

+ func (c *CacheableResponse) WriteCachedResponse(w http.ResponseWriter)

+ func (c *CacheableResponse) WriteHeader(statusCode int)

+ type Config struct

+ BadGatewayPage string

+ CacheSizeBytes int

+ HttpIdleTimeout time.Duration

+ HttpPort int

+ HttpReadTimeout time.Duration

+ HttpWriteTimeout time.Duration

+ HttpsPort int

+ MaxCacheItemSizeBytes int

+ MaxRequestBody int

+ SSLDomain string

+ StoragePath string

+ TargetPort int

+ UpstreamArgs []string

+ UpstreamCommand string

+ XSendfileEnabled bool

+ func NewConfig() (*Config, error)

+ type GetCurrentTime func() time.Time

+ type HandlerOptions struct

+ type LoggingMiddleware struct

+ func NewLoggingMiddleware(logger *slog.Logger, next http.Handler) *LoggingMiddleware

+ func (h *LoggingMiddleware) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type MemoryCache struct

+ func NewMemoryCache(capacity, maxItemSize int) *MemoryCache

+ func (c *MemoryCache) Get(key uint64) ([]byte, bool)

+ func (c *MemoryCache) Set(key uint64, value []byte, expiresAt time.Time)

+ type MemoryCacheEntry struct

+ type MemoryCacheEntryMap map[uint64]*MemoryCacheEntry

+ type MemoryCacheKeyList []uint64

+ type SendfileHandler struct

+ func NewSendfileHandler(enabled bool, next http.Handler) *SendfileHandler

+ func (h *SendfileHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Server struct

+ func NewServer(config *Config, handler http.Handler) *Server

+ func (s *Server) Start()

+ func (s *Server) Stop()

+ type Service struct

+ func NewService(config *Config) *Service

+ func (s *Service) Run() int

+ type UpstreamProcess struct

+ Started chan struct{}

+ func NewUpstreamProcess(name string, arg ...string) *UpstreamProcess

+ func (p *UpstreamProcess) Run() (int, error)

+ func (p *UpstreamProcess) Signal(sig os.Signal) error