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
• type Option
  • func NewOption() Option
• type ServerOption
  • func (o *ServerOption) GetProxyOption() bool
  • func (o *ServerOption) GetTunnelOption() bool
  • func (o *ServerOption) SetProxyOption(enable bool)
  • func (o *ServerOption) SetTunnelOption(enable bool)

Constants

const (
	ConcurrentReconciles           = 1
	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"

	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

Types

type Option

type Option interface {
	SetProxyOption(enable bool)
	SetTunnelOption(enable bool)
	GetProxyOption() bool
	GetTunnelOption() bool
}

func NewOption

func NewOption() Option

type ServerOption

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

func (*ServerOption) GetProxyOption

func (o *ServerOption) GetProxyOption() bool

func (*ServerOption) GetTunnelOption

func (o *ServerOption) GetTunnelOption() bool

func (*ServerOption) SetProxyOption

func (o *ServerOption) SetProxyOption(enable bool)

func (*ServerOption) SetTunnelOption

func (o *ServerOption) SetTunnelOption(enable bool)