kubelink

Documentation

Index

• Constants
• func ShowRoutes(name string) error
• type CIDR
  • func ParseCIDR(s string) (*CIDR, error)
• type Link
  • func (this *Link) AllowIngress(ip net.IP) (granted bool, set bool)
  • func (this *Link) String() string
• type LinkAccessInfo
  • func (this LinkAccessInfo) Equal(other LinkAccessInfo) bool
  • func (this LinkAccessInfo) String() string
• type LinkDNSInfo
  • func (this LinkDNSInfo) Equal(other LinkDNSInfo) bool
  • func (this LinkDNSInfo) String() string
• type LinkForeignData
• type Links
  • func GetSharedLinks(controller controller.Interface) *Links
  • func NewLinks(resc resources.Interface) *Links
  • func (this *Links) GetLink(name string) *Link
  • func (this *Links) GetLinkForClusterAddress(ip net.IP) *Link
  • func (this *Links) GetLinkForEndpoint(dnsname string) *Link
  • func (this *Links) GetLinkForIP(ip net.IP) *Link
  • func (this *Links) GetRoutes(ifce *NodeInterface) Routes
  • func (this *Links) GetRoutesToLink(ifce *NodeInterface, link netlink.Link) Routes
  • func (this *Links) GetSNATRules(ifce *NodeInterface) iptables.Requests
  • func (this *Links) LinkFor(link *v1alpha1.KubeLink) (*Link, error)
  • func (this *Links) LinkInfoUpdated(logger logger.LogContext, name string, access *LinkAccessInfo, ...) *Link
  • func (this *Links) RegisterLink(name string, clusterCIDR *net.IPNet, fqdn string, cidr *net.IPNet) (*Link, error)
  • func (this *Links) RemoveLink(name string)
  • func (this *Links) Setup(logger logger.LogContext, cluster cluster.Interface)
  • func (this *Links) UpdateLink(klink *v1alpha1.KubeLink) (*Link, error)
  • func (this *Links) UpdateLinkInfo(logger logger.LogContext, name string, access *LinkAccessInfo, ...) (*Link, bool)
  • func (this *Links) Visit(visitor func(l *Link) bool)
• type NodeInterface
  • func LookupNodeIP(logger logger.LogContext, cidr *net.IPNet) (*NodeInterface, error)
• type Routes
  • func ListRoutes() (Routes, error)
  • func ListRoutesForInterface(name string) (Routes, error)
  • func (this *Routes) Add(route netlink.Route) Routes
  • func (this Routes) Lookup(route netlink.Route) int
  • func (this Routes) LookupAndLogMismatchReason(logger logger.LogContext, route netlink.Route) int
• type StringList
  • func (this StringList) Equals(r StringList) bool
  • func (this StringList) Index(val string) int
• type StringLists
  • func (this StringLists) Index(l StringList) int

Constants

const DEFAULT_PORT = 80

Functions

func ShowRoutes

func ShowRoutes(name string) error

Types

type CIDR

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

func ParseCIDR

func ParseCIDR(s string) (*CIDR, error)

type Link

type Link struct {
	Name           string
	ServiceCIDR    *net.IPNet
	Egress         tcp.CIDRList
	Ingress        tcp.CIDRList
	ClusterAddress *net.IPNet
	Gateway        net.IP
	Host           string
	Endpoint       string
	LinkForeignData
}

func (*Link) AllowIngress

func (this *Link) AllowIngress(ip net.IP) (granted bool, set bool)

func (*Link) String

func (this *Link) String() string

type LinkAccessInfo

type LinkAccessInfo struct {
	CACert string
	Token  string
}

func (LinkAccessInfo) Equal

func (this LinkAccessInfo) Equal(other LinkAccessInfo) bool

func (LinkAccessInfo) String

func (this LinkAccessInfo) String() string

type LinkDNSInfo

type LinkDNSInfo struct {
	ClusterDomain string
	DnsIP         net.IP
}

func (LinkDNSInfo) Equal

func (this LinkDNSInfo) Equal(other LinkDNSInfo) bool

func (LinkDNSInfo) String

func (this LinkDNSInfo) String() string

type LinkForeignData

type LinkForeignData struct {
	UpdatePending bool
	LinkAccessInfo
	LinkDNSInfo
}

type Links

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

func GetSharedLinks

func GetSharedLinks(controller controller.Interface) *Links

func NewLinks

func NewLinks(resc resources.Interface) *Links

func (*Links) GetLink

func (this *Links) GetLink(name string) *Link

func (*Links) GetLinkForClusterAddress

func (this *Links) GetLinkForClusterAddress(ip net.IP) *Link

func (*Links) GetLinkForEndpoint

func (this *Links) GetLinkForEndpoint(dnsname string) *Link

func (*Links) GetLinkForIP

func (this *Links) GetLinkForIP(ip net.IP) *Link

func (*Links) GetRoutes

func (this *Links) GetRoutes(ifce *NodeInterface) Routes

func (*Links) GetRoutesToLink

func (this *Links) GetRoutesToLink(ifce *NodeInterface, link netlink.Link) Routes

func (*Links) GetSNATRules

func (this *Links) GetSNATRules(ifce *NodeInterface) iptables.Requests

func (*Links) LinkFor

func (this *Links) LinkFor(link *v1alpha1.KubeLink) (*Link, error)

func (*Links) LinkInfoUpdated

func (this *Links) LinkInfoUpdated(logger logger.LogContext, name string, access *LinkAccessInfo, dns *LinkDNSInfo) *Link

func (*Links) RegisterLink

func (this *Links) RegisterLink(name string, clusterCIDR *net.IPNet, fqdn string, cidr *net.IPNet) (*Link, error)

func (*Links) RemoveLink

func (this *Links) RemoveLink(name string)

func (*Links) Setup

func (this *Links) Setup(logger logger.LogContext, cluster cluster.Interface)

func (*Links) UpdateLink

func (this *Links) UpdateLink(klink *v1alpha1.KubeLink) (*Link, error)

func (*Links) UpdateLinkInfo

func (this *Links) UpdateLinkInfo(logger logger.LogContext, name string, access *LinkAccessInfo, dns *LinkDNSInfo, pending bool) (*Link, bool)

func (*Links) Visit

func (this *Links) Visit(visitor func(l *Link) bool)

type NodeInterface

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

func LookupNodeIP

func LookupNodeIP(logger logger.LogContext, cidr *net.IPNet) (*NodeInterface, error)

type Routes

type Routes []netlink.Route

func ListRoutes

func ListRoutes() (Routes, error)

func ListRoutesForInterface

func ListRoutesForInterface(name string) (Routes, error)

func (*Routes) Add

func (this *Routes) Add(route netlink.Route) Routes

func (Routes) Lookup

func (this Routes) Lookup(route netlink.Route) int

func (Routes) LookupAndLogMismatchReason

func (this Routes) LookupAndLogMismatchReason(logger logger.LogContext, route netlink.Route) int

type StringList

type StringList []string

func (StringList) Equals

func (this StringList) Equals(r StringList) bool

func (StringList) Index

func (this StringList) Index(val string) int

type StringLists

type StringLists []StringList

func (StringLists) Index

func (this StringLists) Index(l StringList) int