kubernetes/vendor/github.com/moby/ipvs/ipvs_linux.go

const netlinkRecvSocketsTimeout …

const netlinkSendSocketTimeout …

type Service …

type SvcStats …

type Destination …

type DstStats …

type Config …

type Handle …

// New provides a new ipvs handle in the namespace pointed to by the
// passed path. It will return a valid handle or an error in case an
// error occurred while creating the handle.
func New(path string) (*Handle, error) { … }

// Close closes the ipvs handle. The handle is invalid after Close
// returns.
func (i *Handle) Close() { … }

// NewService creates a new ipvs service in the passed handle.
func (i *Handle) NewService(s *Service) error { … }

// IsServicePresent queries for the ipvs service in the passed handle.
func (i *Handle) IsServicePresent(s *Service) bool { … }

// UpdateService updates an already existing service in the passed
// handle.
func (i *Handle) UpdateService(s *Service) error { … }

// DelService deletes an already existing service in the passed
// handle.
func (i *Handle) DelService(s *Service) error { … }

// Flush deletes all existing services in the passed
// handle.
func (i *Handle) Flush() error { … }

// NewDestination creates a new real server in the passed ipvs
// service which should already be existing in the passed handle.
func (i *Handle) NewDestination(s *Service, d *Destination) error { … }

// UpdateDestination updates an already existing real server in the
// passed ipvs service in the passed handle.
func (i *Handle) UpdateDestination(s *Service, d *Destination) error { … }

// DelDestination deletes an already existing real server in the
// passed ipvs service in the passed handle.
func (i *Handle) DelDestination(s *Service, d *Destination) error { … }

// GetServices returns an array of services configured on the Node
func (i *Handle) GetServices() ([]*Service, error) { … }

// GetDestinations returns an array of Destinations configured for this Service
func (i *Handle) GetDestinations(s *Service) ([]*Destination, error) { … }

// GetService gets details of a specific IPVS services, useful in updating statisics etc.,
func (i *Handle) GetService(s *Service) (*Service, error) { … }

// GetConfig returns the current timeout configuration
func (i *Handle) GetConfig() (*Config, error) { … }

// SetConfig set the current timeout configuration. 0: no change
func (i *Handle) SetConfig(c *Config) error { … }