alibabacloud

Documentation

Index

• Constants
• func NewAlibabaCloudProvider() (cloudprovider.CloudProvider, error)
• type NatGwPlugin
  • func (n NatGwPlugin) Alias() string
  • func (n NatGwPlugin) Init(c client.Client, options cloudprovider.CloudProviderOptions, ...) error
  • func (n NatGwPlugin) Name() string
  • func (n NatGwPlugin) OnPodAdded(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, errors.PluginError)
  • func (n NatGwPlugin) OnPodDeleted(c client.Client, pod *corev1.Pod, ctx context.Context) errors.PluginError
  • func (n NatGwPlugin) OnPodUpdated(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, errors.PluginError)
• type Provider
  • func (ap *Provider) ListPlugins() (map[string]cloudprovider.Plugin, error)
  • func (ap *Provider) Name() string
• type SlbPlugin
  • func (s *SlbPlugin) Alias() string
  • func (s *SlbPlugin) Init(c client.Client, options cloudprovider.CloudProviderOptions, ...) error
  • func (s *SlbPlugin) Name() string
  • func (s *SlbPlugin) OnPodAdded(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)
  • func (s *SlbPlugin) OnPodDeleted(c client.Client, pod *corev1.Pod, ctx context.Context) cperrors.PluginError
  • func (s *SlbPlugin) OnPodUpdated(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)
• type SlbSpPlugin
  • func (s *SlbSpPlugin) Alias() string
  • func (s *SlbSpPlugin) Init(c client.Client, options cloudprovider.CloudProviderOptions, ...) error
  • func (s *SlbSpPlugin) Name() string
  • func (s *SlbSpPlugin) OnPodAdded(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)
  • func (s *SlbSpPlugin) OnPodDeleted(c client.Client, pod *corev1.Pod, ctx context.Context) cperrors.PluginError
  • func (s *SlbSpPlugin) OnPodUpdated(c client.Client, pod *corev1.Pod, ctx context.Context) (*corev1.Pod, cperrors.PluginError)

Constants

const (
	NATGWNetwork       = "AlibabaCloud-NATGW"
	AliasNATGW         = "NATGW-Network"
	FixedConfigName    = "Fixed"
	PortsConfigName    = "Ports"
	ProtocolConfigName = "Protocol"
	DnatAnsKey         = "k8s.aliyun.com/pod-dnat"
	PortsAnsKey        = "k8s.aliyun.com/pod-dnat-expose-port"
	ProtocolAnsKey     = "k8s.aliyun.com/pod-dnat-expose-protocol"
	FixedAnsKey        = "k8s.aliyun.com/pod-dnat-fixed"
)

const (
	SlbNetwork              = "AlibabaCloud-SLB"
	AliasSLB                = "LB-Network"
	SlbIdsConfigName        = "SlbIds"
	PortProtocolsConfigName = "PortProtocols"
	SlbListenerOverrideKey  = "service.beta.kubernetes.io/alibaba-cloud-loadbalancer-force-override-listeners"
	SlbIdAnnotationKey      = "service.beta.kubernetes.io/alibaba-cloud-loadbalancer-id"
	SlbIdLabelKey           = "service.k8s.alibaba/loadbalancer-id"
	SvcSelectorKey          = "statefulset.kubernetes.io/pod-name"
	SlbConfigHashKey        = "game.kruise.io/network-config-hash"
)

const (
	SlbSPNetwork  = "AlibabaCloud-SLB-SharedPort"
	SvcSLBSPLabel = "game.kruise.io/AlibabaCloud-SLB-SharedPort"
)

const (
	AlibabaCloud = "AlibabaCloud"
)

const (
	ErrorUpperLimit = "the number of backends supported by slb reaches the upper limit"
)

Functions

func NewAlibabaCloudProvider

func NewAlibabaCloudProvider() (cloudprovider.CloudProvider, error)

Types

type NatGwPlugin

type NatGwPlugin struct {
}

func (NatGwPlugin) Alias

func (n NatGwPlugin) Alias() string

func (NatGwPlugin) Init

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

func (NatGwPlugin) Name

func (n NatGwPlugin) Name() string

func (NatGwPlugin) OnPodAdded

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

func (NatGwPlugin) OnPodDeleted

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

func (NatGwPlugin) OnPodUpdated

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

type Provider

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

func (*Provider) ListPlugins

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

func (*Provider) Name

func (ap *Provider) Name() string

type SlbPlugin

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

func (*SlbPlugin) Alias

func (s *SlbPlugin) Alias() string

func (*SlbPlugin) Init

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

func (*SlbPlugin) Name

func (s *SlbPlugin) Name() string

func (*SlbPlugin) OnPodAdded

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

func (*SlbPlugin) OnPodDeleted

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

func (*SlbPlugin) OnPodUpdated

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

type SlbSpPlugin

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

func (*SlbSpPlugin) Alias

func (s *SlbSpPlugin) Alias() string

func (*SlbSpPlugin) Init

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

func (*SlbSpPlugin) Name

func (s *SlbSpPlugin) Name() string

func (*SlbSpPlugin) OnPodAdded

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

func (*SlbSpPlugin) OnPodDeleted

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

func (*SlbSpPlugin) OnPodUpdated

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