controllers

package
v0.0.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 17, 2021 License: Apache-2.0, BSD-3-Clause, MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const CMD_UPDATE = "update"
View Source 
const IPCHAIN = "POSTROUTING"
View Source 
const IPIP_CONFIGURE = "configure"
View Source 
const IPIP_NONE = "none"
View Source 
const IPIP_SHARED = "shared"
View Source 
const IPTAB = "nat"

Variables

View Source 
var ENDPOINTS = resources.NewGroupKind("", "Endpoints")
View Source 
var SECRET = resources.NewGroupKind("", "Secret")
View Source 
var SERVICE = resources.NewGroupKind("", "Service")

Functions

func BaseController 

func BaseController(name string, config config.OptionSource) controller.Configuration

func GetEndpoints 

func GetEndpoints(logger *utils.Notifier, obj resources.Object) []net.IP

func GetServicePort 

func GetServicePort(cntr controller.Interface, name string, kind string, proto corev1.Protocol) (int, error)
func IsLocalLink(klink *api.KubeLink) bool

func ObjectName 

func ObjectName(name kubelink.LinkName) resources.ObjectName

func SecretCacheReconciler 

func SecretCacheReconciler(config controller.Configuration) controller.Configuration

func String 

func String(r netlink.Route) string

Types

type Common 

type Common struct {
	reconcile.DefaultReconciler
	// contains filtered or unexported fields
}

func NewCommon 

func NewCommon(controller controller.Interface) Common

func (*Common) Controller 

func (this *Common) Controller() controller.Interface
func (this *Common) TriggerLink(name kubelink.LinkName)

func (*Common) TriggerUpdate 

func (this *Common) TriggerUpdate()

type Config 

type Config struct {
	NodeCIDR *net.IPNet
	IPIP     string
	// contains filtered or unexported fields
}

func (*Config) AddOptionsToSet 

func (this *Config) AddOptionsToSet(set config.OptionSet)

func (*Config) OptionalCIDR 

func (this *Config) OptionalCIDR(s, name string) (net.IP, *net.IPNet, error)

func (*Config) Prepare 

func (this *Config) Prepare() error

func (*Config) RequireCIDR 

func (this *Config) RequireCIDR(s, name string) (net.IP, *net.IPNet, error)

type EmbeddingFunction 

type EmbeddingFunction func() ([]kubelink.RuleDef, utils.StringSet)

type LinkInfo 

type LinkInfo struct {
	Gateway net.IP
	State   string
	Message string
}

type LinkTool 

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

func NewLinkTool 

func NewLinkTool() (*LinkTool, error)

func (*LinkTool) AppendRule 

func (this *LinkTool) AppendRule(t string, c string, r iptables.Rule) error

func (*LinkTool) AssureChains 

func (this *LinkTool) AssureChains(logger utils.NotificationLogger, header string, chains iptables.Requests, cleanup ...string) error

func (*LinkTool) AssureRule 

func (this *LinkTool) AssureRule(logger utils.NotificationLogger, t string, c string, r iptables.Rule, before string) error

func (*LinkTool) ChainRequest 

func (this *LinkTool) ChainRequest(logger utils.NotificationLogger, req *iptables.ChainRequest) error

func (*LinkTool) ClearChain 

func (this *LinkTool) ClearChain(logger utils.NotificationLogger, t string, c string) error

func (*LinkTool) DeleteChain 

func (this *LinkTool) DeleteChain(logger utils.NotificationLogger, t string, c string) error

func (*LinkTool) DeleteRule 

func (this *LinkTool) DeleteRule(t string, c string, r iptables.Rule) error

func (*LinkTool) ExistsRule 

func (this *LinkTool) ExistsRule(t string, c string, r iptables.Rule) (bool, error)

func (*LinkTool) HandleFirewall 

func (this *LinkTool) HandleFirewall(logger logger.LogContext, chains iptables.Requests) error

func (*LinkTool) HandleNat 

func (this *LinkTool) HandleNat(logger logger.LogContext, chains iptables.Requests) error

func (*LinkTool) ListChains 

func (this *LinkTool) ListChains(t string) ([]string, error)

func (*LinkTool) ManageChains 

func (this *LinkTool) ManageChains(logger logger.LogContext, area string, embed EmbeddingFunction, chains iptables.Requests) error

func (*LinkTool) NatRulesAppend 

func (this *LinkTool) NatRulesAppend(rule ...string) error

func (*LinkTool) NatRulesDelete 

func (this *LinkTool) NatRulesDelete(rule ...string) error

func (*LinkTool) NatRulesExists 

func (this *LinkTool) NatRulesExists(rule ...string) (bool, error)
func (this *LinkTool) PrepareLink(logger logger.LogContext, link netlink.Link, clusterAddresses tcp.CIDRList, chains iptables.Requests) (func(), error)

func (*LinkTool) SetLinkAddress 

func (this *LinkTool) SetLinkAddress(link netlink.Link, addr *net.IPNet) error

func (*LinkTool) SetNATRule 

func (this *LinkTool) SetNATRule(link netlink.Link, clusterAddress *net.IPNet) (func(), error)

func (*LinkTool) UpdateLinkAddresses 

func (this *LinkTool) UpdateLinkAddresses(logger logger.LogContext, link netlink.Link, addrs tcp.CIDRList) error

type LocalGatewayInfo 

type LocalGatewayInfo struct {
	Gateway   net.IP
	PublicKey string
}

type NotificationHandler 

type NotificationHandler interface {
	NotifyChange(name resources.ObjectName, object resources.Object)
}

func NotificationFunction 

func NotificationFunction(f func(resources.ObjectName, resources.Object)) NotificationHandler

type Reconciler 

type Reconciler struct {
	Common
	// contains filtered or unexported fields
}

func CreateBaseReconciler 

func CreateBaseReconciler(controller controller.Interface, impl ReconcilerImplementation, defaultport int) (*Reconciler, error)

func (*Reconciler) Command 

func (this *Reconciler) Command(logger logger.LogContext, cmd string) reconcile.Status

func (*Reconciler) Config 

func (this *Reconciler) Config() config.OptionSource

func (*Reconciler) Delete 

func (this *Reconciler) Delete(logger logger.LogContext, obj resources.Object) reconcile.Status

func (*Reconciler) Deleted 

func (this *Reconciler) Deleted(logger logger.LogContext, key resources.ClusterObjectKey) reconcile.Status

func (*Reconciler) LinkTool 

func (this *Reconciler) LinkTool() *LinkTool
func (this *Reconciler) Links() kubelink.Links

func (*Reconciler) NodeInterface 

func (this *Reconciler) NodeInterface() *kubelink.NodeInterface

func (*Reconciler) Reconcile 

func (this *Reconciler) Reconcile(logger logger.LogContext, obj resources.Object) reconcile.Status
func (this *Reconciler) ReconcileAndGetLink(logger logger.LogContext, obj resources.Object) (*kubelink.Link, reconcile.Status)
func (this *Reconciler) ReconcileLink(logger logger.LogContext, obj resources.Object) reconcile.Status

func (*Reconciler) Setup 

func (this *Reconciler) Setup()

func (*Reconciler) SetupIPIP 

func (this *Reconciler) SetupIPIP() error

func (*Reconciler) Start 

func (this *Reconciler) Start()

func (*Reconciler) WaitIPIP 

func (this *Reconciler) WaitIPIP()

func (*Reconciler) WaitNetworkReady 

func (this *Reconciler) WaitNetworkReady()

type ReconcilerImplementation 

type ReconcilerImplementation interface {
	IsManagedRoute(*netlink.Route, kubelink.Routes) bool
	RequiredRoutes() kubelink.Routes
	RequiredIPTablesChains() iptables.Requests
	BaseConfig(config.OptionSource) *Config

	Gateway(obj *api.KubeLink) (*LocalGatewayInfo, error)
	GetLinkInfo(link *api.KubeLink) *LinkInfo

	HandleReconcile(logger logger.LogContext, obj resources.Object, entry *kubelink.Link) (error, error)
	HandleDelete(logger logger.LogContext, name kubelink.LinkName, obj resources.Object) (bool, error)
}

type SecretCache 

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

func GetSharedSecrets 

func GetSharedSecrets(controller controller.Interface) *SecretCache

func NewSecretCache 

func NewSecretCache(r resources.ResourcesSource) *SecretCache

func (*SecretCache) AddNotificationHandler 

func (this *SecretCache) AddNotificationHandler(h NotificationHandler, names ...resources.ObjectName) error

func (*SecretCache) AllocSecret 

func (this *SecretCache) AllocSecret(name resources.ObjectName, link resources.ObjectName)

func (*SecretCache) GetSecretUsers 

func (this *SecretCache) GetSecretUsers(name resources.ObjectName) resources.ObjectNameSet

func (*SecretCache) Notify 

func (this *SecretCache) Notify(name resources.ObjectName, obj resources.Object)

func (*SecretCache) ReleaseSecret 

func (this *SecretCache) ReleaseSecret(name resources.ObjectName, link resources.ObjectName)
func (this *SecretCache) ReleaseSecretForLink(link resources.ObjectName)

func (*SecretCache) RemoveNotificationHandler 

func (this *SecretCache) RemoveNotificationHandler(h NotificationHandler, names ...resources.ObjectName) error

func (*SecretCache) UpdateSecret 

func (this *SecretCache) UpdateSecret(name resources.ObjectName, link resources.ObjectName)

type StatusUpdater 

type StatusUpdater func(obj *api.KubeLink, err error) (bool, error)

Source Files

View all Source files

Directories

Path Synopsis
config
runmode
runmode/bridge
runmode/wireguard

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.