proxy

package

v1.3.0 Latest Latest Go to latest Published: Oct 6, 2025 License: GPL-2.0 Imports: 18 Imported by: 0

Details

View Source

const (
	ClientAPIKeyContextKey contextKey = "client_api_key"
	InstanceIDContextKey   contextKey = "instance_id"
)

This section is empty.

func ClientAPIKeyMiddleware(store *models.ClientAPIKeyStore) func(http.Handler) http.Handler

ClientAPIKeyMiddleware validates client API keys and extracts instance information

func GetClientAPIKeyFromContext(ctx context.Context) *models.ClientAPIKey

GetClientAPIKeyFromContext retrieves the client API key from the request context

func GetInstanceIDFromContext(ctx context.Context) int

GetInstanceIDFromContext retrieves the instance ID from the request context

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

BufferPool provides a thread-safe pool of byte slices for the reverse proxy

func NewBufferPool() *BufferPool

NewBufferPool creates a new buffer pool with 32KB buffers

func (p *BufferPool) Get() []byte

Get returns a buffer from the pool

func (p *BufferPool) Put(buf []byte)

Put returns a buffer to the pool

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

Handler manages reverse proxy requests to qBittorrent instances

func NewHandler(clientPool *qbittorrent.ClientPool, clientAPIKeyStore *models.ClientAPIKeyStore, instanceStore *models.InstanceStore) *Handler

NewHandler creates a new proxy handler

func (h *Handler) Routes(r chi.Router)

Routes sets up the proxy routes

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

ServeHTTP handles the reverse proxy request