api

package
v0.0.0-...-120fae7 Latest Latest
Warning

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

Go to latest
Published: Feb 16, 2017 License: Apache-2.0 Imports: 20 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
resource.proto
logbroker.proto

It has these top-level messages:

Version
Annotations
Resources
ResourceRequirements
Platform
PluginDescription
EngineDescription
NodeDescription
RaftMemberStatus
NodeStatus
Image
Mount
RestartPolicy
UpdateConfig
UpdateStatus
ContainerStatus
PortStatus
TaskStatus
NetworkAttachmentConfig
IPAMConfig
PortConfig
Driver
IPAMOptions
Peer
WeightedPeer
IssuanceStatus
AcceptancePolicy
ExternalCA
CAConfig
OrchestrationConfig
TaskDefaults
DispatcherConfig
RaftConfig
EncryptionConfig
SpreadOver
PlacementPreference
Placement
JoinTokens
RootCA
Certificate
EncryptionKey
ManagerStatus
SecretReference
BlacklistedCertificate
HealthConfig
MaybeEncryptedRecord
NodeSpec
ServiceSpec
ReplicatedService
GlobalService
TaskSpec
NetworkAttachmentSpec
ContainerSpec
EndpointSpec
NetworkSpec
ClusterSpec
SecretSpec
Meta
Node
Service
Endpoint
Task
NetworkAttachment
Network
Cluster
Secret
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
KeyRotation
UpdateClusterRequest
UpdateClusterResponse
GetSecretRequest
GetSecretResponse
UpdateSecretRequest
UpdateSecretResponse
ListSecretsRequest
ListSecretsResponse
CreateSecretRequest
CreateSecretResponse
RemoveSecretRequest
RemoveSecretResponse
SessionRequest
SessionMessage
HeartbeatRequest
HeartbeatResponse
UpdateTaskStatusRequest
UpdateTaskStatusResponse
TasksRequest
TasksMessage
AssignmentsRequest
Assignment
AssignmentChange
AssignmentsMessage
NodeCertificateStatusRequest
NodeCertificateStatusResponse
IssueNodeCertificateRequest
IssueNodeCertificateResponse
GetRootCACertificateRequest
GetRootCACertificateResponse
GetUnlockKeyRequest
GetUnlockKeyResponse
StoreSnapshot
ClusterSnapshot
Snapshot
RaftMember
JoinRequest
JoinResponse
LeaveRequest
LeaveResponse
ProcessRaftMessageRequest
ProcessRaftMessageResponse
ResolveAddressRequest
ResolveAddressResponse
InternalRaftRequest
StoreAction
HealthCheckRequest
HealthCheckResponse
AttachNetworkRequest
AttachNetworkResponse
DetachNetworkRequest
DetachNetworkResponse
LogSubscriptionOptions
LogSelector
LogContext
LogMessage
SubscribeLogsRequest
SubscribeLogsMessage
ListenSubscriptionsRequest
SubscriptionMessage
PublishLogsMessage
PublishLogsResponse

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 (
	ErrInvalidLengthLogbroker = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogbroker   = 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 (
	ErrInvalidLengthResource = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResource   = 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 AssignmentChange_AssignmentAction_name = map[int32]string{
	0: "UPDATE",
	1: "REMOVE",
}
View Source
var AssignmentChange_AssignmentAction_value = map[string]int32{
	"UPDATE": 0,
	"REMOVE": 1,
}
View Source
var AssignmentsMessage_Type_name = map[int32]string{
	0: "COMPLETE",
	1: "INCREMENTAL",
}
View Source
var AssignmentsMessage_Type_value = map[string]int32{
	"COMPLETE":    0,
	"INCREMENTAL": 1,
}
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",
	5: "ROTATE",
}
View Source
var IssuanceStatus_State_value = map[string]int32{
	"UNKNOWN": 0,
	"RENEW":   1,
	"PENDING": 2,
	"ISSUED":  3,
	"FAILED":  4,
	"ROTATE":  5,
}
View Source
var LogStream_name = map[int32]string{
	0: "LOG_STREAM_UNKNOWN",
	1: "LOG_STREAM_STDOUT",
	2: "LOG_STREAM_STDERR",
}
View Source
var LogStream_value = map[string]int32{
	"LOG_STREAM_UNKNOWN": 0,
	"LOG_STREAM_STDOUT":  1,
	"LOG_STREAM_STDERR":  2,
}
View Source
var MaybeEncryptedRecord_Algorithm_name = map[int32]string{
	0: "NONE",
	1: "SECRETBOX_SALSA20_POLY1305",
}
View Source
var MaybeEncryptedRecord_Algorithm_value = map[string]int32{
	"NONE":                       0,
	"SECRETBOX_SALSA20_POLY1305": 1,
}
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 PortConfig_PublishMode_name = map[int32]string{
	0: "INGRESS",
	1: "HOST",
}
View Source
var PortConfig_PublishMode_value = map[string]int32{
	"INGRESS": 0,
	"HOST":    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:  "PENDING",
	192: "ASSIGNED",
	256: "ACCEPTED",
	320: "PREPARING",
	384: "READY",
	448: "STARTING",
	512: "RUNNING",
	576: "COMPLETE",
	640: "SHUTDOWN",
	704: "FAILED",
	768: "REJECTED",
	832: "ORPHANED",
}
View Source
var TaskState_value = map[string]int32{
	"NEW":       0,
	"PENDING":   64,
	"ASSIGNED":  192,
	"ACCEPTED":  256,
	"PREPARING": 320,
	"READY":     384,
	"STARTING":  448,
	"RUNNING":   512,
	"COMPLETE":  576,
	"SHUTDOWN":  640,
	"FAILED":    704,
	"REJECTED":  768,
	"ORPHANED":  832,
}
View Source
var UpdateConfig_FailureAction_name = map[int32]string{
	0: "PAUSE",
	1: "CONTINUE",
	2: "ROLLBACK",
}
View Source
var UpdateConfig_FailureAction_value = map[string]int32{
	"PAUSE":    0,
	"CONTINUE": 1,
	"ROLLBACK": 2,
}
View Source
var UpdateServiceRequest_Rollback_name = map[int32]string{
	0: "NONE",
	1: "PREVIOUS",
}
View Source
var UpdateServiceRequest_Rollback_value = map[string]int32{
	"NONE":     0,
	"PREVIOUS": 1,
}
View Source
var UpdateStatus_UpdateState_name = map[int32]string{
	0: "UNKNOWN",
	1: "UPDATING",
	2: "PAUSED",
	3: "COMPLETED",
	4: "ROLLBACK_STARTED",
	5: "ROLLBACK_PAUSED",
	6: "ROLLBACK_COMPLETED",
}
View Source
var UpdateStatus_UpdateState_value = map[string]int32{
	"UNKNOWN":            0,
	"UPDATING":           1,
	"PAUSED":             2,
	"COMPLETED":          3,
	"ROLLBACK_STARTED":   4,
	"ROLLBACK_PAUSED":    5,
	"ROLLBACK_COMPLETED": 6,
}

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 RegisterLogBrokerServer

func RegisterLogBrokerServer(s *grpc.Server, srv LogBrokerServer)

func RegisterLogsServer

func RegisterLogsServer(s *grpc.Server, srv LogsServer)

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)

func RegisterResourceAllocatorServer

func RegisterResourceAllocatorServer(s *grpc.Server, srv ResourceAllocatorServer)

Types

type AcceptancePolicy

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

func (*AcceptancePolicy) Copy

func (*AcceptancePolicy) CopyFrom

func (m *AcceptancePolicy) CopyFrom(src interface{})

func (*AcceptancePolicy) Descriptor

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

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

func (m *AcceptancePolicy_RoleAdmissionPolicy) CopyFrom(src interface{})

func (*AcceptancePolicy_RoleAdmissionPolicy) Descriptor

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

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

func (m *AcceptancePolicy_RoleAdmissionPolicy_Secret) CopyFrom(src interface{})

func (*AcceptancePolicy_RoleAdmissionPolicy_Secret) Descriptor

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

func (m *Annotations) CopyFrom(src interface{})

func (*Annotations) Descriptor

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

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 Assignment

type Assignment struct {
	// Types that are valid to be assigned to Item:
	//	*Assignment_Task
	//	*Assignment_Secret
	Item isAssignment_Item `protobuf_oneof:"item"`
}

func (*Assignment) Copy

func (m *Assignment) Copy() *Assignment

func (*Assignment) CopyFrom

func (m *Assignment) CopyFrom(src interface{})

func (*Assignment) Descriptor

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

func (*Assignment) GetItem

func (m *Assignment) GetItem() isAssignment_Item

func (*Assignment) GetSecret

func (m *Assignment) GetSecret() *Secret

func (*Assignment) GetTask

func (m *Assignment) GetTask() *Task

func (*Assignment) Marshal

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

func (*Assignment) MarshalTo

func (m *Assignment) MarshalTo(dAtA []byte) (int, error)

func (*Assignment) ProtoMessage

func (*Assignment) ProtoMessage()

func (*Assignment) Reset

func (m *Assignment) Reset()

func (*Assignment) Size

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

func (*Assignment) String

func (this *Assignment) String() string

func (*Assignment) Unmarshal

func (m *Assignment) Unmarshal(dAtA []byte) error

func (*Assignment) XXX_OneofFuncs

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

type AssignmentChange struct {
	Assignment *Assignment                       `protobuf:"bytes,1,opt,name=assignment" json:"assignment,omitempty"`
	Action     AssignmentChange_AssignmentAction `protobuf:"varint,2,opt,name=action,proto3,enum=docker.swarmkit.v1.AssignmentChange_AssignmentAction" json:"action,omitempty"`
}

func (*AssignmentChange) Copy

func (*AssignmentChange) CopyFrom

func (m *AssignmentChange) CopyFrom(src interface{})

func (*AssignmentChange) Descriptor

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

func (*AssignmentChange) Marshal

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

func (*AssignmentChange) MarshalTo

func (m *AssignmentChange) MarshalTo(dAtA []byte) (int, error)

func (*AssignmentChange) ProtoMessage

func (*AssignmentChange) ProtoMessage()

func (*AssignmentChange) Reset

func (m *AssignmentChange) Reset()

func (*AssignmentChange) Size

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

func (*AssignmentChange) String

func (this *AssignmentChange) String() string

func (*AssignmentChange) Unmarshal

func (m *AssignmentChange) Unmarshal(dAtA []byte) error

type AssignmentChange_AssignmentAction

type AssignmentChange_AssignmentAction int32
const (
	AssignmentChange_AssignmentActionUpdate AssignmentChange_AssignmentAction = 0
	AssignmentChange_AssignmentActionRemove AssignmentChange_AssignmentAction = 1
)

func (AssignmentChange_AssignmentAction) EnumDescriptor

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

func (AssignmentChange_AssignmentAction) String

type Assignment_Secret

type Assignment_Secret struct {
	Secret *Secret `protobuf:"bytes,2,opt,name=secret,oneof"`
}

func (*Assignment_Secret) MarshalTo

func (m *Assignment_Secret) MarshalTo(dAtA []byte) (int, error)

func (*Assignment_Secret) Size

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

func (*Assignment_Secret) String

func (this *Assignment_Secret) String() string

type Assignment_Task

type Assignment_Task struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,oneof"`
}

func (*Assignment_Task) MarshalTo

func (m *Assignment_Task) MarshalTo(dAtA []byte) (int, error)

func (*Assignment_Task) Size

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

func (*Assignment_Task) String

func (this *Assignment_Task) String() string

type AssignmentsMessage

type AssignmentsMessage struct {
	Type AssignmentsMessage_Type `protobuf:"varint,1,opt,name=type,proto3,enum=docker.swarmkit.v1.AssignmentsMessage_Type" json:"type,omitempty"`
	// AppliesTo references the previous ResultsIn value, to chain
	// incremental updates together. For the first update in a stream,
	// AppliesTo is empty.  If AppliesTo does not match the previously
	// received ResultsIn, the consumer of the stream should start a new
	// Assignments stream to re-sync.
	AppliesTo string `protobuf:"bytes,2,opt,name=applies_to,json=appliesTo,proto3" json:"applies_to,omitempty"`
	// ResultsIn identifies the result of this assignments message, to
	// match against the next message's AppliesTo value and protect
	// against missed messages.
	ResultsIn string `protobuf:"bytes,3,opt,name=results_in,json=resultsIn,proto3" json:"results_in,omitempty"`
	// AssignmentChange is a set of changes to apply on this node.
	Changes []*AssignmentChange `protobuf:"bytes,4,rep,name=changes" json:"changes,omitempty"`
}

func (*AssignmentsMessage) Copy

func (*AssignmentsMessage) CopyFrom

func (m *AssignmentsMessage) CopyFrom(src interface{})

func (*AssignmentsMessage) Descriptor

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

func (*AssignmentsMessage) Marshal

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

func (*AssignmentsMessage) MarshalTo

func (m *AssignmentsMessage) MarshalTo(dAtA []byte) (int, error)

func (*AssignmentsMessage) ProtoMessage

func (*AssignmentsMessage) ProtoMessage()

func (*AssignmentsMessage) Reset

func (m *AssignmentsMessage) Reset()

func (*AssignmentsMessage) Size

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

func (*AssignmentsMessage) String

func (this *AssignmentsMessage) String() string

func (*AssignmentsMessage) Unmarshal

func (m *AssignmentsMessage) Unmarshal(dAtA []byte) error

type AssignmentsMessage_Type

type AssignmentsMessage_Type int32

AssignmentType specifies whether this assignment message carries the full state, or is an update to an existing state.

const (
	AssignmentsMessage_COMPLETE    AssignmentsMessage_Type = 0
	AssignmentsMessage_INCREMENTAL AssignmentsMessage_Type = 1
)

func (AssignmentsMessage_Type) EnumDescriptor

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

func (AssignmentsMessage_Type) String

func (x AssignmentsMessage_Type) String() string

type AssignmentsRequest

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

func (*AssignmentsRequest) Copy

func (*AssignmentsRequest) CopyFrom

func (m *AssignmentsRequest) CopyFrom(src interface{})

func (*AssignmentsRequest) Descriptor

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

func (*AssignmentsRequest) Marshal

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

func (*AssignmentsRequest) MarshalTo

func (m *AssignmentsRequest) MarshalTo(dAtA []byte) (int, error)

func (*AssignmentsRequest) ProtoMessage

func (*AssignmentsRequest) ProtoMessage()

func (*AssignmentsRequest) Reset

func (m *AssignmentsRequest) Reset()

func (*AssignmentsRequest) Size

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

func (*AssignmentsRequest) String

func (this *AssignmentsRequest) String() string

func (*AssignmentsRequest) Unmarshal

func (m *AssignmentsRequest) Unmarshal(dAtA []byte) error

type AttachNetworkRequest

type AttachNetworkRequest struct {
	Config      *NetworkAttachmentConfig `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"`
	ContainerID string                   `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*AttachNetworkRequest) Copy

func (*AttachNetworkRequest) CopyFrom

func (m *AttachNetworkRequest) CopyFrom(src interface{})

func (*AttachNetworkRequest) Descriptor

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

func (*AttachNetworkRequest) Marshal

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

func (*AttachNetworkRequest) MarshalTo

func (m *AttachNetworkRequest) MarshalTo(dAtA []byte) (int, error)

func (*AttachNetworkRequest) ProtoMessage

func (*AttachNetworkRequest) ProtoMessage()

func (*AttachNetworkRequest) Reset

func (m *AttachNetworkRequest) Reset()

func (*AttachNetworkRequest) Size

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

func (*AttachNetworkRequest) String

func (this *AttachNetworkRequest) String() string

func (*AttachNetworkRequest) Unmarshal

func (m *AttachNetworkRequest) Unmarshal(dAtA []byte) error

type AttachNetworkResponse

type AttachNetworkResponse struct {
	AttachmentID string `protobuf:"bytes,1,opt,name=attachment_id,json=attachmentId,proto3" json:"attachment_id,omitempty"`
}

func (*AttachNetworkResponse) Copy

func (*AttachNetworkResponse) CopyFrom

func (m *AttachNetworkResponse) CopyFrom(src interface{})

func (*AttachNetworkResponse) Descriptor

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

func (*AttachNetworkResponse) Marshal

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

func (*AttachNetworkResponse) MarshalTo

func (m *AttachNetworkResponse) MarshalTo(dAtA []byte) (int, error)

func (*AttachNetworkResponse) ProtoMessage

func (*AttachNetworkResponse) ProtoMessage()

func (*AttachNetworkResponse) Reset

func (m *AttachNetworkResponse) Reset()

func (*AttachNetworkResponse) Size

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

func (*AttachNetworkResponse) String

func (this *AttachNetworkResponse) String() string

func (*AttachNetworkResponse) Unmarshal

func (m *AttachNetworkResponse) Unmarshal(dAtA []byte) error

type BlacklistedCertificate

type BlacklistedCertificate struct {
	// Expiry is the latest known expiration time of a certificate that
	// was issued for the given CN.
	// Note: can't use stdtime because this field is nullable.
	Expiry *google_protobuf.Timestamp `protobuf:"bytes,1,opt,name=expiry" json:"expiry,omitempty"`
}

BlacklistedCertificate is a record for a blacklisted certificate. It does not contain the certificate's CN, because these records are indexed by CN.

func (*BlacklistedCertificate) Copy

func (*BlacklistedCertificate) CopyFrom

func (m *BlacklistedCertificate) CopyFrom(src interface{})

func (*BlacklistedCertificate) Descriptor

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

func (*BlacklistedCertificate) Marshal

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

func (*BlacklistedCertificate) MarshalTo

func (m *BlacklistedCertificate) MarshalTo(dAtA []byte) (int, error)

func (*BlacklistedCertificate) ProtoMessage

func (*BlacklistedCertificate) ProtoMessage()

func (*BlacklistedCertificate) Reset

func (m *BlacklistedCertificate) Reset()

func (*BlacklistedCertificate) Size

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

func (*BlacklistedCertificate) String

func (this *BlacklistedCertificate) String() string

func (*BlacklistedCertificate) Unmarshal

func (m *BlacklistedCertificate) Unmarshal(dAtA []byte) error

type CAClient

type CAClient interface {
	GetRootCACertificate(ctx context.Context, in *GetRootCACertificateRequest, opts ...grpc.CallOption) (*GetRootCACertificateResponse, error)
	// GetUnlockKey returns the current unlock key for the cluster for the role of the client
	// asking.
	GetUnlockKey(ctx context.Context, in *GetUnlockKeyRequest, opts ...grpc.CallOption) (*GetUnlockKeyResponse, error)
}

func NewCAClient

func NewCAClient(cc *grpc.ClientConn) CAClient

type CAConfig

type CAConfig struct {
	// NodeCertExpiry is the duration certificates should be issued for
	// Note: can't use stdduration because this field needs to be nullable.
	NodeCertExpiry *google_protobuf1.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) CopyFrom

func (m *CAConfig) CopyFrom(src interface{})

func (*CAConfig) Descriptor

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

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)
	// GetUnlockKey returns the current unlock key for the cluster for the role of the client
	// asking.
	GetUnlockKey(context.Context, *GetUnlockKeyRequest) (*GetUnlockKeyResponse, error)
}

func NewAuthenticatedWrapperCAServer

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

func NewRaftProxyCAServer

func NewRaftProxyCAServer(local CAServer, connSelector raftselector.ConnProvider, localCtxMod, remoteCtxMod 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) CopyFrom

func (m *Certificate) CopyFrom(src interface{})

func (*Certificate) Descriptor

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

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 */
	// BlacklistedCertificates tracks certificates that should no longer
	// be honored. It's a mapping from CN -> BlacklistedCertificate.
	// swarm. Their certificates should effectively be blacklisted.
	BlacklistedCertificates map[string]*BlacklistedCertificate `` /* 204-byte string literal not displayed */
	// UnlockKeys defines the keys that lock node data at rest.  For example,
	// this would contain the key encrypting key (KEK) that will encrypt the
	// manager TLS keys at rest and the raft encryption keys at rest.
	// If the key is empty, the node will be unlocked (will not require a key
	// to start up from a shut down state).
	UnlockKeys []*EncryptionKey `protobuf:"bytes,9,rep,name=unlock_keys,json=unlockKeys" json:"unlock_keys,omitempty"`
}

Cluster provides global cluster settings.

func (*Cluster) Copy

func (m *Cluster) Copy() *Cluster

func (*Cluster) CopyFrom

func (m *Cluster) CopyFrom(src interface{})

func (*Cluster) Descriptor

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

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,packed,name=removed" json:"removed,omitempty"`
}

ClusterSnapshot stores cluster membership information in snapshots.

func (*ClusterSnapshot) Copy

func (m *ClusterSnapshot) Copy() *ClusterSnapshot

func (*ClusterSnapshot) CopyFrom

func (m *ClusterSnapshot) CopyFrom(src interface{})

func (*ClusterSnapshot) Descriptor

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

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"`
	// EncryptionConfig defines the cluster's encryption settings.
	EncryptionConfig EncryptionConfig `protobuf:"bytes,8,opt,name=encryption_config,json=encryptionConfig" json:"encryption_config"`
}

ClusterSpec specifies global cluster settings.

func (*ClusterSpec) Copy

func (m *ClusterSpec) Copy() *ClusterSpec

func (*ClusterSpec) CopyFrom

func (m *ClusterSpec) CopyFrom(src interface{})

func (*ClusterSpec) Descriptor

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

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"`
	// Hostname specifies the hostname that will be set on containers created by docker swarm.
	// All containers for a given service will have the same hostname
	Hostname string `protobuf:"bytes,14,opt,name=hostname,proto3" json:"hostname,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.
	//
	// Note that the primary group may be specified by appending the group name
	// or id to the user name, separated by a `:`. This syntax is
	// `<user>:<group>`.
	User string `protobuf:"bytes,7,opt,name=user,proto3" json:"user,omitempty"`
	// Groups specifies supplementary groups available to the user.
	Groups []string `protobuf:"bytes,11,rep,name=groups" json:"groups,omitempty"`
	// TTY declares that a TTY should be attached to the standard streams,
	// including stdin if it is still open.
	TTY bool `protobuf:"varint,13,opt,name=tty,proto3" json:"tty,omitempty"`
	// OpenStdin declares that the standard input (stdin) should be open.
	OpenStdin bool `protobuf:"varint,18,opt,name=open_stdin,json=openStdin,proto3" json:"open_stdin,omitempty"`
	// ReadOnly declares that the container root filesystem is read-only.
	// This only impacts the root filesystem, not additional mounts (including
	// tmpfs). For additional mounts that are not part of the initial rootfs,
	// they will be decided by the modes passed in the mount definition.
	ReadOnly bool    `protobuf:"varint,19,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	Mounts   []Mount `protobuf:"bytes,8,rep,name=mounts" json:"mounts"`
	// StopGracePeriod the grace period for stopping the container before
	// forcefully killing the container.
	// Note: Can't use stdduration here because this needs to be nullable.
	StopGracePeriod *google_protobuf1.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"`
	// SecretReference contains references to zero or more secrets that
	// will be exposed to the container.
	Secrets []*SecretReference `protobuf:"bytes,12,rep,name=secrets" json:"secrets,omitempty"`
	// Hosts allow additional entries to be specified in /etc/hosts
	// that associates IP addresses with hostnames.
	// Detailed documentation is available in:
	// http://man7.org/linux/man-pages/man5/hosts.5.html
	//   IP_address canonical_hostname [aliases...]
	//
	// The format of the Hosts in swarmkit follows the same as
	// above.
	// This is different from `docker run --add-host <hostname>:<ip>`
	// where format is `<hostname>:<ip>`
	Hosts []string `protobuf:"bytes,17,rep,name=hosts" json:"hosts,omitempty"`
	// DNSConfig allows one to specify DNS related configuration in resolv.conf
	DNSConfig *ContainerSpec_DNSConfig `protobuf:"bytes,15,opt,name=dns_config,json=dnsConfig" json:"dns_config,omitempty"`
	// Healthcheck describes how to check the container is healthy. If the
	// container is considered unhealthy, it will be destroyed, its creating
	// task will exit and a new task will be rescheduled elsewhere. A container
	// is considered unhealthy after `Retries` number of consecutive failures.
	Healthcheck *HealthConfig `protobuf:"bytes,16,opt,name=healthcheck" json:"healthcheck,omitempty"`
}

Container specifies runtime parameters for a container.

func (*ContainerSpec) Copy

func (m *ContainerSpec) Copy() *ContainerSpec

func (*ContainerSpec) CopyFrom

func (m *ContainerSpec) CopyFrom(src interface{})

func (*ContainerSpec) Descriptor

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

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_DNSConfig

type ContainerSpec_DNSConfig struct {
	// Nameservers specifies the IP addresses of the name servers
	Nameservers []string `protobuf:"bytes,1,rep,name=nameservers" json:"nameservers,omitempty"`
	// Search specifies the search list for host-name lookup
	Search []string `protobuf:"bytes,2,rep,name=search" json:"search,omitempty"`
	// Options allows certain internal resolver variables to be modified
	Options []string `protobuf:"bytes,3,rep,name=options" json:"options,omitempty"`
}

DNSConfig specifies DNS related configurations in resolver configuration file (resolv.conf) Detailed documentation is available in: http://man7.org/linux/man-pages/man5/resolv.conf.5.html TODO: domain is not supported yet

func (*ContainerSpec_DNSConfig) Copy

func (*ContainerSpec_DNSConfig) CopyFrom

func (m *ContainerSpec_DNSConfig) CopyFrom(src interface{})

func (*ContainerSpec_DNSConfig) Descriptor

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

func (*ContainerSpec_DNSConfig) Marshal

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

func (*ContainerSpec_DNSConfig) MarshalTo

func (m *ContainerSpec_DNSConfig) MarshalTo(dAtA []byte) (int, error)

func (*ContainerSpec_DNSConfig) ProtoMessage

func (*ContainerSpec_DNSConfig) ProtoMessage()

func (*ContainerSpec_DNSConfig) Reset

func (m *ContainerSpec_DNSConfig) Reset()

func (*ContainerSpec_DNSConfig) Size

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

func (*ContainerSpec_DNSConfig) String

func (this *ContainerSpec_DNSConfig) String() string

func (*ContainerSpec_DNSConfig) Unmarshal

func (m *ContainerSpec_DNSConfig) 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) CopyFrom

func (m *ContainerSpec_PullOptions) CopyFrom(src interface{})

func (*ContainerSpec_PullOptions) Descriptor

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

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

func (m *ContainerStatus) CopyFrom(src interface{})

func (*ContainerStatus) Descriptor

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

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)
	// GetSecret returns a `GetSecretResponse` with a `Secret` with the same
	// id as `GetSecretRequest.SecretID`
	// - Returns `NotFound` if the Secret with the given id is not found.
	// - Returns `InvalidArgument` if the `GetSecretRequest.SecretID` is empty.
	// - Returns an error if getting fails.
	GetSecret(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)
	// UpdateSecret returns a `UpdateSecretResponse` with a `Secret` with the same
	// id as `GetSecretRequest.SecretID`
	// - Returns `NotFound` if the Secret with the given id is not found.
	// - Returns `InvalidArgument` if the `GetSecretRequest.SecretID` is empty.
	// - Returns an error if updating fails.
	UpdateSecret(ctx context.Context, in *UpdateSecretRequest, opts ...grpc.CallOption) (*UpdateSecretResponse, error)
	// ListSecrets returns a `ListSecretResponse` with a list all non-internal `Secret`s being
	// managed, or all secrets matching any name in `ListSecretsRequest.Names`, any
	// name prefix in `ListSecretsRequest.NamePrefixes`, any id in
	// `ListSecretsRequest.SecretIDs`, or any id prefix in `ListSecretsRequest.IDPrefixes`.
	// - Returns an error if listing fails.
	ListSecrets(ctx context.Context, in *ListSecretsRequest, opts ...grpc.CallOption) (*ListSecretsResponse, error)
	// CreateSecret creates and return a `CreateSecretResponse` with a `Secret` based
	// on the provided `CreateSecretRequest.SecretSpec`.
	// - Returns `InvalidArgument` if the `CreateSecretRequest.SecretSpec` is malformed,
	//   or if the secret data is too long or contains invalid characters.
	// - Returns an error if the creation fails.
	CreateSecret(ctx context.Context, in *CreateSecretRequest, opts ...grpc.CallOption) (*CreateSecretResponse, error)
	// RemoveSecret removes the secret referenced by `RemoveSecretRequest.ID`.
	// - Returns `InvalidArgument` if `RemoveSecretRequest.ID` is empty.
	// - Returns `NotFound` if the a secret named `RemoveSecretRequest.ID` is not found.
	// - Returns an error if the deletion fails.
	RemoveSecret(ctx context.Context, in *RemoveSecretRequest, opts ...grpc.CallOption) (*RemoveSecretResponse, 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)
	// GetSecret returns a `GetSecretResponse` with a `Secret` with the same
	// id as `GetSecretRequest.SecretID`
	// - Returns `NotFound` if the Secret with the given id is not found.
	// - Returns `InvalidArgument` if the `GetSecretRequest.SecretID` is empty.
	// - Returns an error if getting fails.
	GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)
	// UpdateSecret returns a `UpdateSecretResponse` with a `Secret` with the same
	// id as `GetSecretRequest.SecretID`
	// - Returns `NotFound` if the Secret with the given id is not found.
	// - Returns `InvalidArgument` if the `GetSecretRequest.SecretID` is empty.
	// - Returns an error if updating fails.
	UpdateSecret(context.Context, *UpdateSecretRequest) (*UpdateSecretResponse, error)
	// ListSecrets returns a `ListSecretResponse` with a list all non-internal `Secret`s being
	// managed, or all secrets matching any name in `ListSecretsRequest.Names`, any
	// name prefix in `ListSecretsRequest.NamePrefixes`, any id in
	// `ListSecretsRequest.SecretIDs`, or any id prefix in `ListSecretsRequest.IDPrefixes`.
	// - Returns an error if listing fails.
	ListSecrets(context.Context, *ListSecretsRequest) (*ListSecretsResponse, error)
	// CreateSecret creates and return a `CreateSecretResponse` with a `Secret` based
	// on the provided `CreateSecretRequest.SecretSpec`.
	// - Returns `InvalidArgument` if the `CreateSecretRequest.SecretSpec` is malformed,
	//   or if the secret data is too long or contains invalid characters.
	// - Returns an error if the creation fails.
	CreateSecret(context.Context, *CreateSecretRequest) (*CreateSecretResponse, error)
	// RemoveSecret removes the secret referenced by `RemoveSecretRequest.ID`.
	// - Returns `InvalidArgument` if `RemoveSecretRequest.ID` is empty.
	// - Returns `NotFound` if the a secret named `RemoveSecretRequest.ID` is not found.
	// - Returns an error if the deletion fails.
	RemoveSecret(context.Context, *RemoveSecretRequest) (*RemoveSecretResponse, error)
}

func NewAuthenticatedWrapperControlServer

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

func NewRaftProxyControlServer

func NewRaftProxyControlServer(local ControlServer, connSelector raftselector.ConnProvider, localCtxMod, remoteCtxMod 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) CopyFrom

func (m *CreateNetworkRequest) CopyFrom(src interface{})

func (*CreateNetworkRequest) Descriptor

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

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

func (m *CreateNetworkResponse) CopyFrom(src interface{})

func (*CreateNetworkResponse) Descriptor

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

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 CreateSecretRequest

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

CreateSecretRequest specifies a new secret (it will not update an existing secret) to create.

func (*CreateSecretRequest) Copy

func (*CreateSecretRequest) CopyFrom

func (m *CreateSecretRequest) CopyFrom(src interface{})

func (*CreateSecretRequest) Descriptor

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

func (*CreateSecretRequest) Marshal

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

func (*CreateSecretRequest) MarshalTo

func (m *CreateSecretRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateSecretRequest) ProtoMessage

func (*CreateSecretRequest) ProtoMessage()

func (*CreateSecretRequest) Reset

func (m *CreateSecretRequest) Reset()

func (*CreateSecretRequest) Size

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

func (*CreateSecretRequest) String

func (this *CreateSecretRequest) String() string

func (*CreateSecretRequest) Unmarshal

func (m *CreateSecretRequest) Unmarshal(dAtA []byte) error

type CreateSecretResponse

type CreateSecretResponse struct {
	Secret *Secret `protobuf:"bytes,1,opt,name=secret" json:"secret,omitempty"`
}

CreateSecretResponse contains the newly created `Secret“ corresponding to the name in `CreateSecretRequest`. The `Secret.Spec.Data` field should be nil instead of actually containing the secret bytes.

func (*CreateSecretResponse) Copy

func (*CreateSecretResponse) CopyFrom

func (m *CreateSecretResponse) CopyFrom(src interface{})

func (*CreateSecretResponse) Descriptor

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

func (*CreateSecretResponse) Marshal

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

func (*CreateSecretResponse) MarshalTo

func (m *CreateSecretResponse) MarshalTo(dAtA []byte) (int, error)

func (*CreateSecretResponse) ProtoMessage

func (*CreateSecretResponse) ProtoMessage()

func (*CreateSecretResponse) Reset

func (m *CreateSecretResponse) Reset()

func (*CreateSecretResponse) Size

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

func (*CreateSecretResponse) String

func (this *CreateSecretResponse) String() string

func (*CreateSecretResponse) Unmarshal

func (m *CreateSecretResponse) 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) CopyFrom

func (m *CreateServiceRequest) CopyFrom(src interface{})

func (*CreateServiceRequest) Descriptor

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

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

func (m *CreateServiceResponse) CopyFrom(src interface{})

func (*CreateServiceResponse) Descriptor

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

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 DetachNetworkRequest

type DetachNetworkRequest struct {
	AttachmentID string `protobuf:"bytes,1,opt,name=attachment_id,json=attachmentId,proto3" json:"attachment_id,omitempty"`
}

func (*DetachNetworkRequest) Copy

func (*DetachNetworkRequest) CopyFrom

func (m *DetachNetworkRequest) CopyFrom(src interface{})

func (*DetachNetworkRequest) Descriptor

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

func (*DetachNetworkRequest) Marshal

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

func (*DetachNetworkRequest) MarshalTo

func (m *DetachNetworkRequest) MarshalTo(dAtA []byte) (int, error)

func (*DetachNetworkRequest) ProtoMessage

func (*DetachNetworkRequest) ProtoMessage()

func (*DetachNetworkRequest) Reset

func (m *DetachNetworkRequest) Reset()

func (*DetachNetworkRequest) Size

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

func (*DetachNetworkRequest) String

func (this *DetachNetworkRequest) String() string

func (*DetachNetworkRequest) Unmarshal

func (m *DetachNetworkRequest) Unmarshal(dAtA []byte) error

type DetachNetworkResponse

type DetachNetworkResponse struct {
}

func (*DetachNetworkResponse) Copy

func (*DetachNetworkResponse) CopyFrom

func (m *DetachNetworkResponse) CopyFrom(src interface{})

func (*DetachNetworkResponse) Descriptor

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

func (*DetachNetworkResponse) Marshal

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

func (*DetachNetworkResponse) MarshalTo

func (m *DetachNetworkResponse) MarshalTo(dAtA []byte) (int, error)

func (*DetachNetworkResponse) ProtoMessage

func (*DetachNetworkResponse) ProtoMessage()

func (*DetachNetworkResponse) Reset

func (m *DetachNetworkResponse) Reset()

func (*DetachNetworkResponse) Size

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

func (*DetachNetworkResponse) String

func (this *DetachNetworkResponse) String() string

func (*DetachNetworkResponse) Unmarshal

func (m *DetachNetworkResponse) 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)
	// Assignments is a stream of assignments such as tasks and secrets for node.
	// The first message in the stream contains all of the tasks and secrets
	// that are relevant to the node. Future messages in the stream are updates to
	// the set of assignments.
	Assignments(ctx context.Context, in *AssignmentsRequest, opts ...grpc.CallOption) (Dispatcher_AssignmentsClient, error)
}

func NewDispatcherClient

func NewDispatcherClient(cc *grpc.ClientConn) DispatcherClient

type DispatcherConfig

type DispatcherConfig struct {
	// HeartbeatPeriod defines how often agent should send heartbeats to
	// dispatcher.
	// Note: can't use stdduration because this field needs to be nullable.
	HeartbeatPeriod *google_protobuf1.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) CopyFrom

func (m *DispatcherConfig) CopyFrom(src interface{})

func (*DispatcherConfig) Descriptor

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

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
	// Assignments is a stream of assignments such as tasks and secrets for node.
	// The first message in the stream contains all of the tasks and secrets
	// that are relevant to the node. Future messages in the stream are updates to
	// the set of assignments.
	Assignments(*AssignmentsRequest, Dispatcher_AssignmentsServer) error
}

func NewAuthenticatedWrapperDispatcherServer

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

func NewRaftProxyDispatcherServer

func NewRaftProxyDispatcherServer(local DispatcherServer, connSelector raftselector.ConnProvider, localCtxMod, remoteCtxMod func(context.Context) (context.Context, error)) DispatcherServer

type Dispatcher_AssignmentsClient

type Dispatcher_AssignmentsClient interface {
	Recv() (*AssignmentsMessage, error)
	grpc.ClientStream
}

type Dispatcher_AssignmentsServer

type Dispatcher_AssignmentsServer interface {
	Send(*AssignmentsMessage) error
	grpc.ServerStream
}

type Dispatcher_AssignmentsServerWrapper

type Dispatcher_AssignmentsServerWrapper struct {
	Dispatcher_AssignmentsServer
	// contains filtered or unexported fields
}

func (Dispatcher_AssignmentsServerWrapper) Context

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_SessionServerWrapper

type Dispatcher_SessionServerWrapper struct {
	Dispatcher_SessionServer
	// contains filtered or unexported fields
}

func (Dispatcher_SessionServerWrapper) Context

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 Dispatcher_TasksServerWrapper

type Dispatcher_TasksServerWrapper struct {
	Dispatcher_TasksServer
	// contains filtered or unexported fields
}

func (Dispatcher_TasksServerWrapper) Context

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

func (m *Driver) CopyFrom(src interface{})

func (*Driver) Descriptor

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

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 EncryptionConfig

type EncryptionConfig struct {
	// AutoLockManagers specifies whether or not managers TLS keys and raft data
	// should be encrypted at rest in such a way that they must be unlocked
	// before the manager node starts up again.
	AutoLockManagers bool `protobuf:"varint,1,opt,name=auto_lock_managers,json=autoLockManagers,proto3" json:"auto_lock_managers,omitempty"`
}

func (*EncryptionConfig) Copy

func (*EncryptionConfig) CopyFrom

func (m *EncryptionConfig) CopyFrom(src interface{})

func (*EncryptionConfig) Descriptor

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

func (*EncryptionConfig) Marshal

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

func (*EncryptionConfig) MarshalTo

func (m *EncryptionConfig) MarshalTo(dAtA []byte) (int, error)

func (*EncryptionConfig) ProtoMessage

func (*EncryptionConfig) ProtoMessage()

func (*EncryptionConfig) Reset

func (m *EncryptionConfig) Reset()

func (*EncryptionConfig) Size

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

func (*EncryptionConfig) String

func (this *EncryptionConfig) String() string

func (*EncryptionConfig) Unmarshal

func (m *EncryptionConfig) 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) CopyFrom

func (m *EncryptionKey) CopyFrom(src interface{})

func (*EncryptionKey) Descriptor

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

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

func (m *Endpoint) CopyFrom(src interface{})

func (*Endpoint) Descriptor

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

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

func (m *EndpointSpec) CopyFrom(src interface{})

func (*EndpointSpec) Descriptor

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

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
	// accommodate 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) CopyFrom

func (m *Endpoint_VirtualIP) CopyFrom(src interface{})

func (*Endpoint_VirtualIP) Descriptor

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

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

func (m *EngineDescription) CopyFrom(src interface{})

func (*EngineDescription) Descriptor

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

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

func (m *ExternalCA) CopyFrom(src interface{})

func (*ExternalCA) Descriptor

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

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

func (m *GetClusterRequest) CopyFrom(src interface{})

func (*GetClusterRequest) Descriptor

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

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

func (m *GetClusterResponse) CopyFrom(src interface{})

func (*GetClusterResponse) Descriptor

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

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

func (m *GetNetworkRequest) CopyFrom(src interface{})

func (*GetNetworkRequest) Descriptor

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

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

func (m *GetNetworkResponse) CopyFrom(src interface{})

func (*GetNetworkResponse) Descriptor

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

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

func (m *GetNodeRequest) CopyFrom(src interface{})

func (*GetNodeRequest) Descriptor

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

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

func (m *GetNodeResponse) CopyFrom(src interface{})

func (*GetNodeResponse) Descriptor

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

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

func (m *GetRootCACertificateRequest) CopyFrom(src interface{})

func (*GetRootCACertificateRequest) Descriptor

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

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

func (m *GetRootCACertificateResponse) CopyFrom(src interface{})

func (*GetRootCACertificateResponse) Descriptor

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

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 GetSecretRequest

type GetSecretRequest struct {
	SecretID string `protobuf:"bytes,1,opt,name=secret_id,json=secretId,proto3" json:"secret_id,omitempty"`
}

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

func (*GetSecretRequest) Copy

func (*GetSecretRequest) CopyFrom

func (m *GetSecretRequest) CopyFrom(src interface{})

func (*GetSecretRequest) Descriptor

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

func (*GetSecretRequest) Marshal

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

func (*GetSecretRequest) MarshalTo

func (m *GetSecretRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetSecretRequest) ProtoMessage

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) Reset

func (m *GetSecretRequest) Reset()

func (*GetSecretRequest) Size

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

func (*GetSecretRequest) String

func (this *GetSecretRequest) String() string

func (*GetSecretRequest) Unmarshal

func (m *GetSecretRequest) Unmarshal(dAtA []byte) error

type GetSecretResponse

type GetSecretResponse struct {
	Secret *Secret `protobuf:"bytes,1,opt,name=secret" json:"secret,omitempty"`
}

GetSecretResponse contains the Secret corresponding to the id in `GetSecretRequest`, but the `Secret.Spec.Data` field in each `Secret` object should be nil instead of actually containing the secret bytes.

func (*GetSecretResponse) Copy

func (*GetSecretResponse) CopyFrom

func (m *GetSecretResponse) CopyFrom(src interface{})

func (*GetSecretResponse) Descriptor

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

func (*GetSecretResponse) Marshal

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

func (*GetSecretResponse) MarshalTo

func (m *GetSecretResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetSecretResponse) ProtoMessage

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) Reset

func (m *GetSecretResponse) Reset()

func (*GetSecretResponse) Size

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

func (*GetSecretResponse) String

func (this *GetSecretResponse) String() string

func (*GetSecretResponse) Unmarshal

func (m *GetSecretResponse) 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) CopyFrom

func (m *GetServiceRequest) CopyFrom(src interface{})

func (*GetServiceRequest) Descriptor

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

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

func (m *GetServiceResponse) CopyFrom(src interface{})

func (*GetServiceResponse) Descriptor

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

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

func (m *GetTaskRequest) CopyFrom(src interface{})

func (*GetTaskRequest) Descriptor

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

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

func (m *GetTaskResponse) CopyFrom(src interface{})

func (*GetTaskResponse) Descriptor

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

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 GetUnlockKeyRequest

type GetUnlockKeyRequest struct {
}

func (*GetUnlockKeyRequest) Copy

func (*GetUnlockKeyRequest) CopyFrom

func (m *GetUnlockKeyRequest) CopyFrom(src interface{})

func (*GetUnlockKeyRequest) Descriptor

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

func (*GetUnlockKeyRequest) Marshal

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

func (*GetUnlockKeyRequest) MarshalTo

func (m *GetUnlockKeyRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetUnlockKeyRequest) ProtoMessage

func (*GetUnlockKeyRequest) ProtoMessage()

func (*GetUnlockKeyRequest) Reset

func (m *GetUnlockKeyRequest) Reset()

func (*GetUnlockKeyRequest) Size

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

func (*GetUnlockKeyRequest) String

func (this *GetUnlockKeyRequest) String() string

func (*GetUnlockKeyRequest) Unmarshal

func (m *GetUnlockKeyRequest) Unmarshal(dAtA []byte) error

type GetUnlockKeyResponse

type GetUnlockKeyResponse struct {
	UnlockKey []byte  `protobuf:"bytes,1,opt,name=unlock_key,json=unlockKey,proto3" json:"unlock_key,omitempty"`
	Version   Version `protobuf:"bytes,2,opt,name=version" json:"version"`
}

func (*GetUnlockKeyResponse) Copy

func (*GetUnlockKeyResponse) CopyFrom

func (m *GetUnlockKeyResponse) CopyFrom(src interface{})

func (*GetUnlockKeyResponse) Descriptor

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

func (*GetUnlockKeyResponse) Marshal

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

func (*GetUnlockKeyResponse) MarshalTo

func (m *GetUnlockKeyResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetUnlockKeyResponse) ProtoMessage

func (*GetUnlockKeyResponse) ProtoMessage()

func (*GetUnlockKeyResponse) Reset

func (m *GetUnlockKeyResponse) Reset()

func (*GetUnlockKeyResponse) Size

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

func (*GetUnlockKeyResponse) String

func (this *GetUnlockKeyResponse) String() string

func (*GetUnlockKeyResponse) Unmarshal

func (m *GetUnlockKeyResponse) Unmarshal(dAtA []byte) error

type GlobalService

type GlobalService struct {
}

GlobalService represents global service.

func (*GlobalService) Copy

func (m *GlobalService) Copy() *GlobalService

func (*GlobalService) CopyFrom

func (m *GlobalService) CopyFrom(src interface{})

func (*GlobalService) Descriptor

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

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

func (m *HealthCheckRequest) CopyFrom(src interface{})

func (*HealthCheckRequest) Descriptor

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

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

func (m *HealthCheckResponse) CopyFrom(src interface{})

func (*HealthCheckResponse) Descriptor

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

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 HealthConfig

type HealthConfig struct {
	// Test is the test to perform to check that the container is healthy.
	// An empty slice means to inherit the default.
	// The options are:
	// {} : inherit healthcheck
	// {"NONE"} : disable healthcheck
	// {"CMD", args...} : exec arguments directly
	// {"CMD-SHELL", command} : run command with system's default shell
	Test []string `protobuf:"bytes,1,rep,name=test" json:"test,omitempty"`
	// Interval is the time to wait between checks. Zero means inherit.
	// Note: can't use stdduration because this field needs to be nullable.
	Interval *google_protobuf1.Duration `protobuf:"bytes,2,opt,name=interval" json:"interval,omitempty"`
	// Timeout is the time to wait before considering the check to have hung.
	// Zero means inherit.
	// Note: can't use stdduration because this field needs to be nullable.
	Timeout *google_protobuf1.Duration `protobuf:"bytes,3,opt,name=timeout" json:"timeout,omitempty"`
	// Retries is the number of consecutive failures needed to consider a
	// container as unhealthy. Zero means inherit.
	Retries int32 `protobuf:"varint,4,opt,name=retries,proto3" json:"retries,omitempty"`
}

HealthConfig holds configuration settings for the HEALTHCHECK feature.

func (*HealthConfig) Copy

func (m *HealthConfig) Copy() *HealthConfig

func (*HealthConfig) CopyFrom

func (m *HealthConfig) CopyFrom(src interface{})

func (*HealthConfig) Descriptor

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

func (*HealthConfig) Marshal

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

func (*HealthConfig) MarshalTo

func (m *HealthConfig) MarshalTo(dAtA []byte) (int, error)

func (*HealthConfig) ProtoMessage

func (*HealthConfig) ProtoMessage()

func (*HealthConfig) Reset

func (m *HealthConfig) Reset()

func (*HealthConfig) Size

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

func (*HealthConfig) String

func (this *HealthConfig) String() string

func (*HealthConfig) Unmarshal

func (m *HealthConfig) Unmarshal(dAtA []byte) error

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 raftselector.ConnProvider, localCtxMod, remoteCtxMod 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) CopyFrom

func (m *HeartbeatRequest) CopyFrom(src interface{})

func (*HeartbeatRequest) Descriptor

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

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 time.Duration `protobuf:"bytes,1,opt,name=period,stdduration" json:"period"`
}

func (*HeartbeatResponse) Copy

func (*HeartbeatResponse) CopyFrom

func (m *HeartbeatResponse) CopyFrom(src interface{})

func (*HeartbeatResponse) Descriptor

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

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

func (m *IPAMConfig) CopyFrom(src interface{})

func (*IPAMConfig) Descriptor

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

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

func (m *IPAMOptions) CopyFrom(src interface{})

func (*IPAMOptions) Descriptor

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

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

func (m *Image) CopyFrom(src interface{})

func (*Image) Descriptor

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

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

func (m *InternalRaftRequest) CopyFrom(src interface{})

func (*InternalRaftRequest) Descriptor

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

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

func (m *IssuanceStatus) CopyFrom(src interface{})

func (*IssuanceStatus) Descriptor

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

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
	// A new certificate should be issued
	IssuanceStateRenew IssuanceStatus_State = 1
	// Certificate is pending acceptance
	IssuanceStatePending IssuanceStatus_State = 2
	// successful completion certificate issuance
	IssuanceStateIssued IssuanceStatus_State = 3
	// Certificate issuance failed
	IssuanceStateFailed IssuanceStatus_State = 4
	// Signals workers to renew their certificate. From the CA's perspective
	// this is equivalent to IssuanceStateIssued: a noop.
	IssuanceStateRotate IssuanceStatus_State = 5
)

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"`
	// 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 (*IssueNodeCertificateRequest) Copy

func (*IssueNodeCertificateRequest) CopyFrom

func (m *IssueNodeCertificateRequest) CopyFrom(src interface{})

func (*IssueNodeCertificateRequest) Descriptor

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

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

func (m *IssueNodeCertificateResponse) CopyFrom(src interface{})

func (*IssueNodeCertificateResponse) Descriptor

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

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

func (m *JoinRequest) CopyFrom(src interface{})

func (*JoinRequest) Descriptor

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

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,packed,name=removed_members,json=removedMembers" json:"removed_members,omitempty"`
}

func (*JoinResponse) Copy

func (m *JoinResponse) Copy() *JoinResponse

func (*JoinResponse) CopyFrom

func (m *JoinResponse) CopyFrom(src interface{})

func (*JoinResponse) Descriptor

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

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

func (m *JoinTokens) CopyFrom(src interface{})

func (*JoinTokens) Descriptor

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

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 KeyRotation

type KeyRotation struct {
	// WorkerJoinToken tells UpdateCluster to rotate the worker secret token.
	WorkerJoinToken bool `protobuf:"varint,1,opt,name=worker_join_token,json=workerJoinToken,proto3" json:"worker_join_token,omitempty"`
	// ManagerJoinToken tells UpdateCluster to rotate the manager secret token.
	ManagerJoinToken bool `protobuf:"varint,2,opt,name=manager_join_token,json=managerJoinToken,proto3" json:"manager_join_token,omitempty"`
	// ManagerUnlockKey tells UpdateCluster to rotate the manager unlock key
	ManagerUnlockKey bool `protobuf:"varint,3,opt,name=manager_unlock_key,json=managerUnlockKey,proto3" json:"manager_unlock_key,omitempty"`
}

KeyRotation tells UpdateCluster what items to rotate

func (*KeyRotation) Copy

func (m *KeyRotation) Copy() *KeyRotation

func (*KeyRotation) CopyFrom

func (m *KeyRotation) CopyFrom(src interface{})

func (*KeyRotation) Descriptor

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

func (*KeyRotation) Marshal

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

func (*KeyRotation) MarshalTo

func (m *KeyRotation) MarshalTo(dAtA []byte) (int, error)

func (*KeyRotation) ProtoMessage

func (*KeyRotation) ProtoMessage()

func (*KeyRotation) Reset

func (m *KeyRotation) Reset()

func (*KeyRotation) Size

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

func (*KeyRotation) String

func (this *KeyRotation) String() string

func (*KeyRotation) Unmarshal

func (m *KeyRotation) 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) CopyFrom

func (m *LeaveRequest) CopyFrom(src interface{})

func (*LeaveRequest) Descriptor

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

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

func (m *LeaveResponse) CopyFrom(src interface{})

func (*LeaveResponse) Descriptor

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

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

func (m *ListClustersRequest) CopyFrom(src interface{})

func (*ListClustersRequest) Descriptor

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

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

func (m *ListClustersRequest_Filters) CopyFrom(src interface{})

func (*ListClustersRequest_Filters) Descriptor

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

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

func (m *ListClustersResponse) CopyFrom(src interface{})

func (*ListClustersResponse) Descriptor

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

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

func (m *ListNetworksRequest) CopyFrom(src interface{})

func (*ListNetworksRequest) Descriptor

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

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

func (m *ListNetworksRequest_Filters) CopyFrom(src interface{})

func (*ListNetworksRequest_Filters) Descriptor

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

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

func (m *ListNetworksResponse) CopyFrom(src interface{})

func (*ListNetworksResponse) Descriptor

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

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

func (m *ListNodesRequest) CopyFrom(src interface{})

func (*ListNodesRequest) Descriptor

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

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,packed,name=memberships,enum=docker.swarmkit.v1.NodeSpec_Membership" json:"memberships,omitempty"`
	Roles       []NodeRole            `protobuf:"varint,5,rep,packed,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) CopyFrom

func (m *ListNodesRequest_Filters) CopyFrom(src interface{})

func (*ListNodesRequest_Filters) Descriptor

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

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

func (m *ListNodesResponse) CopyFrom(src interface{})

func (*ListNodesResponse) Descriptor

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

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 ListSecretsRequest

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

ListSecretRequest is the request to list all non-internal secrets in the secret store, or all secrets filtered by (name or name prefix or id prefix) and labels.

func (*ListSecretsRequest) Copy

func (*ListSecretsRequest) CopyFrom

func (m *ListSecretsRequest) CopyFrom(src interface{})

func (*ListSecretsRequest) Descriptor

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

func (*ListSecretsRequest) Marshal

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

func (*ListSecretsRequest) MarshalTo

func (m *ListSecretsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListSecretsRequest) ProtoMessage

func (*ListSecretsRequest) ProtoMessage()

func (*ListSecretsRequest) Reset

func (m *ListSecretsRequest) Reset()

func (*ListSecretsRequest) Size

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

func (*ListSecretsRequest) String

func (this *ListSecretsRequest) String() string

func (*ListSecretsRequest) Unmarshal

func (m *ListSecretsRequest) Unmarshal(dAtA []byte) error

type ListSecretsRequest_Filters

type ListSecretsRequest_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 []string          `protobuf:"bytes,4,rep,name=name_prefixes,json=namePrefixes" json:"name_prefixes,omitempty"`
}

func (*ListSecretsRequest_Filters) Copy

func (*ListSecretsRequest_Filters) CopyFrom

func (m *ListSecretsRequest_Filters) CopyFrom(src interface{})

func (*ListSecretsRequest_Filters) Descriptor

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

func (*ListSecretsRequest_Filters) Marshal

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

func (*ListSecretsRequest_Filters) MarshalTo

func (m *ListSecretsRequest_Filters) MarshalTo(dAtA []byte) (int, error)

func (*ListSecretsRequest_Filters) ProtoMessage

func (*ListSecretsRequest_Filters) ProtoMessage()

func (*ListSecretsRequest_Filters) Reset

func (m *ListSecretsRequest_Filters) Reset()

func (*ListSecretsRequest_Filters) Size

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

func (*ListSecretsRequest_Filters) String

func (this *ListSecretsRequest_Filters) String() string

func (*ListSecretsRequest_Filters) Unmarshal

func (m *ListSecretsRequest_Filters) Unmarshal(dAtA []byte) error

type ListSecretsResponse

type ListSecretsResponse struct {
	Secrets []*Secret `protobuf:"bytes,1,rep,name=secrets" json:"secrets,omitempty"`
}

ListSecretResponse contains a list of all the secrets that match the name or name prefix filters provided in `ListSecretRequest`. The `Secret.Spec.Data` field in each `Secret` object should be nil instead of actually containing the secret bytes.

func (*ListSecretsResponse) Copy

func (*ListSecretsResponse) CopyFrom

func (m *ListSecretsResponse) CopyFrom(src interface{})

func (*ListSecretsResponse) Descriptor

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

func (*ListSecretsResponse) Marshal

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

func (*ListSecretsResponse) MarshalTo

func (m *ListSecretsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListSecretsResponse) ProtoMessage

func (*ListSecretsResponse) ProtoMessage()

func (*ListSecretsResponse) Reset

func (m *ListSecretsResponse) Reset()

func (*ListSecretsResponse) Size

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

func (*ListSecretsResponse) String

func (this *ListSecretsResponse) String() string

func (*ListSecretsResponse) Unmarshal

func (m *ListSecretsResponse) 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) CopyFrom

func (m *ListServicesRequest) CopyFrom(src interface{})

func (*ListServicesRequest) Descriptor

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

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

func (m *ListServicesRequest_Filters) CopyFrom(src interface{})

func (*ListServicesRequest_Filters) Descriptor

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

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

func (m *ListServicesResponse) CopyFrom(src interface{})

func (*ListServicesResponse) Descriptor

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

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

func (m *ListTasksRequest) CopyFrom(src interface{})

func (*ListTasksRequest) Descriptor

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

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       `` /* 135-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) CopyFrom

func (m *ListTasksRequest_Filters) CopyFrom(src interface{})

func (*ListTasksRequest_Filters) Descriptor

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

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

func (m *ListTasksResponse) CopyFrom(src interface{})

func (*ListTasksResponse) Descriptor

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

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 ListenSubscriptionsRequest

type ListenSubscriptionsRequest struct {
}

ListenSubscriptionsRequest is a placeholder to begin listening for subscriptions.

func (*ListenSubscriptionsRequest) Copy

func (*ListenSubscriptionsRequest) CopyFrom

func (m *ListenSubscriptionsRequest) CopyFrom(src interface{})

func (*ListenSubscriptionsRequest) Descriptor

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

func (*ListenSubscriptionsRequest) Marshal

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

func (*ListenSubscriptionsRequest) MarshalTo

func (m *ListenSubscriptionsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListenSubscriptionsRequest) ProtoMessage

func (*ListenSubscriptionsRequest) ProtoMessage()

func (*ListenSubscriptionsRequest) Reset

func (m *ListenSubscriptionsRequest) Reset()

func (*ListenSubscriptionsRequest) Size

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

func (*ListenSubscriptionsRequest) String

func (this *ListenSubscriptionsRequest) String() string

func (*ListenSubscriptionsRequest) Unmarshal

func (m *ListenSubscriptionsRequest) Unmarshal(dAtA []byte) error

type LogBrokerClient

type LogBrokerClient interface {
	// ListenSubscriptions starts a subscription stream for the node. For each
	// message received, the node should attempt to satisfy the subscription.
	//
	// Log messages that match the provided subscription should be sent via
	// PublishLogs.
	ListenSubscriptions(ctx context.Context, in *ListenSubscriptionsRequest, opts ...grpc.CallOption) (LogBroker_ListenSubscriptionsClient, error)
	// PublishLogs receives sets of log messages destined for a single
	// subscription identifier.
	PublishLogs(ctx context.Context, opts ...grpc.CallOption) (LogBroker_PublishLogsClient, error)
}

func NewLogBrokerClient

func NewLogBrokerClient(cc *grpc.ClientConn) LogBrokerClient

type LogBrokerServer

type LogBrokerServer interface {
	// ListenSubscriptions starts a subscription stream for the node. For each
	// message received, the node should attempt to satisfy the subscription.
	//
	// Log messages that match the provided subscription should be sent via
	// PublishLogs.
	ListenSubscriptions(*ListenSubscriptionsRequest, LogBroker_ListenSubscriptionsServer) error
	// PublishLogs receives sets of log messages destined for a single
	// subscription identifier.
	PublishLogs(LogBroker_PublishLogsServer) error
}

func NewAuthenticatedWrapperLogBrokerServer

func NewAuthenticatedWrapperLogBrokerServer(local LogBrokerServer, authorize func(context.Context, []string) error) LogBrokerServer

func NewRaftProxyLogBrokerServer

func NewRaftProxyLogBrokerServer(local LogBrokerServer, connSelector raftselector.ConnProvider, localCtxMod, remoteCtxMod func(context.Context) (context.Context, error)) LogBrokerServer

type LogBroker_ListenSubscriptionsClient

type LogBroker_ListenSubscriptionsClient interface {
	Recv() (*SubscriptionMessage, error)
	grpc.ClientStream
}

type LogBroker_ListenSubscriptionsServer

type LogBroker_ListenSubscriptionsServer interface {
	Send(*SubscriptionMessage) error
	grpc.ServerStream
}

type LogBroker_ListenSubscriptionsServerWrapper

type LogBroker_ListenSubscriptionsServerWrapper struct {
	LogBroker_ListenSubscriptionsServer
	// contains filtered or unexported fields
}

func (LogBroker_ListenSubscriptionsServerWrapper) Context

type LogBroker_PublishLogsClient

type LogBroker_PublishLogsClient interface {
	Send(*PublishLogsMessage) error
	CloseAndRecv() (*PublishLogsResponse, error)
	grpc.ClientStream
}

type LogBroker_PublishLogsServer

type LogBroker_PublishLogsServer interface {
	SendAndClose(*PublishLogsResponse) error
	Recv() (*PublishLogsMessage, error)
	grpc.ServerStream
}

type LogBroker_PublishLogsServerWrapper

type LogBroker_PublishLogsServerWrapper struct {
	LogBroker_PublishLogsServer
	// contains filtered or unexported fields
}

func (LogBroker_PublishLogsServerWrapper) Context

type LogContext

type LogContext struct {
	ServiceID string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	NodeID    string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	TaskID    string `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
}

LogContext marks the context from which a log message was generated.

func (*LogContext) Copy

func (m *LogContext) Copy() *LogContext

func (*LogContext) CopyFrom

func (m *LogContext) CopyFrom(src interface{})

func (*LogContext) Descriptor

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

func (*LogContext) Marshal

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

func (*LogContext) MarshalTo

func (m *LogContext) MarshalTo(dAtA []byte) (int, error)

func (*LogContext) ProtoMessage

func (*LogContext) ProtoMessage()

func (*LogContext) Reset

func (m *LogContext) Reset()

func (*LogContext) Size

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

func (*LogContext) String

func (this *LogContext) String() string

func (*LogContext) Unmarshal

func (m *LogContext) Unmarshal(dAtA []byte) error

type LogMessage

type LogMessage struct {
	// Context identifies the source of the log message.
	Context LogContext `protobuf:"bytes,1,opt,name=context" json:"context"`
	// Timestamp is the time at which the message was generated.
	// Note: can't use stdtime because this field is nullable.
	Timestamp *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
	// Stream identifies the stream of the log message, stdout or stderr.
	Stream LogStream `protobuf:"varint,3,opt,name=stream,proto3,enum=docker.swarmkit.v1.LogStream" json:"stream,omitempty"`
	// Data is the raw log message, as generated by the application.
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

LogMessage

func (*LogMessage) Copy

func (m *LogMessage) Copy() *LogMessage

func (*LogMessage) CopyFrom

func (m *LogMessage) CopyFrom(src interface{})

func (*LogMessage) Descriptor

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

func (*LogMessage) Marshal

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

func (*LogMessage) MarshalTo

func (m *LogMessage) MarshalTo(dAtA []byte) (int, error)

func (*LogMessage) ProtoMessage

func (*LogMessage) ProtoMessage()

func (*LogMessage) Reset

func (m *LogMessage) Reset()

func (*LogMessage) Size

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

func (*LogMessage) String

func (this *LogMessage) String() string

func (*LogMessage) Unmarshal

func (m *LogMessage) Unmarshal(dAtA []byte) error

type LogSelector

type LogSelector struct {
	ServiceIDs []string `protobuf:"bytes,1,rep,name=service_ids,json=serviceIds" json:"service_ids,omitempty"`
	NodeIDs    []string `protobuf:"bytes,2,rep,name=node_ids,json=nodeIds" json:"node_ids,omitempty"`
	TaskIDs    []string `protobuf:"bytes,3,rep,name=task_ids,json=taskIds" json:"task_ids,omitempty"`
}

LogSelector will match logs from ANY of the defined parameters.

For the best effect, the client should use the least specific parameter possible. For example, if they want to listen to all the tasks of a service, they should use the service id, rather than specifying the individual tasks.

func (*LogSelector) Copy

func (m *LogSelector) Copy() *LogSelector

func (*LogSelector) CopyFrom

func (m *LogSelector) CopyFrom(src interface{})

func (*LogSelector) Descriptor

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

func (*LogSelector) Marshal

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

func (*LogSelector) MarshalTo

func (m *LogSelector) MarshalTo(dAtA []byte) (int, error)

func (*LogSelector) ProtoMessage

func (*LogSelector) ProtoMessage()

func (*LogSelector) Reset

func (m *LogSelector) Reset()

func (*LogSelector) Size

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

func (*LogSelector) String

func (this *LogSelector) String() string

func (*LogSelector) Unmarshal

func (m *LogSelector) Unmarshal(dAtA []byte) error

type LogStream

type LogStream int32

LogStream defines the stream from which the log message came.

const (
	LogStreamUnknown LogStream = 0
	LogStreamStdout  LogStream = 1
	LogStreamStderr  LogStream = 2
)

func (LogStream) EnumDescriptor

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

func (LogStream) String

func (x LogStream) String() string

type LogSubscriptionOptions

type LogSubscriptionOptions struct {
	// Streams defines which log streams should be sent from the task source.
	// Empty means send all the messages.
	Streams []LogStream `protobuf:"varint,1,rep,packed,name=streams,enum=docker.swarmkit.v1.LogStream" json:"streams,omitempty"`
	// Follow instructs the publisher to continue sending log messages as they
	// are produced, after satisfying the initial query.
	Follow bool `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"`
	// Tail defines how many messages relative to the log stream to send when
	// starting the stream.
	//
	// Positive values will skip that number of messages from the start of the
	// stream before publishing.
	//
	// Negative values will specify messages relative to the end of the stream,
	// offset by one. We can say that the last (-n-1) lines are returned when n
	// < 0. As reference, -1 would mean send no log lines (typically used with
	// follow), -2 would return the last log line, -11 would return the last 10
	// and so on.
	//
	// The default value of zero will return all logs.
	//
	// Note that this is very different from the Docker API.
	Tail int64 `protobuf:"varint,3,opt,name=tail,proto3" json:"tail,omitempty"`
	// Since indicates that only log messages produced after this timestamp
	// should be sent.
	// Note: can't use stdtime because this field is nullable.
	Since *google_protobuf.Timestamp `protobuf:"bytes,4,opt,name=since" json:"since,omitempty"`
}

func (*LogSubscriptionOptions) Copy

func (*LogSubscriptionOptions) CopyFrom

func (m *LogSubscriptionOptions) CopyFrom(src interface{})

func (*LogSubscriptionOptions) Descriptor

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

func (*LogSubscriptionOptions) Marshal

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

func (*LogSubscriptionOptions) MarshalTo

func (m *LogSubscriptionOptions) MarshalTo(dAtA []byte) (int, error)

func (*LogSubscriptionOptions) ProtoMessage

func (*LogSubscriptionOptions) ProtoMessage()

func (*LogSubscriptionOptions) Reset

func (m *LogSubscriptionOptions) Reset()

func (*LogSubscriptionOptions) Size

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

func (*LogSubscriptionOptions) String

func (this *LogSubscriptionOptions) String() string

func (*LogSubscriptionOptions) Unmarshal

func (m *LogSubscriptionOptions) Unmarshal(dAtA []byte) error

type LogsClient

type LogsClient interface {
	// SubscribeLogs starts a subscription with the specified selector and options.
	//
	// The subscription will be distributed to relevant nodes and messages will
	// be collected and sent via the returned stream.
	//
	// The subscription will end with an EOF.
	SubscribeLogs(ctx context.Context, in *SubscribeLogsRequest, opts ...grpc.CallOption) (Logs_SubscribeLogsClient, error)
}

func NewLogsClient

func NewLogsClient(cc *grpc.ClientConn) LogsClient

type LogsServer

type LogsServer interface {
	// SubscribeLogs starts a subscription with the specified selector and options.
	//
	// The subscription will be distributed to relevant nodes and messages will
	// be collected and sent via the returned stream.
	//
	// The subscription will end with an EOF.
	SubscribeLogs(*SubscribeLogsRequest, Logs_SubscribeLogsServer) error
}

func NewAuthenticatedWrapperLogsServer

func NewAuthenticatedWrapperLogsServer(local LogsServer, authorize func(context.Context, []string) error) LogsServer

func NewRaftProxyLogsServer

func NewRaftProxyLogsServer(local LogsServer, connSelector raftselector.ConnProvider, localCtxMod, remoteCtxMod func(context.Context) (context.Context, error)) LogsServer

type Logs_SubscribeLogsClient

type Logs_SubscribeLogsClient interface {
	Recv() (*SubscribeLogsMessage, error)
	grpc.ClientStream
}

type Logs_SubscribeLogsServer

type Logs_SubscribeLogsServer interface {
	Send(*SubscribeLogsMessage) error
	grpc.ServerStream
}

type Logs_SubscribeLogsServerWrapper

type Logs_SubscribeLogsServerWrapper struct {
	Logs_SubscribeLogsServer
	// contains filtered or unexported fields
}

func (Logs_SubscribeLogsServerWrapper) Context

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

func (m *ManagerStatus) CopyFrom(src interface{})

func (*ManagerStatus) Descriptor

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

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 MaybeEncryptedRecord

type MaybeEncryptedRecord struct {
	Algorithm MaybeEncryptedRecord_Algorithm `` /* 127-byte string literal not displayed */
	Data      []byte                         `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Nonce     []byte                         `protobuf:"bytes,3,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

func (*MaybeEncryptedRecord) Copy

func (*MaybeEncryptedRecord) CopyFrom

func (m *MaybeEncryptedRecord) CopyFrom(src interface{})

func (*MaybeEncryptedRecord) Descriptor

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

func (*MaybeEncryptedRecord) Marshal

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

func (*MaybeEncryptedRecord) MarshalTo

func (m *MaybeEncryptedRecord) MarshalTo(dAtA []byte) (int, error)

func (*MaybeEncryptedRecord) ProtoMessage

func (*MaybeEncryptedRecord) ProtoMessage()

func (*MaybeEncryptedRecord) Reset

func (m *MaybeEncryptedRecord) Reset()

func (*MaybeEncryptedRecord) Size

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

func (*MaybeEncryptedRecord) String

func (this *MaybeEncryptedRecord) String() string

func (*MaybeEncryptedRecord) Unmarshal

func (m *MaybeEncryptedRecord) Unmarshal(dAtA []byte) error

type MaybeEncryptedRecord_Algorithm

type MaybeEncryptedRecord_Algorithm int32
const (
	MaybeEncryptedRecord_NotEncrypted                 MaybeEncryptedRecord_Algorithm = 0
	MaybeEncryptedRecord_NACLSecretboxSalsa20Poly1305 MaybeEncryptedRecord_Algorithm = 1
)

func (MaybeEncryptedRecord_Algorithm) EnumDescriptor

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

func (MaybeEncryptedRecord_Algorithm) String

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.
	// Note: can't use stdtime because these fields are nullable.
	CreatedAt *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
	UpdatedAt *google_protobuf.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) CopyFrom

func (m *Meta) CopyFrom(src interface{})

func (*Meta) Descriptor

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

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

func (m *Mount) CopyFrom(src interface{})

func (*Mount) Descriptor

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

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

func (m *Mount_BindOptions) CopyFrom(src interface{})

func (*Mount_BindOptions) Descriptor

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

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

func (m *Mount_TmpfsOptions) CopyFrom(src interface{})

func (*Mount_TmpfsOptions) Descriptor

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

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

func (m *Mount_VolumeOptions) CopyFrom(src interface{})

func (*Mount_VolumeOptions) Descriptor

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

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

func (m *Network) CopyFrom(src interface{})

func (*Network) Descriptor

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

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

func (m *NetworkAttachment) CopyFrom(src interface{})

func (*NetworkAttachment) Descriptor

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

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 NetworkAttachmentConfig

type NetworkAttachmentConfig struct {
	// Target specifies the target network for attachment. This value must be a
	// network ID.
	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"`
	// Addresses specifies a list of ipv4 and ipv6 addresses
	// preferred. If these addresses are not available then the
	// attachment might fail.
	Addresses []string `protobuf:"bytes,3,rep,name=addresses" json:"addresses,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 (*NetworkAttachmentConfig) Copy

func (*NetworkAttachmentConfig) CopyFrom

func (m *NetworkAttachmentConfig) CopyFrom(src interface{})

func (*NetworkAttachmentConfig) Descriptor

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

func (*NetworkAttachmentConfig) Marshal

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

func (*NetworkAttachmentConfig) MarshalTo

func (m *NetworkAttachmentConfig) MarshalTo(dAtA []byte) (int, error)

func (*NetworkAttachmentConfig) ProtoMessage

func (*NetworkAttachmentConfig) ProtoMessage()

func (*NetworkAttachmentConfig) Reset

func (m *NetworkAttachmentConfig) Reset()

func (*NetworkAttachmentConfig) Size

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

func (*NetworkAttachmentConfig) String

func (this *NetworkAttachmentConfig) String() string

func (*NetworkAttachmentConfig) Unmarshal

func (m *NetworkAttachmentConfig) Unmarshal(dAtA []byte) error

type NetworkAttachmentSpec

type NetworkAttachmentSpec struct {
	// ContainerID spcifies a unique ID of the container for which
	// this attachment is for.
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

NetworkAttachmentSpec specifies runtime parameters required to attach a container to a network.

func (*NetworkAttachmentSpec) Copy

func (*NetworkAttachmentSpec) CopyFrom

func (m *NetworkAttachmentSpec) CopyFrom(src interface{})

func (*NetworkAttachmentSpec) Descriptor

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

func (*NetworkAttachmentSpec) Marshal

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

func (*NetworkAttachmentSpec) MarshalTo

func (m *NetworkAttachmentSpec) MarshalTo(dAtA []byte) (int, error)

func (*NetworkAttachmentSpec) ProtoMessage

func (*NetworkAttachmentSpec) ProtoMessage()

func (*NetworkAttachmentSpec) Reset

func (m *NetworkAttachmentSpec) Reset()

func (*NetworkAttachmentSpec) Size

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

func (*NetworkAttachmentSpec) String

func (this *NetworkAttachmentSpec) String() string

func (*NetworkAttachmentSpec) Unmarshal

func (m *NetworkAttachmentSpec) 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"`
	// Attachable allows external(to swarm) entities to manually
	// attach to this network. With this flag enabled, external
	// entities such as containers running in an worker node in
	// the cluster can manually attach to this network and access
	// the services attached to this network. If this flag is not
	// enabled(default case) no manual attachment to this network
	// can happen.
	Attachable bool `protobuf:"varint,6,opt,name=attachable,proto3" json:"attachable,omitempty"`
}

NetworkSpec specifies user defined network parameters.

func (*NetworkSpec) Copy

func (m *NetworkSpec) Copy() *NetworkSpec

func (*NetworkSpec) CopyFrom

func (m *NetworkSpec) CopyFrom(src interface{})

func (*NetworkSpec) Descriptor

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

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"`
	// Role is the *observed* role for this node. It differs from the
	// desired role set in Node.Spec.Role because the role here is only
	// updated after the Raft member list has been reconciled with the
	// desired role from the spec.
	//
	// This field represents the current reconciled state. If an action is
	// to be performed, first verify the role in the cert. This field only
	// shows the privilege level that the CA would currently grant when
	// issuing or renewing the node's certificate.
	Role NodeRole `protobuf:"varint,9,opt,name=role,proto3,enum=docker.swarmkit.v1.NodeRole" json:"role,omitempty"`
}

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

func (*Node) Copy

func (m *Node) Copy() *Node

func (*Node) CopyFrom

func (m *Node) CopyFrom(src interface{})

func (*Node) Descriptor

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

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 raftselector.ConnProvider, localCtxMod, remoteCtxMod 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) CopyFrom

func (m *NodeCertificateStatusRequest) CopyFrom(src interface{})

func (*NodeCertificateStatusRequest) Descriptor

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

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

func (m *NodeCertificateStatusResponse) CopyFrom(src interface{})

func (*NodeCertificateStatusResponse) Descriptor

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

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

func (m *NodeDescription) CopyFrom(src interface{})

func (*NodeDescription) Descriptor

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

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"`
	// DesiredRole defines the role the node should have.
	DesiredRole NodeRole `` /* 128-byte string literal not displayed */
	// 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) CopyFrom

func (m *NodeSpec) CopyFrom(src interface{})

func (*NodeSpec) Descriptor

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

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"`
	// Addr is the node's IP address as observed by the manager
	Addr string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
}

func (*NodeStatus) Copy

func (m *NodeStatus) Copy() *NodeStatus

func (*NodeStatus) CopyFrom

func (m *NodeStatus) CopyFrom(src interface{})

func (*NodeStatus) Descriptor

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

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

func (m *OrchestrationConfig) CopyFrom(src interface{})

func (*OrchestrationConfig) Descriptor

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

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

func (m *Peer) CopyFrom(src interface{})

func (*Peer) Descriptor

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

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"`
	// Preferences provide a way to make the scheduler aware of factors
	// such as topology. They are provided in order from highest to lowest
	// precedence.
	Preferences []*PlacementPreference `protobuf:"bytes,2,rep,name=preferences" json:"preferences,omitempty"`
}

Placement specifies task distribution constraints.

func (*Placement) Copy

func (m *Placement) Copy() *Placement

func (*Placement) CopyFrom

func (m *Placement) CopyFrom(src interface{})

func (*Placement) Descriptor

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

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 PlacementPreference

type PlacementPreference struct {
	// Types that are valid to be assigned to Preference:
	//	*PlacementPreference_Spread
	Preference isPlacementPreference_Preference `protobuf_oneof:"Preference"`
}

func (*PlacementPreference) Copy

func (*PlacementPreference) CopyFrom

func (m *PlacementPreference) CopyFrom(src interface{})

func (*PlacementPreference) Descriptor

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

func (*PlacementPreference) GetPreference

func (m *PlacementPreference) GetPreference() isPlacementPreference_Preference

func (*PlacementPreference) GetSpread

func (m *PlacementPreference) GetSpread() *SpreadOver

func (*PlacementPreference) Marshal

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

func (*PlacementPreference) MarshalTo

func (m *PlacementPreference) MarshalTo(dAtA []byte) (int, error)

func (*PlacementPreference) ProtoMessage

func (*PlacementPreference) ProtoMessage()

func (*PlacementPreference) Reset

func (m *PlacementPreference) Reset()

func (*PlacementPreference) Size

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

func (*PlacementPreference) String

func (this *PlacementPreference) String() string

func (*PlacementPreference) Unmarshal

func (m *PlacementPreference) Unmarshal(dAtA []byte) error

func (*PlacementPreference) XXX_OneofFuncs

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

type PlacementPreference_Spread struct {
	Spread *SpreadOver `protobuf:"bytes,1,opt,name=spread,oneof"`
}

func (*PlacementPreference_Spread) MarshalTo

func (m *PlacementPreference_Spread) MarshalTo(dAtA []byte) (int, error)

func (*PlacementPreference_Spread) Size

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

func (*PlacementPreference_Spread) String

func (this *PlacementPreference_Spread) String() string

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

func (m *Platform) CopyFrom(src interface{})

func (*Platform) Descriptor

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

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

func (m *PluginDescription) CopyFrom(src interface{})

func (*PluginDescription) Descriptor

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

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
	// (value is zero), an available port is automatically assigned.
	PublishedPort uint32 `protobuf:"varint,4,opt,name=published_port,json=publishedPort,proto3" json:"published_port,omitempty"`
	// PublishMode controls how the port is published.
	PublishMode PortConfig_PublishMode `` /* 142-byte string literal not displayed */
}

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

func (m *PortConfig) CopyFrom(src interface{})

func (*PortConfig) Descriptor

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

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 PortConfig_PublishMode

type PortConfig_PublishMode int32

PublishMode controls how ports are published on the swarm.

const (
	// PublishModeIngress exposes the port across the cluster on all nodes.
	PublishModeIngress PortConfig_PublishMode = 0
	// PublishModeHost exposes the port on just the target host.  If the
	// published port is undefined, an ephemeral port will be allocated. If
	// the published port is defined, the node will attempt to allocate it,
	// erroring the task if it fails.
	PublishModeHost PortConfig_PublishMode = 1
)

func (PortConfig_PublishMode) EnumDescriptor

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

func (PortConfig_PublishMode) String

func (x PortConfig_PublishMode) String() string

type PortStatus

type PortStatus struct {
	Ports []*PortConfig `protobuf:"bytes,1,rep,name=ports" json:"ports,omitempty"`
}

PortStatus specifies the actual allocated runtime state of a list of port configs.

func (*PortStatus) Copy

func (m *PortStatus) Copy() *PortStatus

func (*PortStatus) CopyFrom

func (m *PortStatus) CopyFrom(src interface{})

func (*PortStatus) Descriptor

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

func (*PortStatus) Marshal

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

func (*PortStatus) MarshalTo

func (m *PortStatus) MarshalTo(dAtA []byte) (int, error)

func (*PortStatus) ProtoMessage

func (*PortStatus) ProtoMessage()

func (*PortStatus) Reset

func (m *PortStatus) Reset()

func (*PortStatus) Size

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

func (*PortStatus) String

func (this *PortStatus) String() string

func (*PortStatus) Unmarshal

func (m *PortStatus) Unmarshal(dAtA []byte) error

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

func (m *ProcessRaftMessageResponse) CopyFrom(src interface{})

func (*ProcessRaftMessageResponse) Descriptor

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

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 PublishLogsMessage

type PublishLogsMessage struct {
	// SubscriptionID identifies which subscription the set of messages should
	// be sent to. We can think of this as a "mail box" for the subscription.
	SubscriptionID string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// Messages is the log message for publishing.
	Messages []LogMessage `protobuf:"bytes,2,rep,name=messages" json:"messages"`
}

func (*PublishLogsMessage) Copy

func (*PublishLogsMessage) CopyFrom

func (m *PublishLogsMessage) CopyFrom(src interface{})

func (*PublishLogsMessage) Descriptor

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

func (*PublishLogsMessage) Marshal

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

func (*PublishLogsMessage) MarshalTo

func (m *PublishLogsMessage) MarshalTo(dAtA []byte) (int, error)

func (*PublishLogsMessage) ProtoMessage

func (*PublishLogsMessage) ProtoMessage()

func (*PublishLogsMessage) Reset

func (m *PublishLogsMessage) Reset()

func (*PublishLogsMessage) Size

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

func (*PublishLogsMessage) String

func (this *PublishLogsMessage) String() string

func (*PublishLogsMessage) Unmarshal

func (m *PublishLogsMessage) Unmarshal(dAtA []byte) error

type PublishLogsResponse

type PublishLogsResponse struct {
}

func (*PublishLogsResponse) Copy

func (*PublishLogsResponse) CopyFrom

func (m *PublishLogsResponse) CopyFrom(src interface{})

func (*PublishLogsResponse) Descriptor

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

func (*PublishLogsResponse) Marshal

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

func (*PublishLogsResponse) MarshalTo

func (m *PublishLogsResponse) MarshalTo(dAtA []byte) (int, error)

func (*PublishLogsResponse) ProtoMessage

func (*PublishLogsResponse) ProtoMessage()

func (*PublishLogsResponse) Reset

func (m *PublishLogsResponse) Reset()

func (*PublishLogsResponse) Size

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

func (*PublishLogsResponse) String

func (this *PublishLogsResponse) String() string

func (*PublishLogsResponse) Unmarshal

func (m *PublishLogsResponse) 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) CopyFrom

func (m *RaftConfig) CopyFrom(src interface{})

func (*RaftConfig) Descriptor

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

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

func (m *RaftMember) CopyFrom(src interface{})

func (*RaftMember) Descriptor

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

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

func (m *RaftMemberStatus) CopyFrom(src interface{})

func (*RaftMemberStatus) Descriptor

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

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 raftselector.ConnProvider, localCtxMod, remoteCtxMod 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 raftselector.ConnProvider, localCtxMod, remoteCtxMod 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) CopyFrom

func (m *RemoveNetworkRequest) CopyFrom(src interface{})

func (*RemoveNetworkRequest) Descriptor

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

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

func (m *RemoveNetworkResponse) CopyFrom(src interface{})

func (*RemoveNetworkResponse) Descriptor

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

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"`
	Force  bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
}

RemoveNodeRequest requests to delete the specified node from store.

func (*RemoveNodeRequest) Copy

func (*RemoveNodeRequest) CopyFrom

func (m *RemoveNodeRequest) CopyFrom(src interface{})

func (*RemoveNodeRequest) Descriptor

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

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

func (m *RemoveNodeResponse) CopyFrom(src interface{})

func (*RemoveNodeResponse) Descriptor

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

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 RemoveSecretRequest

type RemoveSecretRequest struct {
	SecretID string `protobuf:"bytes,1,opt,name=secret_id,json=secretId,proto3" json:"secret_id,omitempty"`
}

RemoveSecretRequest contains the ID of the secret that should be removed. This removes all versions of the secret.

func (*RemoveSecretRequest) Copy

func (*RemoveSecretRequest) CopyFrom

func (m *RemoveSecretRequest) CopyFrom(src interface{})

func (*RemoveSecretRequest) Descriptor

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

func (*RemoveSecretRequest) Marshal

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

func (*RemoveSecretRequest) MarshalTo

func (m *RemoveSecretRequest) MarshalTo(dAtA []byte) (int, error)

func (*RemoveSecretRequest) ProtoMessage

func (*RemoveSecretRequest) ProtoMessage()

func (*RemoveSecretRequest) Reset

func (m *RemoveSecretRequest) Reset()

func (*RemoveSecretRequest) Size

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

func (*RemoveSecretRequest) String

func (this *RemoveSecretRequest) String() string

func (*RemoveSecretRequest) Unmarshal

func (m *RemoveSecretRequest) Unmarshal(dAtA []byte) error

type RemoveSecretResponse

type RemoveSecretResponse struct {
}

RemoveSecretResponse is an empty object indicating the successful removal of a secret.

func (*RemoveSecretResponse) Copy

func (*RemoveSecretResponse) CopyFrom

func (m *RemoveSecretResponse) CopyFrom(src interface{})

func (*RemoveSecretResponse) Descriptor

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

func (*RemoveSecretResponse) Marshal

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

func (*RemoveSecretResponse) MarshalTo

func (m *RemoveSecretResponse) MarshalTo(dAtA []byte) (int, error)

func (*RemoveSecretResponse) ProtoMessage

func (*RemoveSecretResponse) ProtoMessage()

func (*RemoveSecretResponse) Reset

func (m *RemoveSecretResponse) Reset()

func (*RemoveSecretResponse) Size

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

func (*RemoveSecretResponse) String

func (this *RemoveSecretResponse) String() string

func (*RemoveSecretResponse) Unmarshal

func (m *RemoveSecretResponse) 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) CopyFrom

func (m *RemoveServiceRequest) CopyFrom(src interface{})

func (*RemoveServiceRequest) Descriptor

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

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

func (m *RemoveServiceResponse) CopyFrom(src interface{})

func (*RemoveServiceResponse) Descriptor

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

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

func (m *RemoveTaskRequest) CopyFrom(src interface{})

func (*RemoveTaskRequest) Descriptor

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

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

func (m *RemoveTaskResponse) CopyFrom(src interface{})

func (*RemoveTaskResponse) Descriptor

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

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

func (m *ReplicatedService) CopyFrom(src interface{})

func (*ReplicatedService) Descriptor

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

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

func (m *ResolveAddressRequest) CopyFrom(src interface{})

func (*ResolveAddressRequest) Descriptor

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

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

func (m *ResolveAddressResponse) CopyFrom(src interface{})

func (*ResolveAddressResponse) Descriptor

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

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 ResourceAllocatorClient

type ResourceAllocatorClient interface {
	AttachNetwork(ctx context.Context, in *AttachNetworkRequest, opts ...grpc.CallOption) (*AttachNetworkResponse, error)
	DetachNetwork(ctx context.Context, in *DetachNetworkRequest, opts ...grpc.CallOption) (*DetachNetworkResponse, error)
}

func NewResourceAllocatorClient

func NewResourceAllocatorClient(cc *grpc.ClientConn) ResourceAllocatorClient

type ResourceAllocatorServer

type ResourceAllocatorServer interface {
	AttachNetwork(context.Context, *AttachNetworkRequest) (*AttachNetworkResponse, error)
	DetachNetwork(context.Context, *DetachNetworkRequest) (*DetachNetworkResponse, error)
}

func NewAuthenticatedWrapperResourceAllocatorServer

func NewAuthenticatedWrapperResourceAllocatorServer(local ResourceAllocatorServer, authorize func(context.Context, []string) error) ResourceAllocatorServer

func NewRaftProxyResourceAllocatorServer

func NewRaftProxyResourceAllocatorServer(local ResourceAllocatorServer, connSelector raftselector.ConnProvider, localCtxMod, remoteCtxMod func(context.Context) (context.Context, error)) ResourceAllocatorServer

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

func (m *ResourceRequirements) CopyFrom(src interface{})

func (*ResourceRequirements) Descriptor

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

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

func (m *Resources) CopyFrom(src interface{})

func (*Resources) Descriptor

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

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
	// Note: can't use stdduration because this field needs to be nullable.
	Delay *google_protobuf1.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.
	// Note: can't use stdduration because this field needs to be nullable.
	Window *google_protobuf1.Duration `protobuf:"bytes,4,opt,name=window" json:"window,omitempty"`
}

func (*RestartPolicy) Copy

func (m *RestartPolicy) Copy() *RestartPolicy

func (*RestartPolicy) CopyFrom

func (m *RestartPolicy) CopyFrom(src interface{})

func (*RestartPolicy) Descriptor

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

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

func (m *RootCA) CopyFrom(src interface{})

func (*RootCA) Descriptor

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

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 Secret

type Secret struct {
	ID   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta Meta   `protobuf:"bytes,2,opt,name=meta" json:"meta"`
	// Spec contains the actual secret data, as well as any context around the
	// secret data that the user provides.
	Spec SecretSpec `protobuf:"bytes,3,opt,name=spec" json:"spec"`
	// Whether the secret is an internal secret (not set by a user) or not.
	Internal bool `protobuf:"varint,4,opt,name=internal,proto3" json:"internal,omitempty"`
}

Secret represents a secret that should be passed to a container or a node, and is immutable. It wraps the `spec` provided by the user with useful information that is generated from the secret data in the `spec`, such as the digest and size of the secret data.

func (*Secret) Copy

func (m *Secret) Copy() *Secret

func (*Secret) CopyFrom

func (m *Secret) CopyFrom(src interface{})

func (*Secret) Descriptor

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

func (*Secret) Marshal

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

func (*Secret) MarshalTo

func (m *Secret) MarshalTo(dAtA []byte) (int, error)

func (*Secret) ProtoMessage

func (*Secret) ProtoMessage()

func (*Secret) Reset

func (m *Secret) Reset()

func (*Secret) Size

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

func (*Secret) String

func (this *Secret) String() string

func (*Secret) Unmarshal

func (m *Secret) Unmarshal(dAtA []byte) error

type SecretReference

type SecretReference struct {
	// SecretID represents the ID of the specific Secret that we're
	// referencing. This identifier exists so that SecretReferences don't leak
	// any information about the secret contents.
	SecretID string `protobuf:"bytes,1,opt,name=secret_id,json=secretId,proto3" json:"secret_id,omitempty"`
	// SecretName is the name of the secret that this references, but this is just provided for
	// lookup/display purposes.  The secret in the reference will be identified by its ID.
	SecretName string `protobuf:"bytes,2,opt,name=secret_name,json=secretName,proto3" json:"secret_name,omitempty"`
	// Target specifies how this secret should be exposed to the task.
	//
	// Types that are valid to be assigned to Target:
	//	*SecretReference_File
	Target isSecretReference_Target `protobuf_oneof:"target"`
}

SecretReference is the linkage between a service and a secret that it uses.

func (*SecretReference) Copy

func (m *SecretReference) Copy() *SecretReference

func (*SecretReference) CopyFrom

func (m *SecretReference) CopyFrom(src interface{})

func (*SecretReference) Descriptor

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

func (*SecretReference) GetFile

func (*SecretReference) GetTarget

func (m *SecretReference) GetTarget() isSecretReference_Target

func (*SecretReference) Marshal

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

func (*SecretReference) MarshalTo

func (m *SecretReference) MarshalTo(dAtA []byte) (int, error)

func (*SecretReference) ProtoMessage

func (*SecretReference) ProtoMessage()

func (*SecretReference) Reset

func (m *SecretReference) Reset()

func (*SecretReference) Size

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

func (*SecretReference) String

func (this *SecretReference) String() string

func (*SecretReference) Unmarshal

func (m *SecretReference) Unmarshal(dAtA []byte) error

func (*SecretReference) XXX_OneofFuncs

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

type SecretReference_File struct {
	File *SecretReference_FileTarget `protobuf:"bytes,3,opt,name=file,oneof"`
}

func (*SecretReference_File) MarshalTo

func (m *SecretReference_File) MarshalTo(dAtA []byte) (int, error)

func (*SecretReference_File) Size

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

func (*SecretReference_File) String

func (this *SecretReference_File) String() string

type SecretReference_FileTarget

type SecretReference_FileTarget struct {
	// Name represents the final filename in the filesystem
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// UID represents the file UID
	UID string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// GID represents the file GID
	GID string `protobuf:"bytes,3,opt,name=gid,proto3" json:"gid,omitempty"`
	// Mode represents the FileMode of the file
	Mode os.FileMode `protobuf:"varint,4,opt,name=mode,proto3,customtype=os.FileMode" json:"mode"`
}

FileTarget represents a specific target that is backed by a file

func (*SecretReference_FileTarget) Copy

func (*SecretReference_FileTarget) CopyFrom

func (m *SecretReference_FileTarget) CopyFrom(src interface{})

func (*SecretReference_FileTarget) Descriptor

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

func (*SecretReference_FileTarget) Marshal

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

func (*SecretReference_FileTarget) MarshalTo

func (m *SecretReference_FileTarget) MarshalTo(dAtA []byte) (int, error)

func (*SecretReference_FileTarget) ProtoMessage

func (*SecretReference_FileTarget) ProtoMessage()

func (*SecretReference_FileTarget) Reset

func (m *SecretReference_FileTarget) Reset()

func (*SecretReference_FileTarget) Size

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

func (*SecretReference_FileTarget) String

func (this *SecretReference_FileTarget) String() string

func (*SecretReference_FileTarget) Unmarshal

func (m *SecretReference_FileTarget) Unmarshal(dAtA []byte) error

type SecretSpec

type SecretSpec struct {
	Annotations Annotations `protobuf:"bytes,1,opt,name=annotations" json:"annotations"`
	// Data is the secret payload - the maximum size is 500KB (that is, 500*1024 bytes)
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

SecretSpec specifies a user-provided secret.

func (*SecretSpec) Copy

func (m *SecretSpec) Copy() *SecretSpec

func (*SecretSpec) CopyFrom

func (m *SecretSpec) CopyFrom(src interface{})

func (*SecretSpec) Descriptor

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

func (*SecretSpec) Marshal

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

func (*SecretSpec) MarshalTo

func (m *SecretSpec) MarshalTo(dAtA []byte) (int, error)

func (*SecretSpec) ProtoMessage

func (*SecretSpec) ProtoMessage()

func (*SecretSpec) Reset

func (m *SecretSpec) Reset()

func (*SecretSpec) Size

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

func (*SecretSpec) String

func (this *SecretSpec) String() string

func (*SecretSpec) Unmarshal

func (m *SecretSpec) 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"`
	// PreviousSpec is the previous service spec that was in place before
	// "Spec".
	PreviousSpec *ServiceSpec `protobuf:"bytes,6,opt,name=previous_spec,json=previousSpec" json:"previous_spec,omitempty"`
	// 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) CopyFrom

func (m *Service) CopyFrom(src interface{})

func (*Service) Descriptor

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

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"`
	// Update contains settings which affect updates.
	Update *UpdateConfig `protobuf:"bytes,6,opt,name=update" json:"update,omitempty"`
	// Rollback contains settings which affect rollbacks of updates.
	Rollback *UpdateConfig `protobuf:"bytes,9,opt,name=rollback" json:"rollback,omitempty"`
	// ServiceSpec.Networks has been deprecated and is replaced by
	// Networks field in Task (TaskSpec.Networks).
	// This field (ServiceSpec.Networks) is kept for compatibility.
	// In case TaskSpec.Networks does not exist, ServiceSpec.Networks
	// is still honored if it exists.
	Networks []*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) CopyFrom

func (m *ServiceSpec) CopyFrom(src interface{})

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

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

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

func (m *SessionMessage) CopyFrom(src interface{})

func (*SessionMessage) Descriptor

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

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"`
	// SessionID can be provided to attempt resuming an existing session. If the
	// SessionID is empty or invalid, a new SessionID will be assigned.
	//
	// See SessionMessage.SessionID for details.
	SessionID string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
}

SessionRequest starts a session.

func (*SessionRequest) Copy

func (m *SessionRequest) Copy() *SessionRequest

func (*SessionRequest) CopyFrom

func (m *SessionRequest) CopyFrom(src interface{})

func (*SessionRequest) Descriptor

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

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

func (m *Snapshot) CopyFrom(src interface{})

func (*Snapshot) Descriptor

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

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 SpreadOver

type SpreadOver struct {
	SpreadDescriptor string `protobuf:"bytes,1,opt,name=spread_descriptor,json=spreadDescriptor,proto3" json:"spread_descriptor,omitempty"`
}

func (*SpreadOver) Copy

func (m *SpreadOver) Copy() *SpreadOver

func (*SpreadOver) CopyFrom

func (m *SpreadOver) CopyFrom(src interface{})

func (*SpreadOver) Descriptor

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

func (*SpreadOver) Marshal

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

func (*SpreadOver) MarshalTo

func (m *SpreadOver) MarshalTo(dAtA []byte) (int, error)

func (*SpreadOver) ProtoMessage

func (*SpreadOver) ProtoMessage()

func (*SpreadOver) Reset

func (m *SpreadOver) Reset()

func (*SpreadOver) Size

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

func (*SpreadOver) String

func (this *SpreadOver) String() string

func (*SpreadOver) Unmarshal

func (m *SpreadOver) Unmarshal(dAtA []byte) error

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
	//	*StoreAction_Secret
	Target isStoreAction_Target `protobuf_oneof:"target"`
}

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

func (*StoreAction) Copy

func (m *StoreAction) Copy() *StoreAction

func (*StoreAction) CopyFrom

func (m *StoreAction) CopyFrom(src interface{})

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

func (m *StoreAction) GetSecret() *Secret

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

type StoreAction_Secret struct {
	Secret *Secret `protobuf:"bytes,7,opt,name=secret,oneof"`
}

func (*StoreAction_Secret) MarshalTo

func (m *StoreAction_Secret) MarshalTo(dAtA []byte) (int, error)

func (*StoreAction_Secret) Size

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

func (*StoreAction_Secret) String

func (this *StoreAction_Secret) String() string

type StoreAction_Service

type StoreAction_Service struct {
	Service *Service `protobuf:"bytes,3,opt,name=service,oneof"`
}

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) 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"`
	Secrets  []*Secret  `protobuf:"bytes,6,rep,name=secrets" json:"secrets,omitempty"`
}

StoreSnapshot is used to store snapshots of the store.

func (*StoreSnapshot) Copy

func (m *StoreSnapshot) Copy() *StoreSnapshot

func (*StoreSnapshot) CopyFrom

func (m *StoreSnapshot) CopyFrom(src interface{})

func (*StoreSnapshot) Descriptor

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

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 SubscribeLogsMessage

type SubscribeLogsMessage struct {
	Messages []LogMessage `protobuf:"bytes,1,rep,name=messages" json:"messages"`
}

func (*SubscribeLogsMessage) Copy

func (*SubscribeLogsMessage) CopyFrom

func (m *SubscribeLogsMessage) CopyFrom(src interface{})

func (*SubscribeLogsMessage) Descriptor

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

func (*SubscribeLogsMessage) Marshal

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

func (*SubscribeLogsMessage) MarshalTo

func (m *SubscribeLogsMessage) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeLogsMessage) ProtoMessage

func (*SubscribeLogsMessage) ProtoMessage()

func (*SubscribeLogsMessage) Reset

func (m *SubscribeLogsMessage) Reset()

func (*SubscribeLogsMessage) Size

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

func (*SubscribeLogsMessage) String

func (this *SubscribeLogsMessage) String() string

func (*SubscribeLogsMessage) Unmarshal

func (m *SubscribeLogsMessage) Unmarshal(dAtA []byte) error

type SubscribeLogsRequest

type SubscribeLogsRequest struct {
	// LogSelector describes the logs to which the subscriber is
	Selector *LogSelector            `protobuf:"bytes,1,opt,name=selector" json:"selector,omitempty"`
	Options  *LogSubscriptionOptions `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
}

func (*SubscribeLogsRequest) Copy

func (*SubscribeLogsRequest) CopyFrom

func (m *SubscribeLogsRequest) CopyFrom(src interface{})

func (*SubscribeLogsRequest) Descriptor

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

func (*SubscribeLogsRequest) Marshal

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

func (*SubscribeLogsRequest) MarshalTo

func (m *SubscribeLogsRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeLogsRequest) ProtoMessage

func (*SubscribeLogsRequest) ProtoMessage()

func (*SubscribeLogsRequest) Reset

func (m *SubscribeLogsRequest) Reset()

func (*SubscribeLogsRequest) Size

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

func (*SubscribeLogsRequest) String

func (this *SubscribeLogsRequest) String() string

func (*SubscribeLogsRequest) Unmarshal

func (m *SubscribeLogsRequest) Unmarshal(dAtA []byte) error

type SubscriptionMessage

type SubscriptionMessage struct {
	// ID identifies the subscription.
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Selector defines which sources should be sent for the subscription.
	Selector *LogSelector `protobuf:"bytes,2,opt,name=selector" json:"selector,omitempty"`
	// Options specify how the subscription should be satisfied.
	Options *LogSubscriptionOptions `protobuf:"bytes,3,opt,name=options" json:"options,omitempty"`
	// Close will be true if the node should shutdown the subscription with the
	// provided identifier.
	Close bool `protobuf:"varint,4,opt,name=close,proto3" json:"close,omitempty"`
}

SubscriptionMessage instructs the listener to start publishing messages for the stream or end a subscription.

If Options.Follow == false, the worker should end the subscription on its own.

func (*SubscriptionMessage) Copy

func (*SubscriptionMessage) CopyFrom

func (m *SubscriptionMessage) CopyFrom(src interface{})

func (*SubscriptionMessage) Descriptor

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

func (*SubscriptionMessage) Marshal

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

func (*SubscriptionMessage) MarshalTo

func (m *SubscriptionMessage) MarshalTo(dAtA []byte) (int, error)

func (*SubscriptionMessage) ProtoMessage

func (*SubscriptionMessage) ProtoMessage()

func (*SubscriptionMessage) Reset

func (m *SubscriptionMessage) Reset()

func (*SubscriptionMessage) Size

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

func (*SubscriptionMessage) String

func (this *SubscriptionMessage) String() string

func (*SubscriptionMessage) Unmarshal

func (m *SubscriptionMessage) 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) CopyFrom

func (m *Task) CopyFrom(src interface{})

func (*Task) Descriptor

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

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

func (m *TaskDefaults) CopyFrom(src interface{})

func (*TaskDefaults) Descriptor

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

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_Attachment
	//	*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"`
	// Networks specifies the list of network attachment
	// configurations (which specify the network and per-network
	// aliases) that this task spec is bound to.
	Networks []*NetworkAttachmentConfig `protobuf:"bytes,7,rep,name=networks" json:"networks,omitempty"`
	// ForceUpdate is a counter that triggers an update even if no relevant
	// parameters have been changed. We do this to allow forced restarts
	// using the same reconciliation-based mechanism that performs rolling
	// updates.
	ForceUpdate uint64 `protobuf:"varint,9,opt,name=force_update,json=forceUpdate,proto3" json:"force_update,omitempty"`
}

func (*TaskSpec) Copy

func (m *TaskSpec) Copy() *TaskSpec

func (*TaskSpec) CopyFrom

func (m *TaskSpec) CopyFrom(src interface{})

func (*TaskSpec) Descriptor

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

func (*TaskSpec) GetAttachment

func (m *TaskSpec) GetAttachment() *NetworkAttachmentSpec

func (*TaskSpec) GetContainer

func (m *TaskSpec) GetContainer() *ContainerSpec

func (*TaskSpec) GetRuntime

func (m *TaskSpec) GetRuntime() isTaskSpec_Runtime

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_Attachment

type TaskSpec_Attachment struct {
	Attachment *NetworkAttachmentSpec `protobuf:"bytes,8,opt,name=attachment,oneof"`
}

func (*TaskSpec_Attachment) MarshalTo

func (m *TaskSpec_Attachment) MarshalTo(dAtA []byte) (int, error)

func (*TaskSpec_Attachment) Size

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

func (*TaskSpec_Attachment) String

func (this *TaskSpec_Attachment) String() string

type TaskSpec_Container

type TaskSpec_Container struct {
	Container *ContainerSpec `protobuf:"bytes,1,opt,name=container,oneof"`
}

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
	TaskStatePending   TaskState = 64
	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
	TaskStateOrphaned  TaskState = 832
)

func (TaskState) EnumDescriptor

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

func (TaskState) String

func (x TaskState) String() string

type TaskStatus

type TaskStatus struct {
	// Note: can't use stdtime because this field is nullable.
	Timestamp *google_protobuf.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"`
	// HostPorts provides a list of ports allocated at the host
	// level.
	PortStatus *PortStatus `protobuf:"bytes,6,opt,name=port_status,json=portStatus" json:"port_status,omitempty"`
}

func (*TaskStatus) Copy

func (m *TaskStatus) Copy() *TaskStatus

func (*TaskStatus) CopyFrom

func (m *TaskStatus) CopyFrom(src interface{})

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

func (m *TasksMessage) CopyFrom(src interface{})

func (*TasksMessage) Descriptor

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

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

func (m *TasksRequest) CopyFrom(src interface{})

func (*TasksRequest) Descriptor

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

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 and unlock key rotation
	Rotation KeyRotation `protobuf:"bytes,4,opt,name=rotation" json:"rotation"`
}

func (*UpdateClusterRequest) Copy

func (*UpdateClusterRequest) CopyFrom

func (m *UpdateClusterRequest) CopyFrom(src interface{})

func (*UpdateClusterRequest) Descriptor

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

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

func (m *UpdateClusterResponse) CopyFrom(src interface{})

func (*UpdateClusterResponse) Descriptor

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

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 time.Duration `protobuf:"bytes,2,opt,name=delay,stdduration" json:"delay"`
	// FailureAction is the action to take when an update failures.
	FailureAction UpdateConfig_FailureAction `` /* 152-byte string literal not displayed */
	// Monitor indicates how long to monitor a task for failure after it is
	// created. If the task fails by ending up in one of the states
	// REJECTED, COMPLETED, or FAILED, within Monitor from its creation,
	// this counts as a failure. If it fails after Monitor, it does not
	// count as a failure. If Monitor is unspecified, a default value will
	// be used.
	// Note: can't use stdduration because this field needs to be nullable.
	Monitor *google_protobuf1.Duration `protobuf:"bytes,4,opt,name=monitor" json:"monitor,omitempty"`
	// MaxFailureRatio is the fraction of tasks that may fail during
	// an update before the failure action is invoked. Any task created by
	// the current update which ends up in one of the states REJECTED,
	// COMPLETED or FAILED within Monitor from its creation counts as a
	// failure. The number of failures is divided by the number of tasks
	// being updated, and if this fraction is greater than
	// MaxFailureRatio, the failure action is invoked.
	//
	// If the failure action is CONTINUE, there is no effect.
	// If the failure action is PAUSE, no more tasks will be updated until
	// another update is started.
	// If the failure action is ROLLBACK, the orchestrator will attempt to
	// roll back to the previous service spec. If the MaxFailureRatio
	// threshold is hit during the rollback, the rollback will pause.
	MaxFailureRatio float32 `protobuf:"fixed32,5,opt,name=max_failure_ratio,json=maxFailureRatio,proto3" json:"max_failure_ratio,omitempty"`
}

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

func (m *UpdateConfig) CopyFrom(src interface{})

func (*UpdateConfig) Descriptor

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

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
	UpdateConfig_ROLLBACK UpdateConfig_FailureAction = 2
)

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

func (m *UpdateNodeRequest) CopyFrom(src interface{})

func (*UpdateNodeRequest) Descriptor

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

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

func (m *UpdateNodeResponse) CopyFrom(src interface{})

func (*UpdateNodeResponse) Descriptor

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

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 UpdateSecretRequest

type UpdateSecretRequest struct {
	// SecretID is the secret ID to update.
	SecretID string `protobuf:"bytes,1,opt,name=secret_id,json=secretId,proto3" json:"secret_id,omitempty"`
	// SecretVersion is the version of the secret being updated.
	SecretVersion *Version `protobuf:"bytes,2,opt,name=secret_version,json=secretVersion" json:"secret_version,omitempty"`
	// Spec is the new spec to apply to the Secret
	// Only some fields are allowed to be updated.
	Spec *SecretSpec `protobuf:"bytes,3,opt,name=spec" json:"spec,omitempty"`
}

func (*UpdateSecretRequest) Copy

func (*UpdateSecretRequest) CopyFrom

func (m *UpdateSecretRequest) CopyFrom(src interface{})

func (*UpdateSecretRequest) Descriptor

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

func (*UpdateSecretRequest) Marshal

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

func (*UpdateSecretRequest) MarshalTo

func (m *UpdateSecretRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateSecretRequest) ProtoMessage

func (*UpdateSecretRequest) ProtoMessage()

func (*UpdateSecretRequest) Reset

func (m *UpdateSecretRequest) Reset()

func (*UpdateSecretRequest) Size

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

func (*UpdateSecretRequest) String

func (this *UpdateSecretRequest) String() string

func (*UpdateSecretRequest) Unmarshal

func (m *UpdateSecretRequest) Unmarshal(dAtA []byte) error

type UpdateSecretResponse

type UpdateSecretResponse struct {
	Secret *Secret `protobuf:"bytes,1,opt,name=secret" json:"secret,omitempty"`
}

func (*UpdateSecretResponse) Copy

func (*UpdateSecretResponse) CopyFrom

func (m *UpdateSecretResponse) CopyFrom(src interface{})

func (*UpdateSecretResponse) Descriptor

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

func (*UpdateSecretResponse) Marshal

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

func (*UpdateSecretResponse) MarshalTo

func (m *UpdateSecretResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateSecretResponse) ProtoMessage

func (*UpdateSecretResponse) ProtoMessage()

func (*UpdateSecretResponse) Reset

func (m *UpdateSecretResponse) Reset()

func (*UpdateSecretResponse) Size

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

func (*UpdateSecretResponse) String

func (this *UpdateSecretResponse) String() string

func (*UpdateSecretResponse) Unmarshal

func (m *UpdateSecretResponse) 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"`
	// Rollback may be set to PREVIOUS to request a rollback (the service's
	// spec will be set to the value of its previous_spec field). In this
	// case, the spec field of this request is ignored.
	Rollback UpdateServiceRequest_Rollback `protobuf:"varint,4,opt,name=rollback,proto3,enum=docker.swarmkit.v1.UpdateServiceRequest_Rollback" json:"rollback,omitempty"`
}

func (*UpdateServiceRequest) Copy

func (*UpdateServiceRequest) CopyFrom

func (m *UpdateServiceRequest) CopyFrom(src interface{})

func (*UpdateServiceRequest) Descriptor

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

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 UpdateServiceRequest_Rollback

type UpdateServiceRequest_Rollback int32
const (
	// This is not a rollback. The spec field of the request will
	// be honored.
	UpdateServiceRequest_NONE UpdateServiceRequest_Rollback = 0
	// Roll back the service - get spec from the service's
	// previous_spec.
	UpdateServiceRequest_PREVIOUS UpdateServiceRequest_Rollback = 1
)

func (UpdateServiceRequest_Rollback) EnumDescriptor

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

func (UpdateServiceRequest_Rollback) String

type UpdateServiceResponse

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

func (*UpdateServiceResponse) Copy

func (*UpdateServiceResponse) CopyFrom

func (m *UpdateServiceResponse) CopyFrom(src interface{})

func (*UpdateServiceResponse) Descriptor

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

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, paused, rolling back, or
	// finished rolling back.
	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.
	// Note: can't use stdtime because this field is nullable.
	StartedAt *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=started_at,json=startedAt" json:"started_at,omitempty"`
	// CompletedAt is the time at which the update completed successfully,
	// paused, or finished rolling back.
	// Note: can't use stdtime because this field is nullable.
	CompletedAt *google_protobuf.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) CopyFrom

func (m *UpdateStatus) CopyFrom(src interface{})

func (*UpdateStatus) Descriptor

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

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
	UpdateStatus_ROLLBACK_STARTED   UpdateStatus_UpdateState = 4
	UpdateStatus_ROLLBACK_PAUSED    UpdateStatus_UpdateState = 5
	UpdateStatus_ROLLBACK_COMPLETED UpdateStatus_UpdateState = 6
)

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

func (m *UpdateTaskStatusRequest) CopyFrom(src interface{})

func (*UpdateTaskStatusRequest) Descriptor

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

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

func (m *UpdateTaskStatusRequest_TaskStatusUpdate) CopyFrom(src interface{})

func (*UpdateTaskStatusRequest_TaskStatusUpdate) Descriptor

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

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

func (m *UpdateTaskStatusResponse) CopyFrom(src interface{})

func (*UpdateTaskStatusResponse) Descriptor

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

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

func (m *Version) CopyFrom(src interface{})

func (*Version) Descriptor

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

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

func (m *WeightedPeer) CopyFrom(src interface{})

func (*WeightedPeer) Descriptor

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

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 naming centralizes the naming of SwarmKit objects.
Package naming centralizes the naming of SwarmKit objects.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL