proxy

package

v0.17.2 Latest Latest Go to latest Published: Sep 24, 2026 License: Apache-2.0 Imports: 31 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewProxyManager(ctx context.Context, logger logr.Logger) (*PmManager, error)

func (pm *PmManager) InstrumentHandler(registry prometheus.Registerer) http.Handler

func (pm *PmManager) Ready() bool

func (pm *PmManager) RegisterRoutes(e *echo.Echo, registry prometheus.Registerer)

func (pm *PmManager) ReverseProxy() *httputil.ReverseProxy

func (pm *PmManager) RoundTrip(req *http.Request) (*http.Response, error)

func (pm *PmManager) Start(ctx context.Context) error

func (pm *PmManager) WaitForCacheSync(ctx context.Context) error

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

func NewStore() *Store

func (s *Store) Delete(cluster string)

func (s *Store) Host(cluster string) (string, bool)

func (s *Store) Route(cluster, inURL string) (route, bool)

func (s *Store) SetRoutes(cluster string, routes map[string]route)

func (s *Store) SetTransport(cluster string, transport http.RoundTripper, host string)

func (s *Store) Transport(cluster string) (http.RoundTripper, bool)