util

Documentation

Index

• Constants
• func AddDNSConfigmapToWorkQueue(q workqueue.RateLimitingInterface)
• func AddGatewayProxyInternalService(q workqueue.RateLimitingInterface)
• func AddGatewayToWorkQueue(gwName string, q workqueue.RateLimitingInterface)
• func CheckServer(ctx context.Context, client client.Client) (enableProxy, enableTunnel bool)
• func FormatName(name string) string
• func GetNodeInternalIP(node corev1.Node) string
• func HashObject(o interface{}) string
• func PrettyYaml(obj interface{}) string

Constants

const (
	WorkingNamespace               = "kube-system"
	RavenGlobalConfig              = "raven-cfg"
	RavenAgentConfig               = "raven-agent-config"
	LabelCurrentGatewayEndpoints   = "raven.openyurt.io/endpoints-name"
	GatewayProxyInternalService    = "x-raven-proxy-internal-svc"
	GatewayProxyServiceNamePrefix  = "x-raven-proxy-svc"
	GatewayTunnelServiceNamePrefix = "x-raven-tunnel-svc"
	ExtraAllowedSourceCIDRs        = "raven.openyurt.io/extra-allowed-source-cidrs"

	RavenProxyNodesConfig      = "edge-tunnel-nodes"
	ProxyNodesKey              = "tunnel-nodes"
	ProxyServerSecurePortKey   = "proxy-internal-secure-addr"
	ProxyServerInsecurePortKey = "proxy-internal-insecure-addr"
	ProxyServerExposedPortKey  = "proxy-external-addr"
	VPNServerExposedPortKey    = "tunnel-bind-addr"
	RavenEnableProxy           = "enable-l7-proxy"
	RavenEnableTunnel          = "enable-l3-tunnel"
)

Functions

func AddDNSConfigmapToWorkQueue

func AddDNSConfigmapToWorkQueue(q workqueue.RateLimitingInterface)

func AddGatewayProxyInternalService

func AddGatewayProxyInternalService(q workqueue.RateLimitingInterface)

func AddGatewayToWorkQueue

func AddGatewayToWorkQueue(gwName string,
	q workqueue.RateLimitingInterface)

AddGatewayToWorkQueue adds the Gateway the reconciler's workqueue

func CheckServer

func CheckServer(ctx context.Context, client client.Client) (enableProxy, enableTunnel bool)

func FormatName

func FormatName(name string) string

func GetNodeInternalIP

func GetNodeInternalIP(node corev1.Node) string

GetNodeInternalIP returns internal ip of the given `node`.

func HashObject

func HashObject(o interface{}) string

func PrettyYaml

func PrettyYaml(obj interface{}) string