etcd

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"`
}

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"`
}

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"`
}

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"`
}

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

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"`
}

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

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"`
}

type DoRestoreResponse struct {
}

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"`
}

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

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 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"`
}

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"`
}

type GetInfoRequest struct {
}

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"`
}

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"`
}

type JoinClusterResponse struct {
}

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

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"`
}

type Phase int32

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"`
}

type ReconfigureResponse struct {
}

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"`
}

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

type StopEtcdResponse struct {
}

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"`
}

type UpdateEndpointsResponse struct {
}