proto

type CommitRequest struct {

	// start_ts is the timestamp of prewrite request.
	StartTs uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	Keys    [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

type CommitResponse struct {
	CommitIndex uint64      `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Success     bool        `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Errors      []*KeyError `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

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

type DeleteResponse struct {
	CommitIndex uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Success     bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type DistributionClient interface {
	GetRoute(ctx context.Context, in *GetRouteRequest, opts ...grpc.CallOption) (*GetRouteResponse, error)
	GetTimestamp(ctx context.Context, in *GetTimestampRequest, opts ...grpc.CallOption) (*GetTimestampResponse, error)
	ListRoutes(ctx context.Context, in *ListRoutesRequest, opts ...grpc.CallOption) (*ListRoutesResponse, error)
	SplitRange(ctx context.Context, in *SplitRangeRequest, opts ...grpc.CallOption) (*SplitRangeResponse, error)
}

type DistributionServer interface {
	GetRoute(context.Context, *GetRouteRequest) (*GetRouteResponse, error)
	GetTimestamp(context.Context, *GetTimestampRequest) (*GetTimestampResponse, error)
	ListRoutes(context.Context, *ListRoutesRequest) (*ListRoutesResponse, error)
	SplitRange(context.Context, *SplitRangeRequest) (*SplitRangeResponse, error)
	// contains filtered or unexported methods
}

type DynamoAttributeValue struct {

	// Types that are valid to be assigned to Value:
	//
	//	*DynamoAttributeValue_S
	//	*DynamoAttributeValue_N
	//	*DynamoAttributeValue_B
	//	*DynamoAttributeValue_BoolValue
	//	*DynamoAttributeValue_NullValue
	//	*DynamoAttributeValue_Ss
	//	*DynamoAttributeValue_Ns
	//	*DynamoAttributeValue_Bs
	//	*DynamoAttributeValue_L
	//	*DynamoAttributeValue_M
	Value isDynamoAttributeValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type DynamoAttributeValueList struct {
	Values []*DynamoAttributeValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type DynamoAttributeValueMap struct {
	Values map[string]*DynamoAttributeValue `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DynamoAttributeValue_B struct {
	B []byte `protobuf:"bytes,3,opt,name=b,proto3,oneof"`
}

type DynamoAttributeValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type DynamoAttributeValue_Bs struct {
	Bs *DynamoBinarySet `protobuf:"bytes,8,opt,name=bs,proto3,oneof"`
}

type DynamoAttributeValue_L struct {
	L *DynamoAttributeValueList `protobuf:"bytes,9,opt,name=l,proto3,oneof"`
}

type DynamoAttributeValue_M struct {
	M *DynamoAttributeValueMap `protobuf:"bytes,10,opt,name=m,proto3,oneof"`
}

type DynamoAttributeValue_N struct {
	N string `protobuf:"bytes,2,opt,name=n,proto3,oneof"`
}

type DynamoAttributeValue_Ns struct {
	Ns *DynamoNumberSet `protobuf:"bytes,7,opt,name=ns,proto3,oneof"`
}

type DynamoAttributeValue_NullValue struct {
	NullValue bool `protobuf:"varint,5,opt,name=null_value,json=nullValue,proto3,oneof"`
}

type DynamoAttributeValue_S struct {
	S string `protobuf:"bytes,1,opt,name=s,proto3,oneof"`
}

type DynamoAttributeValue_Ss struct {
	Ss *DynamoStringSet `protobuf:"bytes,6,opt,name=ss,proto3,oneof"`
}

type DynamoBinarySet struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type DynamoGSIProjection struct {
	ProjectionType   string   `protobuf:"bytes,1,opt,name=projection_type,json=projectionType,proto3" json:"projection_type,omitempty"`
	NonKeyAttributes []string `protobuf:"bytes,2,rep,name=non_key_attributes,json=nonKeyAttributes,proto3" json:"non_key_attributes,omitempty"`
	// contains filtered or unexported fields
}

type DynamoGlobalSecondaryIndex struct {
	KeySchema  *DynamoKeySchema     `protobuf:"bytes,1,opt,name=key_schema,json=keySchema,proto3" json:"key_schema,omitempty"`
	Projection *DynamoGSIProjection `protobuf:"bytes,2,opt,name=projection,proto3" json:"projection,omitempty"`
	// contains filtered or unexported fields
}

type DynamoItem struct {
	Attributes map[string]*DynamoAttributeValue `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DynamoKeySchema struct {
	HashKey  string `protobuf:"bytes,1,opt,name=hash_key,json=hashKey,proto3" json:"hash_key,omitempty"`
	RangeKey string `protobuf:"bytes,2,opt,name=range_key,json=rangeKey,proto3" json:"range_key,omitempty"`
	// contains filtered or unexported fields
}

type DynamoNumberSet struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type DynamoStringSet struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type DynamoTableSchema struct {
	TableName               string                                 `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	AttributeDefinitions    map[string]string                      `` /* 195-byte string literal not displayed */
	PrimaryKey              *DynamoKeySchema                       `protobuf:"bytes,3,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	GlobalSecondaryIndexes  map[string]*DynamoGlobalSecondaryIndex `` /* 203-byte string literal not displayed */
	KeyEncodingVersion      uint64                                 `protobuf:"varint,5,opt,name=key_encoding_version,json=keyEncodingVersion,proto3" json:"key_encoding_version,omitempty"`
	MigratingFromGeneration uint64                                 `` /* 133-byte string literal not displayed */
	Generation              uint64                                 `protobuf:"varint,7,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

type ForwardRequest struct {
	IsTxn    bool       `protobuf:"varint,1,opt,name=is_txn,json=isTxn,proto3" json:"is_txn,omitempty"`
	Requests []*Request `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

type ForwardResponse struct {
	Success     bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	CommitIndex uint64 `protobuf:"varint,2,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	// contains filtered or unexported fields
}

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

type GetResponse struct {
	ReadAtIndex uint64 `protobuf:"varint,1,opt,name=read_at_index,json=readAtIndex,proto3" json:"read_at_index,omitempty"`
	Value       []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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

type GetRouteResponse struct {

	// start is inclusive and end is exclusive. A missing end denotes an
	// unbounded range extending to positive infinity.
	Start       []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End         []byte `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	RaftGroupId uint64 `protobuf:"varint,3,opt,name=raft_group_id,json=raftGroupId,proto3" json:"raft_group_id,omitempty"`
	// contains filtered or unexported fields
}

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

type GetTimestampResponse struct {
	Timestamp uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type InternalClient interface {
	// for internal leader redirect only
	Forward(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*ForwardResponse, error)
	RelayPublish(ctx context.Context, in *RelayPublishRequest, opts ...grpc.CallOption) (*RelayPublishResponse, error)
}

type InternalServer interface {
	// for internal leader redirect only
	Forward(context.Context, *ForwardRequest) (*ForwardResponse, error)
	RelayPublish(context.Context, *RelayPublishRequest) (*RelayPublishResponse, error)
	// contains filtered or unexported methods
}

type KeyError struct {
	Message   string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Retryable bool   `protobuf:"varint,2,opt,name=retryable,proto3" json:"retryable,omitempty"`
	// contains filtered or unexported fields
}

type Kv struct {
	Error *KeyError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Key   []byte    `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte    `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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

type ListRoutesResponse struct {
	CatalogVersion uint64             `protobuf:"varint,1,opt,name=catalog_version,json=catalogVersion,proto3" json:"catalog_version,omitempty"`
	Routes         []*RouteDescriptor `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

type Mutation struct {
	Op    Op     `protobuf:"varint,1,opt,name=op,proto3,enum=Op" json:"op,omitempty"`
	Key   []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Op int32

type Phase int32

type PreCommitResponse struct {
	Errors []*KeyError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

type PreWriteRequest struct {

	// mutations is the list of mutations to apply atomically.
	Mutations []*Kv `protobuf:"bytes,2,rep,name=mutations,proto3" json:"mutations,omitempty"`
	// start_ts is the timestamp of the transaction.
	StartTs uint64 `protobuf:"varint,3,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	// lock_ttl is the TTL of the lock in milliseconds.
	LockTtl uint64 `protobuf:"varint,4,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
	// contains filtered or unexported fields
}

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

type PutResponse struct {
	CommitIndex uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Success     bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type RaftCommand struct {
	Requests []*Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

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

type RawDeleteResponse struct {
	CommitIndex uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Success     bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type RawGetRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Ts  uint64 `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"` // optional read timestamp; if zero, server uses current HLC
	// contains filtered or unexported fields
}

type RawGetResponse struct {
	ReadAtIndex uint64 `protobuf:"varint,1,opt,name=read_at_index,json=readAtIndex,proto3" json:"read_at_index,omitempty"`
	Value       []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Exists      bool   `protobuf:"varint,3,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

type RawKVClient interface {
	RawPut(ctx context.Context, in *RawPutRequest, opts ...grpc.CallOption) (*RawPutResponse, error)
	RawGet(ctx context.Context, in *RawGetRequest, opts ...grpc.CallOption) (*RawGetResponse, error)
	RawDelete(ctx context.Context, in *RawDeleteRequest, opts ...grpc.CallOption) (*RawDeleteResponse, error)
	RawLatestCommitTS(ctx context.Context, in *RawLatestCommitTSRequest, opts ...grpc.CallOption) (*RawLatestCommitTSResponse, error)
	RawScanAt(ctx context.Context, in *RawScanAtRequest, opts ...grpc.CallOption) (*RawScanAtResponse, error)
}

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

type RawKVServer interface {
	RawPut(context.Context, *RawPutRequest) (*RawPutResponse, error)
	RawGet(context.Context, *RawGetRequest) (*RawGetResponse, error)
	RawDelete(context.Context, *RawDeleteRequest) (*RawDeleteResponse, error)
	RawLatestCommitTS(context.Context, *RawLatestCommitTSRequest) (*RawLatestCommitTSResponse, error)
	RawScanAt(context.Context, *RawScanAtRequest) (*RawScanAtResponse, error)
	// contains filtered or unexported methods
}

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

type RawLatestCommitTSResponse struct {
	Ts     uint64 `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Exists bool   `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

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

type RawPutResponse struct {
	CommitIndex uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Success     bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type RawScanAtRequest struct {
	StartKey []byte `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	Limit    int64  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` // validated against host int size; large values may be rejected
	Ts       uint64 `protobuf:"varint,4,opt,name=ts,proto3" json:"ts,omitempty"`       // optional read timestamp; if zero, server uses current HLC
	Reverse  bool   `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// contains filtered or unexported fields
}

type RawScanAtResponse struct {
	Kv []*RawKVPair `protobuf:"bytes,1,rep,name=kv,proto3" json:"kv,omitempty"`
	// contains filtered or unexported fields
}

type RedisHashValue struct {
	Entries map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RedisSetValue struct {
	Members []string `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

type RedisStreamEntry struct {
	Id     string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type RedisStreamValue struct {
	Entries []*RedisStreamEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

type RedisZSetEntry struct {
	Member string  `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	Score  float64 `protobuf:"fixed64,2,opt,name=score,proto3" json:"score,omitempty"`
	// contains filtered or unexported fields
}

type RedisZSetValue struct {
	Entries []*RedisZSetEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

type RelayPublishRequest struct {
	Channel []byte `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type RelayPublishResponse struct {
	Subscribers int64 `protobuf:"varint,1,opt,name=subscribers,proto3" json:"subscribers,omitempty"`
	// contains filtered or unexported fields
}

type Request struct {
	IsTxn     bool        `protobuf:"varint,1,opt,name=is_txn,json=isTxn,proto3" json:"is_txn,omitempty"`
	Phase     Phase       `protobuf:"varint,2,opt,name=phase,proto3,enum=Phase" json:"phase,omitempty"`
	Ts        uint64      `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
	Mutations []*Mutation `protobuf:"bytes,4,rep,name=mutations,proto3" json:"mutations,omitempty"`
	// contains filtered or unexported fields
}

type RollbackRequest struct {
	StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	// contains filtered or unexported fields
}

type RollbackResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type RouteDescriptor struct {
	RouteId       uint64     `protobuf:"varint,1,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	Start         []byte     `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	End           []byte     `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	RaftGroupId   uint64     `protobuf:"varint,4,opt,name=raft_group_id,json=raftGroupId,proto3" json:"raft_group_id,omitempty"`
	State         RouteState `protobuf:"varint,5,opt,name=state,proto3,enum=RouteState" json:"state,omitempty"`
	ParentRouteId uint64     `protobuf:"varint,6,opt,name=parent_route_id,json=parentRouteId,proto3" json:"parent_route_id,omitempty"`
	// contains filtered or unexported fields
}

type RouteState int32

type ScanRequest struct {
	StartKey []byte `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	Limit    uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type ScanResponse struct {
	Kv []*Kv `protobuf:"bytes,1,rep,name=kv,proto3" json:"kv,omitempty"`
	// contains filtered or unexported fields
}

type SplitRangeRequest struct {
	ExpectedCatalogVersion uint64 `` /* 130-byte string literal not displayed */
	RouteId                uint64 `protobuf:"varint,2,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	SplitKey               []byte `protobuf:"bytes,3,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
	// contains filtered or unexported fields
}

type SplitRangeResponse struct {
	CatalogVersion uint64           `protobuf:"varint,1,opt,name=catalog_version,json=catalogVersion,proto3" json:"catalog_version,omitempty"`
	Left           *RouteDescriptor `protobuf:"bytes,2,opt,name=left,proto3" json:"left,omitempty"`
	Right          *RouteDescriptor `protobuf:"bytes,3,opt,name=right,proto3" json:"right,omitempty"`
	// contains filtered or unexported fields
}

type TransactionalKVClient interface {
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (*ScanResponse, error)
	PreWrite(ctx context.Context, in *PreWriteRequest, opts ...grpc.CallOption) (*PreCommitResponse, error)
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
	Rollback(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error)
}

type TransactionalKVServer interface {
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Scan(context.Context, *ScanRequest) (*ScanResponse, error)
	PreWrite(context.Context, *PreWriteRequest) (*PreCommitResponse, error)
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
	Rollback(context.Context, *RollbackRequest) (*RollbackResponse, error)
	// contains filtered or unexported methods
}

type UnimplementedDistributionServer struct{}

type UnimplementedInternalServer struct{}

type UnimplementedRawKVServer struct{}

type UnimplementedTransactionalKVServer struct{}