1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
package networkallocator
import (
"github.com/docker/swarmkit/api"
)
const (
// PredefinedLabel identifies internally allocated swarm networks
// corresponding to the node-local predefined networks on the host.
PredefinedLabel = "com.docker.swarm.predefined"
)
// PredefinedNetworkData contains the minimum set of data needed
// to create the correspondent predefined network object in the store.
type PredefinedNetworkData struct {
Name string
Driver string
}
// ServiceAllocationOpts is struct used for functional options in
// IsServiceAllocated
type ServiceAllocationOpts struct {
OnInit bool
}
// OnInit is called for allocator initialization stage
func OnInit(options *ServiceAllocationOpts) {
options.OnInit = true
}
// NetworkAllocator provides network model specific allocation functionality.
type NetworkAllocator interface {
//
// Network Allocation
//
// IsAllocated returns if the passed network has been allocated or not.
IsAllocated(n *api.Network) bool
// Allocate allocates all the necessary resources both general
// and driver-specific which may be specified in the NetworkSpec
Allocate(n *api.Network) error
// Deallocate frees all the general and driver specific resources
// which were assigned to the passed network.
Deallocate(n *api.Network) error
//
// Service Allocation
//
// IsServiceAllocated returns false if the passed service
// needs to have network resources allocated/updated.
IsServiceAllocated(s *api.Service, flags ...func(*ServiceAllocationOpts)) bool
// AllocateService allocates all the network resources such as virtual
// IP and ports needed by the service.
AllocateService(s *api.Service) (err error)
// DeallocateService de-allocates all the network resources such as
// virtual IP and ports associated with the service.
DeallocateService(s *api.Service) error
// HostPublishPortsNeedUpdate returns true if the passed service needs
// allocations for its published ports in host (non ingress) mode
HostPublishPortsNeedUpdate(s *api.Service) bool
//
// Task Allocation
//
// IsTaskAllocated returns if the passed task has its network
// resources allocated or not.
IsTaskAllocated(t *api.Task) bool
// AllocateTask allocates all the endpoint resources for all the
// networks that a task is attached to.
AllocateTask(t *api.Task) error
// DeallocateTask releases all the endpoint resources for all the
// networks that a task is attached to.
DeallocateTask(t *api.Task) error
// AllocateAttachment Allocates a load balancer endpoint for the node
AllocateAttachment(node *api.Node, networkAttachment *api.NetworkAttachment) error
// DeallocateAttachment Deallocates a load balancer endpoint for the node
DeallocateAttachment(node *api.Node, networkAttachment *api.NetworkAttachment) error
// IsAttachmentAllocated If lb endpoint is allocated on the node
IsAttachmentAllocated(node *api.Node, networkAttachment *api.NetworkAttachment) bool
}
// IsIngressNetwork check if the network is an ingress network
func IsIngressNetwork(nw *api.Network) bool {
if nw.Spec.Ingress {
return true
}
// Check if legacy defined ingress network
_, ok := nw.Spec.Annotations.Labels["com.docker.swarm.internal"]
return ok && nw.Spec.Annotations.Name == "ingress"
}
// IsIngressNetworkNeeded checks whether the service requires the routing-mesh
func IsIngressNetworkNeeded(s *api.Service) bool {
if s == nil {
return false
}
if s.Spec.Endpoint == nil {
return false
}
for _, p := range s.Spec.Endpoint.Ports {
// The service to which this task belongs is trying to
// expose ports with PublishMode as Ingress to the
// external world. Automatically attach the task to
// the ingress network.
if p.PublishMode == api.PublishModeIngress {
return true
}
}
return false
}
|
