Documentation
¶
Index ¶
- Variables
- func DeleteServiceAccount(key, paralusAuthzSA, paralusAuthzRole, paralusAuthzRoleBind string, ...)
- func InitPeerCacheRoundTripper() error
- func InitUnixCacheRoundTripper() error
- func NewCachedKubeHandler(cfg *rest.Config, keepalive time.Duration) (*k8proxy.UpgradeAwareHandler, error)
- func NewCachedRoundTripper(rt http.RoundTripper) (http.RoundTripper, error)
- func PeerKubeHandler(tlscfg *tls.Config, relayIP string) (http.Handler, error)
- func UnixDialContext(sockPath, key, username, sni string) func(ctx context.Context, network, addr string) (net.Conn, error)
- func UnixKubeHandler(sockPath, key, username, sni string) (http.Handler, error)
- type Func
- type TCPProxy
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrInvalidUser is returned for invalid user ErrInvalidUser = errors.New("invalid user") )
View Source
var ( // ErrNotSAToken is returned when secret refered by service account is not of type service account token ErrNotSAToken = errors.New("secert is not of type ServiceAccountToken") )
Functions ¶
func DeleteServiceAccount ¶
func DeleteServiceAccount(key, paralusAuthzSA, paralusAuthzRole, paralusAuthzRoleBind string, delCache bool)
DeleteServiceAccount from cluster and cache
func InitPeerCacheRoundTripper ¶
func InitPeerCacheRoundTripper() error
InitPeerCacheRoundTripper initialize the cache
func InitUnixCacheRoundTripper ¶
func InitUnixCacheRoundTripper() error
InitUnixCacheRoundTripper initialize the cache
func NewCachedKubeHandler ¶
func NewCachedKubeHandler(cfg *rest.Config, keepalive time.Duration) (*k8proxy.UpgradeAwareHandler, error)
NewCachedKubeHandler is cached kube handler
func NewCachedRoundTripper ¶
func NewCachedRoundTripper(rt http.RoundTripper) (http.RoundTripper, error)
NewCachedRoundTripper returns new cached round tripper
func PeerKubeHandler ¶
PeerKubeHandler peer proxying handler
Types ¶
type Func ¶
type Func func(w io.Writer, r io.ReadCloser, msg *utils.ControlMessage, req *http.Request)
Func is responsible for forwarding a remote connection to local server and writing the response.
type TCPProxy ¶
type TCPProxy struct {
// contains filtered or unexported fields
}
TCPProxy forwards TCP streams.
func NewKubeCtlTCPProxy ¶
func NewKubeCtlTCPProxy(lg *relaylogger.RelayLog, cfg *utils.ProxyConfig) *TCPProxy
NewKubeCtlTCPProxy creates new direct TCPProxy, everything will be proxied to unix socket.
func NewTCPProxy ¶
func NewTCPProxy(lg *relaylogger.RelayLog, cfg *utils.ProxyConfig) *TCPProxy
NewTCPProxy creates new direct TCPProxy, everything will be proxied to unix socket.
Source Files
Click to show internal directories.
Click to hide internal directories.