service

package
v2.11.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 11, 2024 License: MIT Imports: 42 Imported by: 2

Documentation

Index

Constants

View Source
const StatusClientClosedRequest = 499

StatusClientClosedRequest non-standard HTTP status code for client disconnection.

View Source
const StatusClientClosedRequestText = "Client Closed Request"

StatusClientClosedRequestText non-standard HTTP status for client disconnection.

Variables

This section is empty.

Functions

func AddTransportOnContext added in v2.11.0

func AddTransportOnContext(ctx context.Context) context.Context

Types

type InternalHandlers

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

InternalHandlers is the internal HTTP handlers builder.

func NewInternalHandlers

func NewInternalHandlers(next serviceManager, apiHandler, rest, metricsHandler, pingHandler, dashboard, acmeHTTP http.Handler) *InternalHandlers

NewInternalHandlers creates a new InternalHandlers.

func (*InternalHandlers) BuildHTTP

func (m *InternalHandlers) BuildHTTP(rootCtx context.Context, serviceName string) (http.Handler, error)

BuildHTTP builds an HTTP handler.

type KerberosRoundTripper added in v2.11.0

type KerberosRoundTripper struct {
	OriginalRoundTripper http.RoundTripper
	// contains filtered or unexported fields
}

func (*KerberosRoundTripper) RoundTrip added in v2.11.0

func (k *KerberosRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)

type Manager

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

Manager The service manager.

func NewManager

func NewManager(configs map[string]*runtime.ServiceInfo, metricsRegistry metrics.Registry, routinePool *safe.Pool, roundTripperManager RoundTripperGetter) *Manager

NewManager creates a new Manager.

func (*Manager) BuildHTTP

func (m *Manager) BuildHTTP(rootCtx context.Context, serviceName string) (http.Handler, error)

BuildHTTP Creates a http.Handler for a service configuration.

func (*Manager) LaunchHealthCheck

func (m *Manager) LaunchHealthCheck()

LaunchHealthCheck launches the health checks.

type ManagerFactory

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

ManagerFactory a factory of service manager.

func NewManagerFactory

func NewManagerFactory(staticConfiguration static.Configuration, routinesPool *safe.Pool, metricsRegistry metrics.Registry, roundTripperManager *RoundTripperManager, acmeHTTPHandler http.Handler) *ManagerFactory

NewManagerFactory creates a new ManagerFactory.

func (*ManagerFactory) Build

func (f *ManagerFactory) Build(configuration *runtime.Configuration) *InternalHandlers

Build creates a service manager.

type RoundTripperGetter added in v2.4.0

type RoundTripperGetter interface {
	Get(name string) (http.RoundTripper, error)
}

RoundTripperGetter is a roundtripper getter interface.

type RoundTripperManager added in v2.4.0

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

RoundTripperManager handles roundtripper for the reverse proxy.

func NewRoundTripperManager added in v2.4.0

func NewRoundTripperManager() *RoundTripperManager

NewRoundTripperManager creates a new RoundTripperManager.

func (*RoundTripperManager) Get added in v2.4.0

Get get a roundtripper by name.

func (*RoundTripperManager) Update added in v2.4.0

func (r *RoundTripperManager) Update(newConfigs map[string]*dynamic.ServersTransport)

Update updates the roundtrippers configurations.

Directories

Path Synopsis
loadbalancer
wrr

Jump to

Keyboard shortcuts

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