proxy.go RawHistoryFolder

1package in
2
3import (
4	"context"
5
6	"github.com/bnema/gordon/internal/domain"
7)
8
9// ProxyService defines the contract for proxy routing and state management.
10// HTTP request handling is the adapter's responsibility (adapters/in/http/proxy).
11type ProxyService interface {
12	// GetTarget returns the proxy target for a given domain.
13	GetTarget(ctx context.Context, domain string) (*domain.ProxyTarget, error)
14
15	// RegisterTarget registers a new proxy target for a domain.
16	RegisterTarget(ctx context.Context, domain string, target *domain.ProxyTarget) error
17
18	// UnregisterTarget removes a proxy target for a domain.
19	UnregisterTarget(ctx context.Context, domain string) error
20
21	// RefreshTargets refreshes all proxy targets from container state.
22	RefreshTargets(ctx context.Context) error
23
24	// IsRegistryDomain returns true if the host matches the configured registry domain.
25	IsRegistryDomain(host string) bool
26
27	// TrackInFlight records an in-flight request for a container.
28	// Returns a release function that must be called when the request completes.
29	TrackInFlight(containerID string) func()
30
31	// TrackRegistryRequest increments the registry in-flight counter.
32	TrackRegistryRequest()
33
34	// ReleaseRegistryRequest decrements the registry in-flight counter.
35	ReleaseRegistryRequest()
36
37	// ProxyConfig returns the current proxy configuration.
38	// The adapter uses this for HTTP-level enforcement (body size, response size, concurrency).
39	ProxyConfig() ProxyServiceConfig
40}
41
42// ProxyServiceConfig holds configuration that the proxy adapter needs
43// from the usecase layer for HTTP-level enforcement.
44type ProxyServiceConfig struct {
45	RegistryDomain     string
46	RegistryPort       int
47	MaxBodySize        int64
48	MaxResponseSize    int64
49	MaxConcurrentConns int
50}