Make compatible with Docker Swarmkit

Implement (empty) endpoints for new NetworkAllocate and NetworkFree calls
Also update libnetwork and docker dependencies
This commit is contained in:
Martynas Pumputis authored and Bryan Boreham committed 2017-04-12 10:19:06 +00:00
1 parent ceb0186f46
commit 53cc270f47
4 files changed
+36 -2

No files matched your search

+10
View File
@@ -67,6 +67,16 @@ func (driver *driver) CreateNetwork(create *api.CreateNetworkRequest) error {
return err
}
func (driver *driver) NetworkAllocate(alloc *api.AllocateNetworkRequest) (*api.AllocateNetworkResponse, error) {
driver.logReq("NetworkAllocate", alloc, alloc.NetworkID)
return nil, nil
}
func (driver *driver) NetworkFree(free *api.FreeNetworkRequest) (*api.FreeNetworkResponse, error) {
driver.logReq("NetworkFree", free, free.NetworkID)
return nil, nil
}
// Deal with excessively-generic way the options get decoded from JSON
func stringOptions(create *api.CreateNetworkRequest) map[string]string {
if create.Options != nil {
+24
View File
@@ -26,6 +26,8 @@ type Driver interface {
DeleteEndpoint(delete *api.DeleteEndpointRequest) error
EndpointInfo(req *api.EndpointInfoRequest) (*api.EndpointInfoResponse, error)
JoinEndpoint(j *api.JoinRequest) (response *api.JoinResponse, error error)
NetworkAllocate(*api.AllocateNetworkRequest) (*api.AllocateNetworkResponse, error)
NetworkFree(*api.FreeNetworkRequest) (*api.FreeNetworkResponse, error)
LeaveEndpoint(leave *api.LeaveRequest) error
DiscoverNew(discover *api.DiscoveryNotification) error
DiscoverDelete(delete *api.DiscoveryNotification) error
@@ -58,6 +60,8 @@ func Listen(socket net.Listener, driver Driver, ipamDriver ipamapi.Ipam) error {
handleMethod(networkReceiver, "EndpointOperInfo", listener.infoEndpoint)
handleMethod(networkReceiver, "Join", listener.joinEndpoint)
handleMethod(networkReceiver, "Leave", listener.leaveEndpoint)
handleMethod(networkReceiver, "AllocateNetwork", listener.networkAllocate)
handleMethod(networkReceiver, "FreeNetwork", listener.networkFree)
}
if ipamDriver != nil {
@@ -163,6 +167,26 @@ func (listener *listener) joinEndpoint(w http.ResponseWriter, r *http.Request) {
objectOrErrorResponse(w, res, err)
}
func (listener *listener) networkAllocate(w http.ResponseWriter, r *http.Request) {
var alloc api.AllocateNetworkRequest
if err := json.NewDecoder(r.Body).Decode(&alloc); err != nil {
sendError(w, "Could not decode JSON encode payload", http.StatusBadRequest)
return
}
res, err := listener.d.NetworkAllocate(&alloc)
objectOrErrorResponse(w, res, err)
}
func (listener *listener) networkFree(w http.ResponseWriter, r *http.Request) {
var free api.FreeNetworkRequest
if err := json.NewDecoder(r.Body).Decode(&free); err != nil {
sendError(w, "Could not decode JSON encode payload", http.StatusBadRequest)
return
}
res, err := listener.d.NetworkFree(&free)
objectOrErrorResponse(w, res, err)
}
func (listener *listener) leaveEndpoint(w http.ResponseWriter, r *http.Request) {
var l api.LeaveRequest
if err := json.NewDecoder(r.Body).Decode(&l); err != nil {