moby/libnetwork
Sebastiaan van Stijn 4ff252456b
libnetwork: rewrite Network.isClusterEligible to return agent
This function was used to check if the network is a multi-host, swarm-scoped
network. Part of this check involved a check whether the cluster-agent was
present.

In all places where this function was used, the next step after checking if
the network was "cluster eligible", was to get the agent, and (again) check
if it was not nil.

This patch rewrites the isClusterEligible utility into a clusterAgent utility,
which both checks if the network is cluster-eligible, and returns the agent
(if set). For convenience, an "ok" bool is added, which callers can use to
return early (although just checking for nilness would likely have been
sufficient).

Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
2023-09-21 10:19:21 +02:00
..
bitmap libnetwork/bitmap: improve documentation 2023-07-05 16:10:32 -04:00
cluster Switch from x/net/context -> context 2018-04-24 14:57:04 -07:00
cmd Fix some broken executable flags 2023-08-24 12:23:59 +02:00
config libnetwork/options: OptionExecRoot: skip osl.SetBasePath on non-Linux 2023-08-12 15:29:20 +02:00
datastore Merge pull request #46146 from akerouanton/libnet-errors-into-http-status-code 2023-08-18 17:21:03 +02:00
diagnostic swap logrus types for their containerd/logs aliases 2023-08-01 13:02:55 +02:00
discoverapi libnetwork: drop DatastoreConfig discovery type 2023-01-27 11:47:43 -05:00
docs libnetwork/docs: fix broken link 2023-05-10 12:05:05 +02:00
driverapi libnet: Replace BadRequest with InvalidParameter 2023-08-17 16:45:04 +02:00
drivers libnetwork/portmapper: New(): remove unused argument 2023-09-13 18:12:53 +02:00
drvregistry libnetwork: notify another driver registerer 2023-08-29 10:32:18 -04:00
etchosts libnetwork/etchosts: format code with gofumpt 2023-06-29 00:31:48 +02:00
internal libnetwork: remove most of kvstore 2023-07-25 22:20:18 +02:00
ipam Merge pull request #45759 from akerouanton/validate-ipam-config 2023-08-22 13:58:28 -06:00
ipamapi libnet: Fix error capitalization 2023-08-17 16:48:09 +02:00
ipams libnet: Replace BadRequest with InvalidParameter 2023-08-17 16:45:04 +02:00
ipamutils libnetwork/ipamutils: format code with gofumpt 2023-06-29 00:31:49 +02:00
ipbits libnet/ipam: use netip types internally 2023-02-23 18:10:01 -05:00
iptables remove some remaining pre-go1.17 build-tags 2023-08-24 17:51:07 +02:00
netlabel libnetwork/netlabel: remove dead code 2023-04-06 19:51:56 +02:00
netutils tests: Move libnetwork/testutils to internal/testutils/netnsutils 2023-07-26 21:06:36 +02:00
networkdb swap logrus types for their containerd/logs aliases 2023-08-01 13:02:55 +02:00
ns Switch all logging to use containerd log pkg 2023-06-24 00:23:44 +00:00
options libnetwork/options: remove unused NewGeneric, and use map[string]any 2023-07-16 19:39:59 +02:00
osl libnetwork/osl: add some TODOs 2023-09-20 12:45:45 +02:00
portallocator libnetwork/portallocator: format code with gofumpt 2023-06-29 00:31:48 +02:00
portmapper libnetwork/portmapper: remove unused PortMapper.checkIP 2023-09-13 18:54:11 +02:00
resolvconf libnetwork/resolvconf: format code with gofumpt 2023-06-29 00:31:48 +02:00
scope libnetwork: move datastore Scope consts to libnetwork/scope 2023-07-28 21:56:48 +02:00
support Fixup libnetwork lint errors 2021-06-01 23:48:32 +00:00
types libnet: Replace NoServiceError with UnavailableError 2023-08-17 16:46:53 +02:00
.dockerignore Added back dockerignore 2018-06-22 16:10:22 -07:00
.gitignore Added back dockerignore 2018-06-22 16:10:22 -07:00
agent.go libnetwork: rewrite Network.isClusterEligible to return agent 2023-09-21 10:19:21 +02:00
agent.pb.go update generated files 2023-05-29 03:28:35 +02:00
agent.proto fix protos and "go generate" commands 2023-05-29 03:28:35 +02:00
controller.go libnet: Make sure network names are unique 2023-09-12 10:40:13 +02:00
controller_linux.go libnetwork/osl: remove Sandbox and Info interfaces 2023-08-23 23:29:09 +02:00
controller_others.go libnetwork: implement Controller.setupOSLSandbox 2023-08-23 20:13:15 +02:00
default_gateway.go libnetwork: remove Network interface 2023-07-22 11:56:41 +02:00
default_gateway_freebsd.go libnetwork: remove Network interface 2023-07-22 11:56:41 +02:00
default_gateway_linux.go libnetwork: remove Network interface 2023-07-22 11:56:41 +02:00
default_gateway_windows.go libnetwork: remove Network interface 2023-07-22 11:56:41 +02:00
drivers_freebsd.go libnetwork: fix some missing imports on macOS and FreeBSD 2023-08-29 16:55:44 +02:00
drivers_ipam.go libnet: un-plumb datastores from IPAM inits 2023-01-27 11:47:42 -05:00
drivers_linux.go libnet/drivers: stop passing config to drivers... 2023-07-06 12:57:00 -04:00
drivers_unsupported.go libnetwork: fix some missing imports on macOS and FreeBSD 2023-08-29 16:55:44 +02:00
drivers_windows.go libnet/drivers: stop passing config to drivers... 2023-07-06 12:57:00 -04:00
endpoint.go libnetwork: Network.updateSvcRecord: remove unused localEps arg 2023-09-14 15:58:48 +02:00
endpoint_cnt.go libnetwork: remove Network interface 2023-07-22 11:56:41 +02:00
endpoint_info.go libnetwork: Endpoint.AddStaticRoute don't create StaticRoute if unused 2023-08-29 19:51:41 +02:00
endpoint_info_unix.go remove pre-go1.17 build-tags 2023-05-19 20:38:51 +02:00
endpoint_info_windows.go remove pre-go1.17 build-tags 2023-05-19 20:38:51 +02:00
endpoint_unix_test.go libnetwork: rename unix-only testfiles 2023-08-12 01:27:38 +02:00
error.go libnet: Replace BadRequest with InvalidParameter 2023-08-17 16:45:04 +02:00
errors_test.go libnet: Replace BadRequest with InvalidParameter 2023-08-17 16:45:04 +02:00
firewall_linux.go libnetwork: arrangeUserFilterRule: don't return early 2023-07-21 20:08:58 +02:00
firewall_linux_test.go tests: Move libnetwork/testutils to internal/testutils/netnsutils 2023-07-26 21:06:36 +02:00
firewall_others.go libnetwork: arrangeUserFilterRule: don't return early 2023-07-21 20:08:58 +02:00
libnetwork_internal_test.go libnetwork: remove InterfaceInfo interface 2023-08-20 19:08:21 +02:00
libnetwork_linux_test.go Merge pull request #46205 from thaJeztah/libnetwork_noexecroot 2023-08-23 14:21:30 +02:00
libnetwork_unix_test.go remove pre-go1.17 build-tags 2023-05-19 20:38:51 +02:00
libnetwork_windows_test.go libnetwork: format code with gofumpt 2023-06-29 00:31:49 +02:00
network.go Merge pull request #46480 from thaJeztah/remove_remote_endpoints 2023-09-19 14:00:12 +02:00
network_unix.go libnetwork: remove Network interface 2023-07-22 11:56:41 +02:00
network_windows.go remove uses of libnetwork/Network.Info() 2023-08-08 22:05:30 +02:00
README.md libnetwork: update example in README.md 2023-05-10 12:01:06 +02:00
resolver.go libnetwork: resolver: Resolver.dialExtDNS use joinHostPort and cleanup 2023-08-18 13:06:42 +02:00
resolver_test.go libnetwork: move resolver tests that were skipped on Windows 2023-08-11 15:00:30 +02:00
resolver_unix.go libn: fix resolver restore w/ chatty 'iptables -C' 2023-05-30 14:32:27 -04:00
resolver_unix_test.go libnetwork: move resolver tests that were skipped on Windows 2023-08-11 15:00:30 +02:00
resolver_windows.go remove pre-go1.17 build-tags 2023-05-19 20:38:51 +02:00
sandbox.go libnetwork/osl: remove Sandbox and Info interfaces 2023-08-23 23:29:09 +02:00
sandbox_dns_unix.go libnetwork: implement Controller.GetSandbox(containerID) 2023-08-21 15:06:26 +02:00
sandbox_dns_unix_test.go libnetwork: move TestDNSOptions to a non-windows file 2023-08-11 14:59:30 +02:00
sandbox_dns_windows.go libnetwork: move more osl.Sandbox related code to Linux-only files 2023-08-23 20:13:15 +02:00
sandbox_externalkey_unix.go Merge pull request #46205 from thaJeztah/libnetwork_noexecroot 2023-08-23 14:21:30 +02:00
sandbox_externalkey_unsupported.go remove pre-go1.17 build-tags 2023-05-19 20:38:51 +02:00
sandbox_linux.go libnetwork/osl: remove Sandbox and Info interfaces 2023-08-23 23:29:09 +02:00
sandbox_options.go libnetwork: move all SandboxOptions to a separate file 2023-08-18 13:12:25 +02:00
sandbox_store.go libnetwork: implement Controller.setupOSLSandbox 2023-08-23 20:13:15 +02:00
sandbox_unix_test.go libnetwork: implement Controller.GetSandbox(containerID) 2023-08-21 15:06:26 +02:00
sandbox_unsupported.go libnetwork/osl: remove Sandbox and Info interfaces 2023-08-23 23:29:09 +02:00
service.go libn/i/setmatrix: make generic and constructorless 2023-03-29 13:31:12 -04:00
service_common.go libnetwork: Controller.addServiceBinding: fix duplicate word in comment 2023-08-29 16:55:46 +02:00
service_common_unix_test.go libnetwork: rename unix-only testfiles 2023-08-12 01:27:38 +02:00
service_linux.go libnetwork/osl: remove Sandbox.Info() 2023-08-20 19:26:39 +02:00
service_unsupported.go remove pre-go1.17 build-tags 2023-05-19 20:38:51 +02:00
service_windows.go libnetwork: remove Network interface 2023-07-22 11:56:41 +02:00
store.go libnetwork: remove netWatch.remoteEps, as it's unused 2023-09-14 15:58:48 +02:00
store_linux_test.go libnetwork/datastore: remove Store.KVStore() 2023-07-25 22:42:17 +02:00
store_test.go libnetwork: don't access KVStore directly in tests 2023-07-25 22:21:03 +02:00

libnetwork - networking for containers

Libnetwork provides a native Go implementation for connecting containers

The goal of libnetwork is to deliver a robust Container Network Model that provides a consistent programming interface and the required network abstractions for applications.

Design

Please refer to the design for more information.

Using libnetwork

There are many networking solutions available to suit a broad range of use-cases. libnetwork uses a driver / plugin model to support all of these solutions while abstracting the complexity of the driver implementations by exposing a simple and consistent Network Model to users.

package main

import (
	"fmt"
	"log"

	"github.com/docker/docker/libnetwork"
	"github.com/docker/docker/libnetwork/config"
	"github.com/docker/docker/libnetwork/netlabel"
	"github.com/docker/docker/libnetwork/options"
)

func main() {
	// Select and configure the network driver
	networkType := "bridge"

	// Create a new controller instance
	driverOptions := options.Generic{}
	genericOption := make(map[string]interface{})
	genericOption[netlabel.GenericData] = driverOptions
	controller, err := libnetwork.New(config.OptionDriverConfig(networkType, genericOption))
	if err != nil {
		log.Fatalf("libnetwork.New: %s", err)
	}

	// Create a network for containers to join.
	// NewNetwork accepts Variadic optional arguments that libnetwork and Drivers can use.
	network, err := controller.NewNetwork(networkType, "network1", "")
	if err != nil {
		log.Fatalf("controller.NewNetwork: %s", err)
	}

	// For each new container: allocate IP and interfaces. The returned network
	// settings will be used for container infos (inspect and such), as well as
	// iptables rules for port publishing. This info is contained or accessible
	// from the returned endpoint.
	ep, err := network.CreateEndpoint("Endpoint1")
	if err != nil {
		log.Fatalf("network.CreateEndpoint: %s", err)
	}

	// Create the sandbox for the container.
	// NewSandbox accepts Variadic optional arguments which libnetwork can use.
	sbx, err := controller.NewSandbox("container1",
		libnetwork.OptionHostname("test"),
		libnetwork.OptionDomainname("example.com"))
	if err != nil {
		log.Fatalf("controller.NewSandbox: %s", err)
	}

	// A sandbox can join the endpoint via the join api.
	err = ep.Join(sbx)
	if err != nil {
		log.Fatalf("ep.Join: %s", err)
	}

	// libnetwork client can check the endpoint's operational data via the Info() API
	epInfo, err := ep.DriverInfo()
	if err != nil {
		log.Fatalf("ep.DriverInfo: %s", err)
	}

	macAddress, ok := epInfo[netlabel.MacAddress]
	if !ok {
		log.Fatal("failed to get mac address from endpoint info")
	}

	fmt.Printf("Joined endpoint %s (%s) to sandbox %s (%s)\n", ep.Name(), macAddress, sbx.ContainerID(), sbx.Key())
}

Contributing

Want to hack on libnetwork? Docker's contributions guidelines apply.

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