@@ -130,10 +130,10 @@ github.com/containerd/ttrpc                         f02858b1457c5ca3aaec3a0803eb

 github.com/gogo/googleapis                          d31c731455cb061f42baff3bda55bad0118b126b # v1.2.0

 # cluster

-github.com/docker/swarmkit                          59163bf75df38489d4a10392265d27156dc473c5

+github.com/docker/swarmkit                          1e20cbf4caaeaba79c75af00bce5f41085db4082

 github.com/gogo/protobuf                            ba06b47c162d49f2af050fb4c75bcbc86a159d5c # v1.2.1

 github.com/cloudflare/cfssl                         5d63dbd981b5c408effbb58c442d54761ff94fbd # 1.3.2

-github.com/fernet/fernet-go                         1b2437bc582b3cfbb341ee5a29f8ef5b42912ff2

+github.com/fernet/fernet-go                         9eac43b88a5efb8651d24de9b68e87567e029736

 github.com/google/certificate-transparency-go       37a384cd035e722ea46e55029093e26687138edf # v1.0.20

 golang.org/x/crypto                                 88737f569e3a9c7ab309cdc09a07fe7fc87233c3

 golang.org/x/time                                   fbb02b2291d28baffd63558aa44b4b56f178d650

@@ -51,6 +51,8 @@

 		RemoveServiceResponse

 		ListServicesRequest

 		ListServicesResponse

+		ListServiceStatusesRequest

+		ListServiceStatusesResponse

 		CreateNetworkRequest

 		CreateNetworkResponse

 		GetNetworkRequest

@@ -321,13 +321,62 @@ func (m *ListServicesResponse) Reset()                    { *m = ListServicesRes

 func (*ListServicesResponse) ProtoMessage()               {}

 func (*ListServicesResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{23} }

+// ListServiceStatusesRequest is a request to get the aggregate status of a

+// service by computing the number of running vs desired tasks. It includes

+// only a service ID.

+type ListServiceStatusesRequest struct {

+	// Services is a list of service IDs to get statuses for.

+	Services []string `protobuf:"bytes,1,rep,name=services" json:"services,omitempty"`

+}

+

+func (m *ListServiceStatusesRequest) Reset()      { *m = ListServiceStatusesRequest{} }

+func (*ListServiceStatusesRequest) ProtoMessage() {}

+func (*ListServiceStatusesRequest) Descriptor() ([]byte, []int) {

+	return fileDescriptorControl, []int{24}

+}

+

+// ListServiceStatusesResponse is a response containing the aggregate status of

+// a service, formed by computing the number of running vs desired tasks. The

+// values returned are only valid for the point in time at which the request is

+// made.

+type ListServiceStatusesResponse struct {

+	Statuses []*ListServiceStatusesResponse_ServiceStatus `protobuf:"bytes,1,rep,name=statuses" json:"statuses,omitempty"`

+}

+

+func (m *ListServiceStatusesResponse) Reset()      { *m = ListServiceStatusesResponse{} }

+func (*ListServiceStatusesResponse) ProtoMessage() {}

+func (*ListServiceStatusesResponse) Descriptor() ([]byte, []int) {

+	return fileDescriptorControl, []int{25}

+}

+

+type ListServiceStatusesResponse_ServiceStatus struct {

+	// ServiceID is the ID of the service this status describes

+	ServiceID string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`

+	// DesiredTasks is the number of tasks desired to be running according to the

+	// service definition at request time. It is a uint64 because that is what

+	// the replicas field on the service spec is

+	DesiredTasks uint64 `protobuf:"varint,2,opt,name=desired_tasks,json=desiredTasks,proto3" json:"desired_tasks,omitempty"`

+	// RunningTasks is the number of tasks currently in the Running state at

+	// request time. This may be larger than desired tasks if, for example, a

+	// service has been scaled down.

+	RunningTasks uint64 `protobuf:"varint,3,opt,name=running_tasks,json=runningTasks,proto3" json:"running_tasks,omitempty"`

+}

+

+func (m *ListServiceStatusesResponse_ServiceStatus) Reset() {

+	*m = ListServiceStatusesResponse_ServiceStatus{}

+}

+func (*ListServiceStatusesResponse_ServiceStatus) ProtoMessage() {}

+func (*ListServiceStatusesResponse_ServiceStatus) Descriptor() ([]byte, []int) {

+	return fileDescriptorControl, []int{25, 0}

+}

+

 type CreateNetworkRequest struct {

 	Spec *NetworkSpec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"`

 }

 func (m *CreateNetworkRequest) Reset()                    { *m = CreateNetworkRequest{} }

 func (*CreateNetworkRequest) ProtoMessage()               {}

-func (*CreateNetworkRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{24} }

+func (*CreateNetworkRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{26} }

 type CreateNetworkResponse struct {

 	Network *Network `protobuf:"bytes,1,opt,name=network" json:"network,omitempty"`

@@ -335,7 +384,7 @@ type CreateNetworkResponse struct {

 func (m *CreateNetworkResponse) Reset()                    { *m = CreateNetworkResponse{} }

 func (*CreateNetworkResponse) ProtoMessage()               {}

-func (*CreateNetworkResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{25} }

+func (*CreateNetworkResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{27} }

 type GetNetworkRequest struct {

 	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

@@ -344,7 +393,7 @@ type GetNetworkRequest struct {

 func (m *GetNetworkRequest) Reset()                    { *m = GetNetworkRequest{} }

 func (*GetNetworkRequest) ProtoMessage()               {}

-func (*GetNetworkRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{26} }

+func (*GetNetworkRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{28} }

 type GetNetworkResponse struct {

 	Network *Network `protobuf:"bytes,1,opt,name=network" json:"network,omitempty"`

@@ -352,7 +401,7 @@ type GetNetworkResponse struct {

 func (m *GetNetworkResponse) Reset()                    { *m = GetNetworkResponse{} }

 func (*GetNetworkResponse) ProtoMessage()               {}

-func (*GetNetworkResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{27} }

+func (*GetNetworkResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{29} }

 type RemoveNetworkRequest struct {

 	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

@@ -361,14 +410,14 @@ type RemoveNetworkRequest struct {

 func (m *RemoveNetworkRequest) Reset()                    { *m = RemoveNetworkRequest{} }

 func (*RemoveNetworkRequest) ProtoMessage()               {}

-func (*RemoveNetworkRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{28} }

+func (*RemoveNetworkRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{30} }

 type RemoveNetworkResponse struct {

 }

 func (m *RemoveNetworkResponse) Reset()                    { *m = RemoveNetworkResponse{} }

 func (*RemoveNetworkResponse) ProtoMessage()               {}

-func (*RemoveNetworkResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{29} }

+func (*RemoveNetworkResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{31} }

 type ListNetworksRequest struct {

 	Filters *ListNetworksRequest_Filters `protobuf:"bytes,1,opt,name=filters" json:"filters,omitempty"`

@@ -376,7 +425,7 @@ type ListNetworksRequest struct {

 func (m *ListNetworksRequest) Reset()                    { *m = ListNetworksRequest{} }

 func (*ListNetworksRequest) ProtoMessage()               {}

-func (*ListNetworksRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{30} }

+func (*ListNetworksRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{32} }

 type ListNetworksRequest_Filters struct {

 	Names      []string          `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`

@@ -389,7 +438,7 @@ type ListNetworksRequest_Filters struct {

 func (m *ListNetworksRequest_Filters) Reset()      { *m = ListNetworksRequest_Filters{} }

 func (*ListNetworksRequest_Filters) ProtoMessage() {}

 func (*ListNetworksRequest_Filters) Descriptor() ([]byte, []int) {

-	return fileDescriptorControl, []int{30, 0}

+	return fileDescriptorControl, []int{32, 0}

 }

 type ListNetworksResponse struct {

@@ -398,7 +447,7 @@ type ListNetworksResponse struct {

 func (m *ListNetworksResponse) Reset()                    { *m = ListNetworksResponse{} }

 func (*ListNetworksResponse) ProtoMessage()               {}

-func (*ListNetworksResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{31} }

+func (*ListNetworksResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{33} }

 type GetClusterRequest struct {

 	ClusterID string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`

@@ -406,7 +455,7 @@ type GetClusterRequest struct {

 func (m *GetClusterRequest) Reset()                    { *m = GetClusterRequest{} }

 func (*GetClusterRequest) ProtoMessage()               {}

-func (*GetClusterRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{32} }

+func (*GetClusterRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{34} }

 type GetClusterResponse struct {

 	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`

@@ -414,7 +463,7 @@ type GetClusterResponse struct {

 func (m *GetClusterResponse) Reset()                    { *m = GetClusterResponse{} }

 func (*GetClusterResponse) ProtoMessage()               {}

-func (*GetClusterResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{33} }

+func (*GetClusterResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{35} }

 type ListClustersRequest struct {

 	Filters *ListClustersRequest_Filters `protobuf:"bytes,1,opt,name=filters" json:"filters,omitempty"`

@@ -422,7 +471,7 @@ type ListClustersRequest struct {

 func (m *ListClustersRequest) Reset()                    { *m = ListClustersRequest{} }

 func (*ListClustersRequest) ProtoMessage()               {}

-func (*ListClustersRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{34} }

+func (*ListClustersRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{36} }

 type ListClustersRequest_Filters struct {

 	Names      []string          `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`

@@ -435,7 +484,7 @@ type ListClustersRequest_Filters struct {

 func (m *ListClustersRequest_Filters) Reset()      { *m = ListClustersRequest_Filters{} }

 func (*ListClustersRequest_Filters) ProtoMessage() {}

 func (*ListClustersRequest_Filters) Descriptor() ([]byte, []int) {

-	return fileDescriptorControl, []int{34, 0}

+	return fileDescriptorControl, []int{36, 0}

 }

 type ListClustersResponse struct {

@@ -444,7 +493,7 @@ type ListClustersResponse struct {

 func (m *ListClustersResponse) Reset()                    { *m = ListClustersResponse{} }

 func (*ListClustersResponse) ProtoMessage()               {}

-func (*ListClustersResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{35} }

+func (*ListClustersResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{37} }

 // KeyRotation tells UpdateCluster what items to rotate

 type KeyRotation struct {

@@ -458,7 +507,7 @@ type KeyRotation struct {

 func (m *KeyRotation) Reset()                    { *m = KeyRotation{} }

 func (*KeyRotation) ProtoMessage()               {}

-func (*KeyRotation) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{36} }

+func (*KeyRotation) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{38} }

 type UpdateClusterRequest struct {

 	// ClusterID is the cluster ID to update.

@@ -473,7 +522,7 @@ type UpdateClusterRequest struct {

 func (m *UpdateClusterRequest) Reset()                    { *m = UpdateClusterRequest{} }

 func (*UpdateClusterRequest) ProtoMessage()               {}

-func (*UpdateClusterRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{37} }

+func (*UpdateClusterRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{39} }

 type UpdateClusterResponse struct {

 	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`

@@ -481,7 +530,7 @@ type UpdateClusterResponse struct {

 func (m *UpdateClusterResponse) Reset()                    { *m = UpdateClusterResponse{} }

 func (*UpdateClusterResponse) ProtoMessage()               {}

-func (*UpdateClusterResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{38} }

+func (*UpdateClusterResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{40} }

 // GetSecretRequest is the request to get a `Secret` object given a secret id.

 type GetSecretRequest struct {

@@ -490,7 +539,7 @@ type GetSecretRequest struct {

 func (m *GetSecretRequest) Reset()                    { *m = GetSecretRequest{} }

 func (*GetSecretRequest) ProtoMessage()               {}

-func (*GetSecretRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{39} }

+func (*GetSecretRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{41} }

 // GetSecretResponse contains the Secret corresponding to the id in

 // `GetSecretRequest`, but the `Secret.Spec.Data` field in each `Secret`

@@ -501,7 +550,7 @@ type GetSecretResponse struct {

 func (m *GetSecretResponse) Reset()                    { *m = GetSecretResponse{} }

 func (*GetSecretResponse) ProtoMessage()               {}

-func (*GetSecretResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{40} }

+func (*GetSecretResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{42} }

 type UpdateSecretRequest struct {

 	// SecretID is the secret ID to update.

@@ -515,7 +564,7 @@ type UpdateSecretRequest struct {

 func (m *UpdateSecretRequest) Reset()                    { *m = UpdateSecretRequest{} }

 func (*UpdateSecretRequest) ProtoMessage()               {}

-func (*UpdateSecretRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{41} }

+func (*UpdateSecretRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{43} }

 type UpdateSecretResponse struct {

 	Secret *Secret `protobuf:"bytes,1,opt,name=secret" json:"secret,omitempty"`

@@ -523,7 +572,7 @@ type UpdateSecretResponse struct {

 func (m *UpdateSecretResponse) Reset()                    { *m = UpdateSecretResponse{} }

 func (*UpdateSecretResponse) ProtoMessage()               {}

-func (*UpdateSecretResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{42} }

+func (*UpdateSecretResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{44} }

 // ListSecretRequest is the request to list all non-internal secrets in the secret store,

 // or all secrets filtered by (name or name prefix or id prefix) and labels.

@@ -533,7 +582,7 @@ type ListSecretsRequest struct {

 func (m *ListSecretsRequest) Reset()                    { *m = ListSecretsRequest{} }

 func (*ListSecretsRequest) ProtoMessage()               {}

-func (*ListSecretsRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{43} }

+func (*ListSecretsRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{45} }

 type ListSecretsRequest_Filters struct {

 	Names        []string          `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`

@@ -545,7 +594,7 @@ type ListSecretsRequest_Filters struct {

 func (m *ListSecretsRequest_Filters) Reset()      { *m = ListSecretsRequest_Filters{} }

 func (*ListSecretsRequest_Filters) ProtoMessage() {}

 func (*ListSecretsRequest_Filters) Descriptor() ([]byte, []int) {

-	return fileDescriptorControl, []int{43, 0}

+	return fileDescriptorControl, []int{45, 0}

 }

 // ListSecretResponse contains a list of all the secrets that match the name or

@@ -558,7 +607,7 @@ type ListSecretsResponse struct {

 func (m *ListSecretsResponse) Reset()                    { *m = ListSecretsResponse{} }

 func (*ListSecretsResponse) ProtoMessage()               {}

-func (*ListSecretsResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{44} }

+func (*ListSecretsResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{46} }

 // CreateSecretRequest specifies a new secret (it will not update an existing

 // secret) to create.

@@ -568,7 +617,7 @@ type CreateSecretRequest struct {

 func (m *CreateSecretRequest) Reset()                    { *m = CreateSecretRequest{} }

 func (*CreateSecretRequest) ProtoMessage()               {}

-func (*CreateSecretRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{45} }

+func (*CreateSecretRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{47} }

 // CreateSecretResponse contains the newly created `Secret` corresponding to the

 // name in `CreateSecretRequest`.  The `Secret.Spec.Data` field should be nil instead

@@ -579,7 +628,7 @@ type CreateSecretResponse struct {

 func (m *CreateSecretResponse) Reset()                    { *m = CreateSecretResponse{} }

 func (*CreateSecretResponse) ProtoMessage()               {}

-func (*CreateSecretResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{46} }

+func (*CreateSecretResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{48} }

 // RemoveSecretRequest contains the ID of the secret that should be removed.  This

 // removes all versions of the secret.

@@ -589,7 +638,7 @@ type RemoveSecretRequest struct {

 func (m *RemoveSecretRequest) Reset()                    { *m = RemoveSecretRequest{} }

 func (*RemoveSecretRequest) ProtoMessage()               {}

-func (*RemoveSecretRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{47} }

+func (*RemoveSecretRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{49} }

 // RemoveSecretResponse is an empty object indicating the successful removal of

 // a secret.

@@ -598,7 +647,7 @@ type RemoveSecretResponse struct {

 func (m *RemoveSecretResponse) Reset()                    { *m = RemoveSecretResponse{} }

 func (*RemoveSecretResponse) ProtoMessage()               {}

-func (*RemoveSecretResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{48} }

+func (*RemoveSecretResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{50} }

 // GetConfigRequest is the request to get a `Config` object given a config id.

 type GetConfigRequest struct {

@@ -607,7 +656,7 @@ type GetConfigRequest struct {

 func (m *GetConfigRequest) Reset()                    { *m = GetConfigRequest{} }

 func (*GetConfigRequest) ProtoMessage()               {}

-func (*GetConfigRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{49} }

+func (*GetConfigRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{51} }

 // GetConfigResponse contains the Config corresponding to the id in

 // `GetConfigRequest`.

@@ -617,7 +666,7 @@ type GetConfigResponse struct {

 func (m *GetConfigResponse) Reset()                    { *m = GetConfigResponse{} }

 func (*GetConfigResponse) ProtoMessage()               {}

-func (*GetConfigResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{50} }

+func (*GetConfigResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{52} }

 type UpdateConfigRequest struct {

 	// ConfigID is the config ID to update.

@@ -631,7 +680,7 @@ type UpdateConfigRequest struct {

 func (m *UpdateConfigRequest) Reset()                    { *m = UpdateConfigRequest{} }

 func (*UpdateConfigRequest) ProtoMessage()               {}

-func (*UpdateConfigRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{51} }

+func (*UpdateConfigRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{53} }

 type UpdateConfigResponse struct {

 	Config *Config `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"`

@@ -639,7 +688,7 @@ type UpdateConfigResponse struct {

 func (m *UpdateConfigResponse) Reset()                    { *m = UpdateConfigResponse{} }

 func (*UpdateConfigResponse) ProtoMessage()               {}

-func (*UpdateConfigResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{52} }

+func (*UpdateConfigResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{54} }

 // ListConfigRequest is the request to list all configs in the config store,

 // or all configs filtered by (name or name prefix or id prefix) and labels.

@@ -649,7 +698,7 @@ type ListConfigsRequest struct {

 func (m *ListConfigsRequest) Reset()                    { *m = ListConfigsRequest{} }

 func (*ListConfigsRequest) ProtoMessage()               {}

-func (*ListConfigsRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{53} }

+func (*ListConfigsRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{55} }

 type ListConfigsRequest_Filters struct {

 	Names        []string          `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`

@@ -661,7 +710,7 @@ type ListConfigsRequest_Filters struct {

 func (m *ListConfigsRequest_Filters) Reset()      { *m = ListConfigsRequest_Filters{} }

 func (*ListConfigsRequest_Filters) ProtoMessage() {}

 func (*ListConfigsRequest_Filters) Descriptor() ([]byte, []int) {

-	return fileDescriptorControl, []int{53, 0}

+	return fileDescriptorControl, []int{55, 0}

 }

 // ListConfigResponse contains a list of all the configs that match the name or

@@ -672,7 +721,7 @@ type ListConfigsResponse struct {

 func (m *ListConfigsResponse) Reset()                    { *m = ListConfigsResponse{} }

 func (*ListConfigsResponse) ProtoMessage()               {}

-func (*ListConfigsResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{54} }

+func (*ListConfigsResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{56} }

 // CreateConfigRequest specifies a new config (it will not update an existing

 // config) to create.

@@ -682,7 +731,7 @@ type CreateConfigRequest struct {

 func (m *CreateConfigRequest) Reset()                    { *m = CreateConfigRequest{} }

 func (*CreateConfigRequest) ProtoMessage()               {}

-func (*CreateConfigRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{55} }

+func (*CreateConfigRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{57} }

 // CreateConfigResponse contains the newly created `Config` corresponding to the

 // name in `CreateConfigRequest`.

@@ -692,7 +741,7 @@ type CreateConfigResponse struct {

 func (m *CreateConfigResponse) Reset()                    { *m = CreateConfigResponse{} }

 func (*CreateConfigResponse) ProtoMessage()               {}

-func (*CreateConfigResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{56} }

+func (*CreateConfigResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{58} }

 // RemoveConfigRequest contains the ID of the config that should be removed.  This

 // removes all versions of the config.

@@ -702,7 +751,7 @@ type RemoveConfigRequest struct {

 func (m *RemoveConfigRequest) Reset()                    { *m = RemoveConfigRequest{} }

 func (*RemoveConfigRequest) ProtoMessage()               {}

-func (*RemoveConfigRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{57} }

+func (*RemoveConfigRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{59} }

 // RemoveConfigResponse is an empty object indicating the successful removal of

 // a config.

@@ -711,7 +760,7 @@ type RemoveConfigResponse struct {

 func (m *RemoveConfigResponse) Reset()                    { *m = RemoveConfigResponse{} }

 func (*RemoveConfigResponse) ProtoMessage()               {}

-func (*RemoveConfigResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{58} }

+func (*RemoveConfigResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{60} }

 // CreateExtensionRequest creates a new extension as specified by the provided

 // parameters

@@ -722,7 +771,7 @@ type CreateExtensionRequest struct {

 func (m *CreateExtensionRequest) Reset()                    { *m = CreateExtensionRequest{} }

 func (*CreateExtensionRequest) ProtoMessage()               {}

-func (*CreateExtensionRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{59} }

+func (*CreateExtensionRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{61} }

 // CreateExtensionResponse contains the newly created `Extension` corresponding

 // to the parameters in the CreateExtensionRequest.

@@ -732,7 +781,7 @@ type CreateExtensionResponse struct {

 func (m *CreateExtensionResponse) Reset()                    { *m = CreateExtensionResponse{} }

 func (*CreateExtensionResponse) ProtoMessage()               {}

-func (*CreateExtensionResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{60} }

+func (*CreateExtensionResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{62} }

 // RemoveExtensionRequest contains the ID of the extension that should be removed. This

 // removes all versions of the extension.

@@ -742,7 +791,7 @@ type RemoveExtensionRequest struct {

 func (m *RemoveExtensionRequest) Reset()                    { *m = RemoveExtensionRequest{} }

 func (*RemoveExtensionRequest) ProtoMessage()               {}

-func (*RemoveExtensionRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{61} }

+func (*RemoveExtensionRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{63} }

 // RemoveExtensionResponse is an empty object indicating the successful removal

 // of an extension.

@@ -751,7 +800,7 @@ type RemoveExtensionResponse struct {

 func (m *RemoveExtensionResponse) Reset()                    { *m = RemoveExtensionResponse{} }

 func (*RemoveExtensionResponse) ProtoMessage()               {}

-func (*RemoveExtensionResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{62} }

+func (*RemoveExtensionResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{64} }

 // GetResourceRequest is the request to get a Extension object given a extension id.

 type GetExtensionRequest struct {

@@ -760,7 +809,7 @@ type GetExtensionRequest struct {

 func (m *GetExtensionRequest) Reset()                    { *m = GetExtensionRequest{} }

 func (*GetExtensionRequest) ProtoMessage()               {}

-func (*GetExtensionRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{63} }

+func (*GetExtensionRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{65} }

 // GetExtensionResponse contains the Extension corresponding to the id in

 // `GetExtensionRequest`.

@@ -770,7 +819,7 @@ type GetExtensionResponse struct {

 func (m *GetExtensionResponse) Reset()                    { *m = GetExtensionResponse{} }

 func (*GetExtensionResponse) ProtoMessage()               {}

-func (*GetExtensionResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{64} }

+func (*GetExtensionResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{66} }

 // CreateResourceRequest creates a new resource specified by the included

 // resource object. An existing resource will not be updated.

@@ -782,7 +831,7 @@ type CreateResourceRequest struct {

 func (m *CreateResourceRequest) Reset()                    { *m = CreateResourceRequest{} }

 func (*CreateResourceRequest) ProtoMessage()               {}

-func (*CreateResourceRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{65} }

+func (*CreateResourceRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{67} }

 // CreateResourceResponse contains the newly created `Resource` corresponding

 // to the resource in the CreateResourceRequest.

@@ -792,7 +841,7 @@ type CreateResourceResponse struct {

 func (m *CreateResourceResponse) Reset()                    { *m = CreateResourceResponse{} }

 func (*CreateResourceResponse) ProtoMessage()               {}

-func (*CreateResourceResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{66} }

+func (*CreateResourceResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{68} }

 // RemoveResourceRequest contains the ID of the resource that should be removed. This

 // removes all versions of the resource.

@@ -802,7 +851,7 @@ type RemoveResourceRequest struct {

 func (m *RemoveResourceRequest) Reset()                    { *m = RemoveResourceRequest{} }

 func (*RemoveResourceRequest) ProtoMessage()               {}

-func (*RemoveResourceRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{67} }

+func (*RemoveResourceRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{69} }

 // RemoveResourceResponse is an empty object indicating the successful removal

 // of a resource.

@@ -811,7 +860,7 @@ type RemoveResourceResponse struct {

 func (m *RemoveResourceResponse) Reset()                    { *m = RemoveResourceResponse{} }

 func (*RemoveResourceResponse) ProtoMessage()               {}

-func (*RemoveResourceResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{68} }

+func (*RemoveResourceResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{70} }

 // UpdateResourceRequest updates the resource specified by the given resource object.

 type UpdateResourceRequest struct {

@@ -828,7 +877,7 @@ type UpdateResourceRequest struct {

 func (m *UpdateResourceRequest) Reset()                    { *m = UpdateResourceRequest{} }

 func (*UpdateResourceRequest) ProtoMessage()               {}

-func (*UpdateResourceRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{69} }

+func (*UpdateResourceRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{71} }

 type UpdateResourceResponse struct {

 	Resource *Resource `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"`

@@ -836,7 +885,7 @@ type UpdateResourceResponse struct {

 func (m *UpdateResourceResponse) Reset()                    { *m = UpdateResourceResponse{} }

 func (*UpdateResourceResponse) ProtoMessage()               {}

-func (*UpdateResourceResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{70} }

+func (*UpdateResourceResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{72} }

 // GetResourceRequest is the request to get a Resource object given a resource id.

 type GetResourceRequest struct {

@@ -845,7 +894,7 @@ type GetResourceRequest struct {

 func (m *GetResourceRequest) Reset()                    { *m = GetResourceRequest{} }

 func (*GetResourceRequest) ProtoMessage()               {}

-func (*GetResourceRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{71} }

+func (*GetResourceRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{73} }

 // GetResourceResponse contains the Resource corresponding to the id in

 // `GetResourceRequest`.

@@ -855,7 +904,7 @@ type GetResourceResponse struct {

 func (m *GetResourceResponse) Reset()                    { *m = GetResourceResponse{} }

 func (*GetResourceResponse) ProtoMessage()               {}

-func (*GetResourceResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{72} }

+func (*GetResourceResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{74} }

 // ListResourcesRequest is the request to list all resources in the raft store,

 // or all resources filtered by (name or name prefix or id prefix), labels and extension.

@@ -865,7 +914,7 @@ type ListResourcesRequest struct {

 func (m *ListResourcesRequest) Reset()                    { *m = ListResourcesRequest{} }

 func (*ListResourcesRequest) ProtoMessage()               {}

-func (*ListResourcesRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{73} }

+func (*ListResourcesRequest) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{75} }

 type ListResourcesRequest_Filters struct {

 	Names        []string          `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`

@@ -878,7 +927,7 @@ type ListResourcesRequest_Filters struct {

 func (m *ListResourcesRequest_Filters) Reset()      { *m = ListResourcesRequest_Filters{} }

 func (*ListResourcesRequest_Filters) ProtoMessage() {}

 func (*ListResourcesRequest_Filters) Descriptor() ([]byte, []int) {

-	return fileDescriptorControl, []int{73, 0}

+	return fileDescriptorControl, []int{75, 0}

 }

 // ListResourcesResponse contains a list of all the resources that match the name or

@@ -889,7 +938,7 @@ type ListResourcesResponse struct {

 func (m *ListResourcesResponse) Reset()                    { *m = ListResourcesResponse{} }

 func (*ListResourcesResponse) ProtoMessage()               {}

-func (*ListResourcesResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{74} }

+func (*ListResourcesResponse) Descriptor() ([]byte, []int) { return fileDescriptorControl, []int{76} }

 func init() {

 	proto.RegisterType((*GetNodeRequest)(nil), "docker.swarmkit.v1.GetNodeRequest")

@@ -919,6 +968,9 @@ func init() {

 	proto.RegisterType((*ListServicesRequest)(nil), "docker.swarmkit.v1.ListServicesRequest")

 	proto.RegisterType((*ListServicesRequest_Filters)(nil), "docker.swarmkit.v1.ListServicesRequest.Filters")

 	proto.RegisterType((*ListServicesResponse)(nil), "docker.swarmkit.v1.ListServicesResponse")

+	proto.RegisterType((*ListServiceStatusesRequest)(nil), "docker.swarmkit.v1.ListServiceStatusesRequest")

+	proto.RegisterType((*ListServiceStatusesResponse)(nil), "docker.swarmkit.v1.ListServiceStatusesResponse")

+	proto.RegisterType((*ListServiceStatusesResponse_ServiceStatus)(nil), "docker.swarmkit.v1.ListServiceStatusesResponse.ServiceStatus")

 	proto.RegisterType((*CreateNetworkRequest)(nil), "docker.swarmkit.v1.CreateNetworkRequest")

 	proto.RegisterType((*CreateNetworkResponse)(nil), "docker.swarmkit.v1.CreateNetworkResponse")

 	proto.RegisterType((*GetNetworkRequest)(nil), "docker.swarmkit.v1.GetNetworkRequest")

@@ -1086,6 +1138,14 @@ func (p *authenticatedWrapperControlServer) RemoveService(ctx context.Context, r

 	return p.local.RemoveService(ctx, r)

 }

+func (p *authenticatedWrapperControlServer) ListServiceStatuses(ctx context.Context, r *ListServiceStatusesRequest) (*ListServiceStatusesResponse, error) {

+

+	if err := p.authorize(ctx, []string{"swarm-manager"}); err != nil {

+		return nil, err

+	}

+	return p.local.ListServiceStatuses(ctx, r)

+}

+

 func (p *authenticatedWrapperControlServer) GetNetwork(ctx context.Context, r *GetNetworkRequest) (*GetNetworkResponse, error) {

 	if err := p.authorize(ctx, []string{"swarm-manager"}); err != nil {

@@ -1864,6 +1924,64 @@ func (m *ListServicesResponse) CopyFrom(src interface{}) {

 }

+func (m *ListServiceStatusesRequest) Copy() *ListServiceStatusesRequest {

+	if m == nil {

+		return nil

+	}

+	o := &ListServiceStatusesRequest{}

+	o.CopyFrom(m)

+	return o

+}

+

+func (m *ListServiceStatusesRequest) CopyFrom(src interface{}) {

+

+	o := src.(*ListServiceStatusesRequest)

+	*m = *o

+	if o.Services != nil {

+		m.Services = make([]string, len(o.Services))

+		copy(m.Services, o.Services)

+	}

+

+}

+

+func (m *ListServiceStatusesResponse) Copy() *ListServiceStatusesResponse {

+	if m == nil {

+		return nil

+	}

+	o := &ListServiceStatusesResponse{}

+	o.CopyFrom(m)

+	return o

+}

+

+func (m *ListServiceStatusesResponse) CopyFrom(src interface{}) {

+

+	o := src.(*ListServiceStatusesResponse)

+	*m = *o

+	if o.Statuses != nil {

+		m.Statuses = make([]*ListServiceStatusesResponse_ServiceStatus, len(o.Statuses))

+		for i := range m.Statuses {

+			m.Statuses[i] = &ListServiceStatusesResponse_ServiceStatus{}

+			deepcopy.Copy(m.Statuses[i], o.Statuses[i])

+		}

+	}

+

+}

+

+func (m *ListServiceStatusesResponse_ServiceStatus) Copy() *ListServiceStatusesResponse_ServiceStatus {

+	if m == nil {

+		return nil

+	}

+	o := &ListServiceStatusesResponse_ServiceStatus{}

+	o.CopyFrom(m)

+	return o

+}

+

+func (m *ListServiceStatusesResponse_ServiceStatus) CopyFrom(src interface{}) {

+

+	o := src.(*ListServiceStatusesResponse_ServiceStatus)

+	*m = *o

+}

+

 func (m *CreateNetworkRequest) Copy() *CreateNetworkRequest {

 	if m == nil {

 		return nil

@@ -2993,6 +3111,13 @@ type ControlClient interface {

 	CreateService(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error)

 	UpdateService(ctx context.Context, in *UpdateServiceRequest, opts ...grpc.CallOption) (*UpdateServiceResponse, error)

 	RemoveService(ctx context.Context, in *RemoveServiceRequest, opts ...grpc.CallOption) (*RemoveServiceResponse, error)

+	// ListServiceStatuses returns a `ListServiceStatusesResponse` with the

+	// status of the requested services, formed by computing the number of

+	// running vs desired tasks. It is provided as a shortcut or helper method,

+	// which allows a client to avoid having to calculate this value by listing

+	// all Tasks. If any service requested does not exist, it will be returned

+	// but with empty status values.

+	ListServiceStatuses(ctx context.Context, in *ListServiceStatusesRequest, opts ...grpc.CallOption) (*ListServiceStatusesResponse, error)

 	GetNetwork(ctx context.Context, in *GetNetworkRequest, opts ...grpc.CallOption) (*GetNetworkResponse, error)

 	ListNetworks(ctx context.Context, in *ListNetworksRequest, opts ...grpc.CallOption) (*ListNetworksResponse, error)

 	CreateNetwork(ctx context.Context, in *CreateNetworkRequest, opts ...grpc.CallOption) (*CreateNetworkResponse, error)

@@ -3222,6 +3347,15 @@ func (c *controlClient) RemoveService(ctx context.Context, in *RemoveServiceRequ

 	return out, nil

 }

+func (c *controlClient) ListServiceStatuses(ctx context.Context, in *ListServiceStatusesRequest, opts ...grpc.CallOption) (*ListServiceStatusesResponse, error) {

+	out := new(ListServiceStatusesResponse)

+	err := grpc.Invoke(ctx, "/docker.swarmkit.v1.Control/ListServiceStatuses", in, out, c.cc, opts...)

+	if err != nil {

+		return nil, err

+	}

+	return out, nil

+}

+

 func (c *controlClient) GetNetwork(ctx context.Context, in *GetNetworkRequest, opts ...grpc.CallOption) (*GetNetworkResponse, error) {

 	out := new(GetNetworkResponse)

 	err := grpc.Invoke(ctx, "/docker.swarmkit.v1.Control/GetNetwork", in, out, c.cc, opts...)

@@ -3462,6 +3596,13 @@ type ControlServer interface {

 	CreateService(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)

 	UpdateService(context.Context, *UpdateServiceRequest) (*UpdateServiceResponse, error)

 	RemoveService(context.Context, *RemoveServiceRequest) (*RemoveServiceResponse, error)

+	// ListServiceStatuses returns a `ListServiceStatusesResponse` with the

+	// status of the requested services, formed by computing the number of

+	// running vs desired tasks. It is provided as a shortcut or helper method,

+	// which allows a client to avoid having to calculate this value by listing

+	// all Tasks. If any service requested does not exist, it will be returned

+	// but with empty status values.

+	ListServiceStatuses(context.Context, *ListServiceStatusesRequest) (*ListServiceStatusesResponse, error)

 	GetNetwork(context.Context, *GetNetworkRequest) (*GetNetworkResponse, error)

 	ListNetworks(context.Context, *ListNetworksRequest) (*ListNetworksResponse, error)

 	CreateNetwork(context.Context, *CreateNetworkRequest) (*CreateNetworkResponse, error)

@@ -3795,6 +3936,24 @@ func _Control_RemoveService_Handler(srv interface{}, ctx context.Context, dec fu

 	return interceptor(ctx, in, info, handler)

 }

+func _Control_ListServiceStatuses_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {

+	in := new(ListServiceStatusesRequest)

+	if err := dec(in); err != nil {

+		return nil, err

+	}

+	if interceptor == nil {

+		return srv.(ControlServer).ListServiceStatuses(ctx, in)

+	}

+	info := &grpc.UnaryServerInfo{

+		Server:     srv,

+		FullMethod: "/docker.swarmkit.v1.Control/ListServiceStatuses",

+	}

+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {

+		return srv.(ControlServer).ListServiceStatuses(ctx, req.(*ListServiceStatusesRequest))

+	}

+	return interceptor(ctx, in, info, handler)

+}

+

 func _Control_GetNetwork_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {

 	in := new(GetNetworkRequest)

 	if err := dec(in); err != nil {

@@ -4298,6 +4457,10 @@ var _Control_serviceDesc = grpc.ServiceDesc{

 			Handler:    _Control_RemoveService_Handler,

 		},

 		{

+			MethodName: "ListServiceStatuses",

+			Handler:    _Control_ListServiceStatuses_Handler,

+		},

+		{

 			MethodName: "GetNetwork",

 			Handler:    _Control_GetNetwork_Handler,

 		},

@@ -5431,6 +5594,103 @@ func (m *ListServicesResponse) MarshalTo(dAtA []byte) (int, error) {

 	return i, nil

 }

+func (m *ListServiceStatusesRequest) Marshal() (dAtA []byte, err error) {

+	size := m.Size()

+	dAtA = make([]byte, size)

+	n, err := m.MarshalTo(dAtA)

+	if err != nil {

+		return nil, err

+	}

+	return dAtA[:n], nil

+}

+

+func (m *ListServiceStatusesRequest) MarshalTo(dAtA []byte) (int, error) {

+	var i int

+	_ = i

+	var l int

+	_ = l

+	if len(m.Services) > 0 {

+		for _, s := range m.Services {

+			dAtA[i] = 0xa

+			i++

+			l = len(s)

+			for l >= 1<<7 {

+				dAtA[i] = uint8(uint64(l)&0x7f | 0x80)

+				l >>= 7

+				i++

+			}

+			dAtA[i] = uint8(l)

+			i++

+			i += copy(dAtA[i:], s)

+		}

+	}

+	return i, nil

+}

+

+func (m *ListServiceStatusesResponse) Marshal() (dAtA []byte, err error) {

+	size := m.Size()

+	dAtA = make([]byte, size)

+	n, err := m.MarshalTo(dAtA)

+	if err != nil {

+		return nil, err

+	}

+	return dAtA[:n], nil

+}

+

+func (m *ListServiceStatusesResponse) MarshalTo(dAtA []byte) (int, error) {

+	var i int

+	_ = i

+	var l int

+	_ = l

+	if len(m.Statuses) > 0 {

+		for _, msg := range m.Statuses {

+			dAtA[i] = 0xa

+			i++

+			i = encodeVarintControl(dAtA, i, uint64(msg.Size()))

+			n, err := msg.MarshalTo(dAtA[i:])

+			if err != nil {

+				return 0, err

+			}

+			i += n

+		}

+	}

+	return i, nil

+}

+

+func (m *ListServiceStatusesResponse_ServiceStatus) Marshal() (dAtA []byte, err error) {

+	size := m.Size()

+	dAtA = make([]byte, size)

+	n, err := m.MarshalTo(dAtA)

+	if err != nil {

+		return nil, err

+	}

+	return dAtA[:n], nil

+}

+

+func (m *ListServiceStatusesResponse_ServiceStatus) MarshalTo(dAtA []byte) (int, error) {

+	var i int

+	_ = i

+	var l int

+	_ = l

+	if len(m.ServiceID) > 0 {

+		dAtA[i] = 0xa

+		i++

+		i = encodeVarintControl(dAtA, i, uint64(len(m.ServiceID)))

+		i += copy(dAtA[i:], m.ServiceID)

+	}

+	if m.DesiredTasks != 0 {

+		dAtA[i] = 0x10

+		i++

+		i = encodeVarintControl(dAtA, i, uint64(m.DesiredTasks))

+	}

+	if m.RunningTasks != 0 {

+		dAtA[i] = 0x18

+		i++

+		i = encodeVarintControl(dAtA, i, uint64(m.RunningTasks))

+	}

+	return i, nil

+}

+

 func (m *CreateNetworkRequest) Marshal() (dAtA []byte, err error) {

 	size := m.Size()

 	dAtA = make([]byte, size)

@@ -7819,6 +8079,41 @@ func (p *raftProxyControlServer) RemoveService(ctx context.Context, r *RemoveSer

 	return resp, err

 }

+func (p *raftProxyControlServer) ListServiceStatuses(ctx context.Context, r *ListServiceStatusesRequest) (*ListServiceStatusesResponse, error) {

+

+	conn, err := p.connSelector.LeaderConn(ctx)

+	if err != nil {

+		if err == raftselector.ErrIsLeader {

+			ctx, err = p.runCtxMods(ctx, p.localCtxMods)

+			if err != nil {

+				return nil, err

+			}

+			return p.local.ListServiceStatuses(ctx, r)

+		}

+		return nil, err

+	}

+	modCtx, err := p.runCtxMods(ctx, p.remoteCtxMods)

+	if err != nil {

+		return nil, err

+	}

+

+	resp, err := NewControlClient(conn).ListServiceStatuses(modCtx, r)

+	if err != nil {

+		if !strings.Contains(err.Error(), "is closing") && !strings.Contains(err.Error(), "the connection is unavailable") && !strings.Contains(err.Error(), "connection error") {

+			return resp, err

+		}

+		conn, err := p.pollNewLeaderConn(ctx)

+		if err != nil {

+			if err == raftselector.ErrIsLeader {

+				return p.local.ListServiceStatuses(ctx, r)

+			}

+			return nil, err

+		}

+		return NewControlClient(conn).ListServiceStatuses(modCtx, r)

+	}

+	return resp, err

+}

+

 func (p *raftProxyControlServer) GetNetwork(ctx context.Context, r *GetNetworkRequest) (*GetNetworkResponse, error) {

 	conn, err := p.connSelector.LeaderConn(ctx)

@@ -9099,6 +9394,46 @@ func (m *ListServicesResponse) Size() (n int) {

 	return n

 }

+func (m *ListServiceStatusesRequest) Size() (n int) {

+	var l int

+	_ = l

+	if len(m.Services) > 0 {

+		for _, s := range m.Services {