link

Documentation

Index

• type Endpoint
  • func NewEndpoint(epctx *EndpointCtx) *Endpoint
  • func (r *Endpoint) Deploy(peerEp *Endpoint) error
  • func (r *Endpoint) Destroy() error
  • func (r *Endpoint) Exists() bool
  • func (r *Endpoint) InitPeerVethIndex(peerEp *Endpoint)
  • func (r *Endpoint) SetMAC(mac net.HardwareAddr)
• type EndpointCtx
• type Link
  • func NewLink(cr *invv1alpha1.Link, lctx *LinkCtx) *Link
  • func (r *Link) Deploy() error
  • func (r *Link) Destroy() error
  • func (r *Link) Exists() bool
  • func (r *Link) GetConn() string
  • func (r *Link) HasLocal() bool
  • func (r *Link) IsCrossCluster() bool
  • func (r *Link) IsHostLocal() bool
  • func (r *Link) IsReady() bool
  • func (r *Link) SetMtu(mtu int)
• type LinkCtx

Types

type Endpoint

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

func NewEndpoint

func NewEndpoint(epctx *EndpointCtx) *Endpoint

func (*Endpoint) Deploy

func (r *Endpoint) Deploy(peerEp *Endpoint) error

func (*Endpoint) Destroy

func (r *Endpoint) Destroy() error

Destroy destroys the endpoint for local endpoints it deletes the veth itfce from the container ns for remote endpoints it deletes the tun interface and xdp

func (*Endpoint) Exists

func (r *Endpoint) Exists() bool

Exists validates if the endpoint exists Local endpoints check interface in container namespace Remote endpoints get peerID random name from peerIndex

func (*Endpoint) InitPeerVethIndex

func (r *Endpoint) InitPeerVethIndex(peerEp *Endpoint)

func (*Endpoint) SetMAC

func (r *Endpoint) SetMAC(mac net.HardwareAddr)

SetMAC sets the mac on the endpoint

type EndpointCtx

type EndpointCtx struct {
	IfName              string
	HostConnectivity    invv1alpha1.HostConnectivity
	ClusterConnectivity invv1alpha1.ClusterConnectivity
	NsPath              string
	HostIP              string
	XDP                 xdp.XDP
}

type Link

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

func NewLink

func NewLink(cr *invv1alpha1.Link, lctx *LinkCtx) *Link

func (*Link) Deploy

func (r *Link) Deploy() error

Deploy deploys the link on the host Creates a veth pair Per endpoint deploys either a veth itfce in the container namespace or a remote tunnel for which a veth pair gets cross connected with BPF XDP

func (*Link) Destroy

func (r *Link) Destroy() error

func (*Link) Exists

func (r *Link) Exists() bool

Exists returns true if the link exists. Since we have 2 endpoints it might be some part does not exist. if only a part exists we return true

func (*Link) GetConn

func (r *Link) GetConn() string

GetConn is a debugging facility

func (*Link) HasLocal

func (r *Link) HasLocal() bool

HasLocal returns true is one endpoint of the link is local to the host this indicated that a wiring activity is needed

func (*Link) IsCrossCluster

func (r *Link) IsCrossCluster() bool

IsCrossCluster returns true if the link is connected accross clusters

func (*Link) IsHostLocal

func (r *Link) IsHostLocal() bool

IsHostLocal returns true if both endpoints are on the same host the wiring in this case is all local to the host

func (*Link) IsReady

func (r *Link) IsReady() bool

IsReady returns true if cluster and host information of both endpoints are known

func (*Link) SetMtu

func (r *Link) SetMtu(mtu int)

SetMtu sets the mtu on the link

type LinkCtx

type LinkCtx struct {
	PodManager pod.Manager
	Topologies map[string]struct{}
	XDP        xdp.XDP
}