process

package
v0.5.5 Latest Latest
Warning

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

Go to latest
Published: Jul 5, 2024 License: Apache-2.0 Imports: 22 Imported by: 16

Documentation

Index

Constants

View Source
const (
	HTTPChainCredential  = "credential"
	HTTPChainRateLimiter = "rateLimiter"
	HTTPChainMonitor     = "monitor"
)
View Source
const (
	HTTPRequestCount       = "http_request_count"
	HTTPAuthenticateFailed = "http_request_authenticate_failed"
	HTTPNoPermission       = "http_request_no_permission"
	HTTPThrottled          = "http_request_throttled"

	UserUnknown = "unknown"
)
View Source
const (
	KeyAuthInfo contextKey = "auth"
)

Variables

This section is empty.

Functions

func CPUSetParse

func CPUSetParse(s string) (sets.Int, error)

CPUSetParse constructs an integer cpu set from a Linux CPU list formatted string. See: http://man7.org/linux/man-pages/man7/cpuset.7.html#FORMATS

func Dial

func Dial(unixSocketPath string, timeout time.Duration) (*grpc.ClientConn, error)

func GetAndUnmarshal

func GetAndUnmarshal(url string, v interface{}) error

GetAndUnmarshal gets data from the given url and unmarshal it into the given struct.

func NewDefaultHTTPClient

func NewDefaultHTTPClient() *http.Client

NewDefaultHTTPClient returns a raw HTTP client.

func SetupSignalHandler

func SetupSignalHandler() context.Context

SetupSignalHandler registered for SIGTERM and SIGINT. A stop channel is returned which is closed on one of these signals. If a second signal is caught, the program is terminated with exit code 1.

Types

type HTTPHandler

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

func NewHTTPHandler

func NewHTTPHandler(enabled []string, skipAuthURLPrefix []string, strictAuthentication bool, emitter metrics.MetricEmitter) *HTTPHandler

func (*HTTPHandler) Run

func (h *HTTPHandler) Run(ctx context.Context)

func (*HTTPHandler) WithAuthorization added in v0.4.0

func (h *HTTPHandler) WithAuthorization(auth authorization.AccessControl) error

func (*HTTPHandler) WithCredential added in v0.4.0

func (h *HTTPHandler) WithCredential(cred credential.Credential) error

func (*HTTPHandler) WithHandleChain

func (h *HTTPHandler) WithHandleChain(f http.Handler) http.Handler

WithHandleChain builds handler chains for http.Handler

type StopControl

type StopControl struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewStopControl

func NewStopControl(stopTime time.Time) *StopControl

func (*StopControl) IsStopped

func (sc *StopControl) IsStopped() bool

func (*StopControl) Stop

func (sc *StopControl) Stop()

func (*StopControl) StopGracePeriodExpired

func (sc *StopControl) StopGracePeriodExpired() bool

Jump to

Keyboard shortcuts

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