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 (*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 (*AcceptancePolicy_RoleAdmissionPolicy) Descriptor

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

func (*AcceptancePolicy_RoleAdmissionPolicy) GoString

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 (*AcceptancePolicy_RoleAdmissionPolicy) Size

func (*AcceptancePolicy_RoleAdmissionPolicy) 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 (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Descriptor

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) GoString

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Marshal

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

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) MarshalTo

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) ProtoMessage

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Reset

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Size

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) String

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Unmarshal

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 (*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 (*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 (*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 (*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 (*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 (*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

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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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

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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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

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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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

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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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

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 (*ServiceSpec_NetworkAttachmentConfig) Descriptor

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

func (*ServiceSpec_NetworkAttachmentConfig) GoString

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 (*ServiceSpec_NetworkAttachmentConfig) Size

func (*ServiceSpec_NetworkAttachmentConfig) 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 (*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 (*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

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 (*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 (*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 (*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 (*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 (*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 (*UpdateTaskStatusRequest_TaskStatusUpdate) Descriptor

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

func (*UpdateTaskStatusRequest_TaskStatusUpdate) GoString

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) Reset

func (*UpdateTaskStatusRequest_TaskStatusUpdate) Size

func (*UpdateTaskStatusRequest_TaskStatusUpdate) String

func (*UpdateTaskStatusRequest_TaskStatusUpdate) Unmarshal

type UpdateTaskStatusResponse

type UpdateTaskStatusResponse struct {
}

func (*UpdateTaskStatusResponse) Copy

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

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