controllers

Documentation

Index

• Constants
• 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 Specification

Constants

const (
	ServiceRefLabel = "submariner.io/serviceRef"

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

	AddRules    = true
	DeleteRules = false

	DefaultNumberOfClusterEgressIPs = 8
)

Types

type IngressPodControllers

type IngressPodControllers struct {
	sync.Mutex
	// 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) (Interface, error)

type Specification

type Specification struct {
	ClusterID  string
	Namespace  string
	GlobalCIDR []string
}