util

Documentation

Index

• Constants
• Variables
• func ClientComponentFrom(ctx context.Context) (string, bool)
• func CreateKubeConfigFile(kubeClientConfig *rest.Config, kubeconfigPath string) error
• func Err(err error, w http.ResponseWriter, req *http.Request)
• func FileExists(filename string) (bool, error)
• func IsKubeletLeaseReq(req *http.Request) bool
• func IsSupportedCertMode(certMode string) bool
• func IsSupportedLBMode(lbMode string) bool
• func IsSupportedWorkingMode(workingMode WorkingMode) bool
• func KeyFunc(comp, resource, ns, name string) (string, error)
• func ListSelectorFrom(ctx context.Context) (string, bool)
• func LoadKubeConfig(kubeconfig string) (*clientcmdapi.Config, error)
• func LoadKubeletRestClientConfig(healthyServer *url.URL, kubeletRootCAFilePath, kubeletPairFilePath string) (*rest.Config, error)
• func LoadRESTClientConfig(kubeconfig string) (*rest.Config, error)
• func NewDualReadCloser(req *http.Request, rc io.ReadCloser, isRespBody bool) (io.ReadCloser, io.ReadCloser)
• func ReqCanCacheFrom(ctx context.Context) (bool, bool)
• func ReqContentTypeFrom(ctx context.Context) (string, bool)
• func ReqInfoString(info *apirequest.RequestInfo) string
• func ReqString(req *http.Request) string
• func RespContentTypeFrom(ctx context.Context) (string, bool)
• func SplitKey(key string) (comp, resource, ns, name string)
• func WithClientComponent(parent context.Context, component string) context.Context
• func WithListSelector(parent context.Context, selector string) context.Context
• func WithReqCanCache(parent context.Context, canCache bool) context.Context
• func WithReqContentType(parent context.Context, contentType string) context.Context
• func WithRespContentType(parent context.Context, contentType string) context.Context
• func WithValue(parent context.Context, key interface{}, val interface{}) context.Context
• func WriteObject(statusCode int, obj runtime.Object, w http.ResponseWriter, req *http.Request) error
• type DialFunc
• type Dialer
  • func NewDialer(name string) *Dialer
  • func (d *Dialer) Close(address string)
  • func (d *Dialer) CloseAll()
  • func (d *Dialer) Dial(network, address string) (net.Conn, error)
  • func (d *Dialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)
  • func (d *Dialer) Name() string
• type ProxyKeyType
• type WorkingMode

Constants

const (
	// YurtHubCertificateManagerName represents the certificateManager name in yurthub mode
	YurtHubCertificateManagerName = "hubself"
	// DefaultKubeletPairFilePath represents the default kubelet pair file path
	DefaultKubeletPairFilePath = "/var/lib/kubelet/pki/kubelet-client-current.pem"
	// DefaultKubeletRootCAFilePath represents the default kubelet ca file path
	DefaultKubeletRootCAFilePath = "/etc/kubernetes/pki/ca.crt"
	// ProxyReqContentType represents request content type context key
	ProxyReqContentType ProxyKeyType = iota
	// ProxyRespContentType represents response content type context key
	ProxyRespContentType
	// ProxyClientComponent represents client component context key
	ProxyClientComponent
	// ProxyReqCanCache represents request can cache context key
	ProxyReqCanCache
	// ProxyListSelector represents label selector and filed selector string for list request
	ProxyListSelector
	YurtHubNamespace   = "kube-system"
	CacheUserAgentsKey = "cache_agents"

	YurtHubProxyPort       = "10261"
	YurtHubPort            = "10267"
	YurtHubProxySecurePort = "10268"
)

Variables

var (
	DefaultCacheAgents   = []string{"kubelet", "kube-proxy", "flanneld", "coredns", projectinfo.GetAgentName(), projectinfo.GetHubName()}
	YurthubConfigMapName = fmt.Sprintf("%s-hub-cfg", strings.TrimRightFunc(projectinfo.GetProjectPrefix(), func(c rune) bool { return c == '-' }))
)

Functions

func ClientComponentFrom

func ClientComponentFrom(ctx context.Context) (string, bool)

ClientComponentFrom returns the value of the client component key on the ctx

func CreateKubeConfigFile

func CreateKubeConfigFile(kubeClientConfig *rest.Config, kubeconfigPath string) error

func Err

func Err(err error, w http.ResponseWriter, req *http.Request)

Err write err to response writer

func FileExists

func FileExists(filename string) (bool, error)

FileExists checks if specified file exists.

func IsKubeletLeaseReq

func IsKubeletLeaseReq(req *http.Request) bool

IsKubeletLeaseReq judge whether the request is a lease request from kubelet

func IsSupportedCertMode

func IsSupportedCertMode(certMode string) bool

IsSupportedCertMode check cert mode is supported or not

func IsSupportedLBMode

func IsSupportedLBMode(lbMode string) bool

IsSupportedLBMode check lb mode is supported or not

func IsSupportedWorkingMode

func IsSupportedWorkingMode(workingMode WorkingMode) bool

IsSupportedWorkingMode check working mode is supported or not

func KeyFunc

func KeyFunc(comp, resource, ns, name string) (string, error)

KeyFunc combine comp resource ns name into a key

func ListSelectorFrom

func ListSelectorFrom(ctx context.Context) (string, bool)

ListSelectorFrom returns the value of the list request selector string on the ctx

func LoadKubeConfig

func LoadKubeConfig(kubeconfig string) (*clientcmdapi.Config, error)

func LoadKubeletRestClientConfig

func LoadKubeletRestClientConfig(healthyServer *url.URL, kubeletRootCAFilePath, kubeletPairFilePath string) (*rest.Config, error)

LoadKubeletRestClientConfig load *rest.Config for accessing healthyServer

func LoadRESTClientConfig

func LoadRESTClientConfig(kubeconfig string) (*rest.Config, error)

func NewDualReadCloser

func NewDualReadCloser(req *http.Request, rc io.ReadCloser, isRespBody bool) (io.ReadCloser, io.ReadCloser)

NewDualReadCloser create an dualReadCloser object

func ReqCanCacheFrom

func ReqCanCacheFrom(ctx context.Context) (bool, bool)

ReqCanCacheFrom returns the value of the request can cache key on the ctx

func ReqContentTypeFrom

func ReqContentTypeFrom(ctx context.Context) (string, bool)

ReqContentTypeFrom returns the value of the request content type key on the ctx

func ReqInfoString

func ReqInfoString(info *apirequest.RequestInfo) string

ReqInfoString formats a string for request info

func ReqString

func ReqString(req *http.Request) string

ReqString formats a string for request

func RespContentTypeFrom

func RespContentTypeFrom(ctx context.Context) (string, bool)

RespContentTypeFrom returns the value of the response content type key on the ctx

func SplitKey

func SplitKey(key string) (comp, resource, ns, name string)

SplitKey split key into comp, resource, ns, name

func WithClientComponent

func WithClientComponent(parent context.Context, component string) context.Context

WithClientComponent returns a copy of parent in which the client component value is set

func WithListSelector

func WithListSelector(parent context.Context, selector string) context.Context

WithListSelector returns a copy of parent in which the list request selector string is set

func WithReqCanCache

func WithReqCanCache(parent context.Context, canCache bool) context.Context

WithReqCanCache returns a copy of parent in which the request can cache value is set

func WithReqContentType

func WithReqContentType(parent context.Context, contentType string) context.Context

WithReqContentType returns a copy of parent in which the response content type value is set

func WithRespContentType

func WithRespContentType(parent context.Context, contentType string) context.Context

WithRespContentType returns a copy of parent in which the request content type value is set

func WithValue

func WithValue(parent context.Context, key interface{}, val interface{}) context.Context

WithValue returns a copy of parent in which the value associated with key is val.

func WriteObject

func WriteObject(statusCode int, obj runtime.Object, w http.ResponseWriter, req *http.Request) error

WriteObject write object to response writer

Types

type DialFunc

type DialFunc func(ctx context.Context, network, address string) (net.Conn, error)

DialFunc is a shorthand for signature of net.DialContext.

type Dialer

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

Dialer opens connections through Dial and tracks them.

func NewDialer

func NewDialer(name string) *Dialer

NewDialer creates a new Dialer instance.

If dial is not nil, it will be used to create new underlying connections. Otherwise net.DialContext is used.

func (*Dialer) Close

func (d *Dialer) Close(address string)

Close forcibly closes all tracked connections that specified by address.

Note: new connections may get created before Close returns.

func (*Dialer) CloseAll

func (d *Dialer) CloseAll()

CloseAll forcibly closes all tracked connections.

Note: new connections may get created before CloseAll returns.

func (*Dialer) Dial

func (d *Dialer) Dial(network, address string) (net.Conn, error)

Dial creates a new tracked connection.

func (*Dialer) DialContext

func (d *Dialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)

DialContext creates a new tracked connection.

func (*Dialer) Name

func (d *Dialer) Name() string

Name returns the name of dialer

type ProxyKeyType

type ProxyKeyType int

ProxyKeyType represents the key in proxy request context

type WorkingMode

type WorkingMode string

WorkingMode represents the working mode of yurthub.

const (
	// WorkingModeCloud represents yurthub is working in cloud mode, which means yurthub is deployed on the cloud side.
	WorkingModeCloud WorkingMode = "cloud"
	// WorkingModeEdge represents yurthub is working in edge mode, which means yurthub is deployed on the edge side.
	WorkingModeEdge WorkingMode = "edge"
)