etcd

package
v0.0.0-...-ecdaeff Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package etcd is a generated protocol buffer package.

It is generated from these files: 

pkg/apis/etcd/etcdapi.proto

It has these top-level messages: 

ClusterSpec
Command
RestoreBackupCommand
CreateNewClusterCommand
GetInfoRequest
GetInfoResponse
UpdateEndpointsRequest
MemberMap
MemberMapInfo
UpdateEndpointsResponse
BackupInfo
CommonRequestHeader
DoBackupRequest
DoBackupResponse
DoRestoreRequest
DoRestoreResponse
StopEtcdRequest
StopEtcdResponse
JoinClusterRequest
JoinClusterResponse
ReconfigureRequest
ReconfigureResponse
EtcdCluster
EtcdNode
EtcdState

Index

Constants

This section is empty.

Variables

View Source 
var Phase_name = map[int32]string{
	0: "PHASE_UNKNOWN",
	1: "PHASE_PREPARE",
	2: "PHASE_INITIAL_CLUSTER",
	3: "PHASE_JOIN_EXISTING",
	4: "PHASE_CANCEL_PREPARE",
}
View Source 
var Phase_value = map[string]int32{
	"PHASE_UNKNOWN":         0,
	"PHASE_PREPARE":         1,
	"PHASE_INITIAL_CLUSTER": 2,
	"PHASE_JOIN_EXISTING":   3,
	"PHASE_CANCEL_PREPARE":  4,
}

Functions

func FromJson 

func FromJson(s string, o proto.Message) error

func RegisterEtcdManagerServiceServer 

func RegisterEtcdManagerServiceServer(s *grpc.Server, srv EtcdManagerServiceServer)

func ToJson 

func ToJson(o proto.Message) (string, error)

Types

type BackupInfo 

type BackupInfo struct {
	EtcdVersion string       `protobuf:"bytes,1,opt,name=etcd_version,json=etcdVersion" json:"etcd_version,omitempty"`
	Timestamp   int64        `protobuf:"varint,2,opt,name=timestamp" json:"timestamp,omitempty"`
	ClusterSpec *ClusterSpec `protobuf:"bytes,3,opt,name=cluster_spec,json=clusterSpec" json:"cluster_spec,omitempty"`
}

func (*BackupInfo) Descriptor 

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

func (*BackupInfo) GetClusterSpec 

func (m *BackupInfo) GetClusterSpec() *ClusterSpec

func (*BackupInfo) GetEtcdVersion 

func (m *BackupInfo) GetEtcdVersion() string

func (*BackupInfo) GetTimestamp 

func (m *BackupInfo) GetTimestamp() int64

func (*BackupInfo) ProtoMessage 

func (*BackupInfo) ProtoMessage()

func (*BackupInfo) Reset 

func (m *BackupInfo) Reset()

func (*BackupInfo) String 

func (m *BackupInfo) String() string

type ClusterSpec 

type ClusterSpec struct {
	MemberCount int32  `protobuf:"varint,1,opt,name=member_count,json=memberCount" json:"member_count,omitempty"`
	EtcdVersion string `protobuf:"bytes,2,opt,name=etcd_version,json=etcdVersion" json:"etcd_version,omitempty"`
}

func (*ClusterSpec) Descriptor 

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

func (*ClusterSpec) GetEtcdVersion 

func (m *ClusterSpec) GetEtcdVersion() string

func (*ClusterSpec) GetMemberCount 

func (m *ClusterSpec) GetMemberCount() int32

func (*ClusterSpec) ProtoMessage 

func (*ClusterSpec) ProtoMessage()

func (*ClusterSpec) Reset 

func (m *ClusterSpec) Reset()

func (*ClusterSpec) String 

func (m *ClusterSpec) String() string

type Command 

type Command struct {
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp" json:"timestamp,omitempty"`
	// If restore backup is set, this indicates a request to restore the specified backup
	// This is not normally safe (potential for data loss if the backup is out of date),
	// but either the administrator can set this in a DR scenario,
	// or we set it ourselves immediately after having performed a quarantined backup
	RestoreBackup *RestoreBackupCommand `protobuf:"bytes,10,opt,name=restore_backup,json=restoreBackup" json:"restore_backup,omitempty"`
}

func (*Command) Descriptor 

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

func (*Command) GetRestoreBackup 

func (m *Command) GetRestoreBackup() *RestoreBackupCommand

func (*Command) GetTimestamp 

func (m *Command) GetTimestamp() int64

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) String 

func (m *Command) String() string

type CommonRequestHeader 

type CommonRequestHeader struct {
	LeadershipToken string `protobuf:"bytes,1,opt,name=leadership_token,json=leadershipToken" json:"leadership_token,omitempty"`
	ClusterName     string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName" json:"cluster_name,omitempty"`
}

func (*CommonRequestHeader) Descriptor 

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

func (*CommonRequestHeader) GetClusterName 

func (m *CommonRequestHeader) GetClusterName() string

func (*CommonRequestHeader) GetLeadershipToken 

func (m *CommonRequestHeader) GetLeadershipToken() string

func (*CommonRequestHeader) ProtoMessage 

func (*CommonRequestHeader) ProtoMessage()

func (*CommonRequestHeader) Reset 

func (m *CommonRequestHeader) Reset()

func (*CommonRequestHeader) String 

func (m *CommonRequestHeader) String() string

type CreateNewClusterCommand 

type CreateNewClusterCommand struct {
	ClusterSpec *ClusterSpec `protobuf:"bytes,1,opt,name=cluster_spec,json=clusterSpec" json:"cluster_spec,omitempty"`
}

func (*CreateNewClusterCommand) Descriptor 

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

func (*CreateNewClusterCommand) GetClusterSpec 

func (m *CreateNewClusterCommand) GetClusterSpec() *ClusterSpec

func (*CreateNewClusterCommand) ProtoMessage 

func (*CreateNewClusterCommand) ProtoMessage()

func (*CreateNewClusterCommand) Reset 

func (m *CreateNewClusterCommand) Reset()

func (*CreateNewClusterCommand) String 

func (m *CreateNewClusterCommand) String() string

type DoBackupRequest 

type DoBackupRequest struct {
	Header  *CommonRequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Storage string               `protobuf:"bytes,2,opt,name=storage" json:"storage,omitempty"`
	// If allow_offline_backup is true, backup will be permitted even if etcd is not running on the node
	AllowOfflineBackup bool        `protobuf:"varint,4,opt,name=allow_offline_backup,json=allowOfflineBackup" json:"allow_offline_backup,omitempty"`
	Info               *BackupInfo `protobuf:"bytes,10,opt,name=info" json:"info,omitempty"`
}

func (*DoBackupRequest) Descriptor 

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

func (*DoBackupRequest) GetAllowOfflineBackup 

func (m *DoBackupRequest) GetAllowOfflineBackup() bool

func (*DoBackupRequest) GetHeader 

func (m *DoBackupRequest) GetHeader() *CommonRequestHeader

func (*DoBackupRequest) GetInfo 

func (m *DoBackupRequest) GetInfo() *BackupInfo

func (*DoBackupRequest) GetStorage 

func (m *DoBackupRequest) GetStorage() string

func (*DoBackupRequest) ProtoMessage 

func (*DoBackupRequest) ProtoMessage()

func (*DoBackupRequest) Reset 

func (m *DoBackupRequest) Reset()

func (*DoBackupRequest) String 

func (m *DoBackupRequest) String() string

type DoBackupResponse 

type DoBackupResponse struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*DoBackupResponse) Descriptor 

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

func (*DoBackupResponse) GetName 

func (m *DoBackupResponse) GetName() string

func (*DoBackupResponse) ProtoMessage 

func (*DoBackupResponse) ProtoMessage()

func (*DoBackupResponse) Reset 

func (m *DoBackupResponse) Reset()

func (*DoBackupResponse) String 

func (m *DoBackupResponse) String() string

type DoRestoreRequest 

type DoRestoreRequest struct {
	Header     *CommonRequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Storage    string               `protobuf:"bytes,2,opt,name=storage" json:"storage,omitempty"`
	BackupName string               `protobuf:"bytes,4,opt,name=backup_name,json=backupName" json:"backup_name,omitempty"`
}

func (*DoRestoreRequest) Descriptor 

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

func (*DoRestoreRequest) GetBackupName 

func (m *DoRestoreRequest) GetBackupName() string

func (*DoRestoreRequest) GetHeader 

func (m *DoRestoreRequest) GetHeader() *CommonRequestHeader

func (*DoRestoreRequest) GetStorage 

func (m *DoRestoreRequest) GetStorage() string

func (*DoRestoreRequest) ProtoMessage 

func (*DoRestoreRequest) ProtoMessage()

func (*DoRestoreRequest) Reset 

func (m *DoRestoreRequest) Reset()

func (*DoRestoreRequest) String 

func (m *DoRestoreRequest) String() string

type DoRestoreResponse 

type DoRestoreResponse struct {
}

func (*DoRestoreResponse) Descriptor 

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

func (*DoRestoreResponse) ProtoMessage 

func (*DoRestoreResponse) ProtoMessage()

func (*DoRestoreResponse) Reset 

func (m *DoRestoreResponse) Reset()

func (*DoRestoreResponse) String 

func (m *DoRestoreResponse) String() string

type EtcdCluster 

type EtcdCluster struct {
	DesiredClusterSize int32 `protobuf:"varint,1,opt,name=desired_cluster_size,json=desiredClusterSize" json:"desired_cluster_size,omitempty"`
	//    int32 peer_port = 2;
	//    int32 client_port = 3;
	//    string cluster_name = 4;
	ClusterToken string `protobuf:"bytes,5,opt,name=cluster_token,json=clusterToken" json:"cluster_token,omitempty"`
	// string my_id = 6;
	Nodes []*EtcdNode `protobuf:"bytes,7,rep,name=nodes" json:"nodes,omitempty"`
}

func (*EtcdCluster) Descriptor 

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

func (*EtcdCluster) GetClusterToken 

func (m *EtcdCluster) GetClusterToken() string

func (*EtcdCluster) GetDesiredClusterSize 

func (m *EtcdCluster) GetDesiredClusterSize() int32

func (*EtcdCluster) GetNodes 

func (m *EtcdCluster) GetNodes() []*EtcdNode

func (*EtcdCluster) ProtoMessage 

func (*EtcdCluster) ProtoMessage()

func (*EtcdCluster) Reset 

func (m *EtcdCluster) Reset()

func (*EtcdCluster) String 

func (m *EtcdCluster) String() string

type EtcdManagerServiceClient 

type EtcdManagerServiceClient interface {
	// GetInfo gets info about the node
	GetInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error)
	// UpdateEndpoints is sent to peers so they can update their inter-cluster routing
	UpdateEndpoints(ctx context.Context, in *UpdateEndpointsRequest, opts ...grpc.CallOption) (*UpdateEndpointsResponse, error)
	// JoinCluster requests that the node join an existing cluster
	JoinCluster(ctx context.Context, in *JoinClusterRequest, opts ...grpc.CallOption) (*JoinClusterResponse, error)
	// Reconfigure changes the configuration of an existing node, primarily for a version upgrade/downgrade
	Reconfigure(ctx context.Context, in *ReconfigureRequest, opts ...grpc.CallOption) (*ReconfigureResponse, error)
	// DoBackup requests that the node backup etcd
	DoBackup(ctx context.Context, in *DoBackupRequest, opts ...grpc.CallOption) (*DoBackupResponse, error)
	// DoRestore requests that the node restores an etcd backup
	DoRestore(ctx context.Context, in *DoRestoreRequest, opts ...grpc.CallOption) (*DoRestoreResponse, error)
	// StopEtcd requests that the node no longer run etcd.
	// Typically the node will already have been removed from the etcd cluster.
	StopEtcd(ctx context.Context, in *StopEtcdRequest, opts ...grpc.CallOption) (*StopEtcdResponse, error)
}

func NewEtcdManagerServiceClient 

func NewEtcdManagerServiceClient(cc *grpc.ClientConn) EtcdManagerServiceClient

type EtcdManagerServiceServer 

type EtcdManagerServiceServer interface {
	// GetInfo gets info about the node
	GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error)
	// UpdateEndpoints is sent to peers so they can update their inter-cluster routing
	UpdateEndpoints(context.Context, *UpdateEndpointsRequest) (*UpdateEndpointsResponse, error)
	// JoinCluster requests that the node join an existing cluster
	JoinCluster(context.Context, *JoinClusterRequest) (*JoinClusterResponse, error)
	// Reconfigure changes the configuration of an existing node, primarily for a version upgrade/downgrade
	Reconfigure(context.Context, *ReconfigureRequest) (*ReconfigureResponse, error)
	// DoBackup requests that the node backup etcd
	DoBackup(context.Context, *DoBackupRequest) (*DoBackupResponse, error)
	// DoRestore requests that the node restores an etcd backup
	DoRestore(context.Context, *DoRestoreRequest) (*DoRestoreResponse, error)
	// StopEtcd requests that the node no longer run etcd.
	// Typically the node will already have been removed from the etcd cluster.
	StopEtcd(context.Context, *StopEtcdRequest) (*StopEtcdResponse, error)
}

type EtcdNode 

type EtcdNode struct {
	Name                  string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	PeerUrls              []string `protobuf:"bytes,2,rep,name=peer_urls,json=peerUrls" json:"peer_urls,omitempty"`
	ClientUrls            []string `protobuf:"bytes,3,rep,name=client_urls,json=clientUrls" json:"client_urls,omitempty"`
	QuarantinedClientUrls []string `protobuf:"bytes,4,rep,name=quarantined_client_urls,json=quarantinedClientUrls" json:"quarantined_client_urls,omitempty"`
	TlsEnabled            bool     `protobuf:"varint,5,opt,name=tls_enabled,json=tlsEnabled" json:"tls_enabled,omitempty"`
}

func (*EtcdNode) Descriptor 

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

func (*EtcdNode) GetClientUrls 

func (m *EtcdNode) GetClientUrls() []string

func (*EtcdNode) GetName 

func (m *EtcdNode) GetName() string

func (*EtcdNode) GetPeerUrls 

func (m *EtcdNode) GetPeerUrls() []string

func (*EtcdNode) GetQuarantinedClientUrls 

func (m *EtcdNode) GetQuarantinedClientUrls() []string

func (*EtcdNode) GetTlsEnabled 

func (m *EtcdNode) GetTlsEnabled() bool

func (*EtcdNode) ProtoMessage 

func (*EtcdNode) ProtoMessage()

func (*EtcdNode) Reset 

func (m *EtcdNode) Reset()

func (*EtcdNode) String 

func (m *EtcdNode) String() string

type EtcdState 

type EtcdState struct {
	NewCluster  bool         `protobuf:"varint,1,opt,name=new_cluster,json=newCluster" json:"new_cluster,omitempty"`
	Cluster     *EtcdCluster `protobuf:"bytes,2,opt,name=cluster" json:"cluster,omitempty"`
	EtcdVersion string       `protobuf:"bytes,3,opt,name=etcd_version,json=etcdVersion" json:"etcd_version,omitempty"`
	Quarantined bool         `protobuf:"varint,4,opt,name=quarantined" json:"quarantined,omitempty"`
}

func (*EtcdState) Descriptor 

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

func (*EtcdState) GetCluster 

func (m *EtcdState) GetCluster() *EtcdCluster

func (*EtcdState) GetEtcdVersion 

func (m *EtcdState) GetEtcdVersion() string

func (*EtcdState) GetNewCluster 

func (m *EtcdState) GetNewCluster() bool

func (*EtcdState) GetQuarantined 

func (m *EtcdState) GetQuarantined() bool

func (*EtcdState) ProtoMessage 

func (*EtcdState) ProtoMessage()

func (*EtcdState) Reset 

func (m *EtcdState) Reset()

func (*EtcdState) String 

func (m *EtcdState) String() string

type GetInfoRequest 

type GetInfoRequest struct {
}

func (*GetInfoRequest) Descriptor 

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

func (*GetInfoRequest) ProtoMessage 

func (*GetInfoRequest) ProtoMessage()

func (*GetInfoRequest) Reset 

func (m *GetInfoRequest) Reset()

func (*GetInfoRequest) String 

func (m *GetInfoRequest) String() string

type GetInfoResponse 

type GetInfoResponse struct {
	ClusterName       string     `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName" json:"cluster_name,omitempty"`
	NodeConfiguration *EtcdNode  `protobuf:"bytes,5,opt,name=node_configuration,json=nodeConfiguration" json:"node_configuration,omitempty"`
	EtcdState         *EtcdState `protobuf:"bytes,6,opt,name=etcd_state,json=etcdState" json:"etcd_state,omitempty"`
}

func (*GetInfoResponse) Descriptor 

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

func (*GetInfoResponse) GetClusterName 

func (m *GetInfoResponse) GetClusterName() string

func (*GetInfoResponse) GetEtcdState 

func (m *GetInfoResponse) GetEtcdState() *EtcdState

func (*GetInfoResponse) GetNodeConfiguration 

func (m *GetInfoResponse) GetNodeConfiguration() *EtcdNode

func (*GetInfoResponse) ProtoMessage 

func (*GetInfoResponse) ProtoMessage()

func (*GetInfoResponse) Reset 

func (m *GetInfoResponse) Reset()

func (*GetInfoResponse) String 

func (m *GetInfoResponse) String() string

type JoinClusterRequest 

type JoinClusterRequest struct {
	Header       *CommonRequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Phase        Phase                `protobuf:"varint,2,opt,name=phase,enum=etcd.Phase" json:"phase,omitempty"`
	ClusterToken string               `protobuf:"bytes,4,opt,name=cluster_token,json=clusterToken" json:"cluster_token,omitempty"`
	Nodes        []*EtcdNode          `protobuf:"bytes,5,rep,name=nodes" json:"nodes,omitempty"`
	AddNode      *EtcdNode            `protobuf:"bytes,6,opt,name=add_node,json=addNode" json:"add_node,omitempty"`
	EtcdVersion  string               `protobuf:"bytes,7,opt,name=etcd_version,json=etcdVersion" json:"etcd_version,omitempty"`
}

func (*JoinClusterRequest) Descriptor 

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

func (*JoinClusterRequest) GetAddNode 

func (m *JoinClusterRequest) GetAddNode() *EtcdNode

func (*JoinClusterRequest) GetClusterToken 

func (m *JoinClusterRequest) GetClusterToken() string

func (*JoinClusterRequest) GetEtcdVersion 

func (m *JoinClusterRequest) GetEtcdVersion() string

func (*JoinClusterRequest) GetHeader 

func (m *JoinClusterRequest) GetHeader() *CommonRequestHeader

func (*JoinClusterRequest) GetNodes 

func (m *JoinClusterRequest) GetNodes() []*EtcdNode

func (*JoinClusterRequest) GetPhase 

func (m *JoinClusterRequest) GetPhase() Phase

func (*JoinClusterRequest) ProtoMessage 

func (*JoinClusterRequest) ProtoMessage()

func (*JoinClusterRequest) Reset 

func (m *JoinClusterRequest) Reset()

func (*JoinClusterRequest) String 

func (m *JoinClusterRequest) String() string

type JoinClusterResponse 

type JoinClusterResponse struct {
}

func (*JoinClusterResponse) Descriptor 

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

func (*JoinClusterResponse) ProtoMessage 

func (*JoinClusterResponse) ProtoMessage()

func (*JoinClusterResponse) Reset 

func (m *JoinClusterResponse) Reset()

func (*JoinClusterResponse) String 

func (m *JoinClusterResponse) String() string

type MemberMap 

type MemberMap struct {
	Members []*MemberMapInfo `protobuf:"bytes,1,rep,name=members" json:"members,omitempty"`
}

func (*MemberMap) Descriptor 

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

func (*MemberMap) GetMembers 

func (m *MemberMap) GetMembers() []*MemberMapInfo

func (*MemberMap) ProtoMessage 

func (*MemberMap) ProtoMessage()

func (*MemberMap) Reset 

func (m *MemberMap) Reset()

func (*MemberMap) String 

func (m *MemberMap) String() string

type MemberMapInfo 

type MemberMapInfo struct {
	Name      string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Dns       string   `protobuf:"bytes,2,opt,name=dns" json:"dns,omitempty"`
	Addresses []string `protobuf:"bytes,3,rep,name=addresses" json:"addresses,omitempty"`
}

func (*MemberMapInfo) Descriptor 

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

func (*MemberMapInfo) GetAddresses 

func (m *MemberMapInfo) GetAddresses() []string

func (*MemberMapInfo) GetDns 

func (m *MemberMapInfo) GetDns() string

func (*MemberMapInfo) GetName 

func (m *MemberMapInfo) GetName() string

func (*MemberMapInfo) ProtoMessage 

func (*MemberMapInfo) ProtoMessage()

func (*MemberMapInfo) Reset 

func (m *MemberMapInfo) Reset()

func (*MemberMapInfo) String 

func (m *MemberMapInfo) String() string

type Phase 

type Phase int32
const (
	Phase_PHASE_UNKNOWN         Phase = 0
	Phase_PHASE_PREPARE         Phase = 1
	Phase_PHASE_INITIAL_CLUSTER Phase = 2
	Phase_PHASE_JOIN_EXISTING   Phase = 3
	// Cancel a previous prepare (it times out eventually)
	Phase_PHASE_CANCEL_PREPARE Phase = 4
)

func (Phase) EnumDescriptor 

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

func (Phase) String 

func (x Phase) String() string

type ReconfigureRequest 

type ReconfigureRequest struct {
	Header         *CommonRequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	SetEtcdVersion string               `protobuf:"bytes,10,opt,name=set_etcd_version,json=setEtcdVersion" json:"set_etcd_version,omitempty"`
	// Note that because this is bool this must always be specified
	Quarantined bool `protobuf:"varint,11,opt,name=quarantined" json:"quarantined,omitempty"`
	// Note that because this is bool we need two fields
	EnableTls bool `protobuf:"varint,12,opt,name=enable_tls,json=enableTls" json:"enable_tls,omitempty"`
}

func (*ReconfigureRequest) Descriptor 

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

func (*ReconfigureRequest) GetEnableTls 

func (m *ReconfigureRequest) GetEnableTls() bool

func (*ReconfigureRequest) GetHeader 

func (m *ReconfigureRequest) GetHeader() *CommonRequestHeader

func (*ReconfigureRequest) GetQuarantined 

func (m *ReconfigureRequest) GetQuarantined() bool

func (*ReconfigureRequest) GetSetEtcdVersion 

func (m *ReconfigureRequest) GetSetEtcdVersion() string

func (*ReconfigureRequest) ProtoMessage 

func (*ReconfigureRequest) ProtoMessage()

func (*ReconfigureRequest) Reset 

func (m *ReconfigureRequest) Reset()

func (*ReconfigureRequest) String 

func (m *ReconfigureRequest) String() string

type ReconfigureResponse 

type ReconfigureResponse struct {
}

func (*ReconfigureResponse) Descriptor 

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

func (*ReconfigureResponse) ProtoMessage 

func (*ReconfigureResponse) ProtoMessage()

func (*ReconfigureResponse) Reset 

func (m *ReconfigureResponse) Reset()

func (*ReconfigureResponse) String 

func (m *ReconfigureResponse) String() string

type RestoreBackupCommand 

type RestoreBackupCommand struct {
	// The new cluster spec we should restore into
	ClusterSpec *ClusterSpec `protobuf:"bytes,1,opt,name=cluster_spec,json=clusterSpec" json:"cluster_spec,omitempty"`
	Backup      string       `protobuf:"bytes,3,opt,name=backup" json:"backup,omitempty"`
}

func (*RestoreBackupCommand) Descriptor 

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

func (*RestoreBackupCommand) GetBackup 

func (m *RestoreBackupCommand) GetBackup() string

func (*RestoreBackupCommand) GetClusterSpec 

func (m *RestoreBackupCommand) GetClusterSpec() *ClusterSpec

func (*RestoreBackupCommand) ProtoMessage 

func (*RestoreBackupCommand) ProtoMessage()

func (*RestoreBackupCommand) Reset 

func (m *RestoreBackupCommand) Reset()

func (*RestoreBackupCommand) String 

func (m *RestoreBackupCommand) String() string

type StopEtcdRequest 

type StopEtcdRequest struct {
	Header *CommonRequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*StopEtcdRequest) Descriptor 

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

func (*StopEtcdRequest) GetHeader 

func (m *StopEtcdRequest) GetHeader() *CommonRequestHeader

func (*StopEtcdRequest) ProtoMessage 

func (*StopEtcdRequest) ProtoMessage()

func (*StopEtcdRequest) Reset 

func (m *StopEtcdRequest) Reset()

func (*StopEtcdRequest) String 

func (m *StopEtcdRequest) String() string

type StopEtcdResponse 

type StopEtcdResponse struct {
}

func (*StopEtcdResponse) Descriptor 

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

func (*StopEtcdResponse) ProtoMessage 

func (*StopEtcdResponse) ProtoMessage()

func (*StopEtcdResponse) Reset 

func (m *StopEtcdResponse) Reset()

func (*StopEtcdResponse) String 

func (m *StopEtcdResponse) String() string

type UpdateEndpointsRequest 

type UpdateEndpointsRequest struct {
	// Contains information about the current nodes
	// It can be used for nodes to update /etc/hosts
	MemberMap *MemberMap `protobuf:"bytes,1,opt,name=member_map,json=memberMap" json:"member_map,omitempty"`
}

func (*UpdateEndpointsRequest) Descriptor 

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

func (*UpdateEndpointsRequest) GetMemberMap 

func (m *UpdateEndpointsRequest) GetMemberMap() *MemberMap

func (*UpdateEndpointsRequest) ProtoMessage 

func (*UpdateEndpointsRequest) ProtoMessage()

func (*UpdateEndpointsRequest) Reset 

func (m *UpdateEndpointsRequest) Reset()

func (*UpdateEndpointsRequest) String 

func (m *UpdateEndpointsRequest) String() string

type UpdateEndpointsResponse 

type UpdateEndpointsResponse struct {
}

func (*UpdateEndpointsResponse) Descriptor 

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

func (*UpdateEndpointsResponse) ProtoMessage 

func (*UpdateEndpointsResponse) ProtoMessage()

func (*UpdateEndpointsResponse) Reset 

func (m *UpdateEndpointsResponse) Reset()

func (*UpdateEndpointsResponse) String 

func (m *UpdateEndpointsResponse) String() string

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.