meta

type AlterTableTask struct {
	AlterTable *v1.AlterExpr `protobuf:"bytes,1,opt,name=alter_table,json=alterTable,proto3" json:"alter_table,omitempty"`
	// contains filtered or unexported fields
}

type AlterTableTasks struct {
	Tasks []*AlterTableTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

type AskLeaderRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type AskLeaderResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Leader *Peer           `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

type BatchDeleteRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keys   [][]byte       `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// If prev_kv is set, gets the previous key-value pairs before deleting it.
	// The previous key-value pairs will be returned in the batch delete response.
	PrevKv bool `protobuf:"varint,3,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

type BatchDeleteResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// If prev_kv is set in the request, the previous key-value pairs will be
	// returned.
	PrevKvs []*KeyValue `protobuf:"bytes,2,rep,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs,omitempty"`
	// contains filtered or unexported fields
}

type BatchGetRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keys   [][]byte       `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

type BatchGetResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Kvs    []*KeyValue     `protobuf:"bytes,2,rep,name=kvs,proto3" json:"kvs,omitempty"`
	// contains filtered or unexported fields
}

type BatchPutRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Kvs    []*KeyValue    `protobuf:"bytes,2,rep,name=kvs,proto3" json:"kvs,omitempty"`
	// If prev_kv is set, gets the previous key-value pairs before changing it.
	// The previous key-value pairs will be returned in the batch put response.
	PrevKv bool `protobuf:"varint,3,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

type BatchPutResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// If prev_kv is set in the request, the previous key-value pairs will be
	// returned.
	PrevKvs []*KeyValue `protobuf:"bytes,2,rep,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs,omitempty"`
	// contains filtered or unexported fields
}

type ClusterClient interface {
	// Batch get kvs by input keys from leader's in_memory kv store.
	BatchGet(ctx context.Context, in *BatchGetRequest, opts ...grpc.CallOption) (*BatchGetResponse, error)
	// Range get the kvs from leader's in_memory kv store.
	Range(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)
	// Returns all the peers of metasrv.
	MetasrvPeers(ctx context.Context, in *MetasrvPeersRequest, opts ...grpc.CallOption) (*MetasrvPeersResponse, error)
}

type ClusterServer interface {
	// Batch get kvs by input keys from leader's in_memory kv store.
	BatchGet(context.Context, *BatchGetRequest) (*BatchGetResponse, error)
	// Range get the kvs from leader's in_memory kv store.
	Range(context.Context, *RangeRequest) (*RangeResponse, error)
	// Returns all the peers of metasrv.
	MetasrvPeers(context.Context, *MetasrvPeersRequest) (*MetasrvPeersResponse, error)
	// contains filtered or unexported methods
}

type CompareAndPutRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// key is the key, in bytes, to put into the key-value store.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// expect is the previous value, in bytes
	Expect []byte `protobuf:"bytes,3,opt,name=expect,proto3" json:"expect,omitempty"`
	// value is the value, in bytes, to associate with the key in the
	// key-value store.
	Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type CompareAndPutResponse struct {
	Header  *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Success bool            `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	PrevKv  *KeyValue       `protobuf:"bytes,3,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

type CreateDatabaseTask struct {
	CreateDatabase *v1.CreateDatabaseExpr `protobuf:"bytes,1,opt,name=create_database,json=createDatabase,proto3" json:"create_database,omitempty"`
	// contains filtered or unexported fields
}

type CreateFlowTask struct {
	CreateFlowTask *v1.CreateFlowTaskExpr `protobuf:"bytes,1,opt,name=create_flow_task,json=createFlowTask,proto3" json:"create_flow_task,omitempty"`
	// contains filtered or unexported fields
}

type CreateTableTask struct {
	CreateTable *v1.CreateTableExpr `protobuf:"bytes,1,opt,name=create_table,json=createTable,proto3" json:"create_table,omitempty"`
	Partitions  []*Partition        `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions,omitempty"`
	TableInfo   []byte              `protobuf:"bytes,3,opt,name=table_info,json=tableInfo,proto3" json:"table_info,omitempty"`
	// contains filtered or unexported fields
}

type CreateTableTasks struct {
	Tasks []*CreateTableTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

type DdlTaskClient interface {
	// Submits a DDL task to meta.
	SubmitDdlTask(ctx context.Context, in *SubmitDdlTaskRequest, opts ...grpc.CallOption) (*SubmitDdlTaskResponse, error)
}

type DdlTaskRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are assignable to Task:
	//
	//	*DdlTaskRequest_CreateTableTask
	//	*DdlTaskRequest_DropTableTask
	//	*DdlTaskRequest_AlterTableTask
	//	*DdlTaskRequest_TruncateTableTask
	//	*DdlTaskRequest_CreateTableTasks
	//	*DdlTaskRequest_DropTableTasks
	//	*DdlTaskRequest_AlterTableTasks
	//	*DdlTaskRequest_DropDatabaseTask
	//	*DdlTaskRequest_CreateDatabaseTask
	//	*DdlTaskRequest_CreateFlowTask
	//	*DdlTaskRequest_DropFlowTask
	Task isDdlTaskRequest_Task `protobuf_oneof:"task"`
	// contains filtered or unexported fields
}

type DdlTaskRequest_AlterTableTask struct {
	AlterTableTask *AlterTableTask `protobuf:"bytes,4,opt,name=alter_table_task,json=alterTableTask,proto3,oneof"`
}

type DdlTaskRequest_AlterTableTasks struct {
	AlterTableTasks *AlterTableTasks `protobuf:"bytes,8,opt,name=alter_table_tasks,json=alterTableTasks,proto3,oneof"`
}

type DdlTaskRequest_CreateDatabaseTask struct {
	CreateDatabaseTask *CreateDatabaseTask `protobuf:"bytes,10,opt,name=create_database_task,json=createDatabaseTask,proto3,oneof"`
}

type DdlTaskRequest_CreateFlowTask struct {
	CreateFlowTask *CreateFlowTask `protobuf:"bytes,11,opt,name=create_flow_task,json=createFlowTask,proto3,oneof"`
}

type DdlTaskRequest_CreateTableTask struct {
	CreateTableTask *CreateTableTask `protobuf:"bytes,2,opt,name=create_table_task,json=createTableTask,proto3,oneof"`
}

type DdlTaskRequest_CreateTableTasks struct {
	CreateTableTasks *CreateTableTasks `protobuf:"bytes,6,opt,name=create_table_tasks,json=createTableTasks,proto3,oneof"`
}

type DdlTaskRequest_DropDatabaseTask struct {
	DropDatabaseTask *DropDatabaseTask `protobuf:"bytes,9,opt,name=drop_database_task,json=dropDatabaseTask,proto3,oneof"`
}

type DdlTaskRequest_DropFlowTask struct {
	DropFlowTask *DropFlowTask `protobuf:"bytes,12,opt,name=drop_flow_task,json=dropFlowTask,proto3,oneof"`
}

type DdlTaskRequest_DropTableTask struct {
	DropTableTask *DropTableTask `protobuf:"bytes,3,opt,name=drop_table_task,json=dropTableTask,proto3,oneof"`
}

type DdlTaskRequest_DropTableTasks struct {
	DropTableTasks *DropTableTasks `protobuf:"bytes,7,opt,name=drop_table_tasks,json=dropTableTasks,proto3,oneof"`
}

type DdlTaskRequest_TruncateTableTask struct {
	TruncateTableTask *TruncateTableTask `protobuf:"bytes,5,opt,name=truncate_table_task,json=truncateTableTask,proto3,oneof"`
}

type DdlTaskResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Pid    *ProcedureId    `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// Returns if table created.
	// TODO(jeremy): remove it?
	TableId *TableId `protobuf:"bytes,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	// Returns if the tables created.
	TableIds []*TableId `protobuf:"bytes,5,rep,name=table_ids,json=tableIds,proto3" json:"table_ids,omitempty"`
	// contains filtered or unexported fields
}

type DdlTaskServer interface {
	// Submits a DDL task to meta.
	SubmitDdlTask(context.Context, *SubmitDdlTaskRequest) (*SubmitDdlTaskResponse, error)
	// contains filtered or unexported methods
}

type DdlTaskType int32

type DeleteRangeRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// key is the first key to delete in the range.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// range_end is the key following the last key to delete for the range
	// [key, range_end).
	// If range_end is not given, the range is defined to contain only the key
	// argument.
	// If range_end is one bit larger than the given key, then the range is all
	// the keys with the prefix (the given key).
	// If range_end is '\0', the range is all keys greater than or equal to the
	// key argument.
	RangeEnd []byte `protobuf:"bytes,3,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// If prev_kv is set, gets the previous key-value pairs before deleting it.
	// The previous key-value pairs will be returned in the delete response.
	PrevKv bool `protobuf:"varint,4,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

type DeleteRangeResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// deleted is the number of keys deleted by the delete range request.
	Deleted int64 `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// If prev_kv is set in the request, the previous key-value pairs will be
	// returned.
	PrevKvs []*KeyValue `protobuf:"bytes,3,rep,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs,omitempty"`
	// contains filtered or unexported fields
}

type DropDatabaseTask struct {
	DropDatabase *v1.DropDatabaseExpr `protobuf:"bytes,1,opt,name=drop_database,json=dropDatabase,proto3" json:"drop_database,omitempty"`
	// contains filtered or unexported fields
}

type DropFlowTask struct {
	DropFlowTask *v1.DropFlowTaskExpr `protobuf:"bytes,1,opt,name=drop_flow_task,json=dropFlowTask,proto3" json:"drop_flow_task,omitempty"`
	// contains filtered or unexported fields
}

type DropTableTask struct {
	DropTable *v1.DropTableExpr `protobuf:"bytes,1,opt,name=drop_table,json=dropTable,proto3" json:"drop_table,omitempty"`
	// contains filtered or unexported fields
}

type DropTableTasks struct {
	Tasks []*DropTableTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

type Error struct {
	Code   int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

type GrantedRegion struct {
	RegionId uint64     `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	Role     RegionRole `protobuf:"varint,2,opt,name=role,proto3,enum=greptime.v1.meta.RegionRole" json:"role,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatClient interface {
	// Heartbeat, there may be many contents of the heartbeat, such as:
	// 1. Metadata to be registered to meta server and discoverable by other
	// nodes.
	// 2. Some performance metrics, such as Load, CPU usage, etc.
	// 3. The number of computing tasks being executed.
	Heartbeat(ctx context.Context, opts ...grpc.CallOption) (Heartbeat_HeartbeatClient, error)
	// Ask leader's endpoint.
	AskLeader(ctx context.Context, in *AskLeaderRequest, opts ...grpc.CallOption) (*AskLeaderResponse, error)
}

type HeartbeatRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Self peer
	Peer *Peer `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	// Actually reported time interval
	ReportInterval *TimeInterval `protobuf:"bytes,3,opt,name=report_interval,json=reportInterval,proto3" json:"report_interval,omitempty"`
	// Region stats on this node
	RegionStats []*RegionStat `protobuf:"bytes,4,rep,name=region_stats,json=regionStats,proto3" json:"region_stats,omitempty"`
	// Mailbox send message to Metasrv
	MailboxMessage *MailboxMessage `protobuf:"bytes,5,opt,name=mailbox_message,json=mailboxMessage,proto3" json:"mailbox_message,omitempty"`
	// The duration since the heartbeat task's epoch in milliseconds.
	DurationSinceEpoch uint64 `protobuf:"varint,6,opt,name=duration_since_epoch,json=durationSinceEpoch,proto3" json:"duration_since_epoch,omitempty"`
	// The node's epoch
	NodeEpoch uint64 `protobuf:"varint,7,opt,name=node_epoch,json=nodeEpoch,proto3" json:"node_epoch,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatResponse struct {
	Header         *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	MailboxMessage *MailboxMessage `protobuf:"bytes,2,opt,name=mailbox_message,json=mailboxMessage,proto3" json:"mailbox_message,omitempty"`
	RegionLease    *RegionLease    `protobuf:"bytes,3,opt,name=region_lease,json=regionLease,proto3" json:"region_lease,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatServer interface {
	// Heartbeat, there may be many contents of the heartbeat, such as:
	// 1. Metadata to be registered to meta server and discoverable by other
	// nodes.
	// 2. Some performance metrics, such as Load, CPU usage, etc.
	// 3. The number of computing tasks being executed.
	Heartbeat(Heartbeat_HeartbeatServer) error
	// Ask leader's endpoint.
	AskLeader(context.Context, *AskLeaderRequest) (*AskLeaderResponse, error)
	// contains filtered or unexported methods
}

type Heartbeat_HeartbeatClient interface {
	Send(*HeartbeatRequest) error
	Recv() (*HeartbeatResponse, error)
	grpc.ClientStream
}

type Heartbeat_HeartbeatServer interface {
	Send(*HeartbeatResponse) error
	Recv() (*HeartbeatRequest, error)
	grpc.ServerStream
}

type KeyValue struct {

	// key is the key in bytes. An empty key is not allowed.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// value is the value held by the key, in bytes.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type LockClient interface {
	// Lock acquires a distributed shared lock on a given named lock. On success,
	// it will return a unique key that exists so long as the lock is held by the
	// caller.
	Lock(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	// Unlock takes a key returned by Lock and releases the hold on lock.
	Unlock(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, error)
}

type LockRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Name is the identifier for the distributed shared lock to be acquired.
	Name []byte `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// If the expiration time is exceeded and currently holds the lock, the lock
	// is automatically released.
	ExpireSecs int64 `protobuf:"varint,3,opt,name=expire_secs,json=expireSecs,proto3" json:"expire_secs,omitempty"`
	// contains filtered or unexported fields
}

type LockResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Key will exist as long as lock is held by the caller.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type LockServer interface {
	// Lock acquires a distributed shared lock on a given named lock. On success,
	// it will return a unique key that exists so long as the lock is held by the
	// caller.
	Lock(context.Context, *LockRequest) (*LockResponse, error)
	// Unlock takes a key returned by Lock and releases the hold on lock.
	Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)
	// contains filtered or unexported methods
}

type MailboxMessage struct {

	// The id is used to associate request and response.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The following information plays a bigger role in making messages traceable
	// and facilitating debugging.
	Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	From    string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	To      string `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"`
	// The unix timestamp in milliseconds.
	TimestampMillis int64 `protobuf:"varint,5,opt,name=timestamp_millis,json=timestampMillis,proto3" json:"timestamp_millis,omitempty"`
	// The message body.
	//
	// Types that are assignable to Payload:
	//
	//	*MailboxMessage_Json
	Payload isMailboxMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type MailboxMessage_Json struct {
	Json string `protobuf:"bytes,6,opt,name=json,proto3,oneof"`
}

type MetasrvPeersRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type MetasrvPeersResponse struct {
	Header    *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Leader    *Peer           `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	Followers []*Peer         `protobuf:"bytes,3,rep,name=followers,proto3" json:"followers,omitempty"`
	// contains filtered or unexported fields
}

type MigrateRegionRequest struct {
	Header            *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RegionId          uint64         `protobuf:"varint,3,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	FromPeer          uint64         `protobuf:"varint,4,opt,name=from_peer,json=fromPeer,proto3" json:"from_peer,omitempty"`
	ToPeer            uint64         `protobuf:"varint,5,opt,name=to_peer,json=toPeer,proto3" json:"to_peer,omitempty"`
	ReplayTimeoutSecs uint32         `protobuf:"varint,6,opt,name=replay_timeout_secs,json=replayTimeoutSecs,proto3" json:"replay_timeout_secs,omitempty"`
	// contains filtered or unexported fields
}

type MigrateRegionResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Pid    *ProcedureId    `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

type Partition struct {
	ColumnList [][]byte `protobuf:"bytes,1,rep,name=column_list,json=columnList,proto3" json:"column_list,omitempty"`
	ValueList  [][]byte `protobuf:"bytes,2,rep,name=value_list,json=valueList,proto3" json:"value_list,omitempty"`
	// contains filtered or unexported fields
}

type Peer struct {
	Id   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

type ProcedureId struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type ProcedureServiceClient interface {
	// Query a submitted procedure state
	Query(ctx context.Context, in *QueryProcedureRequest, opts ...grpc.CallOption) (*ProcedureStateResponse, error)
	// Submits a DDL task
	Ddl(ctx context.Context, in *DdlTaskRequest, opts ...grpc.CallOption) (*DdlTaskResponse, error)
	// Submits a region migration task
	Migrate(ctx context.Context, in *MigrateRegionRequest, opts ...grpc.CallOption) (*MigrateRegionResponse, error)
}

type ProcedureServiceServer interface {
	// Query a submitted procedure state
	Query(context.Context, *QueryProcedureRequest) (*ProcedureStateResponse, error)
	// Submits a DDL task
	Ddl(context.Context, *DdlTaskRequest) (*DdlTaskResponse, error)
	// Submits a region migration task
	Migrate(context.Context, *MigrateRegionRequest) (*MigrateRegionResponse, error)
	// contains filtered or unexported methods
}

type ProcedureStateResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Status ProcedureStatus `protobuf:"varint,2,opt,name=status,proto3,enum=greptime.v1.meta.ProcedureStatus" json:"status,omitempty"`
	Error  string          `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ProcedureStatus int32

type PutRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// key is the key, in bytes, to put into the key-value store.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// value is the value, in bytes, to associate with the key in the
	// key-value store.
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// If prev_kv is set, gets the previous key-value pair before changing it.
	// The previous key-value pair will be returned in the put response.
	PrevKv bool `protobuf:"varint,4,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

type PutResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// If prev_kv is set in the request, the previous key-value pair will be
	// returned.
	PrevKv *KeyValue `protobuf:"bytes,2,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

type QueryProcedureRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Pid    *ProcedureId   `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

type RangeRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// key is the first key for the range, If range_end is not given, the
	// request only looks up key.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// range_end is the upper bound on the requested range [key, range_end).
	// If range_end is '\0', the range is all keys >= key.
	// If range_end is key plus one (e.g., "aa"+1 == "ab", "a\xff"+1 == "b"),
	// then the range request gets all keys prefixed with key.
	// If both key and range_end are '\0', then the range request returns all
	// keys.
	RangeEnd []byte `protobuf:"bytes,3,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// limit is a limit on the number of keys returned for the request. When
	// limit is set to 0, it is treated as no limit.
	Limit int64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// keys_only when set returns only the keys and not the values.
	KeysOnly bool `protobuf:"varint,5,opt,name=keys_only,json=keysOnly,proto3" json:"keys_only,omitempty"`
	// contains filtered or unexported fields
}

type RangeResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// kvs is the list of key-value pairs matched by the range request.
	Kvs []*KeyValue `protobuf:"bytes,2,rep,name=kvs,proto3" json:"kvs,omitempty"`
	// more indicates if there are more keys to return in the requested range.
	More bool `protobuf:"varint,3,opt,name=more,proto3" json:"more,omitempty"`
	// contains filtered or unexported fields
}

type Region struct {

	// TODO(LFC): Maybe use message RegionNumber?
	Id        uint64            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Partition *Partition        `protobuf:"bytes,3,opt,name=partition,proto3" json:"partition,omitempty"`
	Attrs     map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RegionLease struct {
	Regions            []*GrantedRegion `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"`
	DurationSinceEpoch uint64           `protobuf:"varint,2,opt,name=duration_since_epoch,json=durationSinceEpoch,proto3" json:"duration_since_epoch,omitempty"`
	LeaseSeconds       uint64           `protobuf:"varint,3,opt,name=lease_seconds,json=leaseSeconds,proto3" json:"lease_seconds,omitempty"`
	CloseableRegionIds []uint64         `protobuf:"varint,4,rep,packed,name=closeable_region_ids,json=closeableRegionIds,proto3" json:"closeable_region_ids,omitempty"`
	// contains filtered or unexported fields
}

type RegionRole int32

type RegionRoute struct {
	Region *Region `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// single leader node for write task
	LeaderPeerIndex uint64 `protobuf:"varint,2,opt,name=leader_peer_index,json=leaderPeerIndex,proto3" json:"leader_peer_index,omitempty"`
	// multiple follower nodes for read task
	FollowerPeerIndexes []uint64 `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RegionStat struct {
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	// The read capacity units during this period
	Rcus int64 `protobuf:"varint,2,opt,name=rcus,proto3" json:"rcus,omitempty"`
	// The write capacity units during this period
	Wcus int64 `protobuf:"varint,3,opt,name=wcus,proto3" json:"wcus,omitempty"`
	// Approximate bytes of this region
	ApproximateBytes int64 `protobuf:"varint,4,opt,name=approximate_bytes,json=approximateBytes,proto3" json:"approximate_bytes,omitempty"`
	// Approximate number of rows in this region
	ApproximateRows int64 `protobuf:"varint,5,opt,name=approximate_rows,json=approximateRows,proto3" json:"approximate_rows,omitempty"`
	// Engine name
	Engine string `protobuf:"bytes,6,opt,name=engine,proto3" json:"engine,omitempty"`
	// Region role
	Role RegionRole `protobuf:"varint,7,opt,name=role,proto3,enum=greptime.v1.meta.RegionRole" json:"role,omitempty"`
	// contains filtered or unexported fields
}

type RequestHeader struct {
	ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// cluster_id is the ID of the cluster which be sent to.
	ClusterId uint64 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// member_id is the ID of the sender server.
	MemberId uint64 `protobuf:"varint,3,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`
	Role     Role   `protobuf:"varint,4,opt,name=role,proto3,enum=greptime.v1.meta.Role" json:"role,omitempty"`
	// Encoded trace_id & span_id, follow the w3c Trace Context
	// https://www.w3.org/TR/trace-context/#header-name
	TracingContext map[string]string `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ResponseHeader struct {
	ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// cluster_id is the ID of the cluster which sent the response.
	ClusterId uint64 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Error     *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}