controllers

Documentation

Index

• Constants
• func DeleteGlobalnetObjects(smClientSet *versioned.Clientset, cfg *rest.Config)
• func GetInternalSvcName(name string) string
• func RemoveGlobalIPAnnotationOnNode(cfg *rest.Config)
• func UninstallDataPath()
• 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(spec Specification, localCIDRs []string, config *watcher.Config) (Interface, error)
  • func NewGlobalEgressIPController(config *syncer.ResourceSyncerConfig, pool *ipam.IPPool) (Interface, error)
  • func NewGlobalIngressIPController(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)
  • func NewServiceExportController(config *syncer.ResourceSyncerConfig, podControllers *IngressPodControllers, ...) (Interface, error)
• 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
)

Functions

func DeleteGlobalnetObjects

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

func GetInternalSvcName

func GetInternalSvcName(name string) string

func RemoveGlobalIPAnnotationOnNode

func RemoveGlobalIPAnnotationOnNode(cfg *rest.Config)

func UninstallDataPath

func UninstallDataPath()

Types

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(spec Specification, localCIDRs []string, config *watcher.Config) (Interface, error)

func NewGlobalEgressIPController

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

func NewGlobalIngressIPController

func NewGlobalIngressIPController(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) (Interface, error)

func NewServiceExportController

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

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
	GnMetricsPort string `default:"8081"`
	Uninstall     bool
}