k8s

Documentation

Index

• type K8Node
• type Nodes
  • func (ns *Nodes) All() map[string]K8Node
  • func (ns *Nodes) Get(name string) *K8Node
  • func (ns *Nodes) Set(n *v1.Node) error
  • func (ns *Nodes) Unset(name string) error
• type SvcEpsMember
  • func FormatMembersFromServiceEndpoints(svc *v1.Service, eps *v1.Endpoints) ([]SvcEpsMember, error)

Types

type K8Node

type K8Node struct {
	MacAddr   string `json:"macaddr"`
	IpAddr    string `json:"ipaddr"`
	MacAddrV6 string `json:"macaddrv6"`
	IpAddrV6  string `json:"ipaddrv6"`
	Name      string `json:"name"`
	NetType   string `json:"nettype"`
}

type Nodes

type Nodes struct {
	Items map[string]*K8Node
	// contains filtered or unexported fields
}

var (
	NodeCache Nodes
)

func (*Nodes) All

func (ns *Nodes) All() map[string]K8Node

func (*Nodes) Get

func (ns *Nodes) Get(name string) *K8Node

func (*Nodes) Set

func (ns *Nodes) Set(n *v1.Node) error

func (*Nodes) Unset

func (ns *Nodes) Unset(name string) error

type SvcEpsMember

type SvcEpsMember struct {
	TargetPort int
	// NodePort   int
	IpAddr  string
	MacAddr string
}

func FormatMembersFromServiceEndpoints

func FormatMembersFromServiceEndpoints(svc *v1.Service, eps *v1.Endpoints) ([]SvcEpsMember, error)