controllers

Documentation

Index

• Constants
• func DeleteGlobalnetObjects(smClientSet *versioned.Clientset, cfg *rest.Config)
• func GetInternalSvcName(name string) string
• func NewGlobalIngressIPController(config *syncer.ResourceSyncerConfig, pool *ipam.IPPool) (*globalIngressIPController, error)
• func NewServiceExportController(config *syncer.ResourceSyncerConfig, podControllers *IngressPodControllers, ...) (*serviceExportController, error)
• func RemoveGlobalIPAnnotationOnNode(cfg *rest.Config)
• func RemoveStaleInternalServices(config *syncer.ResourceSyncerConfig) error
• func UninstallDataPath()
• type GatewayMonitorConfig
• type IngressEndpointsControllers
  • func NewIngressEndpointsControllers(config *syncer.ResourceSyncerConfig) (*IngressEndpointsControllers, error)
• type IngressPodControllers
  • func NewIngressPodControllers(config *syncer.ResourceSyncerConfig) (*IngressPodControllers, error)
• type Interface
  • func NewClusterGlobalEgressIPController(config *syncer.ResourceSyncerConfig, localSubnets []string, pool *ipam.IPPool) (Interface, error)
  • func NewGatewayMonitor(config *GatewayMonitorConfig) (Interface, error)
  • func NewGlobalEgressIPController(config *syncer.ResourceSyncerConfig, pool *ipam.IPPool) (Interface, error)
  • func NewNodeController(config *syncer.ResourceSyncerConfig, pool *ipam.IPPool, nodeName string) (Interface, error)
  • func NewServiceController(config *syncer.ResourceSyncerConfig, podControllers *IngressPodControllers, ...) (Interface, error)
• type LeaderElectionConfig
• type LeaderElectionInfo
• type ServiceExportEndpointsControllers
  • func NewServiceExportEndpointsControllers(config *syncer.ResourceSyncerConfig) (*ServiceExportEndpointsControllers, error)
• type Specification

Constants

const (
	ServiceRefLabel = "submariner.io/serviceRef"

	// InternalServicePrefix is a prefix used for internal services.
	InternalServicePrefix = "submariner-"

	// InternalServiceLabel is a label applied on the internal service created by Globalnet controller and
	// it points to the exported service.
	InternalServiceLabel = "submariner.io/exportedServiceRef"

	// InternalServiceFinalizer is applied on the internal services created by Globalnet controller
	// to protect them from accidental deletion.
	InternalServiceFinalizer = "submariner.io/globalnet-internal-service"

	// The prefix used for the ipset chains created by Globalnet pod.
	IPSetPrefix = "SM-GN-"

	AddRules    = true
	DeleteRules = false

	DefaultNumberOfClusterEgressIPs = 8

	LeaderElectionLockName = "submariner-globalnet-lock"
)

Functions

func DeleteGlobalnetObjects

func DeleteGlobalnetObjects(smClientSet *versioned.Clientset, cfg *rest.Config)

func GetInternalSvcName

func GetInternalSvcName(name string) string

func NewGlobalIngressIPController

func NewGlobalIngressIPController(config *syncer.ResourceSyncerConfig, pool *ipam.IPPool) (*globalIngressIPController, error)

func NewServiceExportController

func NewServiceExportController(config *syncer.ResourceSyncerConfig, podControllers *IngressPodControllers,
	endpointsControllers *ServiceExportEndpointsControllers,
	ingressEndpointsControllers *IngressEndpointsControllers,
) (*serviceExportController, error)

func RemoveGlobalIPAnnotationOnNode

func RemoveGlobalIPAnnotationOnNode(cfg *rest.Config)

func RemoveStaleInternalServices

func RemoveStaleInternalServices(config *syncer.ResourceSyncerConfig) error

func UninstallDataPath

func UninstallDataPath()

Types

type GatewayMonitorConfig

type GatewayMonitorConfig struct {
	RestMapper meta.RESTMapper
	Client     dynamic.Interface
	Scheme     *runtime.Scheme
	LeaderElectionConfig
	Spec       Specification
	LocalCIDRs []string
	KubeClient kubernetes.Interface
	Hostname   string
}

type IngressEndpointsControllers

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

func NewIngressEndpointsControllers

func NewIngressEndpointsControllers(config *syncer.ResourceSyncerConfig) (*IngressEndpointsControllers, error)

type IngressPodControllers

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

func NewIngressPodControllers

func NewIngressPodControllers(config *syncer.ResourceSyncerConfig) (*IngressPodControllers, error)

type Interface

type Interface interface {
	Start() error
	Stop()
}

func NewClusterGlobalEgressIPController

func NewClusterGlobalEgressIPController(config *syncer.ResourceSyncerConfig, localSubnets []string,
	pool *ipam.IPPool,
) (Interface, error)

func NewGatewayMonitor

func NewGatewayMonitor(config *GatewayMonitorConfig) (Interface, error)

func NewGlobalEgressIPController

func NewGlobalEgressIPController(config *syncer.ResourceSyncerConfig, pool *ipam.IPPool) (Interface, error)

func NewNodeController

func NewNodeController(config *syncer.ResourceSyncerConfig, pool *ipam.IPPool, nodeName string) (Interface, error)

func NewServiceController

func NewServiceController(config *syncer.ResourceSyncerConfig, podControllers *IngressPodControllers, serviceExportSyncer syncer.Interface,
	gipSyncer syncer.Interface,
) (Interface, error)

type LeaderElectionConfig

type LeaderElectionConfig struct {
	LeaseDuration time.Duration
	RenewDeadline time.Duration
	RetryPeriod   time.Duration
}

type LeaderElectionInfo

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

type ServiceExportEndpointsControllers

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

func NewServiceExportEndpointsControllers

func NewServiceExportEndpointsControllers(config *syncer.ResourceSyncerConfig) (*ServiceExportEndpointsControllers, error)

type Specification

type Specification struct {
	ClusterID   string
	Namespace   string
	GlobalCIDR  []string
	MetricsPort int `default:"32781"`
	Uninstall   bool
}