ipam

Documentation

Overview

© 2021 Red Hat, Inc. and others

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

© 2021 Red Hat, Inc. and others

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

© 2021 Red Hat, Inc. and others

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

© 2021 Red Hat, Inc. and others

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

© 2021 Red Hat, Inc. and others

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

© 2021 Red Hat, Inc. and others

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

© 2021 Red Hat, Inc. and others

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

© 2021 Red Hat, Inc. and others

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

© 2021 Red Hat, Inc. and others

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• func CreateGlobalNetMarkingChain(ipt iptables.Interface) error
• func MarkRemoteClusterTraffic(ipt iptables.Interface, remoteCidr string, addRules bool)
• func RecordAllocateGlobalIP(cidr string)
• func RecordAvailability(cidr string, count int)
• func RecordDeallocateGlobalIP(cidr string)
• type Controller
  • func NewController(spec *SubmarinerIPAMControllerSpecification, config *InformerConfigStruct, ...) (*Controller, error)
  • func (i *Controller) Start(stopCh <-chan struct{}) error
• type GatewayMonitor
  • func NewGatewayMonitor(spec *SubmarinerIPAMControllerSpecification, ...) (*GatewayMonitor, error)
  • func (gm *GatewayMonitor) Start(stopCh <-chan struct{}) error
  • func (gm *GatewayMonitor) Stop()
• type IPPool
  • func NewIPPool(cidr string) (*IPPool, error)
  • func (p *IPPool) Allocate(key string) (string, error)
  • func (p *IPPool) GetAllocatedIP(key string) string
  • func (p *IPPool) IsAvailable(ip string) bool
  • func (p *IPPool) Release(key string) string
  • func (p *IPPool) RequestIP(key, ip string) (string, error)
• type InformerConfigStruct
• type Operation
• type SubmarinerIPAMControllerSpecification

Constants

const (
	SubmarinerIPAMGlobalIP = "submariner.io/globalIp"

	AddRules    = true
	DeleteRules = false

	Process = "Process"
	Ignore  = "Ignore"
	Requeue = "Requeue"
)

Functions

func CreateGlobalNetMarkingChain

func CreateGlobalNetMarkingChain(ipt iptables.Interface) error

func MarkRemoteClusterTraffic

func MarkRemoteClusterTraffic(ipt iptables.Interface, remoteCidr string, addRules bool)

func RecordAllocateGlobalIP

func RecordAllocateGlobalIP(cidr string)

func RecordAvailability

func RecordAvailability(cidr string, count int)

func RecordDeallocateGlobalIP

func RecordDeallocateGlobalIP(cidr string)

Types

type Controller

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

func NewController

func NewController(spec *SubmarinerIPAMControllerSpecification, config *InformerConfigStruct,
	globalCIDR, gwNodeName string) (*Controller, error)

func (*Controller) Start

func (i *Controller) Start(stopCh <-chan struct{}) error

type GatewayMonitor

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

func NewGatewayMonitor

func NewGatewayMonitor(spec *SubmarinerIPAMControllerSpecification,
	submarinerClient submarinerClientset.Interface, clientSet kubernetes.Interface,
	dynamicClient dynamic.Interface) (*GatewayMonitor, error)

func (*GatewayMonitor) Start

func (gm *GatewayMonitor) Start(stopCh <-chan struct{}) error

func (*GatewayMonitor) Stop

func (gm *GatewayMonitor) Stop()

type IPPool

type IPPool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewIPPool

func NewIPPool(cidr string) (*IPPool, error)

func (*IPPool) Allocate

func (p *IPPool) Allocate(key string) (string, error)

func (*IPPool) GetAllocatedIP

func (p *IPPool) GetAllocatedIP(key string) string

func (*IPPool) IsAvailable

func (p *IPPool) IsAvailable(ip string) bool

func (*IPPool) Release

func (p *IPPool) Release(key string) string

func (*IPPool) RequestIP

func (p *IPPool) RequestIP(key, ip string) (string, error)

type InformerConfigStruct

type InformerConfigStruct struct {
	KubeClientSet    kubernetes.Interface
	ServiceInformer  kubeInformers.ServiceInformer
	PodInformer      kubeInformers.PodInformer
	NodeInformer     kubeInformers.NodeInformer
	SvcExInformer    informers.GenericInformer
	DynamicClientSet dynamic.Interface
	SvcExGvr         schema.GroupVersionResource
}

type Operation

type Operation string

type SubmarinerIPAMControllerSpecification

type SubmarinerIPAMControllerSpecification struct {
	ClusterID  string
	ExcludeNS  []string
	Namespace  string
	GlobalCIDR []string
}