internal

package

Go to main page

Versions in this module

v0

v0.1.3

Mar 21, 2024

v0.1.2

Mar 19, 2024

v0.1.1

Mar 18, 2024

v0.1.0

Mar 7, 2024

v0.0.3

Mar 6, 2024

Changes in this version

+ const ENV_PREFIX

type Config

+ ACMEDirectoryURL string

+ EAB_HMACKey string

+ EAB_KID string

+ LogLevel slog.Level

v0.0.2

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

v0.0.0

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL