consensus

type ChangeConfigRecordPB struct {
	TabletId []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// The old committed configuration config for verification purposes.
	OldConfig *common.RaftConfigPB `protobuf:"bytes,2,req,name=old_config,json=oldConfig" json:"old_config,omitempty"`
	// The new configuration to set the configuration to.
	NewConfig *common.RaftConfigPB `protobuf:"bytes,3,req,name=new_config,json=newConfig" json:"new_config,omitempty"`
	// contains filtered or unexported fields
}

type ChangeConfigRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,4,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	TabletId []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// The type of config change requested.
	// This field must be specified, but is left as optional due to being an enum.
	Type *ChangeConfigType `protobuf:"varint,2,opt,name=type,enum=yb.consensus.ChangeConfigType" json:"type,omitempty"`
	// The peer to add or remove.
	// When 'type' == ADD_SERVER, both the permanent_uuid and last_known_addr
	// fields must be set. For REMOVE_SERVER, either the permanent_uuid field or
	// last_known_addr should be set - 'use_host' is for using the latter.
	Server *common.RaftPeerPB `protobuf:"bytes,3,opt,name=server" json:"server,omitempty"`
	// The OpId index of the committed config to replace.
	// This optional parameter is here to provide an atomic (compare-and-swap)
	// ChangeConfig operation. The ChangeConfig() operation will fail if this
	// parameter is specified and the committed config does not have a matching
	// opid_index. See also the definition of RaftConfigPB.
	CasConfigOpidIndex *int64 `protobuf:"varint,5,opt,name=cas_config_opid_index,json=casConfigOpidIndex" json:"cas_config_opid_index,omitempty"`
	// For REMOVE case, when this is set, we assume that the peer is dead and will not
	// affect the quorum anymore. So we skip checking/using its server uuid and remove
	// it based on the ip/port info from 'server'.
	UseHost *bool `protobuf:"varint,6,opt,name=use_host,json=useHost,def=0" json:"use_host,omitempty"`
	// contains filtered or unexported fields
}

type ChangeConfigResponsePB struct {
	Error *tserver.TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// The hybrid_time chosen by the server for this change config operation.
	// TODO: At the time of writing, this field is never set in the response.
	// TODO: Propagate signed hybrid_times. See KUDU-611.
	HybridTime *uint64 `protobuf:"fixed64,2,opt,name=hybrid_time,json=hybridTime" json:"hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

type ChangeConfigType int32

type ConsensusErrorPB struct {

	// The error code.
	Code *ConsensusErrorPB_Code `protobuf:"varint,1,req,name=code,enum=yb.consensus.ConsensusErrorPB_Code" json:"code,omitempty"`
	// The Status object for the error. This will include a textual
	// message that may be more useful to present in log messages, etc,
	// though its error code is less specific.
	Status *common.AppStatusPB `protobuf:"bytes,2,req,name=status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type ConsensusErrorPB_Code int32

type ConsensusRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte  `protobuf:"bytes,7,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	TabletId *string `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// The uuid of the peer making the call.
	CallerUuid []byte `protobuf:"bytes,2,req,name=caller_uuid,json=callerUuid" json:"caller_uuid,omitempty"`
	// The caller's term. As only leaders can send messages,
	// replicas will accept all messages as long as the term
	// is equal to or higher than the last term they know about.
	// If a leader receives a request with a term higher than its own,
	// it will step down and enter FOLLOWER state (see Raft sec. 5.1).
	CallerTerm *int64 `protobuf:"varint,3,req,name=caller_term,json=callerTerm" json:"caller_term,omitempty"`
	// The id of the operation immediately preceding the first
	// operation in 'ops'. If the replica is receiving 'ops' for
	// the first time 'preceding_id' must match the replica's
	// last operation.
	//
	// This must be set if 'ops' is non-empty.
	PrecedingId *util.OpIdPB `protobuf:"bytes,4,opt,name=preceding_id,json=precedingId" json:"preceding_id,omitempty"`
	// The id of the last committed operation in the configuration. This is the
	// id of the last operation the leader deemed committed from a consensus
	// standpoint (not the last operation the leader applied).
	//
	// Raft calls this field 'leaderCommit'.
	CommittedOpId *util.OpIdPB `protobuf:"bytes,5,req,name=committed_op_id,json=committedOpId" json:"committed_op_id,omitempty"`
	// Sequence of operations to be replicated by this peer.
	// These will be committed when committed_index advances above their
	// respective OpIds. In some cases committed_index can indicate that
	// these operations are already committed, in which case they will be
	// committed during the same request.
	Ops []*ReplicateMsg `protobuf:"bytes,6,rep,name=ops" json:"ops,omitempty"`
	// Leader lease duration in milliseconds. A leader is not allowed to serve up-to-date reads
	// until it is able to replicate a lease extension. A new leader cannot assume its
	// responsibilities until this amount time has definitely passed since the old leader sent the
	// consensus request. Due to potential clock skew, we are not sending a timestamp, but an amount
	// of time followers have to wait.
	LeaderLeaseDurationMs *int32 `protobuf:"varint,8,opt,name=leader_lease_duration_ms,json=leaderLeaseDurationMs" json:"leader_lease_duration_ms,omitempty"`
	// Leader lease expiration, physical part of hybrid time. A new leader cannot add new
	// entries to RAFT log until hybrid time passes this expiration.
	HtLeaseExpiration *uint64 `protobuf:"fixed64,9,opt,name=ht_lease_expiration,json=htLeaseExpiration" json:"ht_lease_expiration,omitempty"`
	// Safe time measured on the leader at the time this request was generated.
	PropagatedSafeTime *uint64 `protobuf:"fixed64,10,opt,name=propagated_safe_time,json=propagatedSafeTime" json:"propagated_safe_time,omitempty"`
	// Hybrid time on the leader when this request was generated.
	PropagatedHybridTime *uint64 `protobuf:"fixed64,11,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

type ConsensusResponsePB struct {

	// The uuid of the peer making the response.
	ResponderUuid []byte `protobuf:"bytes,1,opt,name=responder_uuid,json=responderUuid" json:"responder_uuid,omitempty"`
	// The current term of the peer making the response.
	// This is used to update the caller (and make it step down if it is
	// out of date).
	ResponderTerm *int64 `protobuf:"varint,2,opt,name=responder_term,json=responderTerm" json:"responder_term,omitempty"`
	// The current consensus status of the receiver peer.
	Status *ConsensusStatusPB `protobuf:"bytes,3,opt,name=status" json:"status,omitempty"`
	// A generic error message (such as tablet not found), per operation
	// error messages are sent along with the consensus status.
	Error *tserver.TabletServerErrorPB `protobuf:"bytes,999,opt,name=error" json:"error,omitempty"`
	// Number of SST files in this follower regular db.
	NumSstFiles *int64 `protobuf:"varint,5,opt,name=num_sst_files,json=numSstFiles" json:"num_sst_files,omitempty"`
	// Hybrid time on the follower when this request was processed.
	PropagatedHybridTime *uint64 `protobuf:"fixed64,6,opt,name=propagated_hybrid_time,json=propagatedHybridTime" json:"propagated_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

type ConsensusService interface {
	UpdateConsensus(request *ConsensusRequestPB) (*ConsensusResponsePB, error)
	RequestConsensusVote(request *VoteRequestPB) (*VoteResponsePB, error)
	ChangeConfig(request *ChangeConfigRequestPB) (*ChangeConfigResponsePB, error)
	GetNodeInstance(request *GetNodeInstanceRequestPB) (*GetNodeInstanceResponsePB, error)
	RunLeaderElection(request *RunLeaderElectionRequestPB) (*RunLeaderElectionResponsePB, error)
	LeaderElectionLost(request *LeaderElectionLostRequestPB) (*LeaderElectionLostResponsePB, error)
	LeaderStepDown(request *LeaderStepDownRequestPB) (*LeaderStepDownResponsePB, error)
	GetLastOpId(request *GetLastOpIdRequestPB) (*GetLastOpIdResponsePB, error)
	GetConsensusState(request *GetConsensusStateRequestPB) (*GetConsensusStateResponsePB, error)
	StartRemoteBootstrap(request *StartRemoteBootstrapRequestPB) (*StartRemoteBootstrapResponsePB, error)
}

type ConsensusServiceImpl struct {
	Log       logr.Logger
	Messenger message.Messenger
}

type ConsensusStatusPB struct {

	// The last message received (and replicated) by the peer.
	LastReceived *util.OpIdPB `protobuf:"bytes,1,req,name=last_received,json=lastReceived" json:"last_received,omitempty"`
	// The id of the last op that was replicated by the current leader.
	// This doesn't necessarily mean that the term of this op equals the current
	// term, since the current leader may be replicating ops from a prior term.
	// Unset if none currently received.
	//
	// In the case where there is a log matching property error
	// (PRECEDING_ENTRY_DIDNT_MATCH), this field is important and may still be
	// set, since the leader queue uses this field in conjuction with
	// last_received to decide on the next id to send to the follower.
	LastReceivedCurrentLeader *util.OpIdPB `` /* 133-byte string literal not displayed */
	// The last committed index that is known to the peer.
	LastCommittedIdx *int64 `protobuf:"varint,2,opt,name=last_committed_idx,json=lastCommittedIdx" json:"last_committed_idx,omitempty"`
	// The last operation applied by the peer.
	LastApplied *util.OpIdPB `protobuf:"bytes,5,opt,name=last_applied,json=lastApplied" json:"last_applied,omitempty"`
	// When the last request failed for some consensus related (internal) reason.
	// In some cases the error will have a specific code that the caller will
	// have to handle in certain ways.
	Error *ConsensusErrorPB `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type DriverType int32

type GetConsensusStateRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,2,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	// The id of the tablet.
	TabletId []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// Whether to fetch the committed or active consensus state.
	Type *common.ConsensusConfigType `protobuf:"varint,3,opt,name=type,enum=yb.consensus.ConsensusConfigType,def=1" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type GetConsensusStateResponsePB struct {
	Cstate *common.ConsensusStatePB `protobuf:"bytes,1,opt,name=cstate" json:"cstate,omitempty"`
	// A generic error message (such as tablet not found).
	Error *tserver.TabletServerErrorPB `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	// Allows returning the leader lease status in the same RPC. Useful for waiting for the leader
	// to be allowed to serve requests.
	LeaderLeaseStatus *LeaderLeaseStatus `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetLastOpIdRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,2,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	// the id of the tablet
	TabletId []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// Whether to return the last-received or last-committed OpId.
	OpidType *OpIdType `protobuf:"varint,3,opt,name=opid_type,json=opidType,enum=yb.consensus.OpIdType,def=1" json:"opid_type,omitempty"`
	// contains filtered or unexported fields
}

type GetLastOpIdResponsePB struct {
	Opid *util.OpIdPB `protobuf:"bytes,1,opt,name=opid" json:"opid,omitempty"`
	// A generic error message (such as tablet not found).
	Error *tserver.TabletServerErrorPB `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type GetNodeInstanceRequestPB struct {
	// contains filtered or unexported fields
}

type GetNodeInstanceResponsePB struct {
	NodeInstance *common.NodeInstancePB       `protobuf:"bytes,1,opt,name=node_instance,json=nodeInstance" json:"node_instance,omitempty"`
	Registration *common.ServerRegistrationPB `protobuf:"bytes,2,opt,name=registration" json:"registration,omitempty"`
	// contains filtered or unexported fields
}

type HistoryCutoffPB struct {
	HistoryCutoff *uint64 `protobuf:"fixed64,1,opt,name=history_cutoff,json=historyCutoff" json:"history_cutoff,omitempty"`
	// contains filtered or unexported fields
}

type LeaderElectionLostRequestPB struct {

	// UUID of server this request is addressed to.
	// It is originator_uuid from RunLeaderElectionRequestPB
	DestUuid []byte `protobuf:"bytes,1,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	// the id of the tablet
	TabletId []byte `protobuf:"bytes,2,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// UUID of server that lost election
	ElectionLostByUuid []byte `protobuf:"bytes,3,opt,name=election_lost_by_uuid,json=electionLostByUuid" json:"election_lost_by_uuid,omitempty"`
	// contains filtered or unexported fields
}

type LeaderElectionLostResponsePB struct {

	// A generic error message (such as tablet not found).
	Error *tserver.TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type LeaderLeaseStatus int32

type LeaderStepDownRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,2,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	// The id of the tablet.
	TabletId []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// UUID of the server that should run the election to become the new leader.
	NewLeaderUuid []byte `protobuf:"bytes,3,opt,name=new_leader_uuid,json=newLeaderUuid" json:"new_leader_uuid,omitempty"`
	// Used in tests to ignore check for new leader conditions.
	ForceStepDown *bool `protobuf:"varint,4,opt,name=force_step_down,json=forceStepDown" json:"force_step_down,omitempty"`
	// If new_leader_uuid is not specified, the current leader will attempt
	// to gracefully transfer leadership to another peer. Setting this flag
	// disables that behavior.
	DisableGracefulTransition *bool `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

type LeaderStepDownResponsePB struct {

	// A generic error message (such as tablet not found).
	Error *tserver.TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// Time in milliseconds since previous election failure with the same intended ("protege") leader.
	// This is used to track the remaining amount of time during which the load balancer should not
	// attempt to ask (any) leader of this tablet to step down in favor of the same peer.
	TimeSinceElectionFailureMs *int64 `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type LogEntryBatchPB struct {
	Entry         []*LogEntryPB `protobuf:"bytes,1,rep,name=entry" json:"entry,omitempty"`
	CommittedOpId *util.OpIdPB  `protobuf:"bytes,2,opt,name=committed_op_id,json=committedOpId" json:"committed_op_id,omitempty"`
	// Time when this batch was appended, this time is monotonically increase,
	// and restart safe. I.e. first batch after restart will have time greater than or equal to
	// time of last batch added before restart.
	MonoTime *uint64 `protobuf:"varint,3,opt,name=mono_time,json=monoTime" json:"mono_time,omitempty"`
	// contains filtered or unexported fields
}

type LogEntryPB struct {
	Type      *LogEntryTypePB `protobuf:"varint,1,req,name=type,enum=yb.log.LogEntryTypePB" json:"type,omitempty"`
	Replicate *ReplicateMsg   `protobuf:"bytes,2,opt,name=replicate" json:"replicate,omitempty"`
	// contains filtered or unexported fields
}

type LogEntryTypePB int32

type LogSegmentFooterPB struct {

	// The total number of operations inside this segment.
	NumEntries *int64 `protobuf:"varint,1,req,name=num_entries,json=numEntries" json:"num_entries,omitempty"`
	// The minimum and maximum index of a REPLICATE message in this segment.
	// NOTE: because of log truncation, the min/max are not necessarily the first/last!  For example,
	// a log segment may contain entries "1.5, 1.6, 2.3, 3.3" due to multiple term changes.
	//
	// Because it's possible for a segment to have no REPLICATE messages in it, we set the default
	// to -1 for these fields to avoid accidentally reading 0, which might look like a real log index.
	MinReplicateIndex *int64 `protobuf:"varint,2,opt,name=min_replicate_index,json=minReplicateIndex,def=-1" json:"min_replicate_index,omitempty"`
	MaxReplicateIndex *int64 `protobuf:"varint,3,opt,name=max_replicate_index,json=maxReplicateIndex,def=-1" json:"max_replicate_index,omitempty"`
	// The time (microseconds since epoch) when this segment was closed.
	// NOTE: in configurations where --skip_wal_rewrite=false is specified, log segments are rewritten
	// during bootstrap, so this field will be reset to the time of the bootstrap in each log segment
	// on a newly-restarted server, rather than copied over from the old log segments.
	CloseTimestampMicros *int64 `protobuf:"varint,4,opt,name=close_timestamp_micros,json=closeTimestampMicros" json:"close_timestamp_micros,omitempty"`
	// contains filtered or unexported fields
}

type LogSegmentHeaderPB struct {

	// Log format major version.
	MajorVersion *uint32 `protobuf:"varint,1,req,name=major_version,json=majorVersion" json:"major_version,omitempty"`
	// Log format minor version.
	MinorVersion *uint32 `protobuf:"varint,2,req,name=minor_version,json=minorVersion" json:"minor_version,omitempty"`
	// The ID of the tablet this WAL segment stores entries for.
	TabletId []byte `protobuf:"bytes,5,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// The tablet-specific sequence number of this WAL segment.
	SequenceNumber *uint64 `protobuf:"varint,6,req,name=sequence_number,json=sequenceNumber" json:"sequence_number,omitempty"`
	// Schema used when appending entries to this log, and its version.
	Schema        *common.SchemaPB `protobuf:"bytes,7,req,name=schema" json:"schema,omitempty"`
	SchemaVersion *uint32          `protobuf:"varint,8,opt,name=schema_version,json=schemaVersion" json:"schema_version,omitempty"`
	// contains filtered or unexported fields
}

type NoOpRequestPB struct {

	// Allows to set a dummy payload, for tests.
	PayloadForTests []byte `protobuf:"bytes,1,opt,name=payload_for_tests,json=payloadForTests" json:"payload_for_tests,omitempty"`
	// contains filtered or unexported fields
}

type NoOpResponsePB struct {

	// Allows to set a dummy payload, for tests.
	PayloadForTests []byte `protobuf:"bytes,1,opt,name=payload_for_tests,json=payloadForTests" json:"payload_for_tests,omitempty"`
	// contains filtered or unexported fields
}

type OpIdType int32

type OperationStatusPB struct {
	OpId          *util.OpIdPB   `protobuf:"bytes,1,req,name=op_id,json=opId" json:"op_id,omitempty"`
	OperationType *OperationType `` /* 126-byte string literal not displayed */
	// Time the transaction has been in flight.
	RunningForMicros *int64 `protobuf:"varint,3,req,name=running_for_micros,json=runningForMicros" json:"running_for_micros,omitempty"`
	// Quick human-readable description (e.g., ToString() output).
	Description *string `protobuf:"bytes,4,req,name=description" json:"description,omitempty"`
	// If tracing is enabled when viewing the transaction, the trace
	// buffer is copied here.
	TraceBuffer *string `protobuf:"bytes,6,opt,name=trace_buffer,json=traceBuffer" json:"trace_buffer,omitempty"`
	// contains filtered or unexported fields
}

type OperationType int32

type PerOpErrorPB struct {

	// The id of the operation that failed in the other peer.
	Id *util.OpIdPB `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	// The Status explaining why the operation failed.
	Status *common.AppStatusPB `protobuf:"bytes,2,req,name=status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type ReplicateMsg struct {
	Id *util.OpIdPB `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	// The hybrid time assigned to this message.
	HybridTime *uint64 `protobuf:"fixed64,2,req,name=hybrid_time,json=hybridTime" json:"hybrid_time,omitempty"`
	// A counter that is forever increasing in a tablet (like hybrid time). Used for list indexing.
	MonotonicCounter      *int64                             `protobuf:"varint,9,opt,name=monotonic_counter,json=monotonicCounter" json:"monotonic_counter,omitempty"`
	OpType                *OperationType                     `protobuf:"varint,4,req,name=op_type,json=opType,enum=yb.consensus.OperationType" json:"op_type,omitempty"`
	WriteRequest          *tserver.WriteRequestPB            `protobuf:"bytes,5,opt,name=write_request,json=writeRequest" json:"write_request,omitempty"`
	ChangeMetadataRequest *tserver.ChangeMetadataRequestPB   `protobuf:"bytes,6,opt,name=change_metadata_request,json=changeMetadataRequest" json:"change_metadata_request,omitempty"`
	TransactionState      *tserver.TransactionStatePB        `protobuf:"bytes,10,opt,name=transaction_state,json=transactionState" json:"transaction_state,omitempty"`
	SnapshotRequest       *tserver.TabletSnapshotOpRequestPB `protobuf:"bytes,11,opt,name=snapshot_request,json=snapshotRequest" json:"snapshot_request,omitempty"`
	TruncateRequest       *tserver.TruncateRequestPB         `protobuf:"bytes,12,opt,name=truncate_request,json=truncateRequest" json:"truncate_request,omitempty"`
	SplitRequest          *tserver.SplitTabletRequestPB      `protobuf:"bytes,14,opt,name=split_request,json=splitRequest" json:"split_request,omitempty"`
	ChangeConfigRecord    *ChangeConfigRecordPB              `protobuf:"bytes,7,opt,name=change_config_record,json=changeConfigRecord" json:"change_config_record,omitempty"`
	HistoryCutoff         *HistoryCutoffPB                   `protobuf:"bytes,13,opt,name=history_cutoff,json=historyCutoff" json:"history_cutoff,omitempty"`
	// The Raft operation ID known to the leader to be committed at the time this message was sent.
	// This is used during tablet bootstrap for RocksDB-backed tables.
	CommittedOpId *util.OpIdPB   `protobuf:"bytes,8,opt,name=committed_op_id,json=committedOpId" json:"committed_op_id,omitempty"`
	NoopRequest   *NoOpRequestPB `protobuf:"bytes,999,opt,name=noop_request,json=noopRequest" json:"noop_request,omitempty"`
	// contains filtered or unexported fields
}

type RunLeaderElectionRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,2,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	// the id of the tablet
	TabletId []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// The id of the last operation the current leader has committed to its log.
	// When specified, the peer must wait till the operation has been committed
	// to its log before starting the election to be qualified as a leader.
	CommittedIndex *util.OpIdPB `protobuf:"bytes,3,opt,name=committed_index,json=committedIndex" json:"committed_index,omitempty"`
	// UUID of old leader, that requested this election.
	// If we lost election, we would notify originator about this fact.
	// So it would reset its withold timeout and try to become a leader again.
	OriginatorUuid      []byte `protobuf:"bytes,4,opt,name=originator_uuid,json=originatorUuid" json:"originator_uuid,omitempty"`
	SuppressVoteRequest *bool  `protobuf:"varint,5,opt,name=suppress_vote_request,json=suppressVoteRequest" json:"suppress_vote_request,omitempty"`
	InitialElection     *bool  `protobuf:"varint,6,opt,name=initial_election,json=initialElection" json:"initial_election,omitempty"`
	// contains filtered or unexported fields
}

type RunLeaderElectionResponsePB struct {

	// A generic error message (such as tablet not found).
	Error *tserver.TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type StartRemoteBootstrapRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,5,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	TabletId []byte `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// Identification for the host we are bootstrapping from.
	// TODO: Consider renaming these to bootstrap_source_*.
	BootstrapPeerUuid   []byte               `protobuf:"bytes,2,req,name=bootstrap_peer_uuid,json=bootstrapPeerUuid" json:"bootstrap_peer_uuid,omitempty"`
	SourcePrivateAddr   []*common.HostPortPB `protobuf:"bytes,3,rep,name=source_private_addr,json=sourcePrivateAddr" json:"source_private_addr,omitempty"`
	SourceBroadcastAddr []*common.HostPortPB `protobuf:"bytes,6,rep,name=source_broadcast_addr,json=sourceBroadcastAddr" json:"source_broadcast_addr,omitempty"`
	SourceCloudInfo     *common.CloudInfoPB  `protobuf:"bytes,7,opt,name=source_cloud_info,json=sourceCloudInfo" json:"source_cloud_info,omitempty"`
	// The caller's term. In the case that the target of this request has a
	// TOMBSTONED replica with a term higher than this one, the request will fail.
	CallerTerm *int64 `protobuf:"varint,4,opt,name=caller_term,json=callerTerm,def=-1" json:"caller_term,omitempty"`
	// contains filtered or unexported fields
}

type StartRemoteBootstrapResponsePB struct {
	Error *tserver.TabletServerErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type VoteRequestPB struct {

	// UUID of server this request is addressed to.
	DestUuid []byte `protobuf:"bytes,6,opt,name=dest_uuid,json=destUuid" json:"dest_uuid,omitempty"`
	// Identifies the tablet configuration a the vote is being requested for.
	TabletId *string `protobuf:"bytes,1,req,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// The uuid of the sending peer.
	CandidateUuid []byte `protobuf:"bytes,2,req,name=candidate_uuid,json=candidateUuid" json:"candidate_uuid,omitempty"`
	// The term we are requesting a vote for.
	// If this term is higher than the callee's term, the callee will update its
	// own term to match, and if it is the current leader it will step down.
	CandidateTerm *int64 `protobuf:"varint,3,req,name=candidate_term,json=candidateTerm" json:"candidate_term,omitempty"`
	// The candidate node status so that the voter node can
	// decide whether to vote for it as LEADER.
	//
	// In particular, this includes the last OpId persisted in the candidate's
	// log, which corresponds to the lastLogIndex and lastLogTerm fields in Raft.
	// A replica must vote no for a candidate that has an OpId lower than them.
	CandidateStatus *ConsensusStatusPB `protobuf:"bytes,4,req,name=candidate_status,json=candidateStatus" json:"candidate_status,omitempty"`
	// Normally, replicas will deny a vote with a LEADER_IS_ALIVE error if
	// they are a leader or recently heard from a leader. This is to prevent
	// partitioned nodes from disturbing liveness. If this flag is true,
	// peers will vote even if they think a leader is alive. This can be used
	// for example to force a faster leader hand-off rather than waiting for
	// the election timer to expire.
	IgnoreLiveLeader *bool `protobuf:"varint,5,opt,name=ignore_live_leader,json=ignoreLiveLeader,def=0" json:"ignore_live_leader,omitempty"`
	// true if it is pre-election request and state of voter should not be changed.
	Preelection *bool `protobuf:"varint,7,opt,name=preelection" json:"preelection,omitempty"`
	// contains filtered or unexported fields
}

type VoteResponsePB struct {

	// The uuid of the node sending the reply.
	ResponderUuid []byte `protobuf:"bytes,1,opt,name=responder_uuid,json=responderUuid" json:"responder_uuid,omitempty"`
	// The term of the node sending the reply.
	// Allows the candidate to update itself if it is behind.
	ResponderTerm *int64 `protobuf:"varint,2,opt,name=responder_term,json=responderTerm" json:"responder_term,omitempty"`
	// True if this peer voted for the caller, false otherwise.
	VoteGranted *bool `protobuf:"varint,3,opt,name=vote_granted,json=voteGranted" json:"vote_granted,omitempty"`
	// An upper bound on the remainder of the old leader's lease that the new leader has to wait out
	// before it can start serving read and write requests.
	RemainingLeaderLeaseDurationMs *int32 `` /* 151-byte string literal not displayed */
	// UUID of node that has lease.
	LeaderLeaseUuid []byte `protobuf:"bytes,7,opt,name=leader_lease_uuid,json=leaderLeaseUuid" json:"leader_lease_uuid,omitempty"`
	// An upper bound on the deadline of the old hybrid time leader's lease that the new leader has
	// to wait out before it can start serving read and write requests.
	// Contains only physical part of hybrid time.
	LeaderHtLeaseExpiration *uint64 `` /* 129-byte string literal not displayed */
	// UUID of node that has ht lease.
	LeaderHtLeaseUuid []byte `protobuf:"bytes,8,opt,name=leader_ht_lease_uuid,json=leaderHtLeaseUuid" json:"leader_ht_lease_uuid,omitempty"`
	// true if it is response to pre-election request.
	Preelection *bool `protobuf:"varint,6,opt,name=preelection" json:"preelection,omitempty"`
	// TODO: Migrate ConsensusService to the AppStatusPB RPC style and merge these errors.
	// Error message from the consensus implementation.
	ConsensusError *ConsensusErrorPB `protobuf:"bytes,998,opt,name=consensus_error,json=consensusError" json:"consensus_error,omitempty"`
	// A generic error message (such as tablet not found).
	Error *tserver.TabletServerErrorPB `protobuf:"bytes,999,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}