kubelink

type CIDR struct {
	Broadcast net.IP
	*net.IPNet
}

type FirewallRule struct {
	Allowed tcp.CIDRList
	Denied  tcp.CIDRList
}

type Link struct {
	Name           LinkName
	ServiceCIDR    *net.IPNet
	Egress         tcp.CIDRList
	Ingress        *FirewallRule
	ClusterAddress *net.IPNet
	GatewayLink    *LinkName
	GatewayFor     LinkNameSet
	Gateway        net.IP
	Host           string
	Port           int
	Endpoint       string
	PublicKey      *wgtypes.Key
	PresharedKey   *wgtypes.Key
	LinkForeignData
}

type LinkAccessInfo struct {
	CACert string
	Token  string
}

type LinkDNSInfo struct {
	ClusterDomain  string
	DnsIP          net.IP
	DNSPropagation bool
}

type LinkForeignData struct {
	UpdatePending bool
	LinkAccessInfo
	LinkDNSInfo
}

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

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

type LinkNameSet map[LinkName]struct{}

type LinkSpec = api.KubeLinkSpec

type Links interface {
	Setup(logger logger.LogContext, list []resources.Object)
	SetDefaultMesh(clusterName string, clusterAddress *net.IPNet, meshDNS LinkDNSInfo)

	SetGateway(ip net.IP)
	GetGateway() net.IP
	IsGateway(ifce *NodeInterface) bool

	IsGatewayLink(name LinkName) bool
	HasWireguard() bool
	RegisterLink(name LinkName, clusterCIDR *net.IPNet, fqdn string, cidr *net.IPNet) (*Link, error)

	GetLinks() map[LinkName]*Link
	GetLink(name LinkName) *Link
	LinkInfoUpdated(logger logger.LogContext, name LinkName, access *LinkAccessInfo, dns *LinkDNSInfo) *Link
	UpdateLinkInfo(logger logger.LogContext, name LinkName, access *LinkAccessInfo, dns *LinkDNSInfo, pending bool) (*Link, bool)
	ReplaceLink(link *Link) *Link
	UpdateLink(klink *api.KubeLink) (*Link, bool, error)
	RemoveLink(name LinkName)
	VisitLinks(visitor func(l *Link) bool)
	GetLinkForClusterAddress(ip net.IP) *Link
	GetLinkForIP(ip net.IP) *Link // TODO Rename
	GetLinkForEndpointHost(dnsname string) *Link

	ServedLinksFor(name LinkName) LinkNameSet

	GetMesh(name string) *Mesh
	GetMeshByLinkName(name LinkName) *Mesh
	GetMeshLink(name LinkName) *Link
	GetMeshLinks() map[LinkName]*Link
	GetMeshInfos() map[string]*Mesh
	GetMeshMembersFor(name string) LinkNameSet
	RemoveMesh(name string)
	MarkForDeletion(name LinkName)
	VisitMeshes(visitor func(m *Mesh, l *Link) bool)

	LookupMeshGatewaysFor(ip net.IP) tcp.IPList
	LookupClusterAddressByMeshAddress(ip net.IP) *net.IPNet
	LookupMeshByMeshAddress(ip net.IP) *Mesh

	GetRoutesToLink(ifce *NodeInterface, link netlink.Link) Routes
	GetRoutes(ifce *NodeInterface) Routes
	GetGatewayEgress(ifce *NodeInterface, meshCIDR *net.IPNet) tcp.CIDRList

	GetFirewallChains() iptables.Requests
	GetEgressChain(mesh *net.IPNet) *iptables.ChainRequest
	GetNatChains(clusterAddresses tcp.CIDRList, linkName string) iptables.Requests
	GetGatewayAddrs() tcp.CIDRList

	Locked(func(Links) error) error
}

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

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

type NodeInterface struct {
	Name  string
	Index int
	IP    net.IP
}

type Routes []netlink.Route

type RuleDef struct {
	Table  string
	Chain  string
	Rule   iptables.Rule
	Before string
}

type StringList []string

type StringLists []StringList