api

package
v1.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 26, 2016 License: Apache-2.0 Imports: 21 Imported by: 0

README

Notice

Do not change .pb.go files directly. You need to change the corresponding .proto files and run the following command to regenerate the .pb.go files.

$ make generate

Click here for more information about protobuf.

Documentation

Overview

Package api is a generated protocol buffer package.

It is generated from these files: 

types.proto
specs.proto
objects.proto
control.proto
dispatcher.proto
ca.proto
snapshot.proto
raft.proto
health.proto

It has these top-level messages: 

Version
Annotations
Resources
ResourceRequirements
Platform
PluginDescription
EngineDescription
NodeDescription
RaftMemberStatus
NodeStatus
Image
Mount
RestartPolicy
UpdateConfig
UpdateStatus
ContainerStatus
TaskStatus
IPAMConfig
PortConfig
Driver
IPAMOptions
Peer
WeightedPeer
IssuanceStatus
AcceptancePolicy
ExternalCA
CAConfig
OrchestrationConfig
TaskDefaults
DispatcherConfig
RaftConfig
Placement
JoinTokens
RootCA
Certificate
EncryptionKey
ManagerStatus
NodeSpec
ServiceSpec
ReplicatedService
GlobalService
TaskSpec
ContainerSpec
EndpointSpec
NetworkSpec
ClusterSpec
Meta
Node
Service
Endpoint
Task
NetworkAttachment
Network
Cluster
GetNodeRequest
GetNodeResponse
ListNodesRequest
ListNodesResponse
UpdateNodeRequest
UpdateNodeResponse
RemoveNodeRequest
RemoveNodeResponse
GetTaskRequest
GetTaskResponse
RemoveTaskRequest
RemoveTaskResponse
ListTasksRequest
ListTasksResponse
CreateServiceRequest
CreateServiceResponse
GetServiceRequest
GetServiceResponse
UpdateServiceRequest
UpdateServiceResponse
RemoveServiceRequest
RemoveServiceResponse
ListServicesRequest
ListServicesResponse
CreateNetworkRequest
CreateNetworkResponse
GetNetworkRequest
GetNetworkResponse
RemoveNetworkRequest
RemoveNetworkResponse
ListNetworksRequest
ListNetworksResponse
GetClusterRequest
GetClusterResponse
ListClustersRequest
ListClustersResponse
JoinTokenRotation
UpdateClusterRequest
UpdateClusterResponse
SessionRequest
SessionMessage
HeartbeatRequest
HeartbeatResponse
UpdateTaskStatusRequest
UpdateTaskStatusResponse
TasksRequest
TasksMessage
NodeCertificateStatusRequest
NodeCertificateStatusResponse
IssueNodeCertificateRequest
IssueNodeCertificateResponse
GetRootCACertificateRequest
GetRootCACertificateResponse
StoreSnapshot
ClusterSnapshot
Snapshot
RaftMember
JoinRequest
JoinResponse
LeaveRequest
LeaveResponse
ProcessRaftMessageRequest
ProcessRaftMessageResponse
ResolveAddressRequest
ResolveAddressResponse
InternalRaftRequest
StoreAction
HealthCheckRequest
HealthCheckResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCa = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCa   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthControl = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowControl   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthDispatcher = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDispatcher   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthHealth = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHealth   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthObjects = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowObjects   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRaft = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaft   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSnapshot = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSnapshot   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSpecs = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSpecs   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes   = fmt.Errorf("proto: integer overflow")
)
View Source 
var EncryptionKey_Algorithm_name = map[int32]string{
	0: "AES_128_GCM",
}
View Source 
var EncryptionKey_Algorithm_value = map[string]int32{
	"AES_128_GCM": 0,
}
View Source 
var EndpointSpec_ResolutionMode_name = map[int32]string{
	0: "VIP",
	1: "DNSRR",
}
View Source 
var EndpointSpec_ResolutionMode_value = map[string]int32{
	"VIP":   0,
	"DNSRR": 1,
}
View Source 
var ExternalCA_CAProtocol_name = map[int32]string{
	0: "CFSSL",
}
View Source 
var ExternalCA_CAProtocol_value = map[string]int32{
	"CFSSL": 0,
}
View Source 
var HealthCheckResponse_ServingStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SERVING",
	2: "NOT_SERVING",
}
View Source 
var HealthCheckResponse_ServingStatus_value = map[string]int32{
	"UNKNOWN":     0,
	"SERVING":     1,
	"NOT_SERVING": 2,
}
View Source 
var IPAMConfig_AddressFamily_name = map[int32]string{
	0: "UNKNOWN",
	4: "IPV4",
	6: "IPV6",
}
View Source 
var IPAMConfig_AddressFamily_value = map[string]int32{
	"UNKNOWN": 0,
	"IPV4":    4,
	"IPV6":    6,
}
View Source 
var IssuanceStatus_State_name = map[int32]string{
	0: "UNKNOWN",
	1: "RENEW",
	2: "PENDING",
	3: "ISSUED",
	4: "FAILED",
}
View Source 
var IssuanceStatus_State_value = map[string]int32{
	"UNKNOWN": 0,
	"RENEW":   1,
	"PENDING": 2,
	"ISSUED":  3,
	"FAILED":  4,
}
View Source 
var Mount_BindOptions_MountPropagation_name = map[int32]string{
	0: "RPRIVATE",
	1: "PRIVATE",
	2: "RSHARED",
	3: "SHARED",
	4: "RSLAVE",
	5: "SLAVE",
}
View Source 
var Mount_BindOptions_MountPropagation_value = map[string]int32{
	"RPRIVATE": 0,
	"PRIVATE":  1,
	"RSHARED":  2,
	"SHARED":   3,
	"RSLAVE":   4,
	"SLAVE":    5,
}
View Source 
var Mount_MountType_name = map[int32]string{
	0: "BIND",
	1: "VOLUME",
	2: "TMPFS",
}
View Source 
var Mount_MountType_value = map[string]int32{
	"BIND":   0,
	"VOLUME": 1,
	"TMPFS":  2,
}
View Source 
var NodeRole_name = map[int32]string{
	0: "WORKER",
	1: "MANAGER",
}
View Source 
var NodeRole_value = map[string]int32{
	"WORKER":  0,
	"MANAGER": 1,
}
View Source 
var NodeSpec_Availability_name = map[int32]string{
	0: "ACTIVE",
	1: "PAUSE",
	2: "DRAIN",
}
View Source 
var NodeSpec_Availability_value = map[string]int32{
	"ACTIVE": 0,
	"PAUSE":  1,
	"DRAIN":  2,
}
View Source 
var NodeSpec_Membership_name = map[int32]string{
	0: "PENDING",
	1: "ACCEPTED",
}
View Source 
var NodeSpec_Membership_value = map[string]int32{
	"PENDING":  0,
	"ACCEPTED": 1,
}
View Source 
var NodeStatus_State_name = map[int32]string{
	0: "UNKNOWN",
	1: "DOWN",
	2: "READY",
	3: "DISCONNECTED",
}
View Source 
var NodeStatus_State_value = map[string]int32{
	"UNKNOWN":      0,
	"DOWN":         1,
	"READY":        2,
	"DISCONNECTED": 3,
}
View Source 
var PortConfig_Protocol_name = map[int32]string{
	0: "TCP",
	1: "UDP",
}
View Source 
var PortConfig_Protocol_value = map[string]int32{
	"TCP": 0,
	"UDP": 1,
}
View Source 
var RaftMemberStatus_Reachability_name = map[int32]string{
	0: "UNKNOWN",
	1: "UNREACHABLE",
	2: "REACHABLE",
}
View Source 
var RaftMemberStatus_Reachability_value = map[string]int32{
	"UNKNOWN":     0,
	"UNREACHABLE": 1,
	"REACHABLE":   2,
}
View Source 
var RestartPolicy_RestartCondition_name = map[int32]string{
	0: "NONE",
	1: "ON_FAILURE",
	2: "ANY",
}
View Source 
var RestartPolicy_RestartCondition_value = map[string]int32{
	"NONE":       0,
	"ON_FAILURE": 1,
	"ANY":        2,
}
View Source 
var Snapshot_Version_name = map[int32]string{
	0: "V0",
}
View Source 
var Snapshot_Version_value = map[string]int32{
	"V0": 0,
}
View Source 
var StoreActionKind_name = map[int32]string{
	0: "UNKNOWN",
	1: "STORE_ACTION_CREATE",
	2: "STORE_ACTION_UPDATE",
	3: "STORE_ACTION_REMOVE",
}
View Source 
var StoreActionKind_value = map[string]int32{
	"UNKNOWN":             0,
	"STORE_ACTION_CREATE": 1,
	"STORE_ACTION_UPDATE": 2,
	"STORE_ACTION_REMOVE": 3,
}
View Source 
var TaskState_name = map[int32]string{
	0:   "NEW",
	64:  "ALLOCATED",
	128: "PENDING",
	192: "ASSIGNED",
	256: "ACCEPTED",
	320: "PREPARING",
	384: "READY",
	448: "STARTING",
	512: "RUNNING",
	576: "COMPLETE",
	640: "SHUTDOWN",
	704: "FAILED",
	768: "REJECTED",
}
View Source 
var TaskState_value = map[string]int32{
	"NEW":       0,
	"ALLOCATED": 64,
	"PENDING":   128,
	"ASSIGNED":  192,
	"ACCEPTED":  256,
	"PREPARING": 320,
	"READY":     384,
	"STARTING":  448,
	"RUNNING":   512,
	"COMPLETE":  576,
	"SHUTDOWN":  640,
	"FAILED":    704,
	"REJECTED":  768,
}
View Source 
var UpdateConfig_FailureAction_name = map[int32]string{
	0: "PAUSE",
	1: "CONTINUE",
}
View Source 
var UpdateConfig_FailureAction_value = map[string]int32{
	"PAUSE":    0,
	"CONTINUE": 1,
}
View Source 
var UpdateStatus_UpdateState_name = map[int32]string{
	0: "UNKNOWN",
	1: "UPDATING",
	2: "PAUSED",
	3: "COMPLETED",
}
View Source 
var UpdateStatus_UpdateState_value = map[string]int32{
	"UNKNOWN":   0,
	"UPDATING":  1,
	"PAUSED":    2,
	"COMPLETED": 3,
}

Functions

func RegisterCAServer 

func RegisterCAServer(s *grpc.Server, srv CAServer)

func RegisterControlServer 

func RegisterControlServer(s *grpc.Server, srv ControlServer)

func RegisterDispatcherServer 

func RegisterDispatcherServer(s *grpc.Server, srv DispatcherServer)

func RegisterHealthServer 

func RegisterHealthServer(s *grpc.Server, srv HealthServer)

func RegisterNodeCAServer 

func RegisterNodeCAServer(s *grpc.Server, srv NodeCAServer)

func RegisterRaftMembershipServer 

func RegisterRaftMembershipServer(s *grpc.Server, srv RaftMembershipServer)

func RegisterRaftServer 

func RegisterRaftServer(s *grpc.Server, srv RaftServer)

Types

type AcceptancePolicy 

type AcceptancePolicy struct {
	Policies []*AcceptancePolicy_RoleAdmissionPolicy `protobuf:"bytes,1,rep,name=policies" json:"policies,omitempty"`
}

func (*AcceptancePolicy) Copy 

func (m *AcceptancePolicy) Copy() *AcceptancePolicy

func (*AcceptancePolicy) Descriptor 

func (*AcceptancePolicy) Descriptor() ([]byte, []int)

func (*AcceptancePolicy) GoString 

func (this *AcceptancePolicy) GoString() string

func (*AcceptancePolicy) Marshal 

func (m *AcceptancePolicy) Marshal() (data []byte, err error)

func (*AcceptancePolicy) MarshalTo 

func (m *AcceptancePolicy) MarshalTo(data []byte) (int, error)

func (*AcceptancePolicy) ProtoMessage 

func (*AcceptancePolicy) ProtoMessage()

func (*AcceptancePolicy) Reset 

func (m *AcceptancePolicy) Reset()

func (*AcceptancePolicy) Size 

func (m *AcceptancePolicy) Size() (n int)

func (*AcceptancePolicy) String 

func (this *AcceptancePolicy) String() string

func (*AcceptancePolicy) Unmarshal 

func (m *AcceptancePolicy) Unmarshal(data []byte) error

type AcceptancePolicy_RoleAdmissionPolicy 

type AcceptancePolicy_RoleAdmissionPolicy struct {
	Role NodeRole `protobuf:"varint,1,opt,name=role,proto3,enum=docker.swarmkit.v1.NodeRole" json:"role,omitempty"`
	// Autoaccept controls which roles' certificates are automatically
	// issued without administrator intervention.
	Autoaccept bool `protobuf:"varint,2,opt,name=autoaccept,proto3" json:"autoaccept,omitempty"`
	// Secret represents a user-provided string that is necessary for new
	// nodes to join the cluster
	Secret *AcceptancePolicy_RoleAdmissionPolicy_Secret `protobuf:"bytes,3,opt,name=secret" json:"secret,omitempty"`
}

func (*AcceptancePolicy_RoleAdmissionPolicy) Copy 

func (m *AcceptancePolicy_RoleAdmissionPolicy) Copy() *AcceptancePolicy_RoleAdmissionPolicy

func (*AcceptancePolicy_RoleAdmissionPolicy) Descriptor 

func (*AcceptancePolicy_RoleAdmissionPolicy) Descriptor() ([]byte, []int)

func (*AcceptancePolicy_RoleAdmissionPolicy) GoString 

func (this *AcceptancePolicy_RoleAdmissionPolicy) GoString() string

func (*AcceptancePolicy_RoleAdmissionPolicy) Marshal 

func (m *AcceptancePolicy_RoleAdmissionPolicy) Marshal() (data []byte, err error)

func (*AcceptancePolicy_RoleAdmissionPolicy) MarshalTo 

func (m *AcceptancePolicy_RoleAdmissionPolicy) MarshalTo(data []byte) (int, error)

func (*AcceptancePolicy_RoleAdmissionPolicy) ProtoMessage 

func (*AcceptancePolicy_RoleAdmissionPolicy) ProtoMessage()

func (*AcceptancePolicy_RoleAdmissionPolicy) Reset 

func (m *AcceptancePolicy_RoleAdmissionPolicy) Reset()

func (*AcceptancePolicy_RoleAdmissionPolicy) Size 

func (m *AcceptancePolicy_RoleAdmissionPolicy) Size() (n int)

func (*AcceptancePolicy_RoleAdmissionPolicy) String 

func (this *AcceptancePolicy_RoleAdmissionPolicy) String() string

func (*AcceptancePolicy_RoleAdmissionPolicy) Unmarshal 

func (m *AcceptancePolicy_RoleAdmissionPolicy) Unmarshal(data []byte) error

type AcceptancePolicy_RoleAdmissionPolicy_Secret 

type AcceptancePolicy_RoleAdmissionPolicy_Secret struct {
	// The actual content (possibly hashed)
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The type of hash we are using, or "plaintext"
	Alg string `protobuf:"bytes,2,opt,name=alg,proto3" json:"alg,omitempty"`
}

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Copy 

func (m *AcceptancePolicy_RoleAdmissionPolicy_Secret) Copy() *AcceptancePolicy_RoleAdmissionPolicy_Secret

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Descriptor 

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Descriptor() ([]byte, []int)

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) GoString 

func (this *AcceptancePolicy_RoleAdmissionPolicy_Secret) GoString() string

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Marshal 

func (m *AcceptancePolicy_RoleAdmissionPolicy_Secret) Marshal() (data []byte, err error)

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) MarshalTo 

func (m *AcceptancePolicy_RoleAdmissionPolicy_Secret) MarshalTo(data []byte) (int, error)

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) ProtoMessage 

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) ProtoMessage()

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Reset 

func (m *AcceptancePolicy_RoleAdmissionPolicy_Secret) Reset()

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Size 

func (m *AcceptancePolicy_RoleAdmissionPolicy_Secret) Size() (n int)

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) String 

func (this *AcceptancePolicy_RoleAdmissionPolicy_Secret) String() string

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Unmarshal 

func (m *AcceptancePolicy_RoleAdmissionPolicy_Secret) Unmarshal(data []byte) error

type Annotations 

type Annotations struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 146-byte string literal not displayed */
}

Annotations provide useful information to identify API objects. They are common to all API specs.

func (*Annotations) Copy 

func (m *Annotations) Copy() *Annotations

func (*Annotations) Descriptor 

func (*Annotations) Descriptor() ([]byte, []int)

func (*Annotations) GoString 

func (this *Annotations) GoString() string

func (*Annotations) Marshal 

func (m *Annotations) Marshal() (data []byte, err error)

func (*Annotations) MarshalTo 

func (m *Annotations) MarshalTo(data []byte) (int, error)

func (*Annotations) ProtoMessage 

func (*Annotations) ProtoMessage()

func (*Annotations) Reset 

func (m *Annotations) Reset()

func (*Annotations) Size 

func (m *Annotations) Size() (n int)

func (*Annotations) String 

func (this *Annotations) String() string

func (*Annotations) Unmarshal 

func (m *Annotations) Unmarshal(data []byte) error

type CAClient 

type CAClient interface {
	GetRootCACertificate(ctx context.Context, in *GetRootCACertificateRequest, opts ...grpc.CallOption) (*GetRootCACertificateResponse, error)
}

func NewCAClient 

func NewCAClient(cc *grpc.ClientConn) CAClient

type CAConfig 

type CAConfig struct {
	// NodeCertExpiry is the duration certificates should be issued for
	NodeCertExpiry *docker_swarmkit_v11.Duration `protobuf:"bytes,1,opt,name=node_cert_expiry,json=nodeCertExpiry" json:"node_cert_expiry,omitempty"`
	// ExternalCAs is a list of CAs to which a manager node will make
	// certificate signing requests for node certificates.
	ExternalCAs []*ExternalCA `protobuf:"bytes,2,rep,name=external_cas,json=externalCas" json:"external_cas,omitempty"`
}

func (*CAConfig) Copy 

func (m *CAConfig) Copy() *CAConfig

func (*CAConfig) Descriptor 

func (*CAConfig) Descriptor() ([]byte, []int)

func (*CAConfig) GoString 

func (this *CAConfig) GoString() string

func (*CAConfig) Marshal 

func (m *CAConfig) Marshal() (data []byte, err error)

func (*CAConfig) MarshalTo 

func (m *CAConfig) MarshalTo(data []byte) (int, error)

func (*CAConfig) ProtoMessage 

func (*CAConfig) ProtoMessage()

func (*CAConfig) Reset 

func (m *CAConfig) Reset()

func (*CAConfig) Size 

func (m *CAConfig) Size() (n int)

func (*CAConfig) String 

func (this *CAConfig) String() string

func (*CAConfig) Unmarshal 

func (m *CAConfig) Unmarshal(data []byte) error

type CAServer 

type CAServer interface {
	GetRootCACertificate(context.Context, *GetRootCACertificateRequest) (*GetRootCACertificateResponse, error)
}

func NewAuthenticatedWrapperCAServer 

func NewAuthenticatedWrapperCAServer(local CAServer, authorize func(context.Context, []string) error) CAServer

func NewRaftProxyCAServer 

func NewRaftProxyCAServer(local CAServer, connSelector *raftpicker.ConnSelector, cluster raftpicker.RaftCluster, ctxMod func(context.Context) (context.Context, error)) CAServer

type Certificate 

type Certificate struct {
	Role        NodeRole       `protobuf:"varint,1,opt,name=role,proto3,enum=docker.swarmkit.v1.NodeRole" json:"role,omitempty"`
	CSR         []byte         `protobuf:"bytes,2,opt,name=csr,proto3" json:"csr,omitempty"`
	Status      IssuanceStatus `protobuf:"bytes,3,opt,name=status" json:"status"`
	Certificate []byte         `protobuf:"bytes,4,opt,name=certificate,proto3" json:"certificate,omitempty"`
	// CN represents the node ID.
	CN string `protobuf:"bytes,5,opt,name=cn,proto3" json:"cn,omitempty"`
}

func (*Certificate) Copy 

func (m *Certificate) Copy() *Certificate

func (*Certificate) Descriptor 

func (*Certificate) Descriptor() ([]byte, []int)

func (*Certificate) GoString 

func (this *Certificate) GoString() string

func (*Certificate) Marshal 

func (m *Certificate) Marshal() (data []byte, err error)

func (*Certificate) MarshalTo 

func (m *Certificate) MarshalTo(data []byte) (int, error)

func (*Certificate) ProtoMessage 

func (*Certificate) ProtoMessage()

func (*Certificate) Reset 

func (m *Certificate) Reset()

func (*Certificate) Size 

func (m *Certificate) Size() (n int)

func (*Certificate) String 

func (this *Certificate) String() string

func (*Certificate) Unmarshal 

func (m *Certificate) Unmarshal(data []byte) error

type Cluster 

type Cluster struct {
	ID   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta Meta        `protobuf:"bytes,2,opt,name=meta" json:"meta"`
	Spec ClusterSpec `protobuf:"bytes,3,opt,name=spec" json:"spec"`
	// RootCA contains key material for the root CA.
	RootCA RootCA `protobuf:"bytes,4,opt,name=root_ca,json=rootCa" json:"root_ca"`
	// Symmetric encryption key distributed by the lead manager. Used by agents
	// for securing network bootstrapping and communication.
	NetworkBootstrapKeys []*EncryptionKey `protobuf:"bytes,5,rep,name=network_bootstrap_keys,json=networkBootstrapKeys" json:"network_bootstrap_keys,omitempty"`
	// Logical clock used to timestamp every key.  It allows other managers
	// and agents to unambiguously identify the older key to be deleted when
	// a new key is allocated on key rotation.
	EncryptionKeyLamportClock uint64 `` /* 141-byte string literal not displayed */
}

Cluster provides global cluster settings.

func (*Cluster) Copy 

func (m *Cluster) Copy() *Cluster

func (*Cluster) Descriptor 

func (*Cluster) Descriptor() ([]byte, []int)

func (*Cluster) GoString 

func (this *Cluster) GoString() string

func (*Cluster) Marshal 

func (m *Cluster) Marshal() (data []byte, err error)

func (*Cluster) MarshalTo 

func (m *Cluster) MarshalTo(data []byte) (int, error)

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset 

func (m *Cluster) Reset()

func (*Cluster) Size 

func (m *Cluster) Size() (n int)

func (*Cluster) String 

func (this *Cluster) String() string

func (*Cluster) Unmarshal 

func (m *Cluster) Unmarshal(data []byte) error

type ClusterSnapshot 

type ClusterSnapshot struct {
	Members []*RaftMember `protobuf:"bytes,1,rep,name=members" json:"members,omitempty"`
	Removed []uint64      `protobuf:"varint,2,rep,name=removed" json:"removed,omitempty"`
}

ClusterSnapshot stores cluster membership information in snapshots.

func (*ClusterSnapshot) Copy 

func (m *ClusterSnapshot) Copy() *ClusterSnapshot

func (*ClusterSnapshot) Descriptor 

func (*ClusterSnapshot) Descriptor() ([]byte, []int)

func (*ClusterSnapshot) GoString 

func (this *ClusterSnapshot) GoString() string

func (*ClusterSnapshot) Marshal 

func (m *ClusterSnapshot) Marshal() (data []byte, err error)

func (*ClusterSnapshot) MarshalTo 

func (m *ClusterSnapshot) MarshalTo(data []byte) (int, error)

func (*ClusterSnapshot) ProtoMessage 

func (*ClusterSnapshot) ProtoMessage()

func (*ClusterSnapshot) Reset 

func (m *ClusterSnapshot) Reset()

func (*ClusterSnapshot) Size 

func (m *ClusterSnapshot) Size() (n int)

func (*ClusterSnapshot) String 

func (this *ClusterSnapshot) String() string

func (*ClusterSnapshot) Unmarshal 

func (m *ClusterSnapshot) Unmarshal(data []byte) error

type ClusterSpec 

type ClusterSpec struct {
	Annotations Annotations `protobuf:"bytes,1,opt,name=annotations" json:"annotations"`
	// DEPRECATED: AcceptancePolicy defines the certificate issuance policy.
	// Acceptance policy is no longer customizable, and secrets have been
	// replaced with join tokens.
	AcceptancePolicy AcceptancePolicy `protobuf:"bytes,2,opt,name=acceptance_policy,json=acceptancePolicy" json:"acceptance_policy"`
	// Orchestration defines cluster-level orchestration settings.
	Orchestration OrchestrationConfig `protobuf:"bytes,3,opt,name=orchestration" json:"orchestration"`
	// Raft defines the cluster's raft settings.
	Raft RaftConfig `protobuf:"bytes,4,opt,name=raft" json:"raft"`
	// Dispatcher defines cluster-level dispatcher settings.
	Dispatcher DispatcherConfig `protobuf:"bytes,5,opt,name=dispatcher" json:"dispatcher"`
	// CAConfig defines cluster-level certificate authority settings.
	CAConfig CAConfig `protobuf:"bytes,6,opt,name=ca_config,json=caConfig" json:"ca_config"`
	// TaskDefaults specifies the default values to use for task creation.
	TaskDefaults TaskDefaults `protobuf:"bytes,7,opt,name=task_defaults,json=taskDefaults" json:"task_defaults"`
}

ClusterSpec specifies global cluster settings.

func (*ClusterSpec) Copy 

func (m *ClusterSpec) Copy() *ClusterSpec

func (*ClusterSpec) Descriptor 

func (*ClusterSpec) Descriptor() ([]byte, []int)

func (*ClusterSpec) GoString 

func (this *ClusterSpec) GoString() string

func (*ClusterSpec) Marshal 

func (m *ClusterSpec) Marshal() (data []byte, err error)

func (*ClusterSpec) MarshalTo 

func (m *ClusterSpec) MarshalTo(data []byte) (int, error)

func (*ClusterSpec) ProtoMessage 

func (*ClusterSpec) ProtoMessage()

func (*ClusterSpec) Reset 

func (m *ClusterSpec) Reset()

func (*ClusterSpec) Size 

func (m *ClusterSpec) Size() (n int)

func (*ClusterSpec) String 

func (this *ClusterSpec) String() string

func (*ClusterSpec) Unmarshal 

func (m *ClusterSpec) Unmarshal(data []byte) error

type ContainerSpec 

type ContainerSpec struct {
	// image defines the image reference, as specified in the
	// distribution/reference package. This may include a registry host, name,
	// tag or digest.
	//
	// The field will be directly passed to the engine pulling. Well-behaved
	// service definitions will used immutable references, either through tags
	// that don't change or verifiable digests.
	Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	// Labels defines labels to be added to the container at creation time. If
	// collisions with system labels occur, these labels will be overridden.
	//
	// This field *must* remain compatible with the Labels field of
	// Annotations.
	Labels map[string]string `` /* 146-byte string literal not displayed */
	// Command to run the the container. The first element is a path to the
	// executable and the following elements are treated as arguments.
	//
	// If command is empty, execution will fall back to the image's entrypoint.
	//
	// Command should only be used when overriding entrypoint.
	Command []string `protobuf:"bytes,3,rep,name=command" json:"command,omitempty"`
	// Args specifies arguments provided to the image's entrypoint.
	//
	// If Command and Args are provided, Args will be appended to Command.
	Args []string `protobuf:"bytes,4,rep,name=args" json:"args,omitempty"`
	// Env specifies the environment variables for the container in NAME=VALUE
	// format. These must be compliant with  [IEEE Std
	// 1003.1-2001](http://pubs.opengroup.org/onlinepubs/009695399/basedefs/xbd_chap08.html).
	Env []string `protobuf:"bytes,5,rep,name=env" json:"env,omitempty"`
	// Dir defines the working directory to set for the container process.
	Dir string `protobuf:"bytes,6,opt,name=dir,proto3" json:"dir,omitempty"`
	// User specifies the user that should be employed to run the container.
	User   string  `protobuf:"bytes,7,opt,name=user,proto3" json:"user,omitempty"`
	Mounts []Mount `protobuf:"bytes,8,rep,name=mounts" json:"mounts"`
	// StopGracePeriod the grace period for stopping the container before
	// forcefully killing the container.
	StopGracePeriod *docker_swarmkit_v11.Duration `protobuf:"bytes,9,opt,name=stop_grace_period,json=stopGracePeriod" json:"stop_grace_period,omitempty"`
	// PullOptions parameterize the behavior of image pulls.
	PullOptions *ContainerSpec_PullOptions `protobuf:"bytes,10,opt,name=pull_options,json=pullOptions" json:"pull_options,omitempty"`
}

Container specifies runtime parameters for a container.

func (*ContainerSpec) Copy 

func (m *ContainerSpec) Copy() *ContainerSpec

func (*ContainerSpec) Descriptor 

func (*ContainerSpec) Descriptor() ([]byte, []int)

func (*ContainerSpec) GoString 

func (this *ContainerSpec) GoString() string

func (*ContainerSpec) Marshal 

func (m *ContainerSpec) Marshal() (data []byte, err error)

func (*ContainerSpec) MarshalTo 

func (m *ContainerSpec) MarshalTo(data []byte) (int, error)

func (*ContainerSpec) ProtoMessage 

func (*ContainerSpec) ProtoMessage()

func (*ContainerSpec) Reset 

func (m *ContainerSpec) Reset()

func (*ContainerSpec) Size 

func (m *ContainerSpec) Size() (n int)

func (*ContainerSpec) String 

func (this *ContainerSpec) String() string

func (*ContainerSpec) Unmarshal 

func (m *ContainerSpec) Unmarshal(data []byte) error

type ContainerSpec_PullOptions 

type ContainerSpec_PullOptions struct {
	// RegistryAuth is the registry auth token obtained from the client, required
	// to pull private images. This is the unmodified JSON used as part of
	// the `X-Registry-Auth` header.
	// TODO(nishanttotla): This field will later be deprecated
	RegistryAuth string `protobuf:"bytes,64,opt,name=registry_auth,json=registryAuth,proto3" json:"registry_auth,omitempty"`
}

PullOptions allows one to parameterize an image pull.

func (*ContainerSpec_PullOptions) Copy 

func (m *ContainerSpec_PullOptions) Copy() *ContainerSpec_PullOptions

func (*ContainerSpec_PullOptions) Descriptor 

func (*ContainerSpec_PullOptions) Descriptor() ([]byte, []int)

func (*ContainerSpec_PullOptions) GoString 

func (this *ContainerSpec_PullOptions) GoString() string

func (*ContainerSpec_PullOptions) Marshal 

func (m *ContainerSpec_PullOptions) Marshal() (data []byte, err error)

func (*ContainerSpec_PullOptions) MarshalTo 

func (m *ContainerSpec_PullOptions) MarshalTo(data []byte) (int, error)

func (*ContainerSpec_PullOptions) ProtoMessage 

func (*ContainerSpec_PullOptions) ProtoMessage()

func (*ContainerSpec_PullOptions) Reset 

func (m *ContainerSpec_PullOptions) Reset()

func (*ContainerSpec_PullOptions) Size 

func (m *ContainerSpec_PullOptions) Size() (n int)

func (*ContainerSpec_PullOptions) String 

func (this *ContainerSpec_PullOptions) String() string

func (*ContainerSpec_PullOptions) Unmarshal 

func (m *ContainerSpec_PullOptions) Unmarshal(data []byte) error

type ContainerStatus 

type ContainerStatus struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	PID         int32  `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitCode    int32  `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
}

Container specific status.

func (*ContainerStatus) Copy 

func (m *ContainerStatus) Copy() *ContainerStatus

func (*ContainerStatus) Descriptor 

func (*ContainerStatus) Descriptor() ([]byte, []int)

func (*ContainerStatus) GoString 

func (this *ContainerStatus) GoString() string

func (*ContainerStatus) Marshal 

func (m *ContainerStatus) Marshal() (data []byte, err error)

func (*ContainerStatus) MarshalTo 

func (m *ContainerStatus) MarshalTo(data []byte) (int, error)

func (*ContainerStatus) ProtoMessage 

func (*ContainerStatus) ProtoMessage()

func (*ContainerStatus) Reset 

func (m *ContainerStatus) Reset()

func (*ContainerStatus) Size 

func (m *ContainerStatus) Size() (n int)

func (*ContainerStatus) String 

func (this *ContainerStatus) String() string

func (*ContainerStatus) Unmarshal 

func (m *ContainerStatus) Unmarshal(data []byte) error

type ControlClient 

type ControlClient interface {
	GetNode(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*GetNodeResponse, error)
	ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (*ListNodesResponse, error)
	UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...grpc.CallOption) (*UpdateNodeResponse, error)
	RemoveNode(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error)
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskResponse, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	RemoveTask(ctx context.Context, in *RemoveTaskRequest, opts ...grpc.CallOption) (*RemoveTaskResponse, error)
	GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*GetServiceResponse, error)
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error)
	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)
	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)
	RemoveNetwork(ctx context.Context, in *RemoveNetworkRequest, opts ...grpc.CallOption) (*RemoveNetworkResponse, error)
	GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*GetClusterResponse, error)
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*UpdateClusterResponse, error)
}

func NewControlClient 

func NewControlClient(cc *grpc.ClientConn) ControlClient

type ControlServer 

type ControlServer interface {
	GetNode(context.Context, *GetNodeRequest) (*GetNodeResponse, error)
	ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
	UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeResponse, error)
	RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
	GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	RemoveTask(context.Context, *RemoveTaskRequest) (*RemoveTaskResponse, error)
	GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)
	ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
	CreateService(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
	UpdateService(context.Context, *UpdateServiceRequest) (*UpdateServiceResponse, error)
	RemoveService(context.Context, *RemoveServiceRequest) (*RemoveServiceResponse, error)
	GetNetwork(context.Context, *GetNetworkRequest) (*GetNetworkResponse, error)
	ListNetworks(context.Context, *ListNetworksRequest) (*ListNetworksResponse, error)
	CreateNetwork(context.Context, *CreateNetworkRequest) (*CreateNetworkResponse, error)
	RemoveNetwork(context.Context, *RemoveNetworkRequest) (*RemoveNetworkResponse, error)
	GetCluster(context.Context, *GetClusterRequest) (*GetClusterResponse, error)
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	UpdateCluster(context.Context, *UpdateClusterRequest) (*UpdateClusterResponse, error)
}

func NewAuthenticatedWrapperControlServer 

func NewAuthenticatedWrapperControlServer(local ControlServer, authorize func(context.Context, []string) error) ControlServer

func NewRaftProxyControlServer 

func NewRaftProxyControlServer(local ControlServer, connSelector *raftpicker.ConnSelector, cluster raftpicker.RaftCluster, ctxMod func(context.Context) (context.Context, error)) ControlServer

type CreateNetworkRequest 

type CreateNetworkRequest struct {
	Spec *NetworkSpec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"`
}

func (*CreateNetworkRequest) Copy 

func (m *CreateNetworkRequest) Copy() *CreateNetworkRequest

func (*CreateNetworkRequest) Descriptor 

func (*CreateNetworkRequest) Descriptor() ([]byte, []int)

func (*CreateNetworkRequest) GoString 

func (this *CreateNetworkRequest) GoString() string

func (*CreateNetworkRequest) Marshal 

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

func (*CreateNetworkRequest) MarshalTo 

func (m *CreateNetworkRequest) MarshalTo(data []byte) (int, error)

func (*CreateNetworkRequest) ProtoMessage 

func (*CreateNetworkRequest) ProtoMessage()

func (*CreateNetworkRequest) Reset 

func (m *CreateNetworkRequest) Reset()

func (*CreateNetworkRequest) Size 

func (m *CreateNetworkRequest) Size() (n int)

func (*CreateNetworkRequest) String 

func (this *CreateNetworkRequest) String() string

func (*CreateNetworkRequest) Unmarshal 

func (m *CreateNetworkRequest) Unmarshal(data []byte) error

type CreateNetworkResponse 

type CreateNetworkResponse struct {
	Network *Network `protobuf:"bytes,1,opt,name=network" json:"network,omitempty"`
}

func (*CreateNetworkResponse) Copy 

func (m *CreateNetworkResponse) Copy() *CreateNetworkResponse

func (*CreateNetworkResponse) Descriptor 

func (*CreateNetworkResponse) Descriptor() ([]byte, []int)

func (*CreateNetworkResponse) GoString 

func (this *CreateNetworkResponse) GoString() string

func (*CreateNetworkResponse) Marshal 

func (m *CreateNetworkResponse) Marshal() (data []byte, err error)

func (*CreateNetworkResponse) MarshalTo 

func (m *CreateNetworkResponse) MarshalTo(data []byte) (int, error)

func (*CreateNetworkResponse) ProtoMessage 

func (*CreateNetworkResponse) ProtoMessage()

func (*CreateNetworkResponse) Reset 

func (m *CreateNetworkResponse) Reset()

func (*CreateNetworkResponse) Size 

func (m *CreateNetworkResponse) Size() (n int)

func (*CreateNetworkResponse) String 

func (this *CreateNetworkResponse) String() string

func (*CreateNetworkResponse) Unmarshal 

func (m *CreateNetworkResponse) Unmarshal(data []byte) error

type CreateServiceRequest 

type CreateServiceRequest struct {
	Spec *ServiceSpec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"`
}

func (*CreateServiceRequest) Copy 

func (m *CreateServiceRequest) Copy() *CreateServiceRequest

func (*CreateServiceRequest) Descriptor 

func (*CreateServiceRequest) Descriptor() ([]byte, []int)

func (*CreateServiceRequest) GoString 

func (this *CreateServiceRequest) GoString() string

func (*CreateServiceRequest) Marshal 

func (m *CreateServiceRequest) Marshal() (data []byte, err error)

func (*CreateServiceRequest) MarshalTo 

func (m *CreateServiceRequest) MarshalTo(data []byte) (int, error)

func (*CreateServiceRequest) ProtoMessage 

func (*CreateServiceRequest) ProtoMessage()

func (*CreateServiceRequest) Reset 

func (m *CreateServiceRequest) Reset()

func (*CreateServiceRequest) Size 

func (m *CreateServiceRequest) Size() (n int)

func (*CreateServiceRequest) String 

func (this *CreateServiceRequest) String() string

func (*CreateServiceRequest) Unmarshal 

func (m *CreateServiceRequest) Unmarshal(data []byte) error

type CreateServiceResponse 

type CreateServiceResponse struct {
	Service *Service `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
}

func (*CreateServiceResponse) Copy 

func (m *CreateServiceResponse) Copy() *CreateServiceResponse

func (*CreateServiceResponse) Descriptor 

func (*CreateServiceResponse) Descriptor() ([]byte, []int)

func (*CreateServiceResponse) GoString 

func (this *CreateServiceResponse) GoString() string

func (*CreateServiceResponse) Marshal 

func (m *CreateServiceResponse) Marshal() (data []byte, err error)

func (*CreateServiceResponse) MarshalTo 

func (m *CreateServiceResponse) MarshalTo(data []byte) (int, error)

func (*CreateServiceResponse) ProtoMessage 

func (*CreateServiceResponse) ProtoMessage()

func (*CreateServiceResponse) Reset 

func (m *CreateServiceResponse) Reset()

func (*CreateServiceResponse) Size 

func (m *CreateServiceResponse) Size() (n int)

func (*CreateServiceResponse) String 

func (this *CreateServiceResponse) String() string

func (*CreateServiceResponse) Unmarshal 

func (m *CreateServiceResponse) Unmarshal(data []byte) error

type DispatcherClient 

type DispatcherClient interface {
	// Session starts an agent session with the dispatcher. The session is
	// started after the first SessionMessage is received.
	//
	// Once started, the agent is controlled with a stream of SessionMessage.
	// Agents should list on the stream at all times for instructions.
	Session(ctx context.Context, in *SessionRequest, opts ...grpc.CallOption) (Dispatcher_SessionClient, error)
	// Heartbeat is heartbeat method for nodes. It returns new TTL in response.
	// Node should send new heartbeat earlier than now + TTL, otherwise it will
	// be deregistered from dispatcher and its status will be updated to NodeStatus_DOWN
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	// UpdateTaskStatus updates status of task. Node should send such updates
	// on every status change of its tasks.
	//
	// Whether receiving batch updates or single status updates, this method
	// should be accepting. Errors should only be returned if the entire update
	// should be retried, due to data loss or other problems.
	//
	// If a task is unknown the dispatcher, the status update should be
	// accepted regardless.
	UpdateTaskStatus(ctx context.Context, in *UpdateTaskStatusRequest, opts ...grpc.CallOption) (*UpdateTaskStatusResponse, error)
	// Tasks is a stream of tasks state for node. Each message contains full list
	// of tasks which should be run on node, if task is not present in that list,
	// it should be terminated.
	Tasks(ctx context.Context, in *TasksRequest, opts ...grpc.CallOption) (Dispatcher_TasksClient, error)
}

func NewDispatcherClient 

func NewDispatcherClient(cc *grpc.ClientConn) DispatcherClient

type DispatcherConfig 

type DispatcherConfig struct {
	// HeartbeatPeriod defines how often agent should send heartbeats to
	// dispatcher.
	HeartbeatPeriod *docker_swarmkit_v11.Duration `protobuf:"bytes,1,opt,name=heartbeat_period,json=heartbeatPeriod" json:"heartbeat_period,omitempty"`
}

DispatcherConfig defines cluster-level dispatcher settings.

func (*DispatcherConfig) Copy 

func (m *DispatcherConfig) Copy() *DispatcherConfig

func (*DispatcherConfig) Descriptor 

func (*DispatcherConfig) Descriptor() ([]byte, []int)

func (*DispatcherConfig) GoString 

func (this *DispatcherConfig) GoString() string

func (*DispatcherConfig) Marshal 

func (m *DispatcherConfig) Marshal() (data []byte, err error)

func (*DispatcherConfig) MarshalTo 

func (m *DispatcherConfig) MarshalTo(data []byte) (int, error)

func (*DispatcherConfig) ProtoMessage 

func (*DispatcherConfig) ProtoMessage()

func (*DispatcherConfig) Reset 

func (m *DispatcherConfig) Reset()

func (*DispatcherConfig) Size 

func (m *DispatcherConfig) Size() (n int)

func (*DispatcherConfig) String 

func (this *DispatcherConfig) String() string

func (*DispatcherConfig) Unmarshal 

func (m *DispatcherConfig) Unmarshal(data []byte) error

type DispatcherServer 

type DispatcherServer interface {
	// Session starts an agent session with the dispatcher. The session is
	// started after the first SessionMessage is received.
	//
	// Once started, the agent is controlled with a stream of SessionMessage.
	// Agents should list on the stream at all times for instructions.
	Session(*SessionRequest, Dispatcher_SessionServer) error
	// Heartbeat is heartbeat method for nodes. It returns new TTL in response.
	// Node should send new heartbeat earlier than now + TTL, otherwise it will
	// be deregistered from dispatcher and its status will be updated to NodeStatus_DOWN
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	// UpdateTaskStatus updates status of task. Node should send such updates
	// on every status change of its tasks.
	//
	// Whether receiving batch updates or single status updates, this method
	// should be accepting. Errors should only be returned if the entire update
	// should be retried, due to data loss or other problems.
	//
	// If a task is unknown the dispatcher, the status update should be
	// accepted regardless.
	UpdateTaskStatus(context.Context, *UpdateTaskStatusRequest) (*UpdateTaskStatusResponse, error)
	// Tasks is a stream of tasks state for node. Each message contains full list
	// of tasks which should be run on node, if task is not present in that list,
	// it should be terminated.
	Tasks(*TasksRequest, Dispatcher_TasksServer) error
}

func NewAuthenticatedWrapperDispatcherServer 

func NewAuthenticatedWrapperDispatcherServer(local DispatcherServer, authorize func(context.Context, []string) error) DispatcherServer

func NewRaftProxyDispatcherServer 

func NewRaftProxyDispatcherServer(local DispatcherServer, connSelector *raftpicker.ConnSelector, cluster raftpicker.RaftCluster, ctxMod func(context.Context) (context.Context, error)) DispatcherServer

type Dispatcher_SessionClient 

type Dispatcher_SessionClient interface {
	Recv() (*SessionMessage, error)
	grpc.ClientStream
}

type Dispatcher_SessionServer 

type Dispatcher_SessionServer interface {
	Send(*SessionMessage) error
	grpc.ServerStream
}

type Dispatcher_TasksClient 

type Dispatcher_TasksClient interface {
	Recv() (*TasksMessage, error)
	grpc.ClientStream
}

type Dispatcher_TasksServer 

type Dispatcher_TasksServer interface {
	Send(*TasksMessage) error
	grpc.ServerStream
}

type Driver 

type Driver struct {
	Name    string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Options map[string]string `` /* 148-byte string literal not displayed */
}

Driver is a generic driver type to be used throughout the API. For now, a driver is simply a name and set of options. The field contents depend on the target use case and driver application. For example, a network driver may have different rules than a volume driver.

func (*Driver) Copy 

func (m *Driver) Copy() *Driver

func (*Driver) Descriptor 

func (*Driver) Descriptor() ([]byte, []int)

func (*Driver) GoString 

func (this *Driver) GoString() string

func (*Driver) Marshal 

func (m *Driver) Marshal() (data []byte, err error)

func (*Driver) MarshalTo 

func (m *Driver) MarshalTo(data []byte) (int, error)

func (*Driver) ProtoMessage 

func (*Driver) ProtoMessage()

func (*Driver) Reset 

func (m *Driver) Reset()

func (*Driver) Size 

func (m *Driver) Size() (n int)

func (*Driver) String 

func (this *Driver) String() string

func (*Driver) Unmarshal 

func (m *Driver) Unmarshal(data []byte) error

type EncryptionKey 

type EncryptionKey struct {
	// Agent subsystem the key is intended for. Example:
	// networking:gossip
	Subsystem string                  `protobuf:"bytes,1,opt,name=subsystem,proto3" json:"subsystem,omitempty"`
	Algorithm EncryptionKey_Algorithm `protobuf:"varint,2,opt,name=algorithm,proto3,enum=docker.swarmkit.v1.EncryptionKey_Algorithm" json:"algorithm,omitempty"`
	Key       []byte                  `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Time stamp from the lamport clock of the key allocator to
	// identify the relative age of the key.
	LamportTime uint64 `protobuf:"varint,4,opt,name=lamport_time,json=lamportTime,proto3" json:"lamport_time,omitempty"`
}

Symmetric keys to encrypt inter-agent communication.

func (*EncryptionKey) Copy 

func (m *EncryptionKey) Copy() *EncryptionKey

func (*EncryptionKey) Descriptor 

func (*EncryptionKey) Descriptor() ([]byte, []int)

func (*EncryptionKey) GoString 

func (this *EncryptionKey) GoString() string

func (*EncryptionKey) Marshal 

func (m *EncryptionKey) Marshal() (data []byte, err error)

func (*EncryptionKey) MarshalTo 

func (m *EncryptionKey) MarshalTo(data []byte) (int, error)

func (*EncryptionKey) ProtoMessage 

func (*EncryptionKey) ProtoMessage()

func (*EncryptionKey) Reset 

func (m *EncryptionKey) Reset()

func (*EncryptionKey) Size 

func (m *EncryptionKey) Size() (n int)

func (*EncryptionKey) String 

func (this *EncryptionKey) String() string

func (*EncryptionKey) Unmarshal 

func (m *EncryptionKey) Unmarshal(data []byte) error

type EncryptionKey_Algorithm 

type EncryptionKey_Algorithm int32

Encryption algorithm that can implemented using this key 

const (
	AES_128_GCM EncryptionKey_Algorithm = 0
)

func (EncryptionKey_Algorithm) EnumDescriptor 

func (EncryptionKey_Algorithm) EnumDescriptor() ([]byte, []int)

func (EncryptionKey_Algorithm) String 

func (x EncryptionKey_Algorithm) String() string

type Endpoint 

type Endpoint struct {
	Spec *EndpointSpec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"`
	// Runtime state of the exposed ports which may carry
	// auto-allocated swarm ports in addition to the user
	// configured information.
	Ports []*PortConfig `protobuf:"bytes,2,rep,name=ports" json:"ports,omitempty"`
	// VirtualIPs specifies the IP addresses under which this endpoint will be
	// made available.
	VirtualIPs []*Endpoint_VirtualIP `protobuf:"bytes,3,rep,name=virtual_ips,json=virtualIps" json:"virtual_ips,omitempty"`
}

Endpoint specified all the network parameters required to correctly discover and load balance a service

func (*Endpoint) Copy 

func (m *Endpoint) Copy() *Endpoint

func (*Endpoint) Descriptor 

func (*Endpoint) Descriptor() ([]byte, []int)

func (*Endpoint) GoString 

func (this *Endpoint) GoString() string

func (*Endpoint) Marshal 

func (m *Endpoint) Marshal() (data []byte, err error)

func (*Endpoint) MarshalTo 

func (m *Endpoint) MarshalTo(data []byte) (int, error)

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) Reset 

func (m *Endpoint) Reset()

func (*Endpoint) Size 

func (m *Endpoint) Size() (n int)

func (*Endpoint) String 

func (this *Endpoint) String() string

func (*Endpoint) Unmarshal 

func (m *Endpoint) Unmarshal(data []byte) error

type EndpointSpec 

type EndpointSpec struct {
	Mode EndpointSpec_ResolutionMode `protobuf:"varint,1,opt,name=mode,proto3,enum=docker.swarmkit.v1.EndpointSpec_ResolutionMode" json:"mode,omitempty"`
	// List of exposed ports that this service is accessible from
	// external to the cluster.
	Ports []*PortConfig `protobuf:"bytes,2,rep,name=ports" json:"ports,omitempty"`
}

EndpointSpec defines the properties that can be configured to access and loadbalance the service.

func (*EndpointSpec) Copy 

func (m *EndpointSpec) Copy() *EndpointSpec

func (*EndpointSpec) Descriptor 

func (*EndpointSpec) Descriptor() ([]byte, []int)

func (*EndpointSpec) GoString 

func (this *EndpointSpec) GoString() string

func (*EndpointSpec) Marshal 

func (m *EndpointSpec) Marshal() (data []byte, err error)

func (*EndpointSpec) MarshalTo 

func (m *EndpointSpec) MarshalTo(data []byte) (int, error)

func (*EndpointSpec) ProtoMessage 

func (*EndpointSpec) ProtoMessage()

func (*EndpointSpec) Reset 

func (m *EndpointSpec) Reset()

func (*EndpointSpec) Size 

func (m *EndpointSpec) Size() (n int)

func (*EndpointSpec) String 

func (this *EndpointSpec) String() string

func (*EndpointSpec) Unmarshal 

func (m *EndpointSpec) Unmarshal(data []byte) error

type EndpointSpec_ResolutionMode 

type EndpointSpec_ResolutionMode int32

ResolutionMode specifies the mode of resolution to use for internal loadbalancing between tasks which are all within the cluster. This is sometimes calles east-west data path. 

const (
	// VIP resolution mode specifies that the
	// service resolves to a logical IP and the requests
	// are sent to that logical IP. Packets hitting that
	// logical IP are load balanced to a chosen backend.
	ResolutionModeVirtualIP EndpointSpec_ResolutionMode = 0
	// DNSRR resolution mode specifies that the
	// service directly gets resolved to one of the
	// backend IP and the client directly initiates a
	// request towards the actual backend. This requires
	// that the client does not cache the DNS responses
	// when the DNS response TTL is 0.
	ResolutionModeDNSRoundRobin EndpointSpec_ResolutionMode = 1
)

func (EndpointSpec_ResolutionMode) EnumDescriptor 

func (EndpointSpec_ResolutionMode) EnumDescriptor() ([]byte, []int)

func (EndpointSpec_ResolutionMode) String 

func (x EndpointSpec_ResolutionMode) String() string

type Endpoint_VirtualIP 

type Endpoint_VirtualIP struct {
	// NetworkID for which this endpoint attachment was created.
	NetworkID string `protobuf:"bytes,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
	// A virtual IP is used to address this service in IP
	// layer that the client can use to send requests to
	// this service. A DNS A/AAAA query on the service
	// name might return this IP to the client. This is
	// strictly a logical IP and there may not be any
	// interfaces assigned this IP address or any route
	// created for this address.  More than one to
	// accomodate for both IPv4 and IPv6
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
}

VirtualIP specifies a set of networks this endpoint will be attached to and the IP addresses the target service will be made available under.

func (*Endpoint_VirtualIP) Copy 

func (m *Endpoint_VirtualIP) Copy() *Endpoint_VirtualIP

func (*Endpoint_VirtualIP) Descriptor 

func (*Endpoint_VirtualIP) Descriptor() ([]byte, []int)

func (*Endpoint_VirtualIP) GoString 

func (this *Endpoint_VirtualIP) GoString() string

func (*Endpoint_VirtualIP) Marshal 

func (m *Endpoint_VirtualIP) Marshal() (data []byte, err error)

func (*Endpoint_VirtualIP) MarshalTo 

func (m *Endpoint_VirtualIP) MarshalTo(data []byte) (int, error)

func (*Endpoint_VirtualIP) ProtoMessage 

func (*Endpoint_VirtualIP) ProtoMessage()

func (*Endpoint_VirtualIP) Reset 

func (m *Endpoint_VirtualIP) Reset()

func (*Endpoint_VirtualIP) Size 

func (m *Endpoint_VirtualIP) Size() (n int)

func (*Endpoint_VirtualIP) String 

func (this *Endpoint_VirtualIP) String() string

func (*Endpoint_VirtualIP) Unmarshal 

func (m *Endpoint_VirtualIP) Unmarshal(data []byte) error

type EngineDescription 

type EngineDescription struct {
	// Docker daemon version running on the node.
	EngineVersion string `protobuf:"bytes,1,opt,name=engine_version,json=engineVersion,proto3" json:"engine_version,omitempty"`
	// Labels attached to the engine.
	Labels map[string]string `` /* 146-byte string literal not displayed */
	// Volume, Network, and Auth plugins
	Plugins []PluginDescription `protobuf:"bytes,3,rep,name=plugins" json:"plugins"`
}

func (*EngineDescription) Copy 

func (m *EngineDescription) Copy() *EngineDescription

func (*EngineDescription) Descriptor 

func (*EngineDescription) Descriptor() ([]byte, []int)

func (*EngineDescription) GoString 

func (this *EngineDescription) GoString() string

func (*EngineDescription) Marshal 

func (m *EngineDescription) Marshal() (data []byte, err error)

func (*EngineDescription) MarshalTo 

func (m *EngineDescription) MarshalTo(data []byte) (int, error)

func (*EngineDescription) ProtoMessage 

func (*EngineDescription) ProtoMessage()

func (*EngineDescription) Reset 

func (m *EngineDescription) Reset()

func (*EngineDescription) Size 

func (m *EngineDescription) Size() (n int)

func (*EngineDescription) String 

func (this *EngineDescription) String() string

func (*EngineDescription) Unmarshal 

func (m *EngineDescription) Unmarshal(data []byte) error

type ExternalCA 

type ExternalCA struct {
	// Protocol is the protocol used by this external CA.
	Protocol ExternalCA_CAProtocol `protobuf:"varint,1,opt,name=protocol,proto3,enum=docker.swarmkit.v1.ExternalCA_CAProtocol" json:"protocol,omitempty"`
	// URL is the URL where the external CA can be reached.
	URL string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// Options is a set of additional key/value pairs whose interpretation
	// depends on the specified CA type.
	Options map[string]string `` /* 148-byte string literal not displayed */
}

func (*ExternalCA) Copy 

func (m *ExternalCA) Copy() *ExternalCA

func (*ExternalCA) Descriptor 

func (*ExternalCA) Descriptor() ([]byte, []int)

func (*ExternalCA) GoString 

func (this *ExternalCA) GoString() string

func (*ExternalCA) Marshal 

func (m *ExternalCA) Marshal() (data []byte, err error)

func (*ExternalCA) MarshalTo 

func (m *ExternalCA) MarshalTo(data []byte) (int, error)

func (*ExternalCA) ProtoMessage 

func (*ExternalCA) ProtoMessage()

func (*ExternalCA) Reset 

func (m *ExternalCA) Reset()

func (*ExternalCA) Size 

func (m *ExternalCA) Size() (n int)

func (*ExternalCA) String 

func (this *ExternalCA) String() string

func (*ExternalCA) Unmarshal 

func (m *ExternalCA) Unmarshal(data []byte) error

type ExternalCA_CAProtocol 

type ExternalCA_CAProtocol int32
const (
	ExternalCA_CAProtocolCFSSL ExternalCA_CAProtocol = 0
)

func (ExternalCA_CAProtocol) EnumDescriptor 

func (ExternalCA_CAProtocol) EnumDescriptor() ([]byte, []int)

func (ExternalCA_CAProtocol) String 

func (x ExternalCA_CAProtocol) String() string

type GetClusterRequest 

type GetClusterRequest struct {
	ClusterID string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
}

func (*GetClusterRequest) Copy 

func (m *GetClusterRequest) Copy() *GetClusterRequest

func (*GetClusterRequest) Descriptor 

func (*GetClusterRequest) Descriptor() ([]byte, []int)

func (*GetClusterRequest) GoString 

func (this *GetClusterRequest) GoString() string

func (*GetClusterRequest) Marshal 

func (m *GetClusterRequest) Marshal() (data []byte, err error)

func (*GetClusterRequest) MarshalTo 

func (m *GetClusterRequest) MarshalTo(data []byte) (int, error)

func (*GetClusterRequest) ProtoMessage 

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) Reset 

func (m *GetClusterRequest) Reset()

func (*GetClusterRequest) Size 

func (m *GetClusterRequest) Size() (n int)

func (*GetClusterRequest) String 

func (this *GetClusterRequest) String() string

func (*GetClusterRequest) Unmarshal 

func (m *GetClusterRequest) Unmarshal(data []byte) error

type GetClusterResponse 

type GetClusterResponse struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`
}

func (*GetClusterResponse) Copy 

func (m *GetClusterResponse) Copy() *GetClusterResponse

func (*GetClusterResponse) Descriptor 

func (*GetClusterResponse) Descriptor() ([]byte, []int)

func (*GetClusterResponse) GoString 

func (this *GetClusterResponse) GoString() string

func (*GetClusterResponse) Marshal 

func (m *GetClusterResponse) Marshal() (data []byte, err error)

func (*GetClusterResponse) MarshalTo 

func (m *GetClusterResponse) MarshalTo(data []byte) (int, error)

func (*GetClusterResponse) ProtoMessage 

func (*GetClusterResponse) ProtoMessage()

func (*GetClusterResponse) Reset 

func (m *GetClusterResponse) Reset()

func (*GetClusterResponse) Size 

func (m *GetClusterResponse) Size() (n int)

func (*GetClusterResponse) String 

func (this *GetClusterResponse) String() string

func (*GetClusterResponse) Unmarshal 

func (m *GetClusterResponse) Unmarshal(data []byte) error

type GetNetworkRequest 

type GetNetworkRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	NetworkID string `protobuf:"bytes,2,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
}

func (*GetNetworkRequest) Copy 

func (m *GetNetworkRequest) Copy() *GetNetworkRequest

func (*GetNetworkRequest) Descriptor 

func (*GetNetworkRequest) Descriptor() ([]byte, []int)

func (*GetNetworkRequest) GoString 

func (this *GetNetworkRequest) GoString() string

func (*GetNetworkRequest) Marshal 

func (m *GetNetworkRequest) Marshal() (data []byte, err error)

func (*GetNetworkRequest) MarshalTo 

func (m *GetNetworkRequest) MarshalTo(data []byte) (int, error)

func (*GetNetworkRequest) ProtoMessage 

func (*GetNetworkRequest) ProtoMessage()

func (*GetNetworkRequest) Reset 

func (m *GetNetworkRequest) Reset()

func (*GetNetworkRequest) Size 

func (m *GetNetworkRequest) Size() (n int)

func (*GetNetworkRequest) String 

func (this *GetNetworkRequest) String() string

func (*GetNetworkRequest) Unmarshal 

func (m *GetNetworkRequest) Unmarshal(data []byte) error

type GetNetworkResponse 

type GetNetworkResponse struct {
	Network *Network `protobuf:"bytes,1,opt,name=network" json:"network,omitempty"`
}

func (*GetNetworkResponse) Copy 

func (m *GetNetworkResponse) Copy() *GetNetworkResponse

func (*GetNetworkResponse) Descriptor 

func (*GetNetworkResponse) Descriptor() ([]byte, []int)

func (*GetNetworkResponse) GoString 

func (this *GetNetworkResponse) GoString() string

func (*GetNetworkResponse) Marshal 

func (m *GetNetworkResponse) Marshal() (data []byte, err error)

func (*GetNetworkResponse) MarshalTo 

func (m *GetNetworkResponse) MarshalTo(data []byte) (int, error)

func (*GetNetworkResponse) ProtoMessage 

func (*GetNetworkResponse) ProtoMessage()

func (*GetNetworkResponse) Reset 

func (m *GetNetworkResponse) Reset()

func (*GetNetworkResponse) Size 

func (m *GetNetworkResponse) Size() (n int)

func (*GetNetworkResponse) String 

func (this *GetNetworkResponse) String() string

func (*GetNetworkResponse) Unmarshal 

func (m *GetNetworkResponse) Unmarshal(data []byte) error

type GetNodeRequest 

type GetNodeRequest struct {
	NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*GetNodeRequest) Copy 

func (m *GetNodeRequest) Copy() *GetNodeRequest

func (*GetNodeRequest) Descriptor 

func (*GetNodeRequest) Descriptor() ([]byte, []int)

func (*GetNodeRequest) GoString 

func (this *GetNodeRequest) GoString() string

func (*GetNodeRequest) Marshal 

func (m *GetNodeRequest) Marshal() (data []byte, err error)

func (*GetNodeRequest) MarshalTo 

func (m *GetNodeRequest) MarshalTo(data []byte) (int, error)

func (*GetNodeRequest) ProtoMessage 

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) Reset 

func (m *GetNodeRequest) Reset()

func (*GetNodeRequest) Size 

func (m *GetNodeRequest) Size() (n int)

func (*GetNodeRequest) String 

func (this *GetNodeRequest) String() string

func (*GetNodeRequest) Unmarshal 

func (m *GetNodeRequest) Unmarshal(data []byte) error

type GetNodeResponse 

type GetNodeResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
}

func (*GetNodeResponse) Copy 

func (m *GetNodeResponse) Copy() *GetNodeResponse

func (*GetNodeResponse) Descriptor 

func (*GetNodeResponse) Descriptor() ([]byte, []int)

func (*GetNodeResponse) GoString 

func (this *GetNodeResponse) GoString() string

func (*GetNodeResponse) Marshal 

func (m *GetNodeResponse) Marshal() (data []byte, err error)

func (*GetNodeResponse) MarshalTo 

func (m *GetNodeResponse) MarshalTo(data []byte) (int, error)

func (*GetNodeResponse) ProtoMessage 

func (*GetNodeResponse) ProtoMessage()

func (*GetNodeResponse) Reset 

func (m *GetNodeResponse) Reset()

func (*GetNodeResponse) Size 

func (m *GetNodeResponse) Size() (n int)

func (*GetNodeResponse) String 

func (this *GetNodeResponse) String() string

func (*GetNodeResponse) Unmarshal 

func (m *GetNodeResponse) Unmarshal(data []byte) error

type GetRootCACertificateRequest 

type GetRootCACertificateRequest struct {
}

func (*GetRootCACertificateRequest) Copy 

func (m *GetRootCACertificateRequest) Copy() *GetRootCACertificateRequest

func (*GetRootCACertificateRequest) Descriptor 

func (*GetRootCACertificateRequest) Descriptor() ([]byte, []int)

func (*GetRootCACertificateRequest) GoString 

func (this *GetRootCACertificateRequest) GoString() string

func (*GetRootCACertificateRequest) Marshal 

func (m *GetRootCACertificateRequest) Marshal() (data []byte, err error)

func (*GetRootCACertificateRequest) MarshalTo 

func (m *GetRootCACertificateRequest) MarshalTo(data []byte) (int, error)

func (*GetRootCACertificateRequest) ProtoMessage 

func (*GetRootCACertificateRequest) ProtoMessage()

func (*GetRootCACertificateRequest) Reset 

func (m *GetRootCACertificateRequest) Reset()

func (*GetRootCACertificateRequest) Size 

func (m *GetRootCACertificateRequest) Size() (n int)

func (*GetRootCACertificateRequest) String 

func (this *GetRootCACertificateRequest) String() string

func (*GetRootCACertificateRequest) Unmarshal 

func (m *GetRootCACertificateRequest) Unmarshal(data []byte) error

type GetRootCACertificateResponse 

type GetRootCACertificateResponse struct {
	Certificate []byte `protobuf:"bytes,1,opt,name=certificate,proto3" json:"certificate,omitempty"`
}

func (*GetRootCACertificateResponse) Copy 

func (m *GetRootCACertificateResponse) Copy() *GetRootCACertificateResponse

func (*GetRootCACertificateResponse) Descriptor 

func (*GetRootCACertificateResponse) Descriptor() ([]byte, []int)

func (*GetRootCACertificateResponse) GoString 

func (this *GetRootCACertificateResponse) GoString() string

func (*GetRootCACertificateResponse) Marshal 

func (m *GetRootCACertificateResponse) Marshal() (data []byte, err error)

func (*GetRootCACertificateResponse) MarshalTo 

func (m *GetRootCACertificateResponse) MarshalTo(data []byte) (int, error)

func (*GetRootCACertificateResponse) ProtoMessage 

func (*GetRootCACertificateResponse) ProtoMessage()

func (*GetRootCACertificateResponse) Reset 

func (m *GetRootCACertificateResponse) Reset()

func (*GetRootCACertificateResponse) Size 

func (m *GetRootCACertificateResponse) Size() (n int)

func (*GetRootCACertificateResponse) String 

func (this *GetRootCACertificateResponse) String() string

func (*GetRootCACertificateResponse) Unmarshal 

func (m *GetRootCACertificateResponse) Unmarshal(data []byte) error

type GetServiceRequest 

type GetServiceRequest struct {
	ServiceID string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
}

func (*GetServiceRequest) Copy 

func (m *GetServiceRequest) Copy() *GetServiceRequest

func (*GetServiceRequest) Descriptor 

func (*GetServiceRequest) Descriptor() ([]byte, []int)

func (*GetServiceRequest) GoString 

func (this *GetServiceRequest) GoString() string

func (*GetServiceRequest) Marshal 

func (m *GetServiceRequest) Marshal() (data []byte, err error)

func (*GetServiceRequest) MarshalTo 

func (m *GetServiceRequest) MarshalTo(data []byte) (int, error)

func (*GetServiceRequest) ProtoMessage 

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) Reset 

func (m *GetServiceRequest) Reset()

func (*GetServiceRequest) Size 

func (m *GetServiceRequest) Size() (n int)

func (*GetServiceRequest) String 

func (this *GetServiceRequest) String() string

func (*GetServiceRequest) Unmarshal 

func (m *GetServiceRequest) Unmarshal(data []byte) error

type GetServiceResponse 

type GetServiceResponse struct {
	Service *Service `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
}

func (*GetServiceResponse) Copy 

func (m *GetServiceResponse) Copy() *GetServiceResponse

func (*GetServiceResponse) Descriptor 

func (*GetServiceResponse) Descriptor() ([]byte, []int)

func (*GetServiceResponse) GoString 

func (this *GetServiceResponse) GoString() string

func (*GetServiceResponse) Marshal 

func (m *GetServiceResponse) Marshal() (data []byte, err error)

func (*GetServiceResponse) MarshalTo 

func (m *GetServiceResponse) MarshalTo(data []byte) (int, error)

func (*GetServiceResponse) ProtoMessage 

func (*GetServiceResponse) ProtoMessage()

func (*GetServiceResponse) Reset 

func (m *GetServiceResponse) Reset()

func (*GetServiceResponse) Size 

func (m *GetServiceResponse) Size() (n int)

func (*GetServiceResponse) String 

func (this *GetServiceResponse) String() string

func (*GetServiceResponse) Unmarshal 

func (m *GetServiceResponse) Unmarshal(data []byte) error

type GetTaskRequest 

type GetTaskRequest struct {
	TaskID string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
}

func (*GetTaskRequest) Copy 

func (m *GetTaskRequest) Copy() *GetTaskRequest

func (*GetTaskRequest) Descriptor 

func (*GetTaskRequest) Descriptor() ([]byte, []int)

func (*GetTaskRequest) GoString 

func (this *GetTaskRequest) GoString() string

func (*GetTaskRequest) Marshal 

func (m *GetTaskRequest) Marshal() (data []byte, err error)

func (*GetTaskRequest) MarshalTo 

func (m *GetTaskRequest) MarshalTo(data []byte) (int, error)

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) Reset 

func (m *GetTaskRequest) Reset()

func (*GetTaskRequest) Size 

func (m *GetTaskRequest) Size() (n int)

func (*GetTaskRequest) String 

func (this *GetTaskRequest) String() string

func (*GetTaskRequest) Unmarshal 

func (m *GetTaskRequest) Unmarshal(data []byte) error

type GetTaskResponse 

type GetTaskResponse struct {
	Task *Task `protobuf:"bytes,1,opt,name=task" json:"task,omitempty"`
}

func (*GetTaskResponse) Copy 

func (m *GetTaskResponse) Copy() *GetTaskResponse

func (*GetTaskResponse) Descriptor 

func (*GetTaskResponse) Descriptor() ([]byte, []int)

func (*GetTaskResponse) GoString 

func (this *GetTaskResponse) GoString() string

func (*GetTaskResponse) Marshal 

func (m *GetTaskResponse) Marshal() (data []byte, err error)

func (*GetTaskResponse) MarshalTo 

func (m *GetTaskResponse) MarshalTo(data []byte) (int, error)

func (*GetTaskResponse) ProtoMessage 

func (*GetTaskResponse) ProtoMessage()

func (*GetTaskResponse) Reset 

func (m *GetTaskResponse) Reset()

func (*GetTaskResponse) Size 

func (m *GetTaskResponse) Size() (n int)

func (*GetTaskResponse) String 

func (this *GetTaskResponse) String() string

func (*GetTaskResponse) Unmarshal 

func (m *GetTaskResponse) Unmarshal(data []byte) error

type GlobalService 

type GlobalService struct {
}

GlobalService represents global service.

func (*GlobalService) Copy 

func (m *GlobalService) Copy() *GlobalService

func (*GlobalService) Descriptor 

func (*GlobalService) Descriptor() ([]byte, []int)

func (*GlobalService) GoString 

func (this *GlobalService) GoString() string

func (*GlobalService) Marshal 

func (m *GlobalService) Marshal() (data []byte, err error)

func (*GlobalService) MarshalTo 

func (m *GlobalService) MarshalTo(data []byte) (int, error)

func (*GlobalService) ProtoMessage 

func (*GlobalService) ProtoMessage()

func (*GlobalService) Reset 

func (m *GlobalService) Reset()

func (*GlobalService) Size 

func (m *GlobalService) Size() (n int)

func (*GlobalService) String 

func (this *GlobalService) String() string

func (*GlobalService) Unmarshal 

func (m *GlobalService) Unmarshal(data []byte) error

type HealthCheckRequest 

type HealthCheckRequest struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
}

func (*HealthCheckRequest) Copy 

func (m *HealthCheckRequest) Copy() *HealthCheckRequest

func (*HealthCheckRequest) Descriptor 

func (*HealthCheckRequest) Descriptor() ([]byte, []int)

func (*HealthCheckRequest) GoString 

func (this *HealthCheckRequest) GoString() string

func (*HealthCheckRequest) Marshal 

func (m *HealthCheckRequest) Marshal() (data []byte, err error)

func (*HealthCheckRequest) MarshalTo 

func (m *HealthCheckRequest) MarshalTo(data []byte) (int, error)

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset 

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) Size 

func (m *HealthCheckRequest) Size() (n int)

func (*HealthCheckRequest) String 

func (this *HealthCheckRequest) String() string

func (*HealthCheckRequest) Unmarshal 

func (m *HealthCheckRequest) Unmarshal(data []byte) error

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=docker.swarmkit.v1.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
}

func (*HealthCheckResponse) Copy 

func (m *HealthCheckResponse) Copy() *HealthCheckResponse

func (*HealthCheckResponse) Descriptor 

func (*HealthCheckResponse) Descriptor() ([]byte, []int)

func (*HealthCheckResponse) GoString 

func (this *HealthCheckResponse) GoString() string

func (*HealthCheckResponse) Marshal 

func (m *HealthCheckResponse) Marshal() (data []byte, err error)

func (*HealthCheckResponse) MarshalTo 

func (m *HealthCheckResponse) MarshalTo(data []byte) (int, error)

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) Size 

func (m *HealthCheckResponse) Size() (n int)

func (*HealthCheckResponse) String 

func (this *HealthCheckResponse) String() string

func (*HealthCheckResponse) Unmarshal 

func (m *HealthCheckResponse) Unmarshal(data []byte) error

type HealthCheckResponse_ServingStatus 

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN     HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING     HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2
)

func (HealthCheckResponse_ServingStatus) EnumDescriptor 

func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)

func (HealthCheckResponse_ServingStatus) String 

func (x HealthCheckResponse_ServingStatus) String() string

type HealthClient 

type HealthClient interface {
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

func NewHealthClient 

func NewHealthClient(cc *grpc.ClientConn) HealthClient

type HealthServer 

type HealthServer interface {
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
}

func NewAuthenticatedWrapperHealthServer 

func NewAuthenticatedWrapperHealthServer(local HealthServer, authorize func(context.Context, []string) error) HealthServer

func NewRaftProxyHealthServer 

func NewRaftProxyHealthServer(local HealthServer, connSelector *raftpicker.ConnSelector, cluster raftpicker.RaftCluster, ctxMod func(context.Context) (context.Context, error)) HealthServer

type HeartbeatRequest 

type HeartbeatRequest struct {
	SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
}

HeartbeatRequest provides identifying properties for a single heartbeat.

func (*HeartbeatRequest) Copy 

func (m *HeartbeatRequest) Copy() *HeartbeatRequest

func (*HeartbeatRequest) Descriptor 

func (*HeartbeatRequest) Descriptor() ([]byte, []int)

func (*HeartbeatRequest) GoString 

func (this *HeartbeatRequest) GoString() string

func (*HeartbeatRequest) Marshal 

func (m *HeartbeatRequest) Marshal() (data []byte, err error)

func (*HeartbeatRequest) MarshalTo 

func (m *HeartbeatRequest) MarshalTo(data []byte) (int, error)

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) Reset 

func (m *HeartbeatRequest) Reset()

func (*HeartbeatRequest) Size 

func (m *HeartbeatRequest) Size() (n int)

func (*HeartbeatRequest) String 

func (this *HeartbeatRequest) String() string

func (*HeartbeatRequest) Unmarshal 

func (m *HeartbeatRequest) Unmarshal(data []byte) error

type HeartbeatResponse 

type HeartbeatResponse struct {
	// Period is the duration to wait before sending the next heartbeat.
	// Well-behaved agents should update this on every heartbeat round trip.
	Period docker_swarmkit_v11.Duration `protobuf:"bytes,1,opt,name=period" json:"period"`
}

func (*HeartbeatResponse) Copy 

func (m *HeartbeatResponse) Copy() *HeartbeatResponse

func (*HeartbeatResponse) Descriptor 

func (*HeartbeatResponse) Descriptor() ([]byte, []int)

func (*HeartbeatResponse) GoString 

func (this *HeartbeatResponse) GoString() string

func (*HeartbeatResponse) Marshal 

func (m *HeartbeatResponse) Marshal() (data []byte, err error)

func (*HeartbeatResponse) MarshalTo 

func (m *HeartbeatResponse) MarshalTo(data []byte) (int, error)

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) Reset 

func (m *HeartbeatResponse) Reset()

func (*HeartbeatResponse) Size 

func (m *HeartbeatResponse) Size() (n int)

func (*HeartbeatResponse) String 

func (this *HeartbeatResponse) String() string

func (*HeartbeatResponse) Unmarshal 

func (m *HeartbeatResponse) Unmarshal(data []byte) error

type IPAMConfig 

type IPAMConfig struct {
	Family IPAMConfig_AddressFamily `protobuf:"varint,1,opt,name=family,proto3,enum=docker.swarmkit.v1.IPAMConfig_AddressFamily" json:"family,omitempty"`
	// Subnet defines a network as a CIDR address (ie network and mask
	// 192.168.0.1/24).
	Subnet string `protobuf:"bytes,2,opt,name=subnet,proto3" json:"subnet,omitempty"`
	// Range defines the portion of the subnet to allocate to tasks. This is
	// defined as a subnet within the primary subnet.
	Range string `protobuf:"bytes,3,opt,name=range,proto3" json:"range,omitempty"`
	// Gateway address within the subnet.
	Gateway string `protobuf:"bytes,4,opt,name=gateway,proto3" json:"gateway,omitempty"`
	// Reserved is a list of address from the master pool that should *not* be
	// allocated. These addresses may have already been allocated or may be
	// reserved for another allocation manager.
	Reserved map[string]string `` /* 150-byte string literal not displayed */
}

IPAMConfig specifies parameters for IP Address Management.

func (*IPAMConfig) Copy 

func (m *IPAMConfig) Copy() *IPAMConfig

func (*IPAMConfig) Descriptor 

func (*IPAMConfig) Descriptor() ([]byte, []int)

func (*IPAMConfig) GoString 

func (this *IPAMConfig) GoString() string

func (*IPAMConfig) Marshal 

func (m *IPAMConfig) Marshal() (data []byte, err error)

func (*IPAMConfig) MarshalTo 

func (m *IPAMConfig) MarshalTo(data []byte) (int, error)

func (*IPAMConfig) ProtoMessage 

func (*IPAMConfig) ProtoMessage()

func (*IPAMConfig) Reset 

func (m *IPAMConfig) Reset()

func (*IPAMConfig) Size 

func (m *IPAMConfig) Size() (n int)

func (*IPAMConfig) String 

func (this *IPAMConfig) String() string

func (*IPAMConfig) Unmarshal 

func (m *IPAMConfig) Unmarshal(data []byte) error

type IPAMConfig_AddressFamily 

type IPAMConfig_AddressFamily int32

AddressFamily specifies the network address family that this IPAMConfig belongs to. 

const (
	IPAMConfig_UNKNOWN IPAMConfig_AddressFamily = 0
	IPAMConfig_IPV4    IPAMConfig_AddressFamily = 4
	IPAMConfig_IPV6    IPAMConfig_AddressFamily = 6
)

func (IPAMConfig_AddressFamily) EnumDescriptor 

func (IPAMConfig_AddressFamily) EnumDescriptor() ([]byte, []int)

func (IPAMConfig_AddressFamily) String 

func (x IPAMConfig_AddressFamily) String() string

type IPAMOptions 

type IPAMOptions struct {
	Driver  *Driver       `protobuf:"bytes,1,opt,name=driver" json:"driver,omitempty"`
	Configs []*IPAMConfig `protobuf:"bytes,3,rep,name=configs" json:"configs,omitempty"`
}

func (*IPAMOptions) Copy 

func (m *IPAMOptions) Copy() *IPAMOptions

func (*IPAMOptions) Descriptor 

func (*IPAMOptions) Descriptor() ([]byte, []int)

func (*IPAMOptions) GoString 

func (this *IPAMOptions) GoString() string

func (*IPAMOptions) Marshal 

func (m *IPAMOptions) Marshal() (data []byte, err error)

func (*IPAMOptions) MarshalTo 

func (m *IPAMOptions) MarshalTo(data []byte) (int, error)

func (*IPAMOptions) ProtoMessage 

func (*IPAMOptions) ProtoMessage()

func (*IPAMOptions) Reset 

func (m *IPAMOptions) Reset()

func (*IPAMOptions) Size 

func (m *IPAMOptions) Size() (n int)

func (*IPAMOptions) String 

func (this *IPAMOptions) String() string

func (*IPAMOptions) Unmarshal 

func (m *IPAMOptions) Unmarshal(data []byte) error

type Image 

type Image struct {
	// reference is a docker image reference. This can include a rpository, tag
	// or be fully qualified witha digest. The format is specified in the
	// distribution/reference package.
	Reference string `protobuf:"bytes,1,opt,name=reference,proto3" json:"reference,omitempty"`
}

func (*Image) Copy 

func (m *Image) Copy() *Image

func (*Image) Descriptor 

func (*Image) Descriptor() ([]byte, []int)

func (*Image) GoString 

func (this *Image) GoString() string

func (*Image) Marshal 

func (m *Image) Marshal() (data []byte, err error)

func (*Image) MarshalTo 

func (m *Image) MarshalTo(data []byte) (int, error)

func (*Image) ProtoMessage 

func (*Image) ProtoMessage()

func (*Image) Reset 

func (m *Image) Reset()

func (*Image) Size 

func (m *Image) Size() (n int)

func (*Image) String 

func (this *Image) String() string

func (*Image) Unmarshal 

func (m *Image) Unmarshal(data []byte) error

type InternalRaftRequest 

type InternalRaftRequest struct {
	ID     uint64         `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Action []*StoreAction `protobuf:"bytes,2,rep,name=action" json:"action,omitempty"`
}

Contains one of many protobuf encoded objects to replicate over the raft backend with a request ID to track when the action is effectively applied

func (*InternalRaftRequest) Copy 

func (m *InternalRaftRequest) Copy() *InternalRaftRequest

func (*InternalRaftRequest) Descriptor 

func (*InternalRaftRequest) Descriptor() ([]byte, []int)

func (*InternalRaftRequest) GoString 

func (this *InternalRaftRequest) GoString() string

func (*InternalRaftRequest) Marshal 

func (m *InternalRaftRequest) Marshal() (data []byte, err error)

func (*InternalRaftRequest) MarshalTo 

func (m *InternalRaftRequest) MarshalTo(data []byte) (int, error)

func (*InternalRaftRequest) ProtoMessage 

func (*InternalRaftRequest) ProtoMessage()

func (*InternalRaftRequest) Reset 

func (m *InternalRaftRequest) Reset()

func (*InternalRaftRequest) Size 

func (m *InternalRaftRequest) Size() (n int)

func (*InternalRaftRequest) String 

func (this *InternalRaftRequest) String() string

func (*InternalRaftRequest) Unmarshal 

func (m *InternalRaftRequest) Unmarshal(data []byte) error

type IssuanceStatus 

type IssuanceStatus struct {
	State IssuanceStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=docker.swarmkit.v1.IssuanceStatus_State" json:"state,omitempty"`
	// Err is set if the Certificate Issuance is in an error state.
	// The following states should report a companion error:
	// 	FAILED
	Err string `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
}

func (*IssuanceStatus) Copy 

func (m *IssuanceStatus) Copy() *IssuanceStatus

func (*IssuanceStatus) Descriptor 

func (*IssuanceStatus) Descriptor() ([]byte, []int)

func (*IssuanceStatus) GoString 

func (this *IssuanceStatus) GoString() string

func (*IssuanceStatus) Marshal 

func (m *IssuanceStatus) Marshal() (data []byte, err error)

func (*IssuanceStatus) MarshalTo 

func (m *IssuanceStatus) MarshalTo(data []byte) (int, error)

func (*IssuanceStatus) ProtoMessage 

func (*IssuanceStatus) ProtoMessage()

func (*IssuanceStatus) Reset 

func (m *IssuanceStatus) Reset()

func (*IssuanceStatus) Size 

func (m *IssuanceStatus) Size() (n int)

func (*IssuanceStatus) String 

func (this *IssuanceStatus) String() string

func (*IssuanceStatus) Unmarshal 

func (m *IssuanceStatus) Unmarshal(data []byte) error

type IssuanceStatus_State 

type IssuanceStatus_State int32
const (
	IssuanceStateUnknown IssuanceStatus_State = 0
	IssuanceStateRenew   IssuanceStatus_State = 1
	IssuanceStatePending IssuanceStatus_State = 2
	IssuanceStateIssued  IssuanceStatus_State = 3
	IssuanceStateFailed  IssuanceStatus_State = 4
)

func (IssuanceStatus_State) EnumDescriptor 

func (IssuanceStatus_State) EnumDescriptor() ([]byte, []int)

func (IssuanceStatus_State) String 

func (x IssuanceStatus_State) String() string

type IssueNodeCertificateRequest 

type IssueNodeCertificateRequest struct {
	// DEPRECATED: Role is now selected based on which secret is matched.
	Role NodeRole `protobuf:"varint,1,opt,name=role,proto3,enum=docker.swarmkit.v1.NodeRole" json:"role,omitempty"`
	// CSR is the certificate signing request.
	CSR []byte `protobuf:"bytes,2,opt,name=csr,proto3" json:"csr,omitempty"`
	// Token represents a user-provided string that is necessary for new
	// nodes to join the cluster
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
}

func (*IssueNodeCertificateRequest) Copy 

func (m *IssueNodeCertificateRequest) Copy() *IssueNodeCertificateRequest

func (*IssueNodeCertificateRequest) Descriptor 

func (*IssueNodeCertificateRequest) Descriptor() ([]byte, []int)

func (*IssueNodeCertificateRequest) GoString 

func (this *IssueNodeCertificateRequest) GoString() string

func (*IssueNodeCertificateRequest) Marshal 

func (m *IssueNodeCertificateRequest) Marshal() (data []byte, err error)

func (*IssueNodeCertificateRequest) MarshalTo 

func (m *IssueNodeCertificateRequest) MarshalTo(data []byte) (int, error)

func (*IssueNodeCertificateRequest) ProtoMessage 

func (*IssueNodeCertificateRequest) ProtoMessage()

func (*IssueNodeCertificateRequest) Reset 

func (m *IssueNodeCertificateRequest) Reset()

func (*IssueNodeCertificateRequest) Size 

func (m *IssueNodeCertificateRequest) Size() (n int)

func (*IssueNodeCertificateRequest) String 

func (this *IssueNodeCertificateRequest) String() string

func (*IssueNodeCertificateRequest) Unmarshal 

func (m *IssueNodeCertificateRequest) Unmarshal(data []byte) error

type IssueNodeCertificateResponse 

type IssueNodeCertificateResponse struct {
	NodeID         string              `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	NodeMembership NodeSpec_Membership `` /* 148-byte string literal not displayed */
}

func (*IssueNodeCertificateResponse) Copy 

func (m *IssueNodeCertificateResponse) Copy() *IssueNodeCertificateResponse

func (*IssueNodeCertificateResponse) Descriptor 

func (*IssueNodeCertificateResponse) Descriptor() ([]byte, []int)

func (*IssueNodeCertificateResponse) GoString 

func (this *IssueNodeCertificateResponse) GoString() string

func (*IssueNodeCertificateResponse) Marshal 

func (m *IssueNodeCertificateResponse) Marshal() (data []byte, err error)

func (*IssueNodeCertificateResponse) MarshalTo 

func (m *IssueNodeCertificateResponse) MarshalTo(data []byte) (int, error)

func (*IssueNodeCertificateResponse) ProtoMessage 

func (*IssueNodeCertificateResponse) ProtoMessage()

func (*IssueNodeCertificateResponse) Reset 

func (m *IssueNodeCertificateResponse) Reset()

func (*IssueNodeCertificateResponse) Size 

func (m *IssueNodeCertificateResponse) Size() (n int)

func (*IssueNodeCertificateResponse) String 

func (this *IssueNodeCertificateResponse) String() string

func (*IssueNodeCertificateResponse) Unmarshal 

func (m *IssueNodeCertificateResponse) Unmarshal(data []byte) error

type JoinRequest 

type JoinRequest struct {
	// Addr specifies the address of the member
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
}

func (*JoinRequest) Copy 

func (m *JoinRequest) Copy() *JoinRequest

func (*JoinRequest) Descriptor 

func (*JoinRequest) Descriptor() ([]byte, []int)

func (*JoinRequest) GoString 

func (this *JoinRequest) GoString() string

func (*JoinRequest) Marshal 

func (m *JoinRequest) Marshal() (data []byte, err error)

func (*JoinRequest) MarshalTo 

func (m *JoinRequest) MarshalTo(data []byte) (int, error)

func (*JoinRequest) ProtoMessage 

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) Reset 

func (m *JoinRequest) Reset()

func (*JoinRequest) Size 

func (m *JoinRequest) Size() (n int)

func (*JoinRequest) String 

func (this *JoinRequest) String() string

func (*JoinRequest) Unmarshal 

func (m *JoinRequest) Unmarshal(data []byte) error

type JoinResponse 

type JoinResponse struct {
	// RaftID is the ID assigned to the new member.
	RaftID uint64 `protobuf:"varint,1,opt,name=raft_id,json=raftId,proto3" json:"raft_id,omitempty"`
	// Members is the membership set of the cluster.
	Members []*RaftMember `protobuf:"bytes,2,rep,name=members" json:"members,omitempty"`
	// RemovedMembers is a list of members that have been removed from
	// the cluster, so the new node can avoid communicating with them.
	RemovedMembers []uint64 `protobuf:"varint,3,rep,name=removed_members,json=removedMembers" json:"removed_members,omitempty"`
}

func (*JoinResponse) Copy 

func (m *JoinResponse) Copy() *JoinResponse

func (*JoinResponse) Descriptor 

func (*JoinResponse) Descriptor() ([]byte, []int)

func (*JoinResponse) GoString 

func (this *JoinResponse) GoString() string

func (*JoinResponse) Marshal 

func (m *JoinResponse) Marshal() (data []byte, err error)

func (*JoinResponse) MarshalTo 

func (m *JoinResponse) MarshalTo(data []byte) (int, error)

func (*JoinResponse) ProtoMessage 

func (*JoinResponse) ProtoMessage()

func (*JoinResponse) Reset 

func (m *JoinResponse) Reset()

func (*JoinResponse) Size 

func (m *JoinResponse) Size() (n int)

func (*JoinResponse) String 

func (this *JoinResponse) String() string

func (*JoinResponse) Unmarshal 

func (m *JoinResponse) Unmarshal(data []byte) error

type JoinTokenRotation 

type JoinTokenRotation struct {
	// RotateWorkerToken tells UpdateCluster to rotate the worker secret.
	RotateWorkerToken bool `protobuf:"varint,1,opt,name=rotate_worker_token,json=rotateWorkerToken,proto3" json:"rotate_worker_token,omitempty"`
	// RotateManagerSecret tells UpdateCluster to rotate the manager secret.
	RotateManagerToken bool `protobuf:"varint,2,opt,name=rotate_manager_token,json=rotateManagerToken,proto3" json:"rotate_manager_token,omitempty"`
}

func (*JoinTokenRotation) Copy 

func (m *JoinTokenRotation) Copy() *JoinTokenRotation

func (*JoinTokenRotation) Descriptor 

func (*JoinTokenRotation) Descriptor() ([]byte, []int)

func (*JoinTokenRotation) GoString 

func (this *JoinTokenRotation) GoString() string

func (*JoinTokenRotation) Marshal 

func (m *JoinTokenRotation) Marshal() (data []byte, err error)

func (*JoinTokenRotation) MarshalTo 

func (m *JoinTokenRotation) MarshalTo(data []byte) (int, error)

func (*JoinTokenRotation) ProtoMessage 

func (*JoinTokenRotation) ProtoMessage()

func (*JoinTokenRotation) Reset 

func (m *JoinTokenRotation) Reset()

func (*JoinTokenRotation) Size 

func (m *JoinTokenRotation) Size() (n int)

func (*JoinTokenRotation) String 

func (this *JoinTokenRotation) String() string

func (*JoinTokenRotation) Unmarshal 

func (m *JoinTokenRotation) Unmarshal(data []byte) error

type JoinTokens 

type JoinTokens struct {
	// Worker is the join token workers may use to join the swarm.
	Worker string `protobuf:"bytes,1,opt,name=worker,proto3" json:"worker,omitempty"`
	// Manager is the join token workers may use to join the swarm.
	Manager string `protobuf:"bytes,2,opt,name=manager,proto3" json:"manager,omitempty"`
}

JoinToken contains the join tokens for workers and managers.

func (*JoinTokens) Copy 

func (m *JoinTokens) Copy() *JoinTokens

func (*JoinTokens) Descriptor 

func (*JoinTokens) Descriptor() ([]byte, []int)

func (*JoinTokens) GoString 

func (this *JoinTokens) GoString() string

func (*JoinTokens) Marshal 

func (m *JoinTokens) Marshal() (data []byte, err error)

func (*JoinTokens) MarshalTo 

func (m *JoinTokens) MarshalTo(data []byte) (int, error)

func (*JoinTokens) ProtoMessage 

func (*JoinTokens) ProtoMessage()

func (*JoinTokens) Reset 

func (m *JoinTokens) Reset()

func (*JoinTokens) Size 

func (m *JoinTokens) Size() (n int)

func (*JoinTokens) String 

func (this *JoinTokens) String() string

func (*JoinTokens) Unmarshal 

func (m *JoinTokens) Unmarshal(data []byte) error

type LeaveRequest 

type LeaveRequest struct {
	Node *RaftMember `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
}

func (*LeaveRequest) Copy 

func (m *LeaveRequest) Copy() *LeaveRequest

func (*LeaveRequest) Descriptor 

func (*LeaveRequest) Descriptor() ([]byte, []int)

func (*LeaveRequest) GoString 

func (this *LeaveRequest) GoString() string

func (*LeaveRequest) Marshal 

func (m *LeaveRequest) Marshal() (data []byte, err error)

func (*LeaveRequest) MarshalTo 

func (m *LeaveRequest) MarshalTo(data []byte) (int, error)

func (*LeaveRequest) ProtoMessage 

func (*LeaveRequest) ProtoMessage()

func (*LeaveRequest) Reset 

func (m *LeaveRequest) Reset()

func (*LeaveRequest) Size 

func (m *LeaveRequest) Size() (n int)

func (*LeaveRequest) String 

func (this *LeaveRequest) String() string

func (*LeaveRequest) Unmarshal 

func (m *LeaveRequest) Unmarshal(data []byte) error

type LeaveResponse 

type LeaveResponse struct {
}

func (*LeaveResponse) Copy 

func (m *LeaveResponse) Copy() *LeaveResponse

func (*LeaveResponse) Descriptor 

func (*LeaveResponse) Descriptor() ([]byte, []int)

func (*LeaveResponse) GoString 

func (this *LeaveResponse) GoString() string

func (*LeaveResponse) Marshal 

func (m *LeaveResponse) Marshal() (data []byte, err error)

func (*LeaveResponse) MarshalTo 

func (m *LeaveResponse) MarshalTo(data []byte) (int, error)

func (*LeaveResponse) ProtoMessage 

func (*LeaveResponse) ProtoMessage()

func (*LeaveResponse) Reset 

func (m *LeaveResponse) Reset()

func (*LeaveResponse) Size 

func (m *LeaveResponse) Size() (n int)

func (*LeaveResponse) String 

func (this *LeaveResponse) String() string

func (*LeaveResponse) Unmarshal 

func (m *LeaveResponse) Unmarshal(data []byte) error

type ListClustersRequest 

type ListClustersRequest struct {
	Filters *ListClustersRequest_Filters `protobuf:"bytes,1,opt,name=filters" json:"filters,omitempty"`
}

func (*ListClustersRequest) Copy 

func (m *ListClustersRequest) Copy() *ListClustersRequest

func (*ListClustersRequest) Descriptor 

func (*ListClustersRequest) Descriptor() ([]byte, []int)

func (*ListClustersRequest) GoString 

func (this *ListClustersRequest) GoString() string

func (*ListClustersRequest) Marshal 

func (m *ListClustersRequest) Marshal() (data []byte, err error)

func (*ListClustersRequest) MarshalTo 

func (m *ListClustersRequest) MarshalTo(data []byte) (int, error)

func (*ListClustersRequest) ProtoMessage 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) Reset 

func (m *ListClustersRequest) Reset()

func (*ListClustersRequest) Size 

func (m *ListClustersRequest) Size() (n int)

func (*ListClustersRequest) String 

func (this *ListClustersRequest) String() string

func (*ListClustersRequest) Unmarshal 

func (m *ListClustersRequest) Unmarshal(data []byte) error

type ListClustersRequest_Filters 

type ListClustersRequest_Filters struct {
	Names      []string          `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
	IDPrefixes []string          `protobuf:"bytes,2,rep,name=id_prefixes,json=idPrefixes" json:"id_prefixes,omitempty"`
	Labels     map[string]string `` /* 146-byte string literal not displayed */
	// NamePrefixes matches all objects with the given prefixes
	NamePrefixes []string `protobuf:"bytes,4,rep,name=name_prefixes,json=namePrefixes" json:"name_prefixes,omitempty"`
}

func (*ListClustersRequest_Filters) Copy 

func (m *ListClustersRequest_Filters) Copy() *ListClustersRequest_Filters

func (*ListClustersRequest_Filters) Descriptor 

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

func (*ListClustersRequest_Filters) GoString 

func (this *ListClustersRequest_Filters) GoString() string

func (*ListClustersRequest_Filters) Marshal 

func (m *ListClustersRequest_Filters) Marshal() (data []byte, err error)

func (*ListClustersRequest_Filters) MarshalTo 

func (m *ListClustersRequest_Filters) MarshalTo(data []byte) (int, error)

func (*ListClustersRequest_Filters) ProtoMessage 

func (*ListClustersRequest_Filters) ProtoMessage()

func (*ListClustersRequest_Filters) Reset 

func (m *ListClustersRequest_Filters) Reset()

func (*ListClustersRequest_Filters) Size 

func (m *ListClustersRequest_Filters) Size() (n int)

func (*ListClustersRequest_Filters) String 

func (this *ListClustersRequest_Filters) String() string

func (*ListClustersRequest_Filters) Unmarshal 

func (m *ListClustersRequest_Filters) Unmarshal(data []byte) error

type ListClustersResponse 

type ListClustersResponse struct {
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters" json:"clusters,omitempty"`
}

func (*ListClustersResponse) Copy 

func (m *ListClustersResponse) Copy() *ListClustersResponse

func (*ListClustersResponse) Descriptor 

func (*ListClustersResponse) Descriptor() ([]byte, []int)

func (*ListClustersResponse) GoString 

func (this *ListClustersResponse) GoString() string

func (*ListClustersResponse) Marshal 

func (m *ListClustersResponse) Marshal() (data []byte, err error)

func (*ListClustersResponse) MarshalTo 

func (m *ListClustersResponse) MarshalTo(data []byte) (int, error)

func (*ListClustersResponse) ProtoMessage 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) Reset 

func (m *ListClustersResponse) Reset()

func (*ListClustersResponse) Size 

func (m *ListClustersResponse) Size() (n int)

func (*ListClustersResponse) String 

func (this *ListClustersResponse) String() string

func (*ListClustersResponse) Unmarshal 

func (m *ListClustersResponse) Unmarshal(data []byte) error

type ListNetworksRequest 

type ListNetworksRequest struct {
	Filters *ListNetworksRequest_Filters `protobuf:"bytes,1,opt,name=filters" json:"filters,omitempty"`
}

func (*ListNetworksRequest) Copy 

func (m *ListNetworksRequest) Copy() *ListNetworksRequest

func (*ListNetworksRequest) Descriptor 

func (*ListNetworksRequest) Descriptor() ([]byte, []int)

func (*ListNetworksRequest) GoString 

func (this *ListNetworksRequest) GoString() string

func (*ListNetworksRequest) Marshal 

func (m *ListNetworksRequest) Marshal() (data []byte, err error)

func (*ListNetworksRequest) MarshalTo 

func (m *ListNetworksRequest) MarshalTo(data []byte) (int, error)

func (*ListNetworksRequest) ProtoMessage 

func (*ListNetworksRequest) ProtoMessage()

func (*ListNetworksRequest) Reset 

func (m *ListNetworksRequest) Reset()

func (*ListNetworksRequest) Size 

func (m *ListNetworksRequest) Size() (n int)

func (*ListNetworksRequest) String 

func (this *ListNetworksRequest) String() string

func (*ListNetworksRequest) Unmarshal 

func (m *ListNetworksRequest) Unmarshal(data []byte) error

type ListNetworksRequest_Filters 

type ListNetworksRequest_Filters struct {
	Names      []string          `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
	IDPrefixes []string          `protobuf:"bytes,2,rep,name=id_prefixes,json=idPrefixes" json:"id_prefixes,omitempty"`
	Labels     map[string]string `` /* 146-byte string literal not displayed */
	// NamePrefixes matches all objects with the given prefixes
	NamePrefixes []string `protobuf:"bytes,4,rep,name=name_prefixes,json=namePrefixes" json:"name_prefixes,omitempty"`
}

func (*ListNetworksRequest_Filters) Copy 

func (m *ListNetworksRequest_Filters) Copy() *ListNetworksRequest_Filters

func (*ListNetworksRequest_Filters) Descriptor 

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

func (*ListNetworksRequest_Filters) GoString 

func (this *ListNetworksRequest_Filters) GoString() string

func (*ListNetworksRequest_Filters) Marshal 

func (m *ListNetworksRequest_Filters) Marshal() (data []byte, err error)

func (*ListNetworksRequest_Filters) MarshalTo 

func (m *ListNetworksRequest_Filters) MarshalTo(data []byte) (int, error)

func (*ListNetworksRequest_Filters) ProtoMessage 

func (*ListNetworksRequest_Filters) ProtoMessage()

func (*ListNetworksRequest_Filters) Reset 

func (m *ListNetworksRequest_Filters) Reset()

func (*ListNetworksRequest_Filters) Size 

func (m *ListNetworksRequest_Filters) Size() (n int)

func (*ListNetworksRequest_Filters) String 

func (this *ListNetworksRequest_Filters) String() string

func (*ListNetworksRequest_Filters) Unmarshal 

func (m *ListNetworksRequest_Filters) Unmarshal(data []byte) error

type ListNetworksResponse 

type ListNetworksResponse struct {
	Networks []*Network `protobuf:"bytes,1,rep,name=networks" json:"networks,omitempty"`
}

func (*ListNetworksResponse) Copy 

func (m *ListNetworksResponse) Copy() *ListNetworksResponse

func (*ListNetworksResponse) Descriptor 

func (*ListNetworksResponse) Descriptor() ([]byte, []int)

func (*ListNetworksResponse) GoString 

func (this *ListNetworksResponse) GoString() string

func (*ListNetworksResponse) Marshal 

func (m *ListNetworksResponse) Marshal() (data []byte, err error)

func (*ListNetworksResponse) MarshalTo 

func (m *ListNetworksResponse) MarshalTo(data []byte) (int, error)

func (*ListNetworksResponse) ProtoMessage 

func (*ListNetworksResponse) ProtoMessage()

func (*ListNetworksResponse) Reset 

func (m *ListNetworksResponse) Reset()

func (*ListNetworksResponse) Size 

func (m *ListNetworksResponse) Size() (n int)

func (*ListNetworksResponse) String 

func (this *ListNetworksResponse) String() string

func (*ListNetworksResponse) Unmarshal 

func (m *ListNetworksResponse) Unmarshal(data []byte) error

type ListNodesRequest 

type ListNodesRequest struct {
	Filters *ListNodesRequest_Filters `protobuf:"bytes,1,opt,name=filters" json:"filters,omitempty"`
}

func (*ListNodesRequest) Copy 

func (m *ListNodesRequest) Copy() *ListNodesRequest

func (*ListNodesRequest) Descriptor 

func (*ListNodesRequest) Descriptor() ([]byte, []int)

func (*ListNodesRequest) GoString 

func (this *ListNodesRequest) GoString() string

func (*ListNodesRequest) Marshal 

func (m *ListNodesRequest) Marshal() (data []byte, err error)

func (*ListNodesRequest) MarshalTo 

func (m *ListNodesRequest) MarshalTo(data []byte) (int, error)

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) Reset 

func (m *ListNodesRequest) Reset()

func (*ListNodesRequest) Size 

func (m *ListNodesRequest) Size() (n int)

func (*ListNodesRequest) String 

func (this *ListNodesRequest) String() string

func (*ListNodesRequest) Unmarshal 

func (m *ListNodesRequest) Unmarshal(data []byte) error

type ListNodesRequest_Filters 

type ListNodesRequest_Filters struct {
	Names       []string              `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
	IDPrefixes  []string              `protobuf:"bytes,2,rep,name=id_prefixes,json=idPrefixes" json:"id_prefixes,omitempty"`
	Labels      map[string]string     `` /* 146-byte string literal not displayed */
	Memberships []NodeSpec_Membership `protobuf:"varint,4,rep,name=memberships,enum=docker.swarmkit.v1.NodeSpec_Membership" json:"memberships,omitempty"`
	Roles       []NodeRole            `protobuf:"varint,5,rep,name=roles,enum=docker.swarmkit.v1.NodeRole" json:"roles,omitempty"`
	// NamePrefixes matches all objects with the given prefixes
	NamePrefixes []string `protobuf:"bytes,6,rep,name=name_prefixes,json=namePrefixes" json:"name_prefixes,omitempty"`
}

func (*ListNodesRequest_Filters) Copy 

func (m *ListNodesRequest_Filters) Copy() *ListNodesRequest_Filters

func (*ListNodesRequest_Filters) Descriptor 

func (*ListNodesRequest_Filters) Descriptor() ([]byte, []int)

func (*ListNodesRequest_Filters) GoString 

func (this *ListNodesRequest_Filters) GoString() string

func (*ListNodesRequest_Filters) Marshal 

func (m *ListNodesRequest_Filters) Marshal() (data []byte, err error)

func (*ListNodesRequest_Filters) MarshalTo 

func (m *ListNodesRequest_Filters) MarshalTo(data []byte) (int, error)

func (*ListNodesRequest_Filters) ProtoMessage 

func (*ListNodesRequest_Filters) ProtoMessage()

func (*ListNodesRequest_Filters) Reset 

func (m *ListNodesRequest_Filters) Reset()

func (*ListNodesRequest_Filters) Size 

func (m *ListNodesRequest_Filters) Size() (n int)

func (*ListNodesRequest_Filters) String 

func (this *ListNodesRequest_Filters) String() string

func (*ListNodesRequest_Filters) Unmarshal 

func (m *ListNodesRequest_Filters) Unmarshal(data []byte) error

type ListNodesResponse 

type ListNodesResponse struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
}

func (*ListNodesResponse) Copy 

func (m *ListNodesResponse) Copy() *ListNodesResponse

func (*ListNodesResponse) Descriptor 

func (*ListNodesResponse) Descriptor() ([]byte, []int)

func (*ListNodesResponse) GoString 

func (this *ListNodesResponse) GoString() string

func (*ListNodesResponse) Marshal 

func (m *ListNodesResponse) Marshal() (data []byte, err error)

func (*ListNodesResponse) MarshalTo 

func (m *ListNodesResponse) MarshalTo(data []byte) (int, error)

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) Reset 

func (m *ListNodesResponse) Reset()

func (*ListNodesResponse) Size 

func (m *ListNodesResponse) Size() (n int)

func (*ListNodesResponse) String 

func (this *ListNodesResponse) String() string

func (*ListNodesResponse) Unmarshal 

func (m *ListNodesResponse) Unmarshal(data []byte) error

type ListServicesRequest 

type ListServicesRequest struct {
	Filters *ListServicesRequest_Filters `protobuf:"bytes,1,opt,name=filters" json:"filters,omitempty"`
}

func (*ListServicesRequest) Copy 

func (m *ListServicesRequest) Copy() *ListServicesRequest

func (*ListServicesRequest) Descriptor 

func (*ListServicesRequest) Descriptor() ([]byte, []int)

func (*ListServicesRequest) GoString 

func (this *ListServicesRequest) GoString() string

func (*ListServicesRequest) Marshal 

func (m *ListServicesRequest) Marshal() (data []byte, err error)

func (*ListServicesRequest) MarshalTo 

func (m *ListServicesRequest) MarshalTo(data []byte) (int, error)

func (*ListServicesRequest) ProtoMessage 

func (*ListServicesRequest) ProtoMessage()

func (*ListServicesRequest) Reset 

func (m *ListServicesRequest) Reset()

func (*ListServicesRequest) Size 

func (m *ListServicesRequest) Size() (n int)

func (*ListServicesRequest) String 

func (this *ListServicesRequest) String() string

func (*ListServicesRequest) Unmarshal 

func (m *ListServicesRequest) Unmarshal(data []byte) error

type ListServicesRequest_Filters 

type ListServicesRequest_Filters struct {
	Names      []string          `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
	IDPrefixes []string          `protobuf:"bytes,2,rep,name=id_prefixes,json=idPrefixes" json:"id_prefixes,omitempty"`
	Labels     map[string]string `` /* 146-byte string literal not displayed */
	// NamePrefixes matches all objects with the given prefixes
	NamePrefixes []string `protobuf:"bytes,4,rep,name=name_prefixes,json=namePrefixes" json:"name_prefixes,omitempty"`
}

func (*ListServicesRequest_Filters) Copy 

func (m *ListServicesRequest_Filters) Copy() *ListServicesRequest_Filters

func (*ListServicesRequest_Filters) Descriptor 

func (*ListServicesRequest_Filters) Descriptor() ([]byte, []int)

func (*ListServicesRequest_Filters) GoString 

func (this *ListServicesRequest_Filters) GoString() string

func (*ListServicesRequest_Filters) Marshal 

func (m *ListServicesRequest_Filters) Marshal() (data []byte, err error)

func (*ListServicesRequest_Filters) MarshalTo 

func (m *ListServicesRequest_Filters) MarshalTo(data []byte) (int, error)

func (*ListServicesRequest_Filters) ProtoMessage 

func (*ListServicesRequest_Filters) ProtoMessage()

func (*ListServicesRequest_Filters) Reset 

func (m *ListServicesRequest_Filters) Reset()

func (*ListServicesRequest_Filters) Size 

func (m *ListServicesRequest_Filters) Size() (n int)

func (*ListServicesRequest_Filters) String 

func (this *ListServicesRequest_Filters) String() string

func (*ListServicesRequest_Filters) Unmarshal 

func (m *ListServicesRequest_Filters) Unmarshal(data []byte) error

type ListServicesResponse 

type ListServicesResponse struct {
	Services []*Service `protobuf:"bytes,1,rep,name=services" json:"services,omitempty"`
}

func (*ListServicesResponse) Copy 

func (m *ListServicesResponse) Copy() *ListServicesResponse

func (*ListServicesResponse) Descriptor 

func (*ListServicesResponse) Descriptor() ([]byte, []int)

func (*ListServicesResponse) GoString 

func (this *ListServicesResponse) GoString() string

func (*ListServicesResponse) Marshal 

func (m *ListServicesResponse) Marshal() (data []byte, err error)

func (*ListServicesResponse) MarshalTo 

func (m *ListServicesResponse) MarshalTo(data []byte) (int, error)

func (*ListServicesResponse) ProtoMessage 

func (*ListServicesResponse) ProtoMessage()

func (*ListServicesResponse) Reset 

func (m *ListServicesResponse) Reset()

func (*ListServicesResponse) Size 

func (m *ListServicesResponse) Size() (n int)

func (*ListServicesResponse) String 

func (this *ListServicesResponse) String() string

func (*ListServicesResponse) Unmarshal 

func (m *ListServicesResponse) Unmarshal(data []byte) error

type ListTasksRequest 

type ListTasksRequest struct {
	Filters *ListTasksRequest_Filters `protobuf:"bytes,1,opt,name=filters" json:"filters,omitempty"`
}

func (*ListTasksRequest) Copy 

func (m *ListTasksRequest) Copy() *ListTasksRequest

func (*ListTasksRequest) Descriptor 

func (*ListTasksRequest) Descriptor() ([]byte, []int)

func (*ListTasksRequest) GoString 

func (this *ListTasksRequest) GoString() string

func (*ListTasksRequest) Marshal 

func (m *ListTasksRequest) Marshal() (data []byte, err error)

func (*ListTasksRequest) MarshalTo 

func (m *ListTasksRequest) MarshalTo(data []byte) (int, error)

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) Reset 

func (m *ListTasksRequest) Reset()

func (*ListTasksRequest) Size 

func (m *ListTasksRequest) Size() (n int)

func (*ListTasksRequest) String 

func (this *ListTasksRequest) String() string

func (*ListTasksRequest) Unmarshal 

func (m *ListTasksRequest) Unmarshal(data []byte) error

type ListTasksRequest_Filters 

type ListTasksRequest_Filters struct {
	Names         []string          `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
	IDPrefixes    []string          `protobuf:"bytes,2,rep,name=id_prefixes,json=idPrefixes" json:"id_prefixes,omitempty"`
	Labels        map[string]string `` /* 146-byte string literal not displayed */
	ServiceIDs    []string          `protobuf:"bytes,4,rep,name=service_ids,json=serviceIds" json:"service_ids,omitempty"`
	NodeIDs       []string          `protobuf:"bytes,5,rep,name=node_ids,json=nodeIds" json:"node_ids,omitempty"`
	DesiredStates []TaskState       `` /* 128-byte string literal not displayed */
	// NamePrefixes matches all objects with the given prefixes
	NamePrefixes []string `protobuf:"bytes,7,rep,name=name_prefixes,json=namePrefixes" json:"name_prefixes,omitempty"`
}

func (*ListTasksRequest_Filters) Copy 

func (m *ListTasksRequest_Filters) Copy() *ListTasksRequest_Filters

func (*ListTasksRequest_Filters) Descriptor 

func (*ListTasksRequest_Filters) Descriptor() ([]byte, []int)

func (*ListTasksRequest_Filters) GoString 

func (this *ListTasksRequest_Filters) GoString() string

func (*ListTasksRequest_Filters) Marshal 

func (m *ListTasksRequest_Filters) Marshal() (data []byte, err error)

func (*ListTasksRequest_Filters) MarshalTo 

func (m *ListTasksRequest_Filters) MarshalTo(data []byte) (int, error)

func (*ListTasksRequest_Filters) ProtoMessage 

func (*ListTasksRequest_Filters) ProtoMessage()

func (*ListTasksRequest_Filters) Reset 

func (m *ListTasksRequest_Filters) Reset()

func (*ListTasksRequest_Filters) Size 

func (m *ListTasksRequest_Filters) Size() (n int)

func (*ListTasksRequest_Filters) String 

func (this *ListTasksRequest_Filters) String() string

func (*ListTasksRequest_Filters) Unmarshal 

func (m *ListTasksRequest_Filters) Unmarshal(data []byte) error

type ListTasksResponse 

type ListTasksResponse struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
}

func (*ListTasksResponse) Copy 

func (m *ListTasksResponse) Copy() *ListTasksResponse

func (*ListTasksResponse) Descriptor 

func (*ListTasksResponse) Descriptor() ([]byte, []int)

func (*ListTasksResponse) GoString 

func (this *ListTasksResponse) GoString() string

func (*ListTasksResponse) Marshal 

func (m *ListTasksResponse) Marshal() (data []byte, err error)

func (*ListTasksResponse) MarshalTo 

func (m *ListTasksResponse) MarshalTo(data []byte) (int, error)

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) Reset 

func (m *ListTasksResponse) Reset()

func (*ListTasksResponse) Size 

func (m *ListTasksResponse) Size() (n int)

func (*ListTasksResponse) String 

func (this *ListTasksResponse) String() string

func (*ListTasksResponse) Unmarshal 

func (m *ListTasksResponse) Unmarshal(data []byte) error

type ManagerStatus 

type ManagerStatus struct {
	// RaftID specifies the internal ID used by the manager in a raft context, it can never be modified
	// and is used only for information purposes
	RaftID uint64 `protobuf:"varint,1,opt,name=raft_id,json=raftId,proto3" json:"raft_id,omitempty"`
	// Addr is the address advertised to raft.
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// Leader is set to true if this node is the raft leader.
	Leader bool `protobuf:"varint,3,opt,name=leader,proto3" json:"leader,omitempty"`
	// Reachability specifies whether this node is reachable.
	Reachability RaftMemberStatus_Reachability `` /* 132-byte string literal not displayed */
}

ManagerStatus provides informations about the state of a manager in the cluster.

func (*ManagerStatus) Copy 

func (m *ManagerStatus) Copy() *ManagerStatus

func (*ManagerStatus) Descriptor 

func (*ManagerStatus) Descriptor() ([]byte, []int)

func (*ManagerStatus) GoString 

func (this *ManagerStatus) GoString() string

func (*ManagerStatus) Marshal 

func (m *ManagerStatus) Marshal() (data []byte, err error)

func (*ManagerStatus) MarshalTo 

func (m *ManagerStatus) MarshalTo(data []byte) (int, error)

func (*ManagerStatus) ProtoMessage 

func (*ManagerStatus) ProtoMessage()

func (*ManagerStatus) Reset 

func (m *ManagerStatus) Reset()

func (*ManagerStatus) Size 

func (m *ManagerStatus) Size() (n int)

func (*ManagerStatus) String 

func (this *ManagerStatus) String() string

func (*ManagerStatus) Unmarshal 

func (m *ManagerStatus) Unmarshal(data []byte) error

type Meta 

type Meta struct {
	// Version tracks the current version of the object.
	Version Version `protobuf:"bytes,1,opt,name=version" json:"version"`
	// Object timestamps.
	CreatedAt *docker_swarmkit_v1.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
	UpdatedAt *docker_swarmkit_v1.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt" json:"updated_at,omitempty"`
}

Meta contains metadata about objects. Every object contains a meta field.

func (*Meta) Copy 

func (m *Meta) Copy() *Meta

func (*Meta) Descriptor 

func (*Meta) Descriptor() ([]byte, []int)

func (*Meta) GoString 

func (this *Meta) GoString() string

func (*Meta) Marshal 

func (m *Meta) Marshal() (data []byte, err error)

func (*Meta) MarshalTo 

func (m *Meta) MarshalTo(data []byte) (int, error)

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) Reset 

func (m *Meta) Reset()

func (*Meta) Size 

func (m *Meta) Size() (n int)

func (*Meta) String 

func (this *Meta) String() string

func (*Meta) Unmarshal 

func (m *Meta) Unmarshal(data []byte) error

type Mount 

type Mount struct {
	// Type defines the nature of the mount.
	Type Mount_MountType `protobuf:"varint,1,opt,name=type,proto3,enum=docker.swarmkit.v1.Mount_MountType" json:"type,omitempty"`
	// Source specifies the name of the mount. Depending on mount type, this
	// may be a volume name or a host path, or even ignored.
	Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// Target path in container
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// ReadOnly should be set to true if the mount should not be writable.
	ReadOnly bool `protobuf:"varint,4,opt,name=readonly,proto3" json:"readonly,omitempty"`
	// BindOptions configures properties of a bind mount type.
	//
	// For mounts of type bind, the source must be an absolute host path.
	BindOptions *Mount_BindOptions `protobuf:"bytes,5,opt,name=bind_options,json=bindOptions" json:"bind_options,omitempty"`
	// VolumeOptions configures the properties specific to a volume mount type.
	//
	// For mounts of type volume, the source will be used as the volume name.
	VolumeOptions *Mount_VolumeOptions `protobuf:"bytes,6,opt,name=volume_options,json=volumeOptions" json:"volume_options,omitempty"`
	// TmpfsOptions allows one to set options for mounting a temporary
	// filesystem.
	//
	// The source field will be ignored when using mounts of type tmpfs.
	TmpfsOptions *Mount_TmpfsOptions `protobuf:"bytes,7,opt,name=tmpfs_options,json=tmpfsOptions" json:"tmpfs_options,omitempty"`
}

Mount describes volume mounts for a container.

The Mount type follows the structure of the mount syscall, including a type, source, target. Top-level flags, such as writable, are common to all kinds of mounts, where we also provide options that are specific to a type of mount. This corresponds to flags and data, respectively, in the syscall.

func (*Mount) Copy 

func (m *Mount) Copy() *Mount

func (*Mount) Descriptor 

func (*Mount) Descriptor() ([]byte, []int)

func (*Mount) GoString 

func (this *Mount) GoString() string

func (*Mount) Marshal 

func (m *Mount) Marshal() (data []byte, err error)

func (*Mount) MarshalTo 

func (m *Mount) MarshalTo(data []byte) (int, error)

func (*Mount) ProtoMessage 

func (*Mount) ProtoMessage()

func (*Mount) Reset 

func (m *Mount) Reset()

func (*Mount) Size 

func (m *Mount) Size() (n int)

func (*Mount) String 

func (this *Mount) String() string

func (*Mount) Unmarshal 

func (m *Mount) Unmarshal(data []byte) error

type Mount_BindOptions 

type Mount_BindOptions struct {
	// Propagation mode of mount.
	Propagation Mount_BindOptions_MountPropagation `` /* 135-byte string literal not displayed */
}

BindOptions specifies options that are specific to a bind mount.

func (*Mount_BindOptions) Copy 

func (m *Mount_BindOptions) Copy() *Mount_BindOptions

func (*Mount_BindOptions) Descriptor 

func (*Mount_BindOptions) Descriptor() ([]byte, []int)

func (*Mount_BindOptions) GoString 

func (this *Mount_BindOptions) GoString() string

func (*Mount_BindOptions) Marshal 

func (m *Mount_BindOptions) Marshal() (data []byte, err error)

func (*Mount_BindOptions) MarshalTo 

func (m *Mount_BindOptions) MarshalTo(data []byte) (int, error)

func (*Mount_BindOptions) ProtoMessage 

func (*Mount_BindOptions) ProtoMessage()

func (*Mount_BindOptions) Reset 

func (m *Mount_BindOptions) Reset()

func (*Mount_BindOptions) Size 

func (m *Mount_BindOptions) Size() (n int)

func (*Mount_BindOptions) String 

func (this *Mount_BindOptions) String() string

func (*Mount_BindOptions) Unmarshal 

func (m *Mount_BindOptions) Unmarshal(data []byte) error

type Mount_BindOptions_MountPropagation 

type Mount_BindOptions_MountPropagation int32
const (
	MountPropagationRPrivate Mount_BindOptions_MountPropagation = 0
	MountPropagationPrivate  Mount_BindOptions_MountPropagation = 1
	MountPropagationRShared  Mount_BindOptions_MountPropagation = 2
	MountPropagationShared   Mount_BindOptions_MountPropagation = 3
	MountPropagationRSlave   Mount_BindOptions_MountPropagation = 4
	MountPropagationSlave    Mount_BindOptions_MountPropagation = 5
)

func (Mount_BindOptions_MountPropagation) EnumDescriptor 

func (Mount_BindOptions_MountPropagation) EnumDescriptor() ([]byte, []int)

func (Mount_BindOptions_MountPropagation) String 

func (x Mount_BindOptions_MountPropagation) String() string

type Mount_MountType 

type Mount_MountType int32
const (
	MountTypeBind   Mount_MountType = 0
	MountTypeVolume Mount_MountType = 1
	MountTypeTmpfs  Mount_MountType = 2
)

func (Mount_MountType) EnumDescriptor 

func (Mount_MountType) EnumDescriptor() ([]byte, []int)

func (Mount_MountType) String 

func (x Mount_MountType) String() string

type Mount_TmpfsOptions 

type Mount_TmpfsOptions struct {
	// Size sets the size of the tmpfs, in bytes.
	//
	// This will be converted to an operating system specific value
	// depending on the host. For example, on linux, it will be convered to
	// use a 'k', 'm' or 'g' syntax. BSD, though not widely supported with
	// docker, uses a straight byte value.
	//
	// Percentages are not supported.
	SizeBytes int64 `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// Mode of the tmpfs upon creation
	Mode os.FileMode `protobuf:"varint,2,opt,name=mode,proto3,customtype=os.FileMode" json:"mode"`
}

func (*Mount_TmpfsOptions) Copy 

func (m *Mount_TmpfsOptions) Copy() *Mount_TmpfsOptions

func (*Mount_TmpfsOptions) Descriptor 

func (*Mount_TmpfsOptions) Descriptor() ([]byte, []int)

func (*Mount_TmpfsOptions) GoString 

func (this *Mount_TmpfsOptions) GoString() string

func (*Mount_TmpfsOptions) Marshal 

func (m *Mount_TmpfsOptions) Marshal() (data []byte, err error)

func (*Mount_TmpfsOptions) MarshalTo 

func (m *Mount_TmpfsOptions) MarshalTo(data []byte) (int, error)

func (*Mount_TmpfsOptions) ProtoMessage 

func (*Mount_TmpfsOptions) ProtoMessage()

func (*Mount_TmpfsOptions) Reset 

func (m *Mount_TmpfsOptions) Reset()

func (*Mount_TmpfsOptions) Size 

func (m *Mount_TmpfsOptions) Size() (n int)

func (*Mount_TmpfsOptions) String 

func (this *Mount_TmpfsOptions) String() string

func (*Mount_TmpfsOptions) Unmarshal 

func (m *Mount_TmpfsOptions) Unmarshal(data []byte) error

type Mount_VolumeOptions 

type Mount_VolumeOptions struct {
	// nocopy prevents automatic copying of data to the volume with data from target
	NoCopy bool `protobuf:"varint,1,opt,name=nocopy,proto3" json:"nocopy,omitempty"`
	// labels to apply to the volume if creating
	Labels map[string]string `` /* 146-byte string literal not displayed */
	// DriverConfig specifies the options that may be passed to the driver
	// if the volume is created.
	//
	// If this is empty, no volume will be created if the volume is missing.
	DriverConfig *Driver `protobuf:"bytes,3,opt,name=driver_config,json=driverConfig" json:"driver_config,omitempty"`
}

VolumeOptions contains parameters for mounting the volume.

func (*Mount_VolumeOptions) Copy 

func (m *Mount_VolumeOptions) Copy() *Mount_VolumeOptions

func (*Mount_VolumeOptions) Descriptor 

func (*Mount_VolumeOptions) Descriptor() ([]byte, []int)

func (*Mount_VolumeOptions) GoString 

func (this *Mount_VolumeOptions) GoString() string

func (*Mount_VolumeOptions) Marshal 

func (m *Mount_VolumeOptions) Marshal() (data []byte, err error)

func (*Mount_VolumeOptions) MarshalTo 

func (m *Mount_VolumeOptions) MarshalTo(data []byte) (int, error)

func (*Mount_VolumeOptions) ProtoMessage 

func (*Mount_VolumeOptions) ProtoMessage()

func (*Mount_VolumeOptions) Reset 

func (m *Mount_VolumeOptions) Reset()

func (*Mount_VolumeOptions) Size 

func (m *Mount_VolumeOptions) Size() (n int)

func (*Mount_VolumeOptions) String 

func (this *Mount_VolumeOptions) String() string

func (*Mount_VolumeOptions) Unmarshal 

func (m *Mount_VolumeOptions) Unmarshal(data []byte) error

type Network 

type Network struct {
	ID   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta Meta        `protobuf:"bytes,2,opt,name=meta" json:"meta"`
	Spec NetworkSpec `protobuf:"bytes,3,opt,name=spec" json:"spec"`
	// Driver specific operational state provided by the network driver.
	DriverState *Driver `protobuf:"bytes,4,opt,name=driver_state,json=driverState" json:"driver_state,omitempty"`
	// Runtime state of IPAM options. This may not reflect the
	// ipam options from NetworkSpec.
	IPAM *IPAMOptions `protobuf:"bytes,5,opt,name=ipam" json:"ipam,omitempty"`
}

func (*Network) Copy 

func (m *Network) Copy() *Network

func (*Network) Descriptor 

func (*Network) Descriptor() ([]byte, []int)

func (*Network) GoString 

func (this *Network) GoString() string

func (*Network) Marshal 

func (m *Network) Marshal() (data []byte, err error)

func (*Network) MarshalTo 

func (m *Network) MarshalTo(data []byte) (int, error)

func (*Network) ProtoMessage 

func (*Network) ProtoMessage()

func (*Network) Reset 

func (m *Network) Reset()

func (*Network) Size 

func (m *Network) Size() (n int)

func (*Network) String 

func (this *Network) String() string

func (*Network) Unmarshal 

func (m *Network) Unmarshal(data []byte) error

type NetworkAttachment 

type NetworkAttachment struct {
	// Network state as a whole becomes part of the object so that
	// it always is available for use in agents so that agents
	// don't have any other dependency during execution.
	Network *Network `protobuf:"bytes,1,opt,name=network" json:"network,omitempty"`
	// List of IPv4/IPv6 addresses that are assigned to the object
	// as part of getting attached to this network.
	Addresses []string `protobuf:"bytes,2,rep,name=addresses" json:"addresses,omitempty"`
	// List of aliases by which a task is resolved in a network
	Aliases []string `protobuf:"bytes,3,rep,name=aliases" json:"aliases,omitempty"`
}

NetworkAttachment specifies the network parameters of attachment to a single network by an object such as task or node.

func (*NetworkAttachment) Copy 

func (m *NetworkAttachment) Copy() *NetworkAttachment

func (*NetworkAttachment) Descriptor 

func (*NetworkAttachment) Descriptor() ([]byte, []int)

func (*NetworkAttachment) GoString 

func (this *NetworkAttachment) GoString() string

func (*NetworkAttachment) Marshal 

func (m *NetworkAttachment) Marshal() (data []byte, err error)

func (*NetworkAttachment) MarshalTo 

func (m *NetworkAttachment) MarshalTo(data []byte) (int, error)

func (*NetworkAttachment) ProtoMessage 

func (*NetworkAttachment) ProtoMessage()

func (*NetworkAttachment) Reset 

func (m *NetworkAttachment) Reset()

func (*NetworkAttachment) Size 

func (m *NetworkAttachment) Size() (n int)

func (*NetworkAttachment) String 

func (this *NetworkAttachment) String() string

func (*NetworkAttachment) Unmarshal 

func (m *NetworkAttachment) Unmarshal(data []byte) error

type NetworkSpec 

type NetworkSpec struct {
	Annotations Annotations `protobuf:"bytes,1,opt,name=annotations" json:"annotations"`
	// DriverConfig specific configuration consumed by the network driver.
	DriverConfig *Driver `protobuf:"bytes,2,opt,name=driver_config,json=driverConfig" json:"driver_config,omitempty"`
	// IPv6Enabled enables support for IPv6 on the network.
	Ipv6Enabled bool `protobuf:"varint,3,opt,name=ipv6_enabled,json=ipv6Enabled,proto3" json:"ipv6_enabled,omitempty"`
	// internal restricts external access to the network. This may be
	// accomplished by disabling the default gateway or through other means.
	Internal bool         `protobuf:"varint,4,opt,name=internal,proto3" json:"internal,omitempty"`
	IPAM     *IPAMOptions `protobuf:"bytes,5,opt,name=ipam" json:"ipam,omitempty"`
}

NetworkSpec specifies user defined network parameters.

func (*NetworkSpec) Copy 

func (m *NetworkSpec) Copy() *NetworkSpec

func (*NetworkSpec) Descriptor 

func (*NetworkSpec) Descriptor() ([]byte, []int)

func (*NetworkSpec) GoString 

func (this *NetworkSpec) GoString() string

func (*NetworkSpec) Marshal 

func (m *NetworkSpec) Marshal() (data []byte, err error)

func (*NetworkSpec) MarshalTo 

func (m *NetworkSpec) MarshalTo(data []byte) (int, error)

func (*NetworkSpec) ProtoMessage 

func (*NetworkSpec) ProtoMessage()

func (*NetworkSpec) Reset 

func (m *NetworkSpec) Reset()

func (*NetworkSpec) Size 

func (m *NetworkSpec) Size() (n int)

func (*NetworkSpec) String 

func (this *NetworkSpec) String() string

func (*NetworkSpec) Unmarshal 

func (m *NetworkSpec) Unmarshal(data []byte) error

type Node 

type Node struct {
	// ID specifies the identity of the node.
	ID   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta Meta   `protobuf:"bytes,2,opt,name=meta" json:"meta"`
	// Spec defines the desired state of the node as specified by the user.
	// The system will honor this and will *never* modify it.
	Spec NodeSpec `protobuf:"bytes,3,opt,name=spec" json:"spec"`
	// Description encapsulated the properties of the Node as reported by the
	// agent.
	Description *NodeDescription `protobuf:"bytes,4,opt,name=description" json:"description,omitempty"`
	// Status provides the current status of the node, as seen by the manager.
	Status NodeStatus `protobuf:"bytes,5,opt,name=status" json:"status"`
	// ManagerStatus provides the current status of the node's manager
	// component, if the node is a manager.
	ManagerStatus *ManagerStatus `protobuf:"bytes,6,opt,name=manager_status,json=managerStatus" json:"manager_status,omitempty"`
	// The node attachment to the ingress network.
	Attachment *NetworkAttachment `protobuf:"bytes,7,opt,name=attachment" json:"attachment,omitempty"`
	// Certificate is the TLS certificate issued for the node, if any.
	Certificate Certificate `protobuf:"bytes,8,opt,name=certificate" json:"certificate"`
}

Node provides the internal node state as seen by the cluster.

func (*Node) Copy 

func (m *Node) Copy() *Node

func (*Node) Descriptor 

func (*Node) Descriptor() ([]byte, []int)

func (*Node) GoString 

func (this *Node) GoString() string

func (*Node) Marshal 

func (m *Node) Marshal() (data []byte, err error)

func (*Node) MarshalTo 

func (m *Node) MarshalTo(data []byte) (int, error)

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

func (m *Node) Size() (n int)

func (*Node) String 

func (this *Node) String() string

func (*Node) Unmarshal 

func (m *Node) Unmarshal(data []byte) error

type NodeCAClient 

type NodeCAClient interface {
	IssueNodeCertificate(ctx context.Context, in *IssueNodeCertificateRequest, opts ...grpc.CallOption) (*IssueNodeCertificateResponse, error)
	NodeCertificateStatus(ctx context.Context, in *NodeCertificateStatusRequest, opts ...grpc.CallOption) (*NodeCertificateStatusResponse, error)
}

func NewNodeCAClient 

func NewNodeCAClient(cc *grpc.ClientConn) NodeCAClient

type NodeCAServer 

type NodeCAServer interface {
	IssueNodeCertificate(context.Context, *IssueNodeCertificateRequest) (*IssueNodeCertificateResponse, error)
	NodeCertificateStatus(context.Context, *NodeCertificateStatusRequest) (*NodeCertificateStatusResponse, error)
}

func NewAuthenticatedWrapperNodeCAServer 

func NewAuthenticatedWrapperNodeCAServer(local NodeCAServer, authorize func(context.Context, []string) error) NodeCAServer

func NewRaftProxyNodeCAServer 

func NewRaftProxyNodeCAServer(local NodeCAServer, connSelector *raftpicker.ConnSelector, cluster raftpicker.RaftCluster, ctxMod func(context.Context) (context.Context, error)) NodeCAServer

type NodeCertificateStatusRequest 

type NodeCertificateStatusRequest struct {
	NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*NodeCertificateStatusRequest) Copy 

func (m *NodeCertificateStatusRequest) Copy() *NodeCertificateStatusRequest

func (*NodeCertificateStatusRequest) Descriptor 

func (*NodeCertificateStatusRequest) Descriptor() ([]byte, []int)

func (*NodeCertificateStatusRequest) GoString 

func (this *NodeCertificateStatusRequest) GoString() string

func (*NodeCertificateStatusRequest) Marshal 

func (m *NodeCertificateStatusRequest) Marshal() (data []byte, err error)

func (*NodeCertificateStatusRequest) MarshalTo 

func (m *NodeCertificateStatusRequest) MarshalTo(data []byte) (int, error)

func (*NodeCertificateStatusRequest) ProtoMessage 

func (*NodeCertificateStatusRequest) ProtoMessage()

func (*NodeCertificateStatusRequest) Reset 

func (m *NodeCertificateStatusRequest) Reset()

func (*NodeCertificateStatusRequest) Size 

func (m *NodeCertificateStatusRequest) Size() (n int)

func (*NodeCertificateStatusRequest) String 

func (this *NodeCertificateStatusRequest) String() string

func (*NodeCertificateStatusRequest) Unmarshal 

func (m *NodeCertificateStatusRequest) Unmarshal(data []byte) error

type NodeCertificateStatusResponse 

type NodeCertificateStatusResponse struct {
	Status      *IssuanceStatus `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
	Certificate *Certificate    `protobuf:"bytes,2,opt,name=certificate" json:"certificate,omitempty"`
}

func (*NodeCertificateStatusResponse) Copy 

func (m *NodeCertificateStatusResponse) Copy() *NodeCertificateStatusResponse

func (*NodeCertificateStatusResponse) Descriptor 

func (*NodeCertificateStatusResponse) Descriptor() ([]byte, []int)

func (*NodeCertificateStatusResponse) GoString 

func (this *NodeCertificateStatusResponse) GoString() string

func (*NodeCertificateStatusResponse) Marshal 

func (m *NodeCertificateStatusResponse) Marshal() (data []byte, err error)

func (*NodeCertificateStatusResponse) MarshalTo 

func (m *NodeCertificateStatusResponse) MarshalTo(data []byte) (int, error)

func (*NodeCertificateStatusResponse) ProtoMessage 

func (*NodeCertificateStatusResponse) ProtoMessage()

func (*NodeCertificateStatusResponse) Reset 

func (m *NodeCertificateStatusResponse) Reset()

func (*NodeCertificateStatusResponse) Size 

func (m *NodeCertificateStatusResponse) Size() (n int)

func (*NodeCertificateStatusResponse) String 

func (this *NodeCertificateStatusResponse) String() string

func (*NodeCertificateStatusResponse) Unmarshal 

func (m *NodeCertificateStatusResponse) Unmarshal(data []byte) error

type NodeDescription 

type NodeDescription struct {
	// Hostname of the node as reported by the agent.
	// This is different from spec.meta.name which is user-defined.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Platform of the node.
	Platform *Platform `protobuf:"bytes,2,opt,name=platform" json:"platform,omitempty"`
	// Total resources on the node.
	Resources *Resources `protobuf:"bytes,3,opt,name=resources" json:"resources,omitempty"`
	// Information about the Docker Engine on the node.
	Engine *EngineDescription `protobuf:"bytes,4,opt,name=engine" json:"engine,omitempty"`
}

func (*NodeDescription) Copy 

func (m *NodeDescription) Copy() *NodeDescription

func (*NodeDescription) Descriptor 

func (*NodeDescription) Descriptor() ([]byte, []int)

func (*NodeDescription) GoString 

func (this *NodeDescription) GoString() string

func (*NodeDescription) Marshal 

func (m *NodeDescription) Marshal() (data []byte, err error)

func (*NodeDescription) MarshalTo 

func (m *NodeDescription) MarshalTo(data []byte) (int, error)

func (*NodeDescription) ProtoMessage 

func (*NodeDescription) ProtoMessage()

func (*NodeDescription) Reset 

func (m *NodeDescription) Reset()

func (*NodeDescription) Size 

func (m *NodeDescription) Size() (n int)

func (*NodeDescription) String 

func (this *NodeDescription) String() string

func (*NodeDescription) Unmarshal 

func (m *NodeDescription) Unmarshal(data []byte) error

type NodeRole 

type NodeRole int32
const (
	NodeRoleWorker  NodeRole = 0
	NodeRoleManager NodeRole = 1
)

func (NodeRole) EnumDescriptor 

func (NodeRole) EnumDescriptor() ([]byte, []int)

func (NodeRole) String 

func (x NodeRole) String() string

type NodeSpec 

type NodeSpec struct {
	Annotations Annotations `protobuf:"bytes,1,opt,name=annotations" json:"annotations"`
	// Role defines the role the node should have.
	Role NodeRole `protobuf:"varint,2,opt,name=role,proto3,enum=docker.swarmkit.v1.NodeRole" json:"role,omitempty"`
	// Membership controls the admission of the node into the cluster.
	Membership NodeSpec_Membership `protobuf:"varint,3,opt,name=membership,proto3,enum=docker.swarmkit.v1.NodeSpec_Membership" json:"membership,omitempty"`
	// Availability allows a user to control the current scheduling status of a
	// node.
	Availability NodeSpec_Availability `protobuf:"varint,4,opt,name=availability,proto3,enum=docker.swarmkit.v1.NodeSpec_Availability" json:"availability,omitempty"`
}

func (*NodeSpec) Copy 

func (m *NodeSpec) Copy() *NodeSpec

func (*NodeSpec) Descriptor 

func (*NodeSpec) Descriptor() ([]byte, []int)

func (*NodeSpec) GoString 

func (this *NodeSpec) GoString() string

func (*NodeSpec) Marshal 

func (m *NodeSpec) Marshal() (data []byte, err error)

func (*NodeSpec) MarshalTo 

func (m *NodeSpec) MarshalTo(data []byte) (int, error)

func (*NodeSpec) ProtoMessage 

func (*NodeSpec) ProtoMessage()

func (*NodeSpec) Reset 

func (m *NodeSpec) Reset()

func (*NodeSpec) Size 

func (m *NodeSpec) Size() (n int)

func (*NodeSpec) String 

func (this *NodeSpec) String() string

func (*NodeSpec) Unmarshal 

func (m *NodeSpec) Unmarshal(data []byte) error

type NodeSpec_Availability 

type NodeSpec_Availability int32
const (
	// Active nodes.
	NodeAvailabilityActive NodeSpec_Availability = 0
	// Paused nodes won't be considered by the scheduler, preventing any
	// further task to run on them.
	NodeAvailabilityPause NodeSpec_Availability = 1
	// Drained nodes are paused and any task already running on them will
	// be evicted.
	NodeAvailabilityDrain NodeSpec_Availability = 2
)

func (NodeSpec_Availability) EnumDescriptor 

func (NodeSpec_Availability) EnumDescriptor() ([]byte, []int)

func (NodeSpec_Availability) String 

func (x NodeSpec_Availability) String() string

type NodeSpec_Membership 

type NodeSpec_Membership int32
const (
	NodeMembershipPending  NodeSpec_Membership = 0
	NodeMembershipAccepted NodeSpec_Membership = 1
)

func (NodeSpec_Membership) EnumDescriptor 

func (NodeSpec_Membership) EnumDescriptor() ([]byte, []int)

func (NodeSpec_Membership) String 

func (x NodeSpec_Membership) String() string

type NodeStatus 

type NodeStatus struct {
	State   NodeStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=docker.swarmkit.v1.NodeStatus_State" json:"state,omitempty"`
	Message string           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*NodeStatus) Copy 

func (m *NodeStatus) Copy() *NodeStatus

func (*NodeStatus) Descriptor 

func (*NodeStatus) Descriptor() ([]byte, []int)

func (*NodeStatus) GoString 

func (this *NodeStatus) GoString() string

func (*NodeStatus) Marshal 

func (m *NodeStatus) Marshal() (data []byte, err error)

func (*NodeStatus) MarshalTo 

func (m *NodeStatus) MarshalTo(data []byte) (int, error)

func (*NodeStatus) ProtoMessage 

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) Reset 

func (m *NodeStatus) Reset()

func (*NodeStatus) Size 

func (m *NodeStatus) Size() (n int)

func (*NodeStatus) String 

func (this *NodeStatus) String() string

func (*NodeStatus) Unmarshal 

func (m *NodeStatus) Unmarshal(data []byte) error

type NodeStatus_State 

type NodeStatus_State int32

TODO(aluzzardi) These should be using `gogoproto.enumvalue_customname`. 

const (
	// Unknown indicates the node state cannot be resolved.
	NodeStatus_UNKNOWN NodeStatus_State = 0
	// Down indicates the node is down.
	NodeStatus_DOWN NodeStatus_State = 1
	// Ready indicates the node is ready to accept tasks.
	NodeStatus_READY NodeStatus_State = 2
	// Disconnected indicates the node is currently trying to find new manager.
	NodeStatus_DISCONNECTED NodeStatus_State = 3
)

func (NodeStatus_State) EnumDescriptor 

func (NodeStatus_State) EnumDescriptor() ([]byte, []int)

func (NodeStatus_State) String 

func (x NodeStatus_State) String() string

type OrchestrationConfig 

type OrchestrationConfig struct {
	// TaskHistoryRetentionLimit is the number of historic tasks to keep per instance or
	// node. If negative, never remove completed or failed tasks.
	TaskHistoryRetentionLimit int64 `` /* 141-byte string literal not displayed */
}

OrchestrationConfig defines cluster-level orchestration settings.

func (*OrchestrationConfig) Copy 

func (m *OrchestrationConfig) Copy() *OrchestrationConfig

func (*OrchestrationConfig) Descriptor 

func (*OrchestrationConfig) Descriptor() ([]byte, []int)

func (*OrchestrationConfig) GoString 

func (this *OrchestrationConfig) GoString() string

func (*OrchestrationConfig) Marshal 

func (m *OrchestrationConfig) Marshal() (data []byte, err error)

func (*OrchestrationConfig) MarshalTo 

func (m *OrchestrationConfig) MarshalTo(data []byte) (int, error)

func (*OrchestrationConfig) ProtoMessage 

func (*OrchestrationConfig) ProtoMessage()

func (*OrchestrationConfig) Reset 

func (m *OrchestrationConfig) Reset()

func (*OrchestrationConfig) Size 

func (m *OrchestrationConfig) Size() (n int)

func (*OrchestrationConfig) String 

func (this *OrchestrationConfig) String() string

func (*OrchestrationConfig) Unmarshal 

func (m *OrchestrationConfig) Unmarshal(data []byte) error

type Peer 

type Peer struct {
	NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Addr   string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
}

Peer should be used anywhere where we are describing a remote peer.

func (*Peer) Copy 

func (m *Peer) Copy() *Peer

func (*Peer) Descriptor 

func (*Peer) Descriptor() ([]byte, []int)

func (*Peer) GoString 

func (this *Peer) GoString() string

func (*Peer) Marshal 

func (m *Peer) Marshal() (data []byte, err error)

func (*Peer) MarshalTo 

func (m *Peer) MarshalTo(data []byte) (int, error)

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) Reset 

func (m *Peer) Reset()

func (*Peer) Size 

func (m *Peer) Size() (n int)

func (*Peer) String 

func (this *Peer) String() string

func (*Peer) Unmarshal 

func (m *Peer) Unmarshal(data []byte) error

type Placement 

type Placement struct {
	// constraints specifies a set of requirements a node should meet for a task.
	Constraints []string `protobuf:"bytes,1,rep,name=constraints" json:"constraints,omitempty"`
}

Placement specifies task distribution constraints.

func (*Placement) Copy 

func (m *Placement) Copy() *Placement

func (*Placement) Descriptor 

func (*Placement) Descriptor() ([]byte, []int)

func (*Placement) GoString 

func (this *Placement) GoString() string

func (*Placement) Marshal 

func (m *Placement) Marshal() (data []byte, err error)

func (*Placement) MarshalTo 

func (m *Placement) MarshalTo(data []byte) (int, error)

func (*Placement) ProtoMessage 

func (*Placement) ProtoMessage()

func (*Placement) Reset 

func (m *Placement) Reset()

func (*Placement) Size 

func (m *Placement) Size() (n int)

func (*Placement) String 

func (this *Placement) String() string

func (*Placement) Unmarshal 

func (m *Placement) Unmarshal(data []byte) error

type Platform 

type Platform struct {
	// Architecture (e.g. x86_64)
	Architecture string `protobuf:"bytes,1,opt,name=architecture,proto3" json:"architecture,omitempty"`
	// Operating System (e.g. linux)
	OS string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
}

func (*Platform) Copy 

func (m *Platform) Copy() *Platform

func (*Platform) Descriptor 

func (*Platform) Descriptor() ([]byte, []int)

func (*Platform) GoString 

func (this *Platform) GoString() string

func (*Platform) Marshal 

func (m *Platform) Marshal() (data []byte, err error)

func (*Platform) MarshalTo 

func (m *Platform) MarshalTo(data []byte) (int, error)

func (*Platform) ProtoMessage 

func (*Platform) ProtoMessage()

func (*Platform) Reset 

func (m *Platform) Reset()

func (*Platform) Size 

func (m *Platform) Size() (n int)

func (*Platform) String 

func (this *Platform) String() string

func (*Platform) Unmarshal 

func (m *Platform) Unmarshal(data []byte) error

type PluginDescription 

type PluginDescription struct {
	// Type of plugin. Canonical values for existing types are
	// Volume, Network, and Authorization. More types could be
	// supported in the future.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Name of the plugin
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

PluginDescription describes an engine plugin.

func (*PluginDescription) Copy 

func (m *PluginDescription) Copy() *PluginDescription

func (*PluginDescription) Descriptor 

func (*PluginDescription) Descriptor() ([]byte, []int)

func (*PluginDescription) GoString 

func (this *PluginDescription) GoString() string

func (*PluginDescription) Marshal 

func (m *PluginDescription) Marshal() (data []byte, err error)

func (*PluginDescription) MarshalTo 

func (m *PluginDescription) MarshalTo(data []byte) (int, error)

func (*PluginDescription) ProtoMessage 

func (*PluginDescription) ProtoMessage()

func (*PluginDescription) Reset 

func (m *PluginDescription) Reset()

func (*PluginDescription) Size 

func (m *PluginDescription) Size() (n int)

func (*PluginDescription) String 

func (this *PluginDescription) String() string

func (*PluginDescription) Unmarshal 

func (m *PluginDescription) Unmarshal(data []byte) error

type PortConfig 

type PortConfig struct {
	// Name for the port. If provided the port information can
	// be queried using the name as in a DNS SRV query.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Protocol for the port which is exposed.
	Protocol PortConfig_Protocol `protobuf:"varint,2,opt,name=protocol,proto3,enum=docker.swarmkit.v1.PortConfig_Protocol" json:"protocol,omitempty"`
	// The port which the application is exposing and is bound to.
	TargetPort uint32 `protobuf:"varint,3,opt,name=target_port,json=targetPort,proto3" json:"target_port,omitempty"`
	// PublishedPort specifies the port on which the service is
	// exposed. If specified, the port must be
	// within the available range. If not specified, an available
	// port is automatically assigned.
	PublishedPort uint32 `protobuf:"varint,4,opt,name=published_port,json=publishedPort,proto3" json:"published_port,omitempty"`
}

PortConfig specifies an exposed port which can be addressed using the given name. This can be later queried using a service discovery api or a DNS SRV query. The node port specifies a port that can be used to address this service external to the cluster by sending a connection request to this port to any node on the cluster.

func (*PortConfig) Copy 

func (m *PortConfig) Copy() *PortConfig

func (*PortConfig) Descriptor 

func (*PortConfig) Descriptor() ([]byte, []int)

func (*PortConfig) GoString 

func (this *PortConfig) GoString() string

func (*PortConfig) Marshal 

func (m *PortConfig) Marshal() (data []byte, err error)

func (*PortConfig) MarshalTo 

func (m *PortConfig) MarshalTo(data []byte) (int, error)

func (*PortConfig) ProtoMessage 

func (*PortConfig) ProtoMessage()

func (*PortConfig) Reset 

func (m *PortConfig) Reset()

func (*PortConfig) Size 

func (m *PortConfig) Size() (n int)

func (*PortConfig) String 

func (this *PortConfig) String() string

func (*PortConfig) Unmarshal 

func (m *PortConfig) Unmarshal(data []byte) error

type PortConfig_Protocol 

type PortConfig_Protocol int32
const (
	ProtocolTCP PortConfig_Protocol = 0
	ProtocolUDP PortConfig_Protocol = 1
)

func (PortConfig_Protocol) EnumDescriptor 

func (PortConfig_Protocol) EnumDescriptor() ([]byte, []int)

func (PortConfig_Protocol) String 

func (x PortConfig_Protocol) String() string

type ProcessRaftMessageRequest 

type ProcessRaftMessageRequest struct {
	Message *raftpb.Message `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}

func (*ProcessRaftMessageRequest) Descriptor 

func (*ProcessRaftMessageRequest) Descriptor() ([]byte, []int)

func (*ProcessRaftMessageRequest) GoString 

func (this *ProcessRaftMessageRequest) GoString() string

func (*ProcessRaftMessageRequest) Marshal 

func (m *ProcessRaftMessageRequest) Marshal() (data []byte, err error)

func (*ProcessRaftMessageRequest) MarshalTo 

func (m *ProcessRaftMessageRequest) MarshalTo(data []byte) (int, error)

func (*ProcessRaftMessageRequest) ProtoMessage 

func (*ProcessRaftMessageRequest) ProtoMessage()

func (*ProcessRaftMessageRequest) Reset 

func (m *ProcessRaftMessageRequest) Reset()

func (*ProcessRaftMessageRequest) Size 

func (m *ProcessRaftMessageRequest) Size() (n int)

func (*ProcessRaftMessageRequest) String 

func (this *ProcessRaftMessageRequest) String() string

func (*ProcessRaftMessageRequest) Unmarshal 

func (m *ProcessRaftMessageRequest) Unmarshal(data []byte) error

type ProcessRaftMessageResponse 

type ProcessRaftMessageResponse struct {
}

func (*ProcessRaftMessageResponse) Copy 

func (m *ProcessRaftMessageResponse) Copy() *ProcessRaftMessageResponse

func (*ProcessRaftMessageResponse) Descriptor 

func (*ProcessRaftMessageResponse) Descriptor() ([]byte, []int)

func (*ProcessRaftMessageResponse) GoString 

func (this *ProcessRaftMessageResponse) GoString() string

func (*ProcessRaftMessageResponse) Marshal 

func (m *ProcessRaftMessageResponse) Marshal() (data []byte, err error)

func (*ProcessRaftMessageResponse) MarshalTo 

func (m *ProcessRaftMessageResponse) MarshalTo(data []byte) (int, error)

func (*ProcessRaftMessageResponse) ProtoMessage 

func (*ProcessRaftMessageResponse) ProtoMessage()

func (*ProcessRaftMessageResponse) Reset 

func (m *ProcessRaftMessageResponse) Reset()

func (*ProcessRaftMessageResponse) Size 

func (m *ProcessRaftMessageResponse) Size() (n int)

func (*ProcessRaftMessageResponse) String 

func (this *ProcessRaftMessageResponse) String() string

func (*ProcessRaftMessageResponse) Unmarshal 

func (m *ProcessRaftMessageResponse) Unmarshal(data []byte) error

type RaftClient 

type RaftClient interface {
	// ProcessRaftMessage sends a raft message to be processed on a raft member, it is
	// called from the RaftMember willing to send a message to its destination ('To' field)
	ProcessRaftMessage(ctx context.Context, in *ProcessRaftMessageRequest, opts ...grpc.CallOption) (*ProcessRaftMessageResponse, error)
	// ResolveAddress returns the address where the node with the given ID can be reached.
	ResolveAddress(ctx context.Context, in *ResolveAddressRequest, opts ...grpc.CallOption) (*ResolveAddressResponse, error)
}

func NewRaftClient 

func NewRaftClient(cc *grpc.ClientConn) RaftClient

type RaftConfig 

type RaftConfig struct {
	// SnapshotInterval is the number of log entries between snapshots.
	SnapshotInterval uint64 `protobuf:"varint,1,opt,name=snapshot_interval,json=snapshotInterval,proto3" json:"snapshot_interval,omitempty"`
	// KeepOldSnapshots is the number of snapshots to keep beyond the
	// current snapshot.
	KeepOldSnapshots uint64 `protobuf:"varint,2,opt,name=keep_old_snapshots,json=keepOldSnapshots,proto3" json:"keep_old_snapshots,omitempty"`
	// LogEntriesForSlowFollowers is the number of log entries to keep
	// around to sync up slow followers after a snapshot is created.
	LogEntriesForSlowFollowers uint64 `` /* 146-byte string literal not displayed */
	// HeartbeatTick defines the amount of ticks (in seconds) between
	// each heartbeat message sent to other members for health-check.
	HeartbeatTick uint32 `protobuf:"varint,4,opt,name=heartbeat_tick,json=heartbeatTick,proto3" json:"heartbeat_tick,omitempty"`
	// ElectionTick defines the amount of ticks (in seconds) needed
	// without a leader to trigger a new election.
	ElectionTick uint32 `protobuf:"varint,5,opt,name=election_tick,json=electionTick,proto3" json:"election_tick,omitempty"`
}

RaftConfig defines raft settings for the cluster.

func (*RaftConfig) Copy 

func (m *RaftConfig) Copy() *RaftConfig

func (*RaftConfig) Descriptor 

func (*RaftConfig) Descriptor() ([]byte, []int)

func (*RaftConfig) GoString 

func (this *RaftConfig) GoString() string

func (*RaftConfig) Marshal 

func (m *RaftConfig) Marshal() (data []byte, err error)

func (*RaftConfig) MarshalTo 

func (m *RaftConfig) MarshalTo(data []byte) (int, error)

func (*RaftConfig) ProtoMessage 

func (*RaftConfig) ProtoMessage()

func (*RaftConfig) Reset 

func (m *RaftConfig) Reset()

func (*RaftConfig) Size 

func (m *RaftConfig) Size() (n int)

func (*RaftConfig) String 

func (this *RaftConfig) String() string

func (*RaftConfig) Unmarshal 

func (m *RaftConfig) Unmarshal(data []byte) error

type RaftMember 

type RaftMember struct {
	// RaftID specifies the internal ID used by the manager in a raft context, it can never be modified
	// and is used only for information purposes
	RaftID uint64 `protobuf:"varint,1,opt,name=raft_id,json=raftId,proto3" json:"raft_id,omitempty"`
	// NodeID is the node's ID.
	NodeID string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Addr specifies the address of the member
	Addr string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	// Status provides the current status of the manager from the perspective of another manager.
	Status RaftMemberStatus `protobuf:"bytes,4,opt,name=status" json:"status"`
}

func (*RaftMember) Copy 

func (m *RaftMember) Copy() *RaftMember

func (*RaftMember) Descriptor 

func (*RaftMember) Descriptor() ([]byte, []int)

func (*RaftMember) GoString 

func (this *RaftMember) GoString() string

func (*RaftMember) Marshal 

func (m *RaftMember) Marshal() (data []byte, err error)

func (*RaftMember) MarshalTo 

func (m *RaftMember) MarshalTo(data []byte) (int, error)

func (*RaftMember) ProtoMessage 

func (*RaftMember) ProtoMessage()

func (*RaftMember) Reset 

func (m *RaftMember) Reset()

func (*RaftMember) Size 

func (m *RaftMember) Size() (n int)

func (*RaftMember) String 

func (this *RaftMember) String() string

func (*RaftMember) Unmarshal 

func (m *RaftMember) Unmarshal(data []byte) error

type RaftMemberStatus 

type RaftMemberStatus struct {
	Leader       bool                          `protobuf:"varint,1,opt,name=leader,proto3" json:"leader,omitempty"`
	Reachability RaftMemberStatus_Reachability `` /* 132-byte string literal not displayed */
	Message      string                        `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
}

func (*RaftMemberStatus) Copy 

func (m *RaftMemberStatus) Copy() *RaftMemberStatus

func (*RaftMemberStatus) Descriptor 

func (*RaftMemberStatus) Descriptor() ([]byte, []int)

func (*RaftMemberStatus) GoString 

func (this *RaftMemberStatus) GoString() string

func (*RaftMemberStatus) Marshal 

func (m *RaftMemberStatus) Marshal() (data []byte, err error)

func (*RaftMemberStatus) MarshalTo 

func (m *RaftMemberStatus) MarshalTo(data []byte) (int, error)

func (*RaftMemberStatus) ProtoMessage 

func (*RaftMemberStatus) ProtoMessage()

func (*RaftMemberStatus) Reset 

func (m *RaftMemberStatus) Reset()

func (*RaftMemberStatus) Size 

func (m *RaftMemberStatus) Size() (n int)

func (*RaftMemberStatus) String 

func (this *RaftMemberStatus) String() string

func (*RaftMemberStatus) Unmarshal 

func (m *RaftMemberStatus) Unmarshal(data []byte) error

type RaftMemberStatus_Reachability 

type RaftMemberStatus_Reachability int32
const (
	// Unknown indicates that the manager state cannot be resolved
	RaftMemberStatus_UNKNOWN RaftMemberStatus_Reachability = 0
	// Unreachable indicates that the node cannot be contacted by other
	// raft cluster members.
	RaftMemberStatus_UNREACHABLE RaftMemberStatus_Reachability = 1
	// Reachable indicates that the node is healthy and reachable
	// by other members.
	RaftMemberStatus_REACHABLE RaftMemberStatus_Reachability = 2
)

func (RaftMemberStatus_Reachability) EnumDescriptor 

func (RaftMemberStatus_Reachability) EnumDescriptor() ([]byte, []int)

func (RaftMemberStatus_Reachability) String 

func (x RaftMemberStatus_Reachability) String() string

type RaftMembershipClient 

type RaftMembershipClient interface {
	// Join adds a RaftMember to the raft cluster.
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
	// Leave removes a RaftMember from the raft cluster.
	Leave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*LeaveResponse, error)
}

func NewRaftMembershipClient 

func NewRaftMembershipClient(cc *grpc.ClientConn) RaftMembershipClient

type RaftMembershipServer 

type RaftMembershipServer interface {
	// Join adds a RaftMember to the raft cluster.
	Join(context.Context, *JoinRequest) (*JoinResponse, error)
	// Leave removes a RaftMember from the raft cluster.
	Leave(context.Context, *LeaveRequest) (*LeaveResponse, error)
}

func NewAuthenticatedWrapperRaftMembershipServer 

func NewAuthenticatedWrapperRaftMembershipServer(local RaftMembershipServer, authorize func(context.Context, []string) error) RaftMembershipServer

func NewRaftProxyRaftMembershipServer 

func NewRaftProxyRaftMembershipServer(local RaftMembershipServer, connSelector *raftpicker.ConnSelector, cluster raftpicker.RaftCluster, ctxMod func(context.Context) (context.Context, error)) RaftMembershipServer

type RaftServer 

type RaftServer interface {
	// ProcessRaftMessage sends a raft message to be processed on a raft member, it is
	// called from the RaftMember willing to send a message to its destination ('To' field)
	ProcessRaftMessage(context.Context, *ProcessRaftMessageRequest) (*ProcessRaftMessageResponse, error)
	// ResolveAddress returns the address where the node with the given ID can be reached.
	ResolveAddress(context.Context, *ResolveAddressRequest) (*ResolveAddressResponse, error)
}

func NewAuthenticatedWrapperRaftServer 

func NewAuthenticatedWrapperRaftServer(local RaftServer, authorize func(context.Context, []string) error) RaftServer

func NewRaftProxyRaftServer 

func NewRaftProxyRaftServer(local RaftServer, connSelector *raftpicker.ConnSelector, cluster raftpicker.RaftCluster, ctxMod func(context.Context) (context.Context, error)) RaftServer

type RemoveNetworkRequest 

type RemoveNetworkRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	NetworkID string `protobuf:"bytes,2,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
}

func (*RemoveNetworkRequest) Copy 

func (m *RemoveNetworkRequest) Copy() *RemoveNetworkRequest

func (*RemoveNetworkRequest) Descriptor 

func (*RemoveNetworkRequest) Descriptor() ([]byte, []int)

func (*RemoveNetworkRequest) GoString 

func (this *RemoveNetworkRequest) GoString() string

func (*RemoveNetworkRequest) Marshal 

func (m *RemoveNetworkRequest) Marshal() (data []byte, err error)

func (*RemoveNetworkRequest) MarshalTo 

func (m *RemoveNetworkRequest) MarshalTo(data []byte) (int, error)

func (*RemoveNetworkRequest) ProtoMessage 

func (*RemoveNetworkRequest) ProtoMessage()

func (*RemoveNetworkRequest) Reset 

func (m *RemoveNetworkRequest) Reset()

func (*RemoveNetworkRequest) Size 

func (m *RemoveNetworkRequest) Size() (n int)

func (*RemoveNetworkRequest) String 

func (this *RemoveNetworkRequest) String() string

func (*RemoveNetworkRequest) Unmarshal 

func (m *RemoveNetworkRequest) Unmarshal(data []byte) error

type RemoveNetworkResponse 

type RemoveNetworkResponse struct {
}

func (*RemoveNetworkResponse) Copy 

func (m *RemoveNetworkResponse) Copy() *RemoveNetworkResponse

func (*RemoveNetworkResponse) Descriptor 

func (*RemoveNetworkResponse) Descriptor() ([]byte, []int)

func (*RemoveNetworkResponse) GoString 

func (this *RemoveNetworkResponse) GoString() string

func (*RemoveNetworkResponse) Marshal 

func (m *RemoveNetworkResponse) Marshal() (data []byte, err error)

func (*RemoveNetworkResponse) MarshalTo 

func (m *RemoveNetworkResponse) MarshalTo(data []byte) (int, error)

func (*RemoveNetworkResponse) ProtoMessage 

func (*RemoveNetworkResponse) ProtoMessage()

func (*RemoveNetworkResponse) Reset 

func (m *RemoveNetworkResponse) Reset()

func (*RemoveNetworkResponse) Size 

func (m *RemoveNetworkResponse) Size() (n int)

func (*RemoveNetworkResponse) String 

func (this *RemoveNetworkResponse) String() string

func (*RemoveNetworkResponse) Unmarshal 

func (m *RemoveNetworkResponse) Unmarshal(data []byte) error

type RemoveNodeRequest 

type RemoveNodeRequest struct {
	NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

RemoveNodeRequest requests to delete the specified node from store.

func (*RemoveNodeRequest) Copy 

func (m *RemoveNodeRequest) Copy() *RemoveNodeRequest

func (*RemoveNodeRequest) Descriptor 

func (*RemoveNodeRequest) Descriptor() ([]byte, []int)

func (*RemoveNodeRequest) GoString 

func (this *RemoveNodeRequest) GoString() string

func (*RemoveNodeRequest) Marshal 

func (m *RemoveNodeRequest) Marshal() (data []byte, err error)

func (*RemoveNodeRequest) MarshalTo 

func (m *RemoveNodeRequest) MarshalTo(data []byte) (int, error)

func (*RemoveNodeRequest) ProtoMessage 

func (*RemoveNodeRequest) ProtoMessage()

func (*RemoveNodeRequest) Reset 

func (m *RemoveNodeRequest) Reset()

func (*RemoveNodeRequest) Size 

func (m *RemoveNodeRequest) Size() (n int)

func (*RemoveNodeRequest) String 

func (this *RemoveNodeRequest) String() string

func (*RemoveNodeRequest) Unmarshal 

func (m *RemoveNodeRequest) Unmarshal(data []byte) error

type RemoveNodeResponse 

type RemoveNodeResponse struct {
}

func (*RemoveNodeResponse) Copy 

func (m *RemoveNodeResponse) Copy() *RemoveNodeResponse

func (*RemoveNodeResponse) Descriptor 

func (*RemoveNodeResponse) Descriptor() ([]byte, []int)

func (*RemoveNodeResponse) GoString 

func (this *RemoveNodeResponse) GoString() string

func (*RemoveNodeResponse) Marshal 

func (m *RemoveNodeResponse) Marshal() (data []byte, err error)

func (*RemoveNodeResponse) MarshalTo 

func (m *RemoveNodeResponse) MarshalTo(data []byte) (int, error)

func (*RemoveNodeResponse) ProtoMessage 

func (*RemoveNodeResponse) ProtoMessage()

func (*RemoveNodeResponse) Reset 

func (m *RemoveNodeResponse) Reset()

func (*RemoveNodeResponse) Size 

func (m *RemoveNodeResponse) Size() (n int)

func (*RemoveNodeResponse) String 

func (this *RemoveNodeResponse) String() string

func (*RemoveNodeResponse) Unmarshal 

func (m *RemoveNodeResponse) Unmarshal(data []byte) error

type RemoveServiceRequest 

type RemoveServiceRequest struct {
	ServiceID string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
}

func (*RemoveServiceRequest) Copy 

func (m *RemoveServiceRequest) Copy() *RemoveServiceRequest

func (*RemoveServiceRequest) Descriptor 

func (*RemoveServiceRequest) Descriptor() ([]byte, []int)

func (*RemoveServiceRequest) GoString 

func (this *RemoveServiceRequest) GoString() string

func (*RemoveServiceRequest) Marshal 

func (m *RemoveServiceRequest) Marshal() (data []byte, err error)

func (*RemoveServiceRequest) MarshalTo 

func (m *RemoveServiceRequest) MarshalTo(data []byte) (int, error)

func (*RemoveServiceRequest) ProtoMessage 

func (*RemoveServiceRequest) ProtoMessage()

func (*RemoveServiceRequest) Reset 

func (m *RemoveServiceRequest) Reset()

func (*RemoveServiceRequest) Size 

func (m *RemoveServiceRequest) Size() (n int)

func (*RemoveServiceRequest) String 

func (this *RemoveServiceRequest) String() string

func (*RemoveServiceRequest) Unmarshal 

func (m *RemoveServiceRequest) Unmarshal(data []byte) error

type RemoveServiceResponse 

type RemoveServiceResponse struct {
}

func (*RemoveServiceResponse) Copy 

func (m *RemoveServiceResponse) Copy() *RemoveServiceResponse

func (*RemoveServiceResponse) Descriptor 

func (*RemoveServiceResponse) Descriptor() ([]byte, []int)

func (*RemoveServiceResponse) GoString 

func (this *RemoveServiceResponse) GoString() string

func (*RemoveServiceResponse) Marshal 

func (m *RemoveServiceResponse) Marshal() (data []byte, err error)

func (*RemoveServiceResponse) MarshalTo 

func (m *RemoveServiceResponse) MarshalTo(data []byte) (int, error)

func (*RemoveServiceResponse) ProtoMessage 

func (*RemoveServiceResponse) ProtoMessage()

func (*RemoveServiceResponse) Reset 

func (m *RemoveServiceResponse) Reset()

func (*RemoveServiceResponse) Size 

func (m *RemoveServiceResponse) Size() (n int)

func (*RemoveServiceResponse) String 

func (this *RemoveServiceResponse) String() string

func (*RemoveServiceResponse) Unmarshal 

func (m *RemoveServiceResponse) Unmarshal(data []byte) error

type RemoveTaskRequest 

type RemoveTaskRequest struct {
	TaskID string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
}

func (*RemoveTaskRequest) Copy 

func (m *RemoveTaskRequest) Copy() *RemoveTaskRequest

func (*RemoveTaskRequest) Descriptor 

func (*RemoveTaskRequest) Descriptor() ([]byte, []int)

func (*RemoveTaskRequest) GoString 

func (this *RemoveTaskRequest) GoString() string

func (*RemoveTaskRequest) Marshal 

func (m *RemoveTaskRequest) Marshal() (data []byte, err error)

func (*RemoveTaskRequest) MarshalTo 

func (m *RemoveTaskRequest) MarshalTo(data []byte) (int, error)

func (*RemoveTaskRequest) ProtoMessage 

func (*RemoveTaskRequest) ProtoMessage()

func (*RemoveTaskRequest) Reset 

func (m *RemoveTaskRequest) Reset()

func (*RemoveTaskRequest) Size 

func (m *RemoveTaskRequest) Size() (n int)

func (*RemoveTaskRequest) String 

func (this *RemoveTaskRequest) String() string

func (*RemoveTaskRequest) Unmarshal 

func (m *RemoveTaskRequest) Unmarshal(data []byte) error

type RemoveTaskResponse 

type RemoveTaskResponse struct {
}

func (*RemoveTaskResponse) Copy 

func (m *RemoveTaskResponse) Copy() *RemoveTaskResponse

func (*RemoveTaskResponse) Descriptor 

func (*RemoveTaskResponse) Descriptor() ([]byte, []int)

func (*RemoveTaskResponse) GoString 

func (this *RemoveTaskResponse) GoString() string

func (*RemoveTaskResponse) Marshal 

func (m *RemoveTaskResponse) Marshal() (data []byte, err error)

func (*RemoveTaskResponse) MarshalTo 

func (m *RemoveTaskResponse) MarshalTo(data []byte) (int, error)

func (*RemoveTaskResponse) ProtoMessage 

func (*RemoveTaskResponse) ProtoMessage()

func (*RemoveTaskResponse) Reset 

func (m *RemoveTaskResponse) Reset()

func (*RemoveTaskResponse) Size 

func (m *RemoveTaskResponse) Size() (n int)

func (*RemoveTaskResponse) String 

func (this *RemoveTaskResponse) String() string

func (*RemoveTaskResponse) Unmarshal 

func (m *RemoveTaskResponse) Unmarshal(data []byte) error

type ReplicatedService 

type ReplicatedService struct {
	Replicas uint64 `protobuf:"varint,1,opt,name=replicas,proto3" json:"replicas,omitempty"`
}

ReplicatedService sets the reconciliation target to certain number of replicas.

func (*ReplicatedService) Copy 

func (m *ReplicatedService) Copy() *ReplicatedService

func (*ReplicatedService) Descriptor 

func (*ReplicatedService) Descriptor() ([]byte, []int)

func (*ReplicatedService) GoString 

func (this *ReplicatedService) GoString() string

func (*ReplicatedService) Marshal 

func (m *ReplicatedService) Marshal() (data []byte, err error)

func (*ReplicatedService) MarshalTo 

func (m *ReplicatedService) MarshalTo(data []byte) (int, error)

func (*ReplicatedService) ProtoMessage 

func (*ReplicatedService) ProtoMessage()

func (*ReplicatedService) Reset 

func (m *ReplicatedService) Reset()

func (*ReplicatedService) Size 

func (m *ReplicatedService) Size() (n int)

func (*ReplicatedService) String 

func (this *ReplicatedService) String() string

func (*ReplicatedService) Unmarshal 

func (m *ReplicatedService) Unmarshal(data []byte) error

type ResolveAddressRequest 

type ResolveAddressRequest struct {
	// raft_id is the ID to resolve to an address.
	RaftID uint64 `protobuf:"varint,1,opt,name=raft_id,json=raftId,proto3" json:"raft_id,omitempty"`
}

func (*ResolveAddressRequest) Copy 

func (m *ResolveAddressRequest) Copy() *ResolveAddressRequest

func (*ResolveAddressRequest) Descriptor 

func (*ResolveAddressRequest) Descriptor() ([]byte, []int)

func (*ResolveAddressRequest) GoString 

func (this *ResolveAddressRequest) GoString() string

func (*ResolveAddressRequest) Marshal 

func (m *ResolveAddressRequest) Marshal() (data []byte, err error)

func (*ResolveAddressRequest) MarshalTo 

func (m *ResolveAddressRequest) MarshalTo(data []byte) (int, error)

func (*ResolveAddressRequest) ProtoMessage 

func (*ResolveAddressRequest) ProtoMessage()

func (*ResolveAddressRequest) Reset 

func (m *ResolveAddressRequest) Reset()

func (*ResolveAddressRequest) Size 

func (m *ResolveAddressRequest) Size() (n int)

func (*ResolveAddressRequest) String 

func (this *ResolveAddressRequest) String() string

func (*ResolveAddressRequest) Unmarshal 

func (m *ResolveAddressRequest) Unmarshal(data []byte) error

type ResolveAddressResponse 

type ResolveAddressResponse struct {
	// Addr specifies the address of the member
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
}

func (*ResolveAddressResponse) Copy 

func (m *ResolveAddressResponse) Copy() *ResolveAddressResponse

func (*ResolveAddressResponse) Descriptor 

func (*ResolveAddressResponse) Descriptor() ([]byte, []int)

func (*ResolveAddressResponse) GoString 

func (this *ResolveAddressResponse) GoString() string

func (*ResolveAddressResponse) Marshal 

func (m *ResolveAddressResponse) Marshal() (data []byte, err error)

func (*ResolveAddressResponse) MarshalTo 

func (m *ResolveAddressResponse) MarshalTo(data []byte) (int, error)

func (*ResolveAddressResponse) ProtoMessage 

func (*ResolveAddressResponse) ProtoMessage()

func (*ResolveAddressResponse) Reset 

func (m *ResolveAddressResponse) Reset()

func (*ResolveAddressResponse) Size 

func (m *ResolveAddressResponse) Size() (n int)

func (*ResolveAddressResponse) String 

func (this *ResolveAddressResponse) String() string

func (*ResolveAddressResponse) Unmarshal 

func (m *ResolveAddressResponse) Unmarshal(data []byte) error

type ResourceRequirements 

type ResourceRequirements struct {
	Limits       *Resources `protobuf:"bytes,1,opt,name=limits" json:"limits,omitempty"`
	Reservations *Resources `protobuf:"bytes,2,opt,name=reservations" json:"reservations,omitempty"`
}

func (*ResourceRequirements) Copy 

func (m *ResourceRequirements) Copy() *ResourceRequirements

func (*ResourceRequirements) Descriptor 

func (*ResourceRequirements) Descriptor() ([]byte, []int)

func (*ResourceRequirements) GoString 

func (this *ResourceRequirements) GoString() string

func (*ResourceRequirements) Marshal 

func (m *ResourceRequirements) Marshal() (data []byte, err error)

func (*ResourceRequirements) MarshalTo 

func (m *ResourceRequirements) MarshalTo(data []byte) (int, error)

func (*ResourceRequirements) ProtoMessage 

func (*ResourceRequirements) ProtoMessage()

func (*ResourceRequirements) Reset 

func (m *ResourceRequirements) Reset()

func (*ResourceRequirements) Size 

func (m *ResourceRequirements) Size() (n int)

func (*ResourceRequirements) String 

func (this *ResourceRequirements) String() string

func (*ResourceRequirements) Unmarshal 

func (m *ResourceRequirements) Unmarshal(data []byte) error

type Resources 

type Resources struct {
	// Amount of CPUs (e.g. 2000000000 = 2 CPU cores)
	NanoCPUs int64 `protobuf:"varint,1,opt,name=nano_cpus,json=nanoCpus,proto3" json:"nano_cpus,omitempty"`
	// Amount of memory in bytes.
	MemoryBytes int64 `protobuf:"varint,2,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
}

func (*Resources) Copy 

func (m *Resources) Copy() *Resources

func (*Resources) Descriptor 

func (*Resources) Descriptor() ([]byte, []int)

func (*Resources) GoString 

func (this *Resources) GoString() string

func (*Resources) Marshal 

func (m *Resources) Marshal() (data []byte, err error)

func (*Resources) MarshalTo 

func (m *Resources) MarshalTo(data []byte) (int, error)

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) Reset 

func (m *Resources) Reset()

func (*Resources) Size 

func (m *Resources) Size() (n int)

func (*Resources) String 

func (this *Resources) String() string

func (*Resources) Unmarshal 

func (m *Resources) Unmarshal(data []byte) error

type RestartPolicy 

type RestartPolicy struct {
	Condition RestartPolicy_RestartCondition `` /* 127-byte string literal not displayed */
	// Delay between restart attempts
	Delay *docker_swarmkit_v11.Duration `protobuf:"bytes,2,opt,name=delay" json:"delay,omitempty"`
	// MaxAttempts is the maximum number of restarts to attempt on an
	// instance before giving up. Ignored if 0.
	MaxAttempts uint64 `protobuf:"varint,3,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	// Window is the time window used to evaluate the restart policy.
	// The time window is unbounded if this is 0.
	Window *docker_swarmkit_v11.Duration `protobuf:"bytes,4,opt,name=window" json:"window,omitempty"`
}

func (*RestartPolicy) Copy 

func (m *RestartPolicy) Copy() *RestartPolicy

func (*RestartPolicy) Descriptor 

func (*RestartPolicy) Descriptor() ([]byte, []int)

func (*RestartPolicy) GoString 

func (this *RestartPolicy) GoString() string

func (*RestartPolicy) Marshal 

func (m *RestartPolicy) Marshal() (data []byte, err error)

func (*RestartPolicy) MarshalTo 

func (m *RestartPolicy) MarshalTo(data []byte) (int, error)

func (*RestartPolicy) ProtoMessage 

func (*RestartPolicy) ProtoMessage()

func (*RestartPolicy) Reset 

func (m *RestartPolicy) Reset()

func (*RestartPolicy) Size 

func (m *RestartPolicy) Size() (n int)

func (*RestartPolicy) String 

func (this *RestartPolicy) String() string

func (*RestartPolicy) Unmarshal 

func (m *RestartPolicy) Unmarshal(data []byte) error

type RestartPolicy_RestartCondition 

type RestartPolicy_RestartCondition int32
const (
	RestartOnNone    RestartPolicy_RestartCondition = 0
	RestartOnFailure RestartPolicy_RestartCondition = 1
	RestartOnAny     RestartPolicy_RestartCondition = 2
)

func (RestartPolicy_RestartCondition) EnumDescriptor 

func (RestartPolicy_RestartCondition) EnumDescriptor() ([]byte, []int)

func (RestartPolicy_RestartCondition) String 

func (x RestartPolicy_RestartCondition) String() string

type RootCA 

type RootCA struct {
	// CAKey is the root CA private key.
	CAKey []byte `protobuf:"bytes,1,opt,name=ca_key,json=caKey,proto3" json:"ca_key,omitempty"`
	// CACert is the root CA certificate.
	CACert []byte `protobuf:"bytes,2,opt,name=ca_cert,json=caCert,proto3" json:"ca_cert,omitempty"`
	// CACertHash is the digest of the CA Certificate.
	CACertHash string `protobuf:"bytes,3,opt,name=ca_cert_hash,json=caCertHash,proto3" json:"ca_cert_hash,omitempty"`
	// JoinTokens contains the join tokens for workers and managers.
	JoinTokens JoinTokens `protobuf:"bytes,4,opt,name=join_tokens,json=joinTokens" json:"join_tokens"`
}

func (*RootCA) Copy 

func (m *RootCA) Copy() *RootCA

func (*RootCA) Descriptor 

func (*RootCA) Descriptor() ([]byte, []int)

func (*RootCA) GoString 

func (this *RootCA) GoString() string

func (*RootCA) Marshal 

func (m *RootCA) Marshal() (data []byte, err error)

func (*RootCA) MarshalTo 

func (m *RootCA) MarshalTo(data []byte) (int, error)

func (*RootCA) ProtoMessage 

func (*RootCA) ProtoMessage()

func (*RootCA) Reset 

func (m *RootCA) Reset()

func (*RootCA) Size 

func (m *RootCA) Size() (n int)

func (*RootCA) String 

func (this *RootCA) String() string

func (*RootCA) Unmarshal 

func (m *RootCA) Unmarshal(data []byte) error

type Service 

type Service struct {
	ID   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta Meta        `protobuf:"bytes,2,opt,name=meta" json:"meta"`
	Spec ServiceSpec `protobuf:"bytes,3,opt,name=spec" json:"spec"`
	// Runtime state of service endpoint. This may be different
	// from the spec version because the user may not have entered
	// the optional fields like node_port or virtual_ip and it
	// could be auto allocated by the system.
	Endpoint *Endpoint `protobuf:"bytes,4,opt,name=endpoint" json:"endpoint,omitempty"`
	// UpdateStatus contains the status of an update, if one is in
	// progress.
	UpdateStatus *UpdateStatus `protobuf:"bytes,5,opt,name=update_status,json=updateStatus" json:"update_status,omitempty"`
}

func (*Service) Copy 

func (m *Service) Copy() *Service

func (*Service) Descriptor 

func (*Service) Descriptor() ([]byte, []int)

func (*Service) GoString 

func (this *Service) GoString() string

func (*Service) Marshal 

func (m *Service) Marshal() (data []byte, err error)

func (*Service) MarshalTo 

func (m *Service) MarshalTo(data []byte) (int, error)

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) Size 

func (m *Service) Size() (n int)

func (*Service) String 

func (this *Service) String() string

func (*Service) Unmarshal 

func (m *Service) Unmarshal(data []byte) error

type ServiceSpec 

type ServiceSpec struct {
	Annotations Annotations `protobuf:"bytes,1,opt,name=annotations" json:"annotations"`
	// Task defines the task template this service will spawn.
	Task TaskSpec `protobuf:"bytes,2,opt,name=task" json:"task"`
	// Types that are valid to be assigned to Mode:
	//	*ServiceSpec_Replicated
	//	*ServiceSpec_Global
	Mode isServiceSpec_Mode `protobuf_oneof:"mode"`
	// UpdateConfig controls the rate and policy of updates.
	Update   *UpdateConfig                          `protobuf:"bytes,6,opt,name=update" json:"update,omitempty"`
	Networks []*ServiceSpec_NetworkAttachmentConfig `protobuf:"bytes,7,rep,name=networks" json:"networks,omitempty"`
	// Service endpoint specifies the user provided configuration
	// to properly discover and load balance a service.
	Endpoint *EndpointSpec `protobuf:"bytes,8,opt,name=endpoint" json:"endpoint,omitempty"`
}

ServiceSpec defines the properties of a service.

A service instructs the cluster in orchestrating repeated instances of a template, implemented as tasks. Based on the number of instances, scheduling strategy and restart policy, a number of application-level behaviors can be defined.

func (*ServiceSpec) Copy 

func (m *ServiceSpec) Copy() *ServiceSpec

func (*ServiceSpec) Descriptor 

func (*ServiceSpec) Descriptor() ([]byte, []int)

func (*ServiceSpec) GetGlobal 

func (m *ServiceSpec) GetGlobal() *GlobalService

func (*ServiceSpec) GetMode 

func (m *ServiceSpec) GetMode() isServiceSpec_Mode

func (*ServiceSpec) GetReplicated 

func (m *ServiceSpec) GetReplicated() *ReplicatedService

func (*ServiceSpec) GoString 

func (this *ServiceSpec) GoString() string

func (*ServiceSpec) Marshal 

func (m *ServiceSpec) Marshal() (data []byte, err error)

func (*ServiceSpec) MarshalTo 

func (m *ServiceSpec) MarshalTo(data []byte) (int, error)

func (*ServiceSpec) ProtoMessage 

func (*ServiceSpec) ProtoMessage()

func (*ServiceSpec) Reset 

func (m *ServiceSpec) Reset()

func (*ServiceSpec) Size 

func (m *ServiceSpec) Size() (n int)

func (*ServiceSpec) String 

func (this *ServiceSpec) String() string

func (*ServiceSpec) Unmarshal 

func (m *ServiceSpec) Unmarshal(data []byte) error

func (*ServiceSpec) XXX_OneofFuncs 

func (*ServiceSpec) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ServiceSpec_Global 

type ServiceSpec_Global struct {
	Global *GlobalService `protobuf:"bytes,4,opt,name=global,oneof"`
}

func (*ServiceSpec_Global) GoString 

func (this *ServiceSpec_Global) GoString() string

func (*ServiceSpec_Global) MarshalTo 

func (m *ServiceSpec_Global) MarshalTo(data []byte) (int, error)

func (*ServiceSpec_Global) Size 

func (m *ServiceSpec_Global) Size() (n int)

func (*ServiceSpec_Global) String 

func (this *ServiceSpec_Global) String() string

type ServiceSpec_NetworkAttachmentConfig 

type ServiceSpec_NetworkAttachmentConfig struct {
	// Target specifies the target network for attachment. This value may be a
	// network name or identifier. Only identifiers are supported at this time.
	Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// Aliases specifies a list of discoverable alternate names for the service on this Target.
	Aliases []string `protobuf:"bytes,2,rep,name=aliases" json:"aliases,omitempty"`
}

NetworkAttachmentConfig specifies how a service should be attached to a particular network.

For now, this is a simple struct, but this can include future information instructing Swarm on how this service should work on the particular network.

func (*ServiceSpec_NetworkAttachmentConfig) Copy 

func (m *ServiceSpec_NetworkAttachmentConfig) Copy() *ServiceSpec_NetworkAttachmentConfig

func (*ServiceSpec_NetworkAttachmentConfig) Descriptor 

func (*ServiceSpec_NetworkAttachmentConfig) Descriptor() ([]byte, []int)

func (*ServiceSpec_NetworkAttachmentConfig) GoString 

func (this *ServiceSpec_NetworkAttachmentConfig) GoString() string

func (*ServiceSpec_NetworkAttachmentConfig) Marshal 

func (m *ServiceSpec_NetworkAttachmentConfig) Marshal() (data []byte, err error)

func (*ServiceSpec_NetworkAttachmentConfig) MarshalTo 

func (m *ServiceSpec_NetworkAttachmentConfig) MarshalTo(data []byte) (int, error)

func (*ServiceSpec_NetworkAttachmentConfig) ProtoMessage 

func (*ServiceSpec_NetworkAttachmentConfig) ProtoMessage()

func (*ServiceSpec_NetworkAttachmentConfig) Reset 

func (m *ServiceSpec_NetworkAttachmentConfig) Reset()

func (*ServiceSpec_NetworkAttachmentConfig) Size 

func (m *ServiceSpec_NetworkAttachmentConfig) Size() (n int)

func (*ServiceSpec_NetworkAttachmentConfig) String 

func (this *ServiceSpec_NetworkAttachmentConfig) String() string

func (*ServiceSpec_NetworkAttachmentConfig) Unmarshal 

func (m *ServiceSpec_NetworkAttachmentConfig) Unmarshal(data []byte) error

type ServiceSpec_Replicated 

type ServiceSpec_Replicated struct {
	Replicated *ReplicatedService `protobuf:"bytes,3,opt,name=replicated,oneof"`
}

func (*ServiceSpec_Replicated) GoString 

func (this *ServiceSpec_Replicated) GoString() string

func (*ServiceSpec_Replicated) MarshalTo 

func (m *ServiceSpec_Replicated) MarshalTo(data []byte) (int, error)

func (*ServiceSpec_Replicated) Size 

func (m *ServiceSpec_Replicated) Size() (n int)

func (*ServiceSpec_Replicated) String 

func (this *ServiceSpec_Replicated) String() string

type SessionMessage 

type SessionMessage struct {
	// SessionID is allocated after a successful registration. It should be
	// used on all RPC calls after registration. A dispatcher may choose to
	// change the SessionID, at which time an agent must re-register and obtain
	// a new one.
	//
	// All Dispatcher calls after register should include the SessionID. If the
	// Dispatcher so chooses, it may reject the call with an InvalidArgument
	// error code, at which time the agent should call Register to start a new
	// session.
	//
	// As a rule, once an agent has a SessionID, it should never save it to
	// disk or try to otherwise reuse. If the agent loses its SessionID, it
	// must start a new session through a call to Register. A Dispatcher may
	// choose to reuse the SessionID, if it sees fit, but it is not advised.
	//
	// The actual implementation of the SessionID is Dispatcher specific and
	// should be treated as opaque by agents.
	//
	// From a Dispatcher perspective, there are many ways to use the SessionID
	// to ensure uniqueness of a set of client RPC calls. One method is to keep
	// the SessionID unique to every call to Register in a single Dispatcher
	// instance. This ensures that the SessionID represents the unique
	// session from a single Agent to Manager. If the Agent restarts, we
	// allocate a new session, since the restarted Agent is not aware of the
	// new SessionID.
	//
	// The most compelling use case is to support duplicate node detection. If
	// one clones a virtual machine, including certificate material, two nodes
	// may end up with the same identity. This can also happen if two identical
	// agent processes are coming from the same node. If the SessionID is
	// replicated through the cluster, we can immediately detect the condition
	// and address it.
	//
	// Extending from the case above, we can actually detect a compromised
	// identity. Coupled with provisions to rebuild node identity, we can ban
	// the compromised node identity and have the nodes re-authenticate and
	// build a new identity. At this time, an administrator can then
	// re-authorize the compromised nodes, if it was a mistake or ensure that a
	// misbehaved node can no longer connect to the cluster.
	//
	// We considered placing this field in a GRPC header. Because this is a
	// critical feature of the protocol, we thought it should be represented
	// directly in the RPC message set.
	SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Node identifies the registering node.
	Node *Node `protobuf:"bytes,2,opt,name=node" json:"node,omitempty"`
	// Managers provides a weight list of alternative dispatchers
	Managers []*WeightedPeer `protobuf:"bytes,3,rep,name=managers" json:"managers,omitempty"`
	// Symmetric encryption key distributed by the lead manager. Used by agents
	// for securing network bootstrapping and communication.
	NetworkBootstrapKeys []*EncryptionKey `protobuf:"bytes,4,rep,name=network_bootstrap_keys,json=networkBootstrapKeys" json:"network_bootstrap_keys,omitempty"`
}

SessionMessage instructs an agent on various actions as part of the current session. An agent should act immediately on the contents.

func (*SessionMessage) Copy 

func (m *SessionMessage) Copy() *SessionMessage

func (*SessionMessage) Descriptor 

func (*SessionMessage) Descriptor() ([]byte, []int)

func (*SessionMessage) GoString 

func (this *SessionMessage) GoString() string

func (*SessionMessage) Marshal 

func (m *SessionMessage) Marshal() (data []byte, err error)

func (*SessionMessage) MarshalTo 

func (m *SessionMessage) MarshalTo(data []byte) (int, error)

func (*SessionMessage) ProtoMessage 

func (*SessionMessage) ProtoMessage()

func (*SessionMessage) Reset 

func (m *SessionMessage) Reset()

func (*SessionMessage) Size 

func (m *SessionMessage) Size() (n int)

func (*SessionMessage) String 

func (this *SessionMessage) String() string

func (*SessionMessage) Unmarshal 

func (m *SessionMessage) Unmarshal(data []byte) error

type SessionRequest 

type SessionRequest struct {
	Description *NodeDescription `protobuf:"bytes,1,opt,name=description" json:"description,omitempty"`
}

SessionRequest starts a session.

func (*SessionRequest) Copy 

func (m *SessionRequest) Copy() *SessionRequest

func (*SessionRequest) Descriptor 

func (*SessionRequest) Descriptor() ([]byte, []int)

func (*SessionRequest) GoString 

func (this *SessionRequest) GoString() string

func (*SessionRequest) Marshal 

func (m *SessionRequest) Marshal() (data []byte, err error)

func (*SessionRequest) MarshalTo 

func (m *SessionRequest) MarshalTo(data []byte) (int, error)

func (*SessionRequest) ProtoMessage 

func (*SessionRequest) ProtoMessage()

func (*SessionRequest) Reset 

func (m *SessionRequest) Reset()

func (*SessionRequest) Size 

func (m *SessionRequest) Size() (n int)

func (*SessionRequest) String 

func (this *SessionRequest) String() string

func (*SessionRequest) Unmarshal 

func (m *SessionRequest) Unmarshal(data []byte) error

type Snapshot 

type Snapshot struct {
	Version    Snapshot_Version `protobuf:"varint,1,opt,name=version,proto3,enum=docker.swarmkit.v1.Snapshot_Version" json:"version,omitempty"`
	Membership ClusterSnapshot  `protobuf:"bytes,2,opt,name=membership" json:"membership"`
	Store      StoreSnapshot    `protobuf:"bytes,3,opt,name=store" json:"store"`
}

func (*Snapshot) Copy 

func (m *Snapshot) Copy() *Snapshot

func (*Snapshot) Descriptor 

func (*Snapshot) Descriptor() ([]byte, []int)

func (*Snapshot) GoString 

func (this *Snapshot) GoString() string

func (*Snapshot) Marshal 

func (m *Snapshot) Marshal() (data []byte, err error)

func (*Snapshot) MarshalTo 

func (m *Snapshot) MarshalTo(data []byte) (int, error)

func (*Snapshot) ProtoMessage 

func (*Snapshot) ProtoMessage()

func (*Snapshot) Reset 

func (m *Snapshot) Reset()

func (*Snapshot) Size 

func (m *Snapshot) Size() (n int)

func (*Snapshot) String 

func (this *Snapshot) String() string

func (*Snapshot) Unmarshal 

func (m *Snapshot) Unmarshal(data []byte) error

type Snapshot_Version 

type Snapshot_Version int32
const (
	// V0 is the initial version of the StoreSnapshot message.
	Snapshot_V0 Snapshot_Version = 0
)

func (Snapshot_Version) EnumDescriptor 

func (Snapshot_Version) EnumDescriptor() ([]byte, []int)

func (Snapshot_Version) String 

func (x Snapshot_Version) String() string

type StoreAction 

type StoreAction struct {
	Action StoreActionKind `protobuf:"varint,1,opt,name=action,proto3,enum=docker.swarmkit.v1.StoreActionKind" json:"action,omitempty"`
	// Types that are valid to be assigned to Target:
	//	*StoreAction_Node
	//	*StoreAction_Service
	//	*StoreAction_Task
	//	*StoreAction_Network
	//	*StoreAction_Cluster
	Target isStoreAction_Target `protobuf_oneof:"target"`
}

StoreAction defines a taret and operation to apply on the storage system.

func (*StoreAction) Copy 

func (m *StoreAction) Copy() *StoreAction

func (*StoreAction) Descriptor 

func (*StoreAction) Descriptor() ([]byte, []int)

func (*StoreAction) GetCluster 

func (m *StoreAction) GetCluster() *Cluster

func (*StoreAction) GetNetwork 

func (m *StoreAction) GetNetwork() *Network

func (*StoreAction) GetNode 

func (m *StoreAction) GetNode() *Node

func (*StoreAction) GetService 

func (m *StoreAction) GetService() *Service

func (*StoreAction) GetTarget 

func (m *StoreAction) GetTarget() isStoreAction_Target

func (*StoreAction) GetTask 

func (m *StoreAction) GetTask() *Task

func (*StoreAction) GoString 

func (this *StoreAction) GoString() string

func (*StoreAction) Marshal 

func (m *StoreAction) Marshal() (data []byte, err error)

func (*StoreAction) MarshalTo 

func (m *StoreAction) MarshalTo(data []byte) (int, error)

func (*StoreAction) ProtoMessage 

func (*StoreAction) ProtoMessage()

func (*StoreAction) Reset 

func (m *StoreAction) Reset()

func (*StoreAction) Size 

func (m *StoreAction) Size() (n int)

func (*StoreAction) String 

func (this *StoreAction) String() string

func (*StoreAction) Unmarshal 

func (m *StoreAction) Unmarshal(data []byte) error

func (*StoreAction) XXX_OneofFuncs 

func (*StoreAction) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type StoreActionKind 

type StoreActionKind int32

StoreActionKind defines the operation to take on the store for the target of a storage action. 

const (
	StoreActionKindUnknown StoreActionKind = 0
	StoreActionKindCreate  StoreActionKind = 1
	StoreActionKindUpdate  StoreActionKind = 2
	StoreActionKindRemove  StoreActionKind = 3
)

func (StoreActionKind) EnumDescriptor 

func (StoreActionKind) EnumDescriptor() ([]byte, []int)

func (StoreActionKind) String 

func (x StoreActionKind) String() string

type StoreAction_Cluster 

type StoreAction_Cluster struct {
	Cluster *Cluster `protobuf:"bytes,6,opt,name=cluster,oneof"`
}

func (*StoreAction_Cluster) GoString 

func (this *StoreAction_Cluster) GoString() string

func (*StoreAction_Cluster) MarshalTo 

func (m *StoreAction_Cluster) MarshalTo(data []byte) (int, error)

func (*StoreAction_Cluster) Size 

func (m *StoreAction_Cluster) Size() (n int)

func (*StoreAction_Cluster) String 

func (this *StoreAction_Cluster) String() string

type StoreAction_Network 

type StoreAction_Network struct {
	Network *Network `protobuf:"bytes,5,opt,name=network,oneof"`
}

func (*StoreAction_Network) GoString 

func (this *StoreAction_Network) GoString() string

func (*StoreAction_Network) MarshalTo 

func (m *StoreAction_Network) MarshalTo(data []byte) (int, error)

func (*StoreAction_Network) Size 

func (m *StoreAction_Network) Size() (n int)

func (*StoreAction_Network) String 

func (this *StoreAction_Network) String() string

type StoreAction_Node 

type StoreAction_Node struct {
	Node *Node `protobuf:"bytes,2,opt,name=node,oneof"`
}

func (*StoreAction_Node) GoString 

func (this *StoreAction_Node) GoString() string

func (*StoreAction_Node) MarshalTo 

func (m *StoreAction_Node) MarshalTo(data []byte) (int, error)

func (*StoreAction_Node) Size 

func (m *StoreAction_Node) Size() (n int)

func (*StoreAction_Node) String 

func (this *StoreAction_Node) String() string

type StoreAction_Service 

type StoreAction_Service struct {
	Service *Service `protobuf:"bytes,3,opt,name=service,oneof"`
}

func (*StoreAction_Service) GoString 

func (this *StoreAction_Service) GoString() string

func (*StoreAction_Service) MarshalTo 

func (m *StoreAction_Service) MarshalTo(data []byte) (int, error)

func (*StoreAction_Service) Size 

func (m *StoreAction_Service) Size() (n int)

func (*StoreAction_Service) String 

func (this *StoreAction_Service) String() string

type StoreAction_Task 

type StoreAction_Task struct {
	Task *Task `protobuf:"bytes,4,opt,name=task,oneof"`
}

func (*StoreAction_Task) GoString 

func (this *StoreAction_Task) GoString() string

func (*StoreAction_Task) MarshalTo 

func (m *StoreAction_Task) MarshalTo(data []byte) (int, error)

func (*StoreAction_Task) Size 

func (m *StoreAction_Task) Size() (n int)

func (*StoreAction_Task) String 

func (this *StoreAction_Task) String() string

type StoreSnapshot 

type StoreSnapshot struct {
	Nodes    []*Node    `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
	Services []*Service `protobuf:"bytes,2,rep,name=services" json:"services,omitempty"`
	Networks []*Network `protobuf:"bytes,3,rep,name=networks" json:"networks,omitempty"`
	Tasks    []*Task    `protobuf:"bytes,4,rep,name=tasks" json:"tasks,omitempty"`
	Clusters []*Cluster `protobuf:"bytes,5,rep,name=clusters" json:"clusters,omitempty"`
}

StoreSnapshot is used to store snapshots of the store.

func (*StoreSnapshot) Copy 

func (m *StoreSnapshot) Copy() *StoreSnapshot

func (*StoreSnapshot) Descriptor 

func (*StoreSnapshot) Descriptor() ([]byte, []int)

func (*StoreSnapshot) GoString 

func (this *StoreSnapshot) GoString() string

func (*StoreSnapshot) Marshal 

func (m *StoreSnapshot) Marshal() (data []byte, err error)

func (*StoreSnapshot) MarshalTo 

func (m *StoreSnapshot) MarshalTo(data []byte) (int, error)

func (*StoreSnapshot) ProtoMessage 

func (*StoreSnapshot) ProtoMessage()

func (*StoreSnapshot) Reset 

func (m *StoreSnapshot) Reset()

func (*StoreSnapshot) Size 

func (m *StoreSnapshot) Size() (n int)

func (*StoreSnapshot) String 

func (this *StoreSnapshot) String() string

func (*StoreSnapshot) Unmarshal 

func (m *StoreSnapshot) Unmarshal(data []byte) error

type Task 

type Task struct {
	ID   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta Meta   `protobuf:"bytes,2,opt,name=meta" json:"meta"`
	// Spec defines the desired state of the task as specified by the user.
	// The system will honor this and will *never* modify it.
	Spec TaskSpec `protobuf:"bytes,3,opt,name=spec" json:"spec"`
	// ServiceID indicates the service under which this task is orchestrated. This
	// should almost always be set.
	ServiceID string `protobuf:"bytes,4,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// Slot is the service slot number for a task.
	// For example, if a replicated service has replicas = 2, there will be a
	// task with slot = 1, and another with slot = 2.
	Slot uint64 `protobuf:"varint,5,opt,name=slot,proto3" json:"slot,omitempty"`
	// NodeID indicates the node to which the task is assigned. If this field
	// is empty or not set, the task is unassigned.
	NodeID string `protobuf:"bytes,6,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Annotations defines the names and labels for the runtime, as set by
	// the cluster manager.
	//
	// As backup, if this field has an empty name, the runtime will
	// allocate a unique name for the actual container.
	//
	// NOTE(stevvooe): The preserves the ability for us to making naming
	// decisions for tasks in orchestrator, albeit, this is left empty for now.
	Annotations Annotations `protobuf:"bytes,7,opt,name=annotations" json:"annotations"`
	// ServiceAnnotations is a direct copy of the service name and labels when
	// this task is created.
	//
	// Labels set here will *not* be propagated to the runtime target, such as a
	// container. Use labels on the runtime target for that purpose.
	ServiceAnnotations Annotations `protobuf:"bytes,8,opt,name=service_annotations,json=serviceAnnotations" json:"service_annotations"`
	Status             TaskStatus  `protobuf:"bytes,9,opt,name=status" json:"status"`
	// DesiredState is the target state for the task. It is set to
	// TaskStateRunning when a task is first created, and changed to
	// TaskStateShutdown if the manager wants to terminate the task. This field
	// is only written by the manager.
	DesiredState TaskState `` /* 133-byte string literal not displayed */
	// List of network attachments by the task.
	Networks []*NetworkAttachment `protobuf:"bytes,11,rep,name=networks" json:"networks,omitempty"`
	// A copy of runtime state of service endpoint from Service
	// object to be distributed to agents as part of the task.
	Endpoint *Endpoint `protobuf:"bytes,12,opt,name=endpoint" json:"endpoint,omitempty"`
	// LogDriver specifies the selected log driver to use for the task. Agent
	// processes should always favor the value in this field.
	//
	// If present in the TaskSpec, this will be a copy of that value. The
	// orchestrator may choose to insert a value here, which should be honored,
	// such a cluster default or policy-based value.
	//
	// If not present, the daemon's default will be used.
	LogDriver *Driver `protobuf:"bytes,13,opt,name=log_driver,json=logDriver" json:"log_driver,omitempty"`
}

Task specifies the parameters for implementing a Spec. A task is effectively immutable and idempotent. Once it is dispatched to a node, it will not be dispatched to another node.

func (*Task) Copy 

func (m *Task) Copy() *Task

func (*Task) Descriptor 

func (*Task) Descriptor() ([]byte, []int)

func (*Task) GoString 

func (this *Task) GoString() string

func (*Task) Marshal 

func (m *Task) Marshal() (data []byte, err error)

func (*Task) MarshalTo 

func (m *Task) MarshalTo(data []byte) (int, error)

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) Size 

func (m *Task) Size() (n int)

func (*Task) String 

func (this *Task) String() string

func (*Task) Unmarshal 

func (m *Task) Unmarshal(data []byte) error

type TaskDefaults 

type TaskDefaults struct {
	// LogDriver specifies the log driver to use for the cluster if not
	// specified for each task.
	//
	// If this is changed, only new tasks will pick up the new log driver.
	// Existing tasks will continue to use the previous default until rescheduled.
	LogDriver *Driver `protobuf:"bytes,1,opt,name=log_driver,json=logDriver" json:"log_driver,omitempty"`
}

TaskDefaults specifies default values for task creation.

func (*TaskDefaults) Copy 

func (m *TaskDefaults) Copy() *TaskDefaults

func (*TaskDefaults) Descriptor 

func (*TaskDefaults) Descriptor() ([]byte, []int)

func (*TaskDefaults) GoString 

func (this *TaskDefaults) GoString() string

func (*TaskDefaults) Marshal 

func (m *TaskDefaults) Marshal() (data []byte, err error)

func (*TaskDefaults) MarshalTo 

func (m *TaskDefaults) MarshalTo(data []byte) (int, error)

func (*TaskDefaults) ProtoMessage 

func (*TaskDefaults) ProtoMessage()

func (*TaskDefaults) Reset 

func (m *TaskDefaults) Reset()

func (*TaskDefaults) Size 

func (m *TaskDefaults) Size() (n int)

func (*TaskDefaults) String 

func (this *TaskDefaults) String() string

func (*TaskDefaults) Unmarshal 

func (m *TaskDefaults) Unmarshal(data []byte) error

type TaskSpec 

type TaskSpec struct {
	// Types that are valid to be assigned to Runtime:
	//	*TaskSpec_Container
	Runtime isTaskSpec_Runtime `protobuf_oneof:"runtime"`
	// Resource requirements for the container.
	Resources *ResourceRequirements `protobuf:"bytes,2,opt,name=resources" json:"resources,omitempty"`
	// RestartPolicy specifies what to do when a task fails or finishes.
	Restart *RestartPolicy `protobuf:"bytes,4,opt,name=restart" json:"restart,omitempty"`
	// Placement specifies node selection constraints
	Placement *Placement `protobuf:"bytes,5,opt,name=placement" json:"placement,omitempty"`
	// LogDriver specifies the log driver to use for the task. Any runtime will
	// direct logs into the specified driver for the duration of the task.
	LogDriver *Driver `protobuf:"bytes,6,opt,name=log_driver,json=logDriver" json:"log_driver,omitempty"`
}

func (*TaskSpec) Copy 

func (m *TaskSpec) Copy() *TaskSpec

func (*TaskSpec) Descriptor 

func (*TaskSpec) Descriptor() ([]byte, []int)

func (*TaskSpec) GetContainer 

func (m *TaskSpec) GetContainer() *ContainerSpec

func (*TaskSpec) GetRuntime 

func (m *TaskSpec) GetRuntime() isTaskSpec_Runtime

func (*TaskSpec) GoString 

func (this *TaskSpec) GoString() string

func (*TaskSpec) Marshal 

func (m *TaskSpec) Marshal() (data []byte, err error)

func (*TaskSpec) MarshalTo 

func (m *TaskSpec) MarshalTo(data []byte) (int, error)

func (*TaskSpec) ProtoMessage 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) Reset 

func (m *TaskSpec) Reset()

func (*TaskSpec) Size 

func (m *TaskSpec) Size() (n int)

func (*TaskSpec) String 

func (this *TaskSpec) String() string

func (*TaskSpec) Unmarshal 

func (m *TaskSpec) Unmarshal(data []byte) error

func (*TaskSpec) XXX_OneofFuncs 

func (*TaskSpec) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type TaskSpec_Container 

type TaskSpec_Container struct {
	Container *ContainerSpec `protobuf:"bytes,1,opt,name=container,oneof"`
}

func (*TaskSpec_Container) GoString 

func (this *TaskSpec_Container) GoString() string

func (*TaskSpec_Container) MarshalTo 

func (m *TaskSpec_Container) MarshalTo(data []byte) (int, error)

func (*TaskSpec_Container) Size 

func (m *TaskSpec_Container) Size() (n int)

func (*TaskSpec_Container) String 

func (this *TaskSpec_Container) String() string

type TaskState 

type TaskState int32

TaskState enumerates the states that a task progresses through within an agent. States are designed to be monotonically increasing, such that if two states are seen by a task, the greater of the new represents the true state. 

const (
	TaskStateNew       TaskState = 0
	TaskStateAllocated TaskState = 64
	TaskStatePending   TaskState = 128
	TaskStateAssigned  TaskState = 192
	TaskStateAccepted  TaskState = 256
	TaskStatePreparing TaskState = 320
	TaskStateReady     TaskState = 384
	TaskStateStarting  TaskState = 448
	TaskStateRunning   TaskState = 512
	TaskStateCompleted TaskState = 576
	TaskStateShutdown  TaskState = 640
	TaskStateFailed    TaskState = 704
	TaskStateRejected  TaskState = 768
)

func (TaskState) EnumDescriptor 

func (TaskState) EnumDescriptor() ([]byte, []int)

func (TaskState) String 

func (x TaskState) String() string

type TaskStatus 

type TaskStatus struct {
	Timestamp *docker_swarmkit_v1.Timestamp `protobuf:"bytes,1,opt,name=timestamp" json:"timestamp,omitempty"`
	// State expresses the current state of the task.
	State TaskState `protobuf:"varint,2,opt,name=state,proto3,enum=docker.swarmkit.v1.TaskState" json:"state,omitempty"`
	// Message reports a message for the task status. This should provide a
	// human readable message that can point to how the task actually arrived
	// at a current state.
	//
	// As a convention, we place the a small message here that led to the
	// current state. For example, if the task is in ready, because it was
	// prepared, we'd place "prepared" in this field. If we skipped preparation
	// because the task is prepared, we would put "already prepared" in this
	// field.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Err is set if the task is in an error state.
	//
	// The following states should report a companion error:
	//
	// 	FAILED, REJECTED
	//
	// TODO(stevvooe) Integrate this field with the error interface.
	Err string `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
	// Container status contains container specific status information.
	//
	// Types that are valid to be assigned to RuntimeStatus:
	//	*TaskStatus_Container
	RuntimeStatus isTaskStatus_RuntimeStatus `protobuf_oneof:"runtime_status"`
}

func (*TaskStatus) Copy 

func (m *TaskStatus) Copy() *TaskStatus

func (*TaskStatus) Descriptor 

func (*TaskStatus) Descriptor() ([]byte, []int)

func (*TaskStatus) GetContainer 

func (m *TaskStatus) GetContainer() *ContainerStatus

func (*TaskStatus) GetRuntimeStatus 

func (m *TaskStatus) GetRuntimeStatus() isTaskStatus_RuntimeStatus

func (*TaskStatus) GoString 

func (this *TaskStatus) GoString() string

func (*TaskStatus) Marshal 

func (m *TaskStatus) Marshal() (data []byte, err error)

func (*TaskStatus) MarshalTo 

func (m *TaskStatus) MarshalTo(data []byte) (int, error)

func (*TaskStatus) ProtoMessage 

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) Reset 

func (m *TaskStatus) Reset()

func (*TaskStatus) Size 

func (m *TaskStatus) Size() (n int)

func (*TaskStatus) String 

func (this *TaskStatus) String() string

func (*TaskStatus) Unmarshal 

func (m *TaskStatus) Unmarshal(data []byte) error

func (*TaskStatus) XXX_OneofFuncs 

func (*TaskStatus) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type TaskStatus_Container 

type TaskStatus_Container struct {
	Container *ContainerStatus `protobuf:"bytes,5,opt,name=container,oneof"`
}

func (*TaskStatus_Container) GoString 

func (this *TaskStatus_Container) GoString() string

func (*TaskStatus_Container) MarshalTo 

func (m *TaskStatus_Container) MarshalTo(data []byte) (int, error)

func (*TaskStatus_Container) Size 

func (m *TaskStatus_Container) Size() (n int)

func (*TaskStatus_Container) String 

func (this *TaskStatus_Container) String() string

type TasksMessage 

type TasksMessage struct {
	// Tasks is the set of tasks that should be running on the node.
	// Tasks outside of this set running on the node should be terminated.
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
}

func (*TasksMessage) Copy 

func (m *TasksMessage) Copy() *TasksMessage

func (*TasksMessage) Descriptor 

func (*TasksMessage) Descriptor() ([]byte, []int)

func (*TasksMessage) GoString 

func (this *TasksMessage) GoString() string

func (*TasksMessage) Marshal 

func (m *TasksMessage) Marshal() (data []byte, err error)

func (*TasksMessage) MarshalTo 

func (m *TasksMessage) MarshalTo(data []byte) (int, error)

func (*TasksMessage) ProtoMessage 

func (*TasksMessage) ProtoMessage()

func (*TasksMessage) Reset 

func (m *TasksMessage) Reset()

func (*TasksMessage) Size 

func (m *TasksMessage) Size() (n int)

func (*TasksMessage) String 

func (this *TasksMessage) String() string

func (*TasksMessage) Unmarshal 

func (m *TasksMessage) Unmarshal(data []byte) error

type TasksRequest 

type TasksRequest struct {
	SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
}

func (*TasksRequest) Copy 

func (m *TasksRequest) Copy() *TasksRequest

func (*TasksRequest) Descriptor 

func (*TasksRequest) Descriptor() ([]byte, []int)

func (*TasksRequest) GoString 

func (this *TasksRequest) GoString() string

func (*TasksRequest) Marshal 

func (m *TasksRequest) Marshal() (data []byte, err error)

func (*TasksRequest) MarshalTo 

func (m *TasksRequest) MarshalTo(data []byte) (int, error)

func (*TasksRequest) ProtoMessage 

func (*TasksRequest) ProtoMessage()

func (*TasksRequest) Reset 

func (m *TasksRequest) Reset()

func (*TasksRequest) Size 

func (m *TasksRequest) Size() (n int)

func (*TasksRequest) String 

func (this *TasksRequest) String() string

func (*TasksRequest) Unmarshal 

func (m *TasksRequest) Unmarshal(data []byte) error

type UpdateClusterRequest 

type UpdateClusterRequest struct {
	// ClusterID is the cluster ID to update.
	ClusterID string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// ClusterVersion is the version of the cluster being updated.
	ClusterVersion *Version `protobuf:"bytes,2,opt,name=cluster_version,json=clusterVersion" json:"cluster_version,omitempty"`
	// Spec is the new spec to apply to the cluster.
	Spec *ClusterSpec `protobuf:"bytes,3,opt,name=spec" json:"spec,omitempty"`
	// Rotation contains flags for join token rotation
	Rotation JoinTokenRotation `protobuf:"bytes,4,opt,name=rotation" json:"rotation"`
}

func (*UpdateClusterRequest) Copy 

func (m *UpdateClusterRequest) Copy() *UpdateClusterRequest

func (*UpdateClusterRequest) Descriptor 

func (*UpdateClusterRequest) Descriptor() ([]byte, []int)

func (*UpdateClusterRequest) GoString 

func (this *UpdateClusterRequest) GoString() string

func (*UpdateClusterRequest) Marshal 

func (m *UpdateClusterRequest) Marshal() (data []byte, err error)

func (*UpdateClusterRequest) MarshalTo 

func (m *UpdateClusterRequest) MarshalTo(data []byte) (int, error)

func (*UpdateClusterRequest) ProtoMessage 

func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) Reset 

func (m *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) Size 

func (m *UpdateClusterRequest) Size() (n int)

func (*UpdateClusterRequest) String 

func (this *UpdateClusterRequest) String() string

func (*UpdateClusterRequest) Unmarshal 

func (m *UpdateClusterRequest) Unmarshal(data []byte) error

type UpdateClusterResponse 

type UpdateClusterResponse struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`
}

func (*UpdateClusterResponse) Copy 

func (m *UpdateClusterResponse) Copy() *UpdateClusterResponse

func (*UpdateClusterResponse) Descriptor 

func (*UpdateClusterResponse) Descriptor() ([]byte, []int)

func (*UpdateClusterResponse) GoString 

func (this *UpdateClusterResponse) GoString() string

func (*UpdateClusterResponse) Marshal 

func (m *UpdateClusterResponse) Marshal() (data []byte, err error)

func (*UpdateClusterResponse) MarshalTo 

func (m *UpdateClusterResponse) MarshalTo(data []byte) (int, error)

func (*UpdateClusterResponse) ProtoMessage 

func (*UpdateClusterResponse) ProtoMessage()

func (*UpdateClusterResponse) Reset 

func (m *UpdateClusterResponse) Reset()

func (*UpdateClusterResponse) Size 

func (m *UpdateClusterResponse) Size() (n int)

func (*UpdateClusterResponse) String 

func (this *UpdateClusterResponse) String() string

func (*UpdateClusterResponse) Unmarshal 

func (m *UpdateClusterResponse) Unmarshal(data []byte) error

type UpdateConfig 

type UpdateConfig struct {
	// Maximum number of tasks to be updated in one iteration.
	// 0 means unlimited parallelism.
	Parallelism uint64 `protobuf:"varint,1,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// Amount of time between updates.
	Delay docker_swarmkit_v11.Duration `protobuf:"bytes,2,opt,name=delay" json:"delay"`
	// FailureAction is the action to take when an update failures.
	// Currently, a failure is defined as a single updated task failing to
	// reach the RUNNING state. In the future, there will be configuration
	// to define what is treated as a failure (see #486 for a proposal).
	FailureAction UpdateConfig_FailureAction `` /* 152-byte string literal not displayed */
}

UpdateConfig specifies the rate and policy of updates. TODO(aluzzardi): Consider making this a oneof with RollingStrategy and LockstepStrategy.

func (*UpdateConfig) Copy 

func (m *UpdateConfig) Copy() *UpdateConfig

func (*UpdateConfig) Descriptor 

func (*UpdateConfig) Descriptor() ([]byte, []int)

func (*UpdateConfig) GoString 

func (this *UpdateConfig) GoString() string

func (*UpdateConfig) Marshal 

func (m *UpdateConfig) Marshal() (data []byte, err error)

func (*UpdateConfig) MarshalTo 

func (m *UpdateConfig) MarshalTo(data []byte) (int, error)

func (*UpdateConfig) ProtoMessage 

func (*UpdateConfig) ProtoMessage()

func (*UpdateConfig) Reset 

func (m *UpdateConfig) Reset()

func (*UpdateConfig) Size 

func (m *UpdateConfig) Size() (n int)

func (*UpdateConfig) String 

func (this *UpdateConfig) String() string

func (*UpdateConfig) Unmarshal 

func (m *UpdateConfig) Unmarshal(data []byte) error

type UpdateConfig_FailureAction 

type UpdateConfig_FailureAction int32
const (
	UpdateConfig_PAUSE    UpdateConfig_FailureAction = 0
	UpdateConfig_CONTINUE UpdateConfig_FailureAction = 1
)

func (UpdateConfig_FailureAction) EnumDescriptor 

func (UpdateConfig_FailureAction) EnumDescriptor() ([]byte, []int)

func (UpdateConfig_FailureAction) String 

func (x UpdateConfig_FailureAction) String() string

type UpdateNodeRequest 

type UpdateNodeRequest struct {
	NodeID      string    `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	NodeVersion *Version  `protobuf:"bytes,2,opt,name=node_version,json=nodeVersion" json:"node_version,omitempty"`
	Spec        *NodeSpec `protobuf:"bytes,3,opt,name=spec" json:"spec,omitempty"`
}

UpdateNodeRequest requests an update to the specified node. This may be used to request a new availability for a node, such as PAUSE. Invalid updates will be denied and cause an error.

func (*UpdateNodeRequest) Copy 

func (m *UpdateNodeRequest) Copy() *UpdateNodeRequest

func (*UpdateNodeRequest) Descriptor 

func (*UpdateNodeRequest) Descriptor() ([]byte, []int)

func (*UpdateNodeRequest) GoString 

func (this *UpdateNodeRequest) GoString() string

func (*UpdateNodeRequest) Marshal 

func (m *UpdateNodeRequest) Marshal() (data []byte, err error)

func (*UpdateNodeRequest) MarshalTo 

func (m *UpdateNodeRequest) MarshalTo(data []byte) (int, error)

func (*UpdateNodeRequest) ProtoMessage 

func (*UpdateNodeRequest) ProtoMessage()

func (*UpdateNodeRequest) Reset 

func (m *UpdateNodeRequest) Reset()

func (*UpdateNodeRequest) Size 

func (m *UpdateNodeRequest) Size() (n int)

func (*UpdateNodeRequest) String 

func (this *UpdateNodeRequest) String() string

func (*UpdateNodeRequest) Unmarshal 

func (m *UpdateNodeRequest) Unmarshal(data []byte) error

type UpdateNodeResponse 

type UpdateNodeResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
}

func (*UpdateNodeResponse) Copy 

func (m *UpdateNodeResponse) Copy() *UpdateNodeResponse

func (*UpdateNodeResponse) Descriptor 

func (*UpdateNodeResponse) Descriptor() ([]byte, []int)

func (*UpdateNodeResponse) GoString 

func (this *UpdateNodeResponse) GoString() string

func (*UpdateNodeResponse) Marshal 

func (m *UpdateNodeResponse) Marshal() (data []byte, err error)

func (*UpdateNodeResponse) MarshalTo 

func (m *UpdateNodeResponse) MarshalTo(data []byte) (int, error)

func (*UpdateNodeResponse) ProtoMessage 

func (*UpdateNodeResponse) ProtoMessage()

func (*UpdateNodeResponse) Reset 

func (m *UpdateNodeResponse) Reset()

func (*UpdateNodeResponse) Size 

func (m *UpdateNodeResponse) Size() (n int)

func (*UpdateNodeResponse) String 

func (this *UpdateNodeResponse) String() string

func (*UpdateNodeResponse) Unmarshal 

func (m *UpdateNodeResponse) Unmarshal(data []byte) error

type UpdateServiceRequest 

type UpdateServiceRequest struct {
	ServiceID      string       `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	ServiceVersion *Version     `protobuf:"bytes,2,opt,name=service_version,json=serviceVersion" json:"service_version,omitempty"`
	Spec           *ServiceSpec `protobuf:"bytes,3,opt,name=spec" json:"spec,omitempty"`
}

func (*UpdateServiceRequest) Copy 

func (m *UpdateServiceRequest) Copy() *UpdateServiceRequest

func (*UpdateServiceRequest) Descriptor 

func (*UpdateServiceRequest) Descriptor() ([]byte, []int)

func (*UpdateServiceRequest) GoString 

func (this *UpdateServiceRequest) GoString() string

func (*UpdateServiceRequest) Marshal 

func (m *UpdateServiceRequest) Marshal() (data []byte, err error)

func (*UpdateServiceRequest) MarshalTo 

func (m *UpdateServiceRequest) MarshalTo(data []byte) (int, error)

func (*UpdateServiceRequest) ProtoMessage 

func (*UpdateServiceRequest) ProtoMessage()

func (*UpdateServiceRequest) Reset 

func (m *UpdateServiceRequest) Reset()

func (*UpdateServiceRequest) Size 

func (m *UpdateServiceRequest) Size() (n int)

func (*UpdateServiceRequest) String 

func (this *UpdateServiceRequest) String() string

func (*UpdateServiceRequest) Unmarshal 

func (m *UpdateServiceRequest) Unmarshal(data []byte) error

type UpdateServiceResponse 

type UpdateServiceResponse struct {
	Service *Service `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
}

func (*UpdateServiceResponse) Copy 

func (m *UpdateServiceResponse) Copy() *UpdateServiceResponse

func (*UpdateServiceResponse) Descriptor 

func (*UpdateServiceResponse) Descriptor() ([]byte, []int)

func (*UpdateServiceResponse) GoString 

func (this *UpdateServiceResponse) GoString() string

func (*UpdateServiceResponse) Marshal 

func (m *UpdateServiceResponse) Marshal() (data []byte, err error)

func (*UpdateServiceResponse) MarshalTo 

func (m *UpdateServiceResponse) MarshalTo(data []byte) (int, error)

func (*UpdateServiceResponse) ProtoMessage 

func (*UpdateServiceResponse) ProtoMessage()

func (*UpdateServiceResponse) Reset 

func (m *UpdateServiceResponse) Reset()

func (*UpdateServiceResponse) Size 

func (m *UpdateServiceResponse) Size() (n int)

func (*UpdateServiceResponse) String 

func (this *UpdateServiceResponse) String() string

func (*UpdateServiceResponse) Unmarshal 

func (m *UpdateServiceResponse) Unmarshal(data []byte) error

type UpdateStatus 

type UpdateStatus struct {
	// State is the state of this update. It indicates whether the
	// update is in progress, completed, or is paused.
	State UpdateStatus_UpdateState `protobuf:"varint,1,opt,name=state,proto3,enum=docker.swarmkit.v1.UpdateStatus_UpdateState" json:"state,omitempty"`
	// StartedAt is the time at which the update was started.
	StartedAt *docker_swarmkit_v1.Timestamp `protobuf:"bytes,2,opt,name=started_at,json=startedAt" json:"started_at,omitempty"`
	// CompletedAt is the time at which the update completed.
	CompletedAt *docker_swarmkit_v1.Timestamp `protobuf:"bytes,3,opt,name=completed_at,json=completedAt" json:"completed_at,omitempty"`
	// Message explains how the update got into its current state. For
	// example, if the update is paused, it will explain what is preventing
	// the update from proceeding (typically the failure of a task to start up
	// when OnFailure is PAUSE).
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
}

UpdateStatus is the status of an update in progress.

func (*UpdateStatus) Copy 

func (m *UpdateStatus) Copy() *UpdateStatus

func (*UpdateStatus) Descriptor 

func (*UpdateStatus) Descriptor() ([]byte, []int)

func (*UpdateStatus) GoString 

func (this *UpdateStatus) GoString() string

func (*UpdateStatus) Marshal 

func (m *UpdateStatus) Marshal() (data []byte, err error)

func (*UpdateStatus) MarshalTo 

func (m *UpdateStatus) MarshalTo(data []byte) (int, error)

func (*UpdateStatus) ProtoMessage 

func (*UpdateStatus) ProtoMessage()

func (*UpdateStatus) Reset 

func (m *UpdateStatus) Reset()

func (*UpdateStatus) Size 

func (m *UpdateStatus) Size() (n int)

func (*UpdateStatus) String 

func (this *UpdateStatus) String() string

func (*UpdateStatus) Unmarshal 

func (m *UpdateStatus) Unmarshal(data []byte) error

type UpdateStatus_UpdateState 

type UpdateStatus_UpdateState int32
const (
	UpdateStatus_UNKNOWN   UpdateStatus_UpdateState = 0
	UpdateStatus_UPDATING  UpdateStatus_UpdateState = 1
	UpdateStatus_PAUSED    UpdateStatus_UpdateState = 2
	UpdateStatus_COMPLETED UpdateStatus_UpdateState = 3
)

func (UpdateStatus_UpdateState) EnumDescriptor 

func (UpdateStatus_UpdateState) EnumDescriptor() ([]byte, []int)

func (UpdateStatus_UpdateState) String 

func (x UpdateStatus_UpdateState) String() string

type UpdateTaskStatusRequest 

type UpdateTaskStatusRequest struct {
	// Tasks should contain all statuses for running tasks. Only the status
	// field must be set. The spec is not required.
	SessionID string                                      `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Updates   []*UpdateTaskStatusRequest_TaskStatusUpdate `protobuf:"bytes,3,rep,name=updates" json:"updates,omitempty"`
}

func (*UpdateTaskStatusRequest) Copy 

func (m *UpdateTaskStatusRequest) Copy() *UpdateTaskStatusRequest

func (*UpdateTaskStatusRequest) Descriptor 

func (*UpdateTaskStatusRequest) Descriptor() ([]byte, []int)

func (*UpdateTaskStatusRequest) GoString 

func (this *UpdateTaskStatusRequest) GoString() string

func (*UpdateTaskStatusRequest) Marshal 

func (m *UpdateTaskStatusRequest) Marshal() (data []byte, err error)

func (*UpdateTaskStatusRequest) MarshalTo 

func (m *UpdateTaskStatusRequest) MarshalTo(data []byte) (int, error)

func (*UpdateTaskStatusRequest) ProtoMessage 

func (*UpdateTaskStatusRequest) ProtoMessage()

func (*UpdateTaskStatusRequest) Reset 

func (m *UpdateTaskStatusRequest) Reset()

func (*UpdateTaskStatusRequest) Size 

func (m *UpdateTaskStatusRequest) Size() (n int)

func (*UpdateTaskStatusRequest) String 

func (this *UpdateTaskStatusRequest) String() string

func (*UpdateTaskStatusRequest) Unmarshal 

func (m *UpdateTaskStatusRequest) Unmarshal(data []byte) error

type UpdateTaskStatusRequest_TaskStatusUpdate 

type UpdateTaskStatusRequest_TaskStatusUpdate struct {
	TaskID string      `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Status *TaskStatus `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
}

func (*UpdateTaskStatusRequest_TaskStatusUpdate) Copy 

func (m *UpdateTaskStatusRequest_TaskStatusUpdate) Copy() *UpdateTaskStatusRequest_TaskStatusUpdate

func (*UpdateTaskStatusRequest_TaskStatusUpdate) Descriptor 

func (*UpdateTaskStatusRequest_TaskStatusUpdate) Descriptor() ([]byte, []int)

func (*UpdateTaskStatusRequest_TaskStatusUpdate) GoString 

func (this *UpdateTaskStatusRequest_TaskStatusUpdate) GoString() string

func (*UpdateTaskStatusRequest_TaskStatusUpdate) Marshal 

func (m *UpdateTaskStatusRequest_TaskStatusUpdate) Marshal() (data []byte, err error)

func (*UpdateTaskStatusRequest_TaskStatusUpdate) MarshalTo 

func (m *UpdateTaskStatusRequest_TaskStatusUpdate) MarshalTo(data []byte) (int, error)

func (*UpdateTaskStatusRequest_TaskStatusUpdate) ProtoMessage 

func (*UpdateTaskStatusRequest_TaskStatusUpdate) ProtoMessage()

func (*UpdateTaskStatusRequest_TaskStatusUpdate) Reset 

func (m *UpdateTaskStatusRequest_TaskStatusUpdate) Reset()

func (*UpdateTaskStatusRequest_TaskStatusUpdate) Size 

func (m *UpdateTaskStatusRequest_TaskStatusUpdate) Size() (n int)

func (*UpdateTaskStatusRequest_TaskStatusUpdate) String 

func (this *UpdateTaskStatusRequest_TaskStatusUpdate) String() string

func (*UpdateTaskStatusRequest_TaskStatusUpdate) Unmarshal 

func (m *UpdateTaskStatusRequest_TaskStatusUpdate) Unmarshal(data []byte) error

type UpdateTaskStatusResponse 

type UpdateTaskStatusResponse struct {
}

func (*UpdateTaskStatusResponse) Copy 

func (m *UpdateTaskStatusResponse) Copy() *UpdateTaskStatusResponse

func (*UpdateTaskStatusResponse) Descriptor 

func (*UpdateTaskStatusResponse) Descriptor() ([]byte, []int)

func (*UpdateTaskStatusResponse) GoString 

func (this *UpdateTaskStatusResponse) GoString() string

func (*UpdateTaskStatusResponse) Marshal 

func (m *UpdateTaskStatusResponse) Marshal() (data []byte, err error)

func (*UpdateTaskStatusResponse) MarshalTo 

func (m *UpdateTaskStatusResponse) MarshalTo(data []byte) (int, error)

func (*UpdateTaskStatusResponse) ProtoMessage 

func (*UpdateTaskStatusResponse) ProtoMessage()

func (*UpdateTaskStatusResponse) Reset 

func (m *UpdateTaskStatusResponse) Reset()

func (*UpdateTaskStatusResponse) Size 

func (m *UpdateTaskStatusResponse) Size() (n int)

func (*UpdateTaskStatusResponse) String 

func (this *UpdateTaskStatusResponse) String() string

func (*UpdateTaskStatusResponse) Unmarshal 

func (m *UpdateTaskStatusResponse) Unmarshal(data []byte) error

type Version 

type Version struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
}

Version tracks the last time an object in the store was updated.

func (*Version) Copy 

func (m *Version) Copy() *Version

func (*Version) Descriptor 

func (*Version) Descriptor() ([]byte, []int)

func (*Version) GoString 

func (this *Version) GoString() string

func (*Version) Marshal 

func (m *Version) Marshal() (data []byte, err error)

func (*Version) MarshalTo 

func (m *Version) MarshalTo(data []byte) (int, error)

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) Reset 

func (m *Version) Reset()

func (*Version) Size 

func (m *Version) Size() (n int)

func (*Version) String 

func (this *Version) String() string

func (*Version) Unmarshal 

func (m *Version) Unmarshal(data []byte) error

type WeightedPeer 

type WeightedPeer struct {
	Peer   *Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
	Weight int64 `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
}

WeightedPeer should be used anywhere where we are describing a remote peer with a weight.

func (*WeightedPeer) Copy 

func (m *WeightedPeer) Copy() *WeightedPeer

func (*WeightedPeer) Descriptor 

func (*WeightedPeer) Descriptor() ([]byte, []int)

func (*WeightedPeer) GoString 

func (this *WeightedPeer) GoString() string

func (*WeightedPeer) Marshal 

func (m *WeightedPeer) Marshal() (data []byte, err error)

func (*WeightedPeer) MarshalTo 

func (m *WeightedPeer) MarshalTo(data []byte) (int, error)

func (*WeightedPeer) ProtoMessage 

func (*WeightedPeer) ProtoMessage()

func (*WeightedPeer) Reset 

func (m *WeightedPeer) Reset()

func (*WeightedPeer) Size 

func (m *WeightedPeer) Size() (n int)

func (*WeightedPeer) String 

func (this *WeightedPeer) String() string

func (*WeightedPeer) Unmarshal 

func (m *WeightedPeer) Unmarshal(data []byte) error

Source Files

View all Source files

Directories

Path Synopsis
Package duration is a generated protocol buffer package.
 Package duration is a generated protocol buffer package.
Package timestamp is a generated protocol buffer package.
 Package timestamp is a generated protocol buffer package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.