kubernetes

Documentation

Index

• Constants
• func NewKubernetesProvider() (cloudprovider.CloudProvider, error)
• type HostPortPlugin
  • func (hpp *HostPortPlugin) Alias() string
  • func (hpp *HostPortPlugin) Init(c client.Client, options cloudprovider.CloudProviderOptions, ...) error
  • func (hpp *HostPortPlugin) Name() string
  • func (hpp *HostPortPlugin) OnPodAdded(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, errors.PluginError)
  • func (hpp *HostPortPlugin) OnPodDeleted(c client.Client, pod *corev1.Pod, ctx context.Context) errors.PluginError
  • func (hpp *HostPortPlugin) OnPodUpdated(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, errors.PluginError)
• type IngressPlugin
  • func (i IngressPlugin) Alias() string
  • func (i IngressPlugin) Init(client client.Client, options cloudprovider.CloudProviderOptions, ...) error
  • func (i IngressPlugin) Name() string
  • func (i IngressPlugin) OnPodAdded(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)
  • func (i IngressPlugin) OnPodDeleted(c client.Client, pod *corev1.Pod, ctx context.Context) cperrors.PluginError
  • func (i IngressPlugin) OnPodUpdated(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)
• type NodePortPlugin
  • func (n *NodePortPlugin) Alias() string
  • func (n *NodePortPlugin) Init(client client.Client, options cloudprovider.CloudProviderOptions, ...) error
  • func (n *NodePortPlugin) Name() string
  • func (n *NodePortPlugin) OnPodAdded(client client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)
  • func (n *NodePortPlugin) OnPodDeleted(client client.Client, pod *corev1.Pod, ctx context.Context) cperrors.PluginError
  • func (n *NodePortPlugin) OnPodUpdated(client client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)
• type Provider
  • func (kp *Provider) ListPlugins() (map[string]cloudprovider.Plugin, error)
  • func (kp *Provider) Name() string

Constants

const (
	HostPortNetwork = "Kubernetes-HostPort"
	//ContainerPortsKey represents the configuration key when using hostPort.
	//Its corresponding value format is as follows, containerName:port1/protocol1,port2/protocol2,... e.g. game-server:25565/TCP
	//When no protocol is specified, TCP is used by default
	ContainerPortsKey = "ContainerPorts"
)

const (
	IngressNetwork = "Kubernetes-Ingress"
	// PathTypeKey determines the interpretation of the Path matching, which is same as PathType in HTTPIngressPath.
	PathTypeKey = "PathType"
	// PathKey is matched against the path of an incoming request, the meaning of which is same as Path in HTTPIngressPath.
	// Users can add <id> to any position of the path, and the network plugin will generate the path corresponding to the game server.
	// e.g. /game<id>(/|$)(.*) The ingress path of GameServer 0 is /game0(/|$)(.*), the ingress path of GameServer 1 is /game1(/|$)(.*), and so on.
	PathKey = "Path"
	// PortKey indicates the exposed port value of game server.
	PortKey = "Port"
	// IngressClassNameKey indicates the name of the IngressClass cluster resource, which is same as IngressClassName in IngressSpec.
	IngressClassNameKey = "IngressClassName"
	// HostKey indicates domain name, which is same as Host in IngressRule.
	HostKey = "Host"
	// TlsHostsKey indicates hosts that included in the TLS certificate, the meaning of which is the same as that of Hosts in IngressTLS.
	// Its corresponding value format is as follows, host1,host2,... e.g. xxx.xx.com
	TlsHostsKey = "TlsHosts"
	// TlsSecretNameKey indicates the name of the secret used to terminate TLS traffic on port 443, which is same as SecretName in IngressTLS.
	TlsSecretNameKey = "TlsSecretName"
	// AnnotationKey is the key of an annotation for ingress.
	// Its corresponding value format is as follows, key: value(note that there is a space after: ) e.g. nginx.ingress.kubernetes.io/rewrite-target: /$2
	// If the user wants to fill in multiple annotations, just fill in multiple AnnotationKeys in the network config.
	AnnotationKey = "Annotation"
	// FixedKey indicates whether the ingress object is still retained when the pod is deleted.
	// If True, ingress will not be deleted even though the pod is deleted.
	// If False, ingress will be deleted along with pod deletion.
	FixedKey = "Fixed"
)

const (
	SvcSelectorKey = "statefulset.kubernetes.io/pod-name"
	IngressHashKey = "game.kruise.io/ingress-hash"
	ServiceHashKey = "game.kruise.io/svc-hash"
)

const (
	NodePortNetwork = "Kubernetes-NodePort"

	PortProtocolsConfigName = "PortProtocols"
)

Functions

func NewKubernetesProvider

func NewKubernetesProvider() (cloudprovider.CloudProvider, error)

Types

type HostPortPlugin

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

func (*HostPortPlugin) Alias

func (hpp *HostPortPlugin) Alias() string

func (*HostPortPlugin) Init

func (hpp *HostPortPlugin) Init(c client.Client, options cloudprovider.CloudProviderOptions, ctx context.Context) error

func (*HostPortPlugin) Name

func (hpp *HostPortPlugin) Name() string

func (*HostPortPlugin) OnPodAdded

func (hpp *HostPortPlugin) OnPodAdded(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, errors.PluginError)

func (*HostPortPlugin) OnPodDeleted

func (hpp *HostPortPlugin) OnPodDeleted(c client.Client, pod *corev1.Pod, ctx context.Context) errors.PluginError

func (*HostPortPlugin) OnPodUpdated

func (hpp *HostPortPlugin) OnPodUpdated(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, errors.PluginError)

type IngressPlugin

type IngressPlugin struct {
}

func (IngressPlugin) Alias

func (i IngressPlugin) Alias() string

func (IngressPlugin) Init

func (i IngressPlugin) Init(client client.Client, options cloudprovider.CloudProviderOptions, ctx context.Context) error

func (IngressPlugin) Name

func (i IngressPlugin) Name() string

func (IngressPlugin) OnPodAdded

func (i IngressPlugin) OnPodAdded(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)

func (IngressPlugin) OnPodDeleted

func (i IngressPlugin) OnPodDeleted(c client.Client, pod *corev1.Pod, ctx context.Context) cperrors.PluginError

func (IngressPlugin) OnPodUpdated

func (i IngressPlugin) OnPodUpdated(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)

type NodePortPlugin

type NodePortPlugin struct {
}

func (*NodePortPlugin) Alias

func (n *NodePortPlugin) Alias() string

func (*NodePortPlugin) Init

func (n *NodePortPlugin) Init(client client.Client, options cloudprovider.CloudProviderOptions, ctx context.Context) error

func (*NodePortPlugin) Name

func (n *NodePortPlugin) Name() string

func (*NodePortPlugin) OnPodAdded

func (n *NodePortPlugin) OnPodAdded(client client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)

func (*NodePortPlugin) OnPodDeleted

func (n *NodePortPlugin) OnPodDeleted(client client.Client, pod *corev1.Pod, ctx context.Context) cperrors.PluginError

func (*NodePortPlugin) OnPodUpdated

func (n *NodePortPlugin) OnPodUpdated(client client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)

type Provider

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

func (*Provider) ListPlugins

func (kp *Provider) ListPlugins() (map[string]cloudprovider.Plugin, error)

func (*Provider) Name

func (kp *Provider) Name() string