process

package

v0.5.0 Latest Latest Go to latest Published: Apr 28, 2024 License: Apache-2.0 Imports: 22 Imported by: 16

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubewharf/katalyst-core

Links

Open Source Insights

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
type StopControl
- func NewStopControl(stopTime time.Time) *StopControl

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

Source Files ¶

View all Source files

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