api

package
v0.0.0-...-bebb8f8 Latest Latest
Warning

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

 Go to latest Published: May 7, 2018 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Overview

Package api is a generated protocol buffer package.

It is generated from these files: 

github.com/docker/swarmkit/api/ca.proto
github.com/docker/swarmkit/api/control.proto
github.com/docker/swarmkit/api/dispatcher.proto
github.com/docker/swarmkit/api/health.proto
github.com/docker/swarmkit/api/logbroker.proto
github.com/docker/swarmkit/api/objects.proto
github.com/docker/swarmkit/api/raft.proto
github.com/docker/swarmkit/api/resource.proto
github.com/docker/swarmkit/api/snapshot.proto
github.com/docker/swarmkit/api/specs.proto
github.com/docker/swarmkit/api/types.proto
github.com/docker/swarmkit/api/watch.proto

It has these top-level messages: 

NodeCertificateStatusRequest
NodeCertificateStatusResponse
IssueNodeCertificateRequest
IssueNodeCertificateResponse
GetRootCACertificateRequest
GetRootCACertificateResponse
GetUnlockKeyRequest
GetUnlockKeyResponse
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
GetConfigRequest
GetConfigResponse
UpdateConfigRequest
UpdateConfigResponse
ListConfigsRequest
ListConfigsResponse
CreateConfigRequest
CreateConfigResponse
RemoveConfigRequest
RemoveConfigResponse
SessionRequest
SessionMessage
HeartbeatRequest
HeartbeatResponse
UpdateTaskStatusRequest
UpdateTaskStatusResponse
TasksRequest
TasksMessage
AssignmentsRequest
Assignment
AssignmentChange
AssignmentsMessage
HealthCheckRequest
HealthCheckResponse
LogSubscriptionOptions
LogSelector
LogContext
LogAttr
LogMessage
SubscribeLogsRequest
SubscribeLogsMessage
ListenSubscriptionsRequest
SubscriptionMessage
PublishLogsMessage
PublishLogsResponse
Meta
Node
Service
Endpoint
Task
NetworkAttachment
Network
Cluster
Secret
Config
Resource
Extension
RaftMember
JoinRequest
JoinResponse
LeaveRequest
LeaveResponse
ProcessRaftMessageRequest
ProcessRaftMessageResponse
StreamRaftMessageRequest
StreamRaftMessageResponse
ResolveAddressRequest
ResolveAddressResponse
InternalRaftRequest
StoreAction
AttachNetworkRequest
AttachNetworkResponse
DetachNetworkRequest
DetachNetworkResponse
StoreSnapshot
ClusterSnapshot
Snapshot
NodeSpec
ServiceSpec
ReplicatedService
GlobalService
TaskSpec
ResourceReference
GenericRuntimeSpec
NetworkAttachmentSpec
ContainerSpec
EndpointSpec
NetworkSpec
ClusterSpec
SecretSpec
ConfigSpec
Version
IndexEntry
Annotations
NamedGenericResource
DiscreteGenericResource
GenericResource
Resources
ResourceRequirements
Platform
PluginDescription
EngineDescription
NodeDescription
NodeTLSInfo
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
FileTarget
SecretReference
ConfigReference
BlacklistedCertificate
HealthConfig
MaybeEncryptedRecord
RootRotation
Privileges
Object
SelectBySlot
SelectByCustom
SelectBy
WatchRequest
WatchMessage

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

Functions

func RegisterCAServer 

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

func RegisterNodeCAServer 

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

Types

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 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 GetRootCACertificateRequest 

type GetRootCACertificateRequest struct {
}

func (*GetRootCACertificateRequest) Copy 

func (m *GetRootCACertificateRequest) Copy() *GetRootCACertificateRequest

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 (m *GetRootCACertificateResponse) Copy() *GetRootCACertificateResponse

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 GetUnlockKeyRequest 

type GetUnlockKeyRequest struct {
}

func (*GetUnlockKeyRequest) Copy 

func (m *GetUnlockKeyRequest) Copy() *GetUnlockKeyRequest

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 (m *GetUnlockKeyResponse) Copy() *GetUnlockKeyResponse

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 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 (m *IssueNodeCertificateRequest) Copy() *IssueNodeCertificateRequest

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 (m *IssueNodeCertificateResponse) Copy() *IssueNodeCertificateResponse

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 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 (m *NodeCertificateStatusRequest) Copy() *NodeCertificateStatusRequest

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 (m *NodeCertificateStatusResponse) Copy() *NodeCertificateStatusResponse

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.