process

Documentation

Index

• Constants
• func CPUSetParse(s string) (sets.Int, error)
• func Dial(unixSocketPath string, timeout time.Duration) (*grpc.ClientConn, error)
• func GetAndUnmarshal(url string, v interface{}) error
• func NewDefaultHTTPClient() *http.Client
• func SetupSignalHandler() context.Context
• type HTTPHandler
  • func NewHTTPHandler(enabled []string, skipAuthURLPrefix []string, strictAuthentication bool, ...) *HTTPHandler
  • func (h *HTTPHandler) Run(ctx context.Context)
  • func (h *HTTPHandler) WithAuthorization(auth authorization.AccessControl) error
  • func (h *HTTPHandler) WithCredential(cred credential.Credential) error
  • func (h *HTTPHandler) WithHandleChain(f http.Handler) http.Handler
• type StopControl
  • func NewStopControl(stopTime time.Time) *StopControl
  • func (sc *StopControl) IsStopped() bool
  • func (sc *StopControl) Stop()
  • func (sc *StopControl) StopGracePeriodExpired() bool

Constants

const (
	HTTPChainCredential  = "credential"
	HTTPChainRateLimiter = "rateLimiter"
	HTTPChainMonitor     = "monitor"
)

const (
	HTTPRequestCount       = "http_request_count"
	HTTPAuthenticateFailed = "http_request_authenticate_failed"
	HTTPNoPermission       = "http_request_no_permission"
	HTTPThrottled          = "http_request_throttled"

	UserUnknown = "unknown"
)

const (
	KeyAuthInfo contextKey = "auth"
)

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

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

func (*HTTPHandler) WithCredential

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