utils

Documentation

Index

• Constants
• Variables
• func GetNATType() (string, error)
• func GetPublicIP() (string, error)
• func GetPublicPort() (int, error)
• func Install(c *mux.Router)
• func RunMetaServer(ctx context.Context, addr string)

Constants

const (
	MaxRetries           = 15
	RavenProxyClientName = "raven-proxy-client"
	RavenProxyServerName = "raven-proxy-server"
	RavenProxyUserName   = "raven-proxy-user"

	RavenProxyClientCSRCN = "tunnel-agent-client"
	RavenProxyServerCSRCN = "tunnel-proxy-server"
	RavenProxyUserCSRCN   = "tunnel-proxy-client"
	RavenCSROrg           = "openyurt:yurttunnel"

	RavenCAFile    = "/var/run/secrets/kubernetes.io/serviceaccount/ca.crt"
	RavenTokenFile = "/var/run/secrets/kubernetes.io/serviceaccount/token"

	RavenProxyServerCertDir = "/var/lib/raven/proxy.server/pki"
	RavenProxyClientCertDir = "/var/lib/raven/proxy.client/pki"
	RavenProxyServerUDSFile = "/tmp/interceptor-proxier.sock"

	DefaultLoopBackIP4                   = "127.0.0.1"
	DefaultLoopBackIP6                   = "::1"
	RavenProxyHostHeaderKey              = "X-Tunnel-Proxy-Host"
	RavenProxyDestHeaderKey              = "X-Tunnel-Proxy-Dest"
	RavenProxyUserHeaderKey              = "User-Agent"
	RavenProxyServerForwardModeHeaderKey = "Forward-Mode"
	RavenProxyServerForwardLocalMode     = "Local"
	RavenProxyServerForwardRemoteMode    = "Remote"

	WorkingNamespace  = "kube-system"
	RavenConfigName   = "raven-cfg"
	RavenEnableProxy  = "enable-l7-proxy"
	RavenEnableTunnel = "enable-l3-tunnel"

	GatewayProxyInternalService  = "x-raven-proxy-internal-svc"
	LabelCurrentGatewayEndpoints = "raven.openyurt.io/endpoints-name"
	LabelCurrentGatewayType      = "raven.openyurt.io/gateway-type"

	NATSymmetric      = "Symmetric NAT"
	NATPortRestricted = "Port Restricted cone NAT"
	NATUndefined      = "Undefined"
)

Variables

var (
	NATType    string
	PublicPort int
)

var (
	APIs = [...]string{
		"https://ifconfig.me",
		"https://icanhazip.com",
		"https://ipinfo.io/json",
		"https://api.ipify.org",
		"https://api.my-ip.io/ip",
		"https://ip4.seeip.org",
	}
)

var IPv4RE = regexp.MustCompile(`(?:\d{1,3}\.){3}\d{1,3}`)

Functions

func GetNATType

func GetNATType() (string, error)

func GetPublicIP

func GetPublicIP() (string, error)

func GetPublicPort

func GetPublicPort() (int, error)

func Install

func Install(c *mux.Router)

Install adds the Profiling webservice to the given mux.

func RunMetaServer

func RunMetaServer(ctx context.Context, addr string)