@@ -57,7 +57,7 @@ require (

 	github.com/miekg/dns v1.1.43

 	github.com/mistifyio/go-zfs v2.1.2-0.20190413222219-f784269be439+incompatible

 	github.com/moby/buildkit v0.10.6

-	github.com/moby/ipvs v1.0.2

+	github.com/moby/ipvs v1.1.0

 	github.com/moby/locker v1.0.1

 	github.com/moby/patternmatcher v0.5.0

 	github.com/moby/pubsub v1.0.0

@@ -807,8 +807,8 @@ github.com/mitchellh/mapstructure v1.1.2/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh

 github.com/mitchellh/osext v0.0.0-20151018003038-5e2d6d41470f/go.mod h1:OkQIRizQZAeMln+1tSwduZz7+Af5oFlKirV/MSYes2A=

 github.com/moby/buildkit v0.10.6 h1:DJlEuLIgnu34HQKF4n9Eg6q2YqQVC0eOpMb4p2eRS2w=

 github.com/moby/buildkit v0.10.6/go.mod h1:tQuuyTWtOb9D+RE425cwOCUkX0/oZ+5iBZ+uWpWQ9bU=

-github.com/moby/ipvs v1.0.2 h1:NSbzuRTvfneftLU3VwPU5QuA6NZ0IUmqq9+VHcQxqHw=

-github.com/moby/ipvs v1.0.2/go.mod h1:2pngiyseZbIKXNv7hsKj3O9UEz30c53MT9005gt2hxQ=

+github.com/moby/ipvs v1.1.0 h1:ONN4pGaZQgAx+1Scz5RvWV4Q7Gb+mvfRh3NsPS+1XQQ=

+github.com/moby/ipvs v1.1.0/go.mod h1:4VJMWuf098bsUMmZEiD4Tjk/O7mOn3l1PTD3s4OoYAs=

 github.com/moby/locker v1.0.1 h1:fOXqR41zeveg4fFODix+1Ch4mj/gT0NE1XJbp/epuBg=

 github.com/moby/locker v1.0.1/go.mod h1:S7SDdo5zpBK84bzzVlKr2V0hz+7x9hWbYC/kq7oQppc=

 github.com/moby/patternmatcher v0.5.0 h1:YCZgJOeULcxLw1Q+sVR636pmS7sPEn1Qo2iAN6M7DBo=

new file mode 100644

@@ -0,0 +1,8 @@

+linters:

+  disable-all: true

+  enable:

+    - gofmt

+    - govet

+    - ineffassign

+    - misspell

+    - revive

@@ -1,4 +1,5 @@

-Apache License

+

+                                 Apache License

                            Version 2.0, January 2004

                         http://www.apache.org/licenses/

@@ -178,7 +179,7 @@ Apache License

    APPENDIX: How to apply the Apache License to your work.

       To apply the Apache License to your work, attach the following

-      boilerplate notice, with the fields enclosed by brackets "{}"

+      boilerplate notice, with the fields enclosed by brackets "[]"

       replaced with your own identifying information. (Don't include

       the brackets!)  The text should be enclosed in the appropriate

       comment syntax for the file format. We also recommend that a

@@ -186,7 +187,7 @@ Apache License

       same "printed page" as the copyright notice for easier

       identification within third-party archives.

-   Copyright {yyyy} {name of copyright owner}

+   Copyright [yyyy] [name of copyright owner]

    Licensed under the Apache License, Version 2.0 (the "License");

    you may not use this file except in compliance with the License.

@@ -199,4 +200,3 @@ Apache License

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

    See the License for the specific language governing permissions and

    limitations under the License.

-

@@ -31,4 +31,5 @@ func main() {

 Want to hack on ipvs? [Docker's contributions guidelines](https://github.com/docker/docker/blob/master/CONTRIBUTING.md) apply.

 ## Copyright and license

-Code and documentation copyright 2015 Docker, inc. Code released under the Apache 2.0 license. Docs released under Creative commons.

+

+Copyright 2015 Docker, inc. Code released under the [Apache 2.0 license](LICENSE).

deleted file mode 100644

@@ -1,178 +0,0 @@

-// +build linux

-

-package ipvs

-

-const (

-	genlCtrlID = 0x10

-)

-

-// GENL control commands

-const (

-	genlCtrlCmdUnspec uint8 = iota

-	genlCtrlCmdNewFamily

-	genlCtrlCmdDelFamily

-	genlCtrlCmdGetFamily

-)

-

-// GENL family attributes

-const (

-	genlCtrlAttrUnspec int = iota

-	genlCtrlAttrFamilyID

-	genlCtrlAttrFamilyName

-)

-

-// IPVS genl commands

-const (

-	ipvsCmdUnspec uint8 = iota

-	ipvsCmdNewService

-	ipvsCmdSetService

-	ipvsCmdDelService

-	ipvsCmdGetService

-	ipvsCmdNewDest

-	ipvsCmdSetDest

-	ipvsCmdDelDest

-	ipvsCmdGetDest

-	ipvsCmdNewDaemon

-	ipvsCmdDelDaemon

-	ipvsCmdGetDaemon

-	ipvsCmdSetConfig

-	ipvsCmdGetConfig

-	ipvsCmdSetInfo

-	ipvsCmdGetInfo

-	ipvsCmdZero

-	ipvsCmdFlush

-)

-

-// Attributes used in the first level of commands

-const (

-	ipvsCmdAttrUnspec int = iota

-	ipvsCmdAttrService

-	ipvsCmdAttrDest

-	ipvsCmdAttrDaemon

-	ipvsCmdAttrTimeoutTCP

-	ipvsCmdAttrTimeoutTCPFin

-	ipvsCmdAttrTimeoutUDP

-)

-

-// Attributes used to describe a service. Used inside nested attribute

-// ipvsCmdAttrService

-const (

-	ipvsSvcAttrUnspec int = iota

-	ipvsSvcAttrAddressFamily

-	ipvsSvcAttrProtocol

-	ipvsSvcAttrAddress

-	ipvsSvcAttrPort

-	ipvsSvcAttrFWMark

-	ipvsSvcAttrSchedName

-	ipvsSvcAttrFlags

-	ipvsSvcAttrTimeout

-	ipvsSvcAttrNetmask

-	ipvsSvcAttrStats

-	ipvsSvcAttrPEName

-)

-

-// Attributes used to describe a destination (real server). Used

-// inside nested attribute ipvsCmdAttrDest.

-const (

-	ipvsDestAttrUnspec int = iota

-	ipvsDestAttrAddress

-	ipvsDestAttrPort

-	ipvsDestAttrForwardingMethod

-	ipvsDestAttrWeight

-	ipvsDestAttrUpperThreshold

-	ipvsDestAttrLowerThreshold

-	ipvsDestAttrActiveConnections

-	ipvsDestAttrInactiveConnections

-	ipvsDestAttrPersistentConnections

-	ipvsDestAttrStats

-	ipvsDestAttrAddressFamily

-)

-

-// IPVS Statistics constants

-

-const (

-	ipvsStatsUnspec int = iota

-	ipvsStatsConns

-	ipvsStatsPktsIn

-	ipvsStatsPktsOut

-	ipvsStatsBytesIn

-	ipvsStatsBytesOut

-	ipvsStatsCPS

-	ipvsStatsPPSIn

-	ipvsStatsPPSOut

-	ipvsStatsBPSIn

-	ipvsStatsBPSOut

-)

-

-// Destination forwarding methods

-const (

-	// ConnectionFlagFwdmask indicates the mask in the connection

-	// flags which is used by forwarding method bits.

-	ConnectionFlagFwdMask = 0x0007

-

-	// ConnectionFlagMasq is used for masquerade forwarding method.

-	ConnectionFlagMasq = 0x0000

-

-	// ConnectionFlagLocalNode is used for local node forwarding

-	// method.

-	ConnectionFlagLocalNode = 0x0001

-

-	// ConnectionFlagTunnel is used for tunnel mode forwarding

-	// method.

-	ConnectionFlagTunnel = 0x0002

-

-	// ConnectionFlagDirectRoute is used for direct routing

-	// forwarding method.

-	ConnectionFlagDirectRoute = 0x0003

-)

-

-const (

-	// RoundRobin distributes jobs equally amongst the available

-	// real servers.

-	RoundRobin = "rr"

-

-	// LeastConnection assigns more jobs to real servers with

-	// fewer active jobs.

-	LeastConnection = "lc"

-

-	// DestinationHashing assigns jobs to servers through looking

-	// up a statically assigned hash table by their destination IP

-	// addresses.

-	DestinationHashing = "dh"

-

-	// SourceHashing assigns jobs to servers through looking up

-	// a statically assigned hash table by their source IP

-	// addresses.

-	SourceHashing = "sh"

-

-	// WeightedRoundRobin assigns jobs to real servers proportionally

-	// to there real servers' weight. Servers with higher weights

-	// receive new jobs first and get more jobs than servers

-	// with lower weights. Servers with equal weights get

-	// an equal distribution of new jobs

-	WeightedRoundRobin = "wrr"

-

-	// WeightedLeastConnection assigns more jobs to servers

-	// with fewer jobs and relative to the real servers' weight

-	WeightedLeastConnection = "wlc"

-)

-

-const (

-	// ConnFwdMask is a mask for the fwd methods

-	ConnFwdMask = 0x0007

-

-	// ConnFwdMasq denotes forwarding via masquerading/NAT

-	ConnFwdMasq = 0x0000

-

-	// ConnFwdLocalNode denotes forwarding to a local node

-	ConnFwdLocalNode = 0x0001

-

-	// ConnFwdTunnel denotes forwarding via a tunnel

-	ConnFwdTunnel = 0x0002

-

-	// ConnFwdDirectRoute denotes forwarding via direct routing

-	ConnFwdDirectRoute = 0x0003

-

-	// ConnFwdBypass denotes forwarding while bypassing the cache

-	ConnFwdBypass = 0x0004

-)

new file mode 100644

@@ -0,0 +1,176 @@

+package ipvs

+

+const (

+	genlCtrlID = 0x10

+)

+

+// GENL control commands

+const (

+	genlCtrlCmdUnspec uint8 = iota

+	genlCtrlCmdNewFamily

+	genlCtrlCmdDelFamily

+	genlCtrlCmdGetFamily

+)

+

+// GENL family attributes

+const (

+	genlCtrlAttrUnspec int = iota

+	genlCtrlAttrFamilyID

+	genlCtrlAttrFamilyName

+)

+

+// IPVS genl commands

+const (

+	ipvsCmdUnspec uint8 = iota

+	ipvsCmdNewService

+	ipvsCmdSetService

+	ipvsCmdDelService

+	ipvsCmdGetService

+	ipvsCmdNewDest

+	ipvsCmdSetDest

+	ipvsCmdDelDest

+	ipvsCmdGetDest

+	ipvsCmdNewDaemon

+	ipvsCmdDelDaemon

+	ipvsCmdGetDaemon

+	ipvsCmdSetConfig

+	ipvsCmdGetConfig

+	ipvsCmdSetInfo

+	ipvsCmdGetInfo

+	ipvsCmdZero

+	ipvsCmdFlush

+)

+

+// Attributes used in the first level of commands

+const (

+	ipvsCmdAttrUnspec int = iota

+	ipvsCmdAttrService

+	ipvsCmdAttrDest

+	ipvsCmdAttrDaemon

+	ipvsCmdAttrTimeoutTCP

+	ipvsCmdAttrTimeoutTCPFin

+	ipvsCmdAttrTimeoutUDP

+)

+

+// Attributes used to describe a service. Used inside nested attribute

+// ipvsCmdAttrService

+const (

+	ipvsSvcAttrUnspec int = iota

+	ipvsSvcAttrAddressFamily

+	ipvsSvcAttrProtocol

+	ipvsSvcAttrAddress

+	ipvsSvcAttrPort

+	ipvsSvcAttrFWMark

+	ipvsSvcAttrSchedName

+	ipvsSvcAttrFlags

+	ipvsSvcAttrTimeout

+	ipvsSvcAttrNetmask

+	ipvsSvcAttrStats

+	ipvsSvcAttrPEName

+)

+

+// Attributes used to describe a destination (real server). Used

+// inside nested attribute ipvsCmdAttrDest.

+const (

+	ipvsDestAttrUnspec int = iota

+	ipvsDestAttrAddress

+	ipvsDestAttrPort

+	ipvsDestAttrForwardingMethod

+	ipvsDestAttrWeight

+	ipvsDestAttrUpperThreshold

+	ipvsDestAttrLowerThreshold

+	ipvsDestAttrActiveConnections

+	ipvsDestAttrInactiveConnections

+	ipvsDestAttrPersistentConnections

+	ipvsDestAttrStats

+	ipvsDestAttrAddressFamily

+)

+

+// IPVS Statistics constants

+

+const (

+	ipvsStatsUnspec int = iota

+	ipvsStatsConns

+	ipvsStatsPktsIn

+	ipvsStatsPktsOut

+	ipvsStatsBytesIn

+	ipvsStatsBytesOut

+	ipvsStatsCPS

+	ipvsStatsPPSIn

+	ipvsStatsPPSOut

+	ipvsStatsBPSIn

+	ipvsStatsBPSOut

+)

+

+// Destination forwarding methods

+const (

+	// ConnectionFlagFwdmask indicates the mask in the connection

+	// flags which is used by forwarding method bits.

+	ConnectionFlagFwdMask = 0x0007

+

+	// ConnectionFlagMasq is used for masquerade forwarding method.

+	ConnectionFlagMasq = 0x0000

+

+	// ConnectionFlagLocalNode is used for local node forwarding

+	// method.

+	ConnectionFlagLocalNode = 0x0001

+

+	// ConnectionFlagTunnel is used for tunnel mode forwarding

+	// method.

+	ConnectionFlagTunnel = 0x0002

+

+	// ConnectionFlagDirectRoute is used for direct routing

+	// forwarding method.

+	ConnectionFlagDirectRoute = 0x0003

+)

+

+const (

+	// RoundRobin distributes jobs equally amongst the available

+	// real servers.

+	RoundRobin = "rr"

+

+	// LeastConnection assigns more jobs to real servers with

+	// fewer active jobs.

+	LeastConnection = "lc"

+

+	// DestinationHashing assigns jobs to servers through looking

+	// up a statically assigned hash table by their destination IP

+	// addresses.

+	DestinationHashing = "dh"

+

+	// SourceHashing assigns jobs to servers through looking up

+	// a statically assigned hash table by their source IP

+	// addresses.

+	SourceHashing = "sh"

+

+	// WeightedRoundRobin assigns jobs to real servers proportionally

+	// to there real servers' weight. Servers with higher weights

+	// receive new jobs first and get more jobs than servers

+	// with lower weights. Servers with equal weights get

+	// an equal distribution of new jobs

+	WeightedRoundRobin = "wrr"

+

+	// WeightedLeastConnection assigns more jobs to servers

+	// with fewer jobs and relative to the real servers' weight

+	WeightedLeastConnection = "wlc"

+)

+

+const (

+	// ConnFwdMask is a mask for the fwd methods

+	ConnFwdMask = 0x0007

+

+	// ConnFwdMasq denotes forwarding via masquerading/NAT

+	ConnFwdMasq = 0x0000

+

+	// ConnFwdLocalNode denotes forwarding to a local node

+	ConnFwdLocalNode = 0x0001

+

+	// ConnFwdTunnel denotes forwarding via a tunnel

+	ConnFwdTunnel = 0x0002

+

+	// ConnFwdDirectRoute denotes forwarding via direct routing

+	ConnFwdDirectRoute = 0x0003

+

+	// ConnFwdBypass denotes forwarding while bypassing the cache

+	ConnFwdBypass = 0x0004

+)

deleted file mode 100644

@@ -1,206 +0,0 @@

-// +build linux

-

-package ipvs

-

-import (

-	"fmt"

-	"net"

-	"time"

-

-	"github.com/vishvananda/netlink/nl"

-	"github.com/vishvananda/netns"

-	"golang.org/x/sys/unix"

-)

-

-const (

-	netlinkRecvSocketsTimeout = 3 * time.Second

-	netlinkSendSocketTimeout  = 30 * time.Second

-)

-

-// Service defines an IPVS service in its entirety.

-type Service struct {

-	// Virtual service address.

-	Address  net.IP

-	Protocol uint16

-	Port     uint16

-	FWMark   uint32 // Firewall mark of the service.

-

-	// Virtual service options.

-	SchedName     string

-	Flags         uint32

-	Timeout       uint32

-	Netmask       uint32

-	AddressFamily uint16

-	PEName        string

-	Stats         SvcStats

-}

-

-// SvcStats defines an IPVS service statistics

-type SvcStats struct {

-	Connections uint32

-	PacketsIn   uint32

-	PacketsOut  uint32

-	BytesIn     uint64

-	BytesOut    uint64

-	CPS         uint32

-	BPSOut      uint32

-	PPSIn       uint32

-	PPSOut      uint32

-	BPSIn       uint32

-}

-

-// Destination defines an IPVS destination (real server) in its

-// entirety.

-type Destination struct {

-	Address             net.IP

-	Port                uint16

-	Weight              int

-	ConnectionFlags     uint32

-	AddressFamily       uint16

-	UpperThreshold      uint32

-	LowerThreshold      uint32

-	ActiveConnections   int

-	InactiveConnections int

-	Stats               DstStats

-}

-

-// DstStats defines IPVS destination (real server) statistics

-type DstStats SvcStats

-

-// Config defines IPVS timeout configuration

-type Config struct {

-	TimeoutTCP    time.Duration

-	TimeoutTCPFin time.Duration

-	TimeoutUDP    time.Duration

-}

-

-// Handle provides a namespace specific ipvs handle to program ipvs

-// rules.

-type Handle struct {

-	seq  uint32

-	sock *nl.NetlinkSocket

-}

-

-// 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) {

-	setup()

-

-	n := netns.None()

-	if path != "" {

-		var err error

-		n, err = netns.GetFromPath(path)

-		if err != nil {

-			return nil, err

-		}

-	}

-	defer n.Close()

-

-	sock, err := nl.GetNetlinkSocketAt(n, netns.None(), unix.NETLINK_GENERIC)

-	if err != nil {

-		return nil, err

-	}

-	// Add operation timeout to avoid deadlocks

-	tv := unix.NsecToTimeval(netlinkSendSocketTimeout.Nanoseconds())

-	if err := sock.SetSendTimeout(&tv); err != nil {

-		return nil, err

-	}

-	tv = unix.NsecToTimeval(netlinkRecvSocketsTimeout.Nanoseconds())

-	if err := sock.SetReceiveTimeout(&tv); err != nil {

-		return nil, err

-	}

-

-	return &Handle{sock: sock}, nil

-}

-

-// Close closes the ipvs handle. The handle is invalid after Close

-// returns.

-func (i *Handle) Close() {

-	if i.sock != nil {

-		i.sock.Close()

-	}

-}

-

-// NewService creates a new ipvs service in the passed handle.

-func (i *Handle) NewService(s *Service) error {

-	return i.doCmd(s, nil, ipvsCmdNewService)

-}

-

-// IsServicePresent queries for the ipvs service in the passed handle.

-func (i *Handle) IsServicePresent(s *Service) bool {

-	return nil == i.doCmd(s, nil, ipvsCmdGetService)

-}

-

-// UpdateService updates an already existing service in the passed

-// handle.

-func (i *Handle) UpdateService(s *Service) error {

-	return i.doCmd(s, nil, ipvsCmdSetService)

-}

-

-// DelService deletes an already existing service in the passed

-// handle.

-func (i *Handle) DelService(s *Service) error {

-	return i.doCmd(s, nil, ipvsCmdDelService)

-}

-

-// Flush deletes all existing services in the passed

-// handle.

-func (i *Handle) Flush() error {

-	_, err := i.doCmdWithoutAttr(ipvsCmdFlush)

-	return err

-}

-

-// 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 {

-	return i.doCmd(s, d, ipvsCmdNewDest)

-}

-

-// 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 {

-	return i.doCmd(s, d, ipvsCmdSetDest)

-}

-

-// 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 {

-	return i.doCmd(s, d, ipvsCmdDelDest)

-}

-

-// GetServices returns an array of services configured on the Node

-func (i *Handle) GetServices() ([]*Service, error) {

-	return i.doGetServicesCmd(nil)

-}

-

-// GetDestinations returns an array of Destinations configured for this Service

-func (i *Handle) GetDestinations(s *Service) ([]*Destination, error) {

-	return i.doGetDestinationsCmd(s, nil)

-}

-

-// GetService gets details of a specific IPVS services, useful in updating statisics etc.,

-func (i *Handle) GetService(s *Service) (*Service, error) {

-

-	res, err := i.doGetServicesCmd(s)

-	if err != nil {

-		return nil, err

-	}

-

-	// We are looking for exactly one service otherwise error out

-	if len(res) != 1 {

-		return nil, fmt.Errorf("Expected only one service obtained=%d", len(res))

-	}

-

-	return res[0], nil

-}

-

-// GetConfig returns the current timeout configuration

-func (i *Handle) GetConfig() (*Config, error) {

-	return i.doGetConfigCmd()

-}

-

-// SetConfig set the current timeout configuration. 0: no change

-func (i *Handle) SetConfig(c *Config) error {

-	return i.doSetConfigCmd(c)

-}

new file mode 100644

@@ -0,0 +1,203 @@

+package ipvs

+

+import (

+	"fmt"

+	"net"

+	"time"

+

+	"github.com/vishvananda/netlink/nl"

+	"github.com/vishvananda/netns"

+	"golang.org/x/sys/unix"

+)

+

+const (

+	netlinkRecvSocketsTimeout = 3 * time.Second

+	netlinkSendSocketTimeout  = 30 * time.Second

+)

+

+// Service defines an IPVS service in its entirety.

+type Service struct {

+	// Virtual service address.

+	Address  net.IP

+	Protocol uint16

+	Port     uint16

+	FWMark   uint32 // Firewall mark of the service.

+

+	// Virtual service options.

+	SchedName     string

+	Flags         uint32

+	Timeout       uint32

+	Netmask       uint32

+	AddressFamily uint16

+	PEName        string

+	Stats         SvcStats

+}

+

+// SvcStats defines an IPVS service statistics

+type SvcStats struct {

+	Connections uint32

+	PacketsIn   uint32

+	PacketsOut  uint32

+	BytesIn     uint64

+	BytesOut    uint64

+	CPS         uint32

+	BPSOut      uint32

+	PPSIn       uint32

+	PPSOut      uint32

+	BPSIn       uint32

+}

+

+// Destination defines an IPVS destination (real server) in its

+// entirety.

+type Destination struct {

+	Address             net.IP

+	Port                uint16

+	Weight              int

+	ConnectionFlags     uint32

+	AddressFamily       uint16

+	UpperThreshold      uint32

+	LowerThreshold      uint32

+	ActiveConnections   int

+	InactiveConnections int

+	Stats               DstStats

+}

+

+// DstStats defines IPVS destination (real server) statistics

+type DstStats SvcStats

+

+// Config defines IPVS timeout configuration

+type Config struct {

+	TimeoutTCP    time.Duration

+	TimeoutTCPFin time.Duration

+	TimeoutUDP    time.Duration

+}

+

+// Handle provides a namespace specific ipvs handle to program ipvs

+// rules.

+type Handle struct {

+	seq  uint32

+	sock *nl.NetlinkSocket

+}

+

+// 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) {

+	setup()

+

+	n := netns.None()

+	if path != "" {

+		var err error

+		n, err = netns.GetFromPath(path)

+		if err != nil {

+			return nil, err

+		}

+	}

+	defer n.Close()

+

+	sock, err := nl.GetNetlinkSocketAt(n, netns.None(), unix.NETLINK_GENERIC)

+	if err != nil {

+		return nil, err

+	}

+	// Add operation timeout to avoid deadlocks

+	tv := unix.NsecToTimeval(netlinkSendSocketTimeout.Nanoseconds())

+	if err := sock.SetSendTimeout(&tv); err != nil {

+		return nil, err

+	}

+	tv = unix.NsecToTimeval(netlinkRecvSocketsTimeout.Nanoseconds())

+	if err := sock.SetReceiveTimeout(&tv); err != nil {

+		return nil, err

+	}

+

+	return &Handle{sock: sock}, nil

+}

+

+// Close closes the ipvs handle. The handle is invalid after Close

+// returns.

+func (i *Handle) Close() {

+	if i.sock != nil {

+		i.sock.Close()

+	}

+}

+

+// NewService creates a new ipvs service in the passed handle.

+func (i *Handle) NewService(s *Service) error {

+	return i.doCmd(s, nil, ipvsCmdNewService)

+}

+

+// IsServicePresent queries for the ipvs service in the passed handle.

+func (i *Handle) IsServicePresent(s *Service) bool {

+	return nil == i.doCmd(s, nil, ipvsCmdGetService)

+}

+

+// UpdateService updates an already existing service in the passed

+// handle.

+func (i *Handle) UpdateService(s *Service) error {

+	return i.doCmd(s, nil, ipvsCmdSetService)

+}

+

+// DelService deletes an already existing service in the passed

+// handle.

+func (i *Handle) DelService(s *Service) error {

+	return i.doCmd(s, nil, ipvsCmdDelService)

+}

+

+// Flush deletes all existing services in the passed

+// handle.

+func (i *Handle) Flush() error {

+	_, err := i.doCmdWithoutAttr(ipvsCmdFlush)

+	return err

+}

+

+// 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 {

+	return i.doCmd(s, d, ipvsCmdNewDest)

+}

+

+// 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 {

+	return i.doCmd(s, d, ipvsCmdSetDest)

+}

+

+// 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 {

+	return i.doCmd(s, d, ipvsCmdDelDest)

+}

+

+// GetServices returns an array of services configured on the Node

+func (i *Handle) GetServices() ([]*Service, error) {

+	return i.doGetServicesCmd(nil)

+}

+

+// GetDestinations returns an array of Destinations configured for this Service

+func (i *Handle) GetDestinations(s *Service) ([]*Destination, error) {

+	return i.doGetDestinationsCmd(s, nil)

+}

+

+// GetService gets details of a specific IPVS services, useful in updating statisics etc.,

+func (i *Handle) GetService(s *Service) (*Service, error) {

+	res, err := i.doGetServicesCmd(s)

+	if err != nil {

+		return nil, err

+	}

+

+	// We are looking for exactly one service otherwise error out

+	if len(res) != 1 {

+		return nil, fmt.Errorf("Expected only one service obtained=%d", len(res))

+	}

+

+	return res[0], nil

+}

+

+// GetConfig returns the current timeout configuration

+func (i *Handle) GetConfig() (*Config, error) {

+	return i.doGetConfigCmd()

+}

+

+// SetConfig set the current timeout configuration. 0: no change

+func (i *Handle) SetConfig(c *Config) error {

+	return i.doSetConfigCmd(c)

+}

deleted file mode 100644

@@ -1,681 +0,0 @@

-// +build linux

-

-package ipvs

-

-import (

-	"bytes"

-	"encoding/binary"

-	"errors"

-	"fmt"

-	"net"

-	"os/exec"

-	"strings"

-	"sync"

-	"sync/atomic"

-	"syscall"

-	"time"

-	"unsafe"

-

-	"github.com/sirupsen/logrus"

-	"github.com/vishvananda/netlink/nl"

-	"github.com/vishvananda/netns"

-)

-

-// For Quick Reference IPVS related netlink message is described at the end of this file.

-var (

-	native     = nl.NativeEndian()

-	ipvsFamily int

-	ipvsOnce   sync.Once

-)

-