libipvs

package module
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Dec 11, 2017 License: MIT Imports: 9 Imported by: 0

README

libipvsgo

test
  • required IP_VS kernel module
sudo -E go test -v
LICENSE

This software is released under the MIT License, see LICENSE.

Documentation

Index

Constants

View Source 
const (
	IPVS_CMD_UNSPEC uint8 = iota

	IPVS_CMD_NEW_SERVICE // add service
	IPVS_CMD_SET_SERVICE // modify service
	IPVS_CMD_DEL_SERVICE // delete service
	IPVS_CMD_GET_SERVICE // get info about specific service

	IPVS_CMD_NEW_DEST //add destination
	IPVS_CMD_SET_DEST //modify destination
	IPVS_CMD_DEL_DEST //delete destination
	IPVS_CMD_GET_DEST //get list of all service dests

	IPVS_CMD_NEW_DAEMON //start sync daemon
	IPVS_CMD_DEL_DAEMON //stop sync daemon
	IPVS_CMD_GET_DAEMON //get sync daemon status

	IPVS_CMD_SET_TIMEOUT //set TCP and UDP timeouts
	IPVS_CMD_GET_TIMEOUT //get TCP and UDP timeouts

	IPVS_CMD_SET_INFO //only used in GET_INFO reply
	IPVS_CMD_GET_INFO //get general IPVS info

	IPVS_CMD_ZERO  //zero all counters and stats
	IPVS_CMD_FLUSH //flush services and dests
)

IPVS genl commands

View Source 
const (
	IPVS_CMD_ATTR_UNSPEC          int = iota
	IPVS_CMD_ATTR_SERVICE             // nested service attribute //
	IPVS_CMD_ATTR_DEST                // nested destination attribute //
	IPVS_CMD_ATTR_DAEMON              // nested sync daemon attribute //
	IPVS_CMD_ATTR_TIMEOUT_TCP         // TCP connection timeout //
	IPVS_CMD_ATTR_TIMEOUT_TCP_FIN     // TCP FIN wait timeout //
	IPVS_CMD_ATTR_TIMEOUT_UDP         //UDP timeout //
)

Attributes used in the first level of commands

View Source 
const (
	IPVS_SVC_ATTR_UNSPEC   int = iota
	IPVS_SVC_ATTR_AF           // address family //
	IPVS_SVC_ATTR_PROTOCOL     // virtual service protocol //
	IPVS_SVC_ATTR_ADDR         // virtual service address //
	IPVS_SVC_ATTR_PORT         // virtual service port //
	IPVS_SVC_ATTR_FWMARK       // firewall mark of service //

	IPVS_SVC_ATTR_SCHED_NAME // name of scheduler //
	IPVS_SVC_ATTR_FLAGS      // virtual service flags //
	IPVS_SVC_ATTR_TIMEOUT    // persistent timeout //
	IPVS_SVC_ATTR_NETMASK    // persistent netmask //

	IPVS_SVC_ATTR_STATS // nested attribute for service stats //

	IPVS_SVC_ATTR_PE_NAME // name of ct retriever //

	IPVS_SVC_ATTR_STATS64 // nested attribute for service stats //
)

Attributes used to describe a service. Used inside nested attribute ipvsCmdAttrService

View Source 
const (
	IPVS_DEST_ATTR_UNSPEC int = iota
	IPVS_DEST_ATTR_ADDR       // real server address
	IPVS_DEST_ATTR_PORT       // real server port

	IPVS_DEST_ATTR_FWD_METHOD // forwarding method
	IPVS_DEST_ATTR_WEIGHT     // destination weight
	IPVS_DEST_ATTR_U_THRESH   // upper threshold
	IPVS_DEST_ATTR_L_THRESH   // lower threshold

	IPVS_DEST_ATTR_ACTIVE_CONNS  // active connections
	IPVS_DEST_ATTR_INACT_CONNS   // inactive connections
	IPVS_DEST_ATTR_PERSIST_CONNS // persistent connections

	IPVS_DEST_ATTR_STATS // nested attribute for dest stats

	IPVS_DEST_ATTR_ADDR_FAMILY // Address family of address

	IPVS_DEST_ATTR_STATS64 //nested attribute for dest stats
)

Attributes used to describe a destination (real server). Used inside nested attribute ipvsCmdAttrDest.

View Source 
const (
	IPVS_STATS_ATTR_UNSPEC   int = iota
	IPVS_STATS_ATTR_CONNS        // connections scheduled
	IPVS_STATS_ATTR_INPKTS       // incoming packets
	IPVS_STATS_ATTR_OUTPKTS      // outgoing packets
	IPVS_STATS_ATTR_INBYTES      // incoming bytes
	IPVS_STATS_ATTR_OUTBYTES     // outgoing bytes

	IPVS_STATS_ATTR_CPS    // current connection rate
	IPVS_STATS_ATTR_INPPS  // current in packet rate
	IPVS_STATS_ATTR_OUTPPS // current out packet rate
	IPVS_STATS_ATTR_INBPS  // current in byte rate
	IPVS_STATS_ATTR_OUTBPS // current out byte rate
	IPVS_STATS_ATTR_PAD
)
  • Attributes used to describe service or destination entry statistics *
  • Used inside nested attributes IPVS_SVC_ATTR_STATS, IPVS_DEST_ATTR_STATS,
  • IPVS_SVC_ATTR_STATS64 and IPVS_DEST_ATTR_STATS64.

IPVS Svc Statistics constancs

View Source 
const (
	IP_VS_CONN_F_FWD_MASK   = 0x0007 //mask for the fwd methods
	IP_VS_CONN_F_MASQ       = 0x0000 //masquerading/NAT
	IP_VS_CONN_F_LOCALNODE  = 0x0001 //local node
	IP_VS_CONN_F_TUNNEL     = 0x0002 //tunneling
	IP_VS_CONN_F_DROUTE     = 0x0003 //direct routing
	IP_VS_CONN_F_BYPASS     = 0x0004 //cache bypass
	IP_VS_CONN_F_SYNC       = 0x0020 //entry created by sync
	IP_VS_CONN_F_HASHED     = 0x0040 //hashed entry
	IP_VS_CONN_F_NOOUTPUT   = 0x0080 //no output packets
	IP_VS_CONN_F_INACTIVE   = 0x0100 //not established
	IP_VS_CONN_F_OUT_SEQ    = 0x0200 //must do output seq adjust
	IP_VS_CONN_F_IN_SEQ     = 0x0400 //must do input seq adjust
	IP_VS_CONN_F_SEQ_MASK   = 0x0600 //in/out sequence mask
	IP_VS_CONN_F_NO_CPORT   = 0x0800 //no client port set yet
	IP_VS_CONN_F_TEMPLATE   = 0x1000 //template, not connection
	IP_VS_CONN_F_ONE_PACKET = 0x2000 //forward only one packet
)
IPVS Connection Flags
Only flags 0..15 are sent to backup server

Destination forwarding methods

Variables

View Source 
var (
	Name     string
	Version  string
	Revision string
)

Functions

This section is empty.

Types

type DestinationEntry 

type DestinationEntry struct {
	Address        string `json:"RIP"`
	Port           int    `json:"port"`
	Weight         int    `json:"weight"`
	Method         string `json:"method"`
	AddressFamily  string `json:"addressfamily"`
	UpperThreshold int
	LowerThreshold int

	ActiveConnections   uint32
	InActiveConnections uint32
	PersistConnections  uint32
	Stats               Stats
}

func (*DestinationEntry) Serialize 

func (d *DestinationEntry) Serialize() (nl.NetlinkRequestData, error)

type Entry 

type Entry struct {
	Service      *ServiceEntry
	Destinations []*DestinationEntry
}

type IPVSHandler 

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

func NewIPVSHandler 

func NewIPVSHandler() (*IPVSHandler, error)

func (*IPVSHandler) AddDestination 

func (h *IPVSHandler) AddDestination(si *ServiceEntry, ip string, port int, weight int, method string) error

func (*IPVSHandler) AddService 

func (h *IPVSHandler) AddService(vip string, port int, protocol string, schedName string) error

func (*IPVSHandler) DeleteDestination 

func (h *IPVSHandler) DeleteDestination(vip string, vport int, rip string, rport int, protocol string) error

func (*IPVSHandler) DeleteService 

func (h *IPVSHandler) DeleteService(vip string, port int, protocol string) error

func (*IPVSHandler) Flush 

func (h *IPVSHandler) Flush() error

func (*IPVSHandler) GetAllEntry 

func (h *IPVSHandler) GetAllEntry() ([]*Entry, error)

func (*IPVSHandler) GetDestination 

func (h *IPVSHandler) GetDestination(si *ServiceEntry, rip string, rport int) (*DestinationEntry, error)

func (*IPVSHandler) GetDestinations 

func (h *IPVSHandler) GetDestinations(si *ServiceEntry) ([]*DestinationEntry, error)

func (*IPVSHandler) GetService 

func (h *IPVSHandler) GetService(vip string, port int, protocol string) (*ServiceEntry, error)

func (*IPVSHandler) GetServices 

func (h *IPVSHandler) GetServices() ([]*ServiceEntry, error)

func (*IPVSHandler) IsRegisteredService 

func (h *IPVSHandler) IsRegisteredService(vip string, port int, protocol string) (bool, error)

func (*IPVSHandler) UpdateDestination 

func (h *IPVSHandler) UpdateDestination(si *ServiceEntry, ip string, port int, weight int, method string) error

func (*IPVSHandler) UpdateService 

func (h *IPVSHandler) UpdateService(ip string, port int, protocol string, schedName string) error

type ServiceEntry 

type ServiceEntry struct {
	Address  string `json:"vip"`
	Protocol string `json:"protocol"`
	Port     int    `json:"port"`
	FWMark   int    `json:"fwmark"`

	SchedName     string `json:"scheduler"`
	Flags         int    `json:"flags"`
	Timeout       int    `json:"timeout"`
	Netmask       int    `json:"netmask"`
	AddressFamily string `json:"addressfamily"`
	PEName        string `json:"pename"`
	Stats         Stats
}

func (*ServiceEntry) Serialize 

func (s *ServiceEntry) Serialize() (nl.NetlinkRequestData, error)

type Stats 

type Stats struct {
	Connections uint32 //IPVS_STATS_ATTR_CONNS
	PacketsIn   uint32 //IPVS_STATS_ATTR_INPKTS
	PacketsOut  uint32 //IPVS_STATS_ATTR_OUTPKTS
	BytesIn     uint64 //IPVS_STATS_ATTR_INBYTES
	BytesOut    uint64 //IPVS_STATS_ATTR_OUTBYTES
	CPS         uint32 //IPVS_STATS_ATTR_CPS
	PPSIn       uint32 //IPVS_STATS_ATTR_INPPS
	PPSOut      uint32 //IPVS_STATS_ATTR_OUTPPS
	BPSIn       uint32 //IPVS_STATS_ATTR_INBPS
	BPSOut      uint32 //IPVS_STATS_ATTR_OUTBPS
}

Stats defines an IPVS service statistics

Source Files

View all Source files

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.