proto

type AdapterSummary struct {
	Adapter   string  `protobuf:"bytes,1,opt,name=adapter,proto3" json:"adapter,omitempty"`
	Operation string  `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	Requests  uint64  `protobuf:"varint,3,opt,name=requests,proto3" json:"requests,omitempty"`
	InFlight  uint64  `protobuf:"varint,4,opt,name=in_flight,json=inFlight,proto3" json:"in_flight,omitempty"`
	BytesIn   uint64  `protobuf:"varint,5,opt,name=bytes_in,json=bytesIn,proto3" json:"bytes_in,omitempty"`
	BytesOut  uint64  `protobuf:"varint,6,opt,name=bytes_out,json=bytesOut,proto3" json:"bytes_out,omitempty"`
	P50Ns     float64 `protobuf:"fixed64,7,opt,name=p50_ns,json=p50Ns,proto3" json:"p50_ns,omitempty"`
	P95Ns     float64 `protobuf:"fixed64,8,opt,name=p95_ns,json=p95Ns,proto3" json:"p95_ns,omitempty"`
	P99Ns     float64 `protobuf:"fixed64,9,opt,name=p99_ns,json=p99Ns,proto3" json:"p99_ns,omitempty"`
	// contains filtered or unexported fields
}

type AdminClient interface {
	GetClusterOverview(ctx context.Context, in *GetClusterOverviewRequest, opts ...grpc.CallOption) (*GetClusterOverviewResponse, error)
	GetRaftGroups(ctx context.Context, in *GetRaftGroupsRequest, opts ...grpc.CallOption) (*GetRaftGroupsResponse, error)
	GetAdapterSummary(ctx context.Context, in *GetAdapterSummaryRequest, opts ...grpc.CallOption) (*GetAdapterSummaryResponse, error)
	GetKeyVizMatrix(ctx context.Context, in *GetKeyVizMatrixRequest, opts ...grpc.CallOption) (*GetKeyVizMatrixResponse, error)
	GetRouteDetail(ctx context.Context, in *GetRouteDetailRequest, opts ...grpc.CallOption) (*GetRouteDetailResponse, error)
	StreamEvents(ctx context.Context, in *StreamEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamEventsEvent], error)
}

type AdminForwardClient interface {
	// Forward dispatches an admin write operation on the leader's
	// behalf. Returns a structured response carrying the same JSON
	// payload the leader's handler would have written to the wire.
	Forward(ctx context.Context, in *AdminForwardRequest, opts ...grpc.CallOption) (*AdminForwardResponse, error)
}

type AdminForwardRequest struct {
	Principal *AdminPrincipal `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Operation AdminOperation  `protobuf:"varint,2,opt,name=operation,proto3,enum=AdminOperation" json:"operation,omitempty"`
	// payload is the JSON-encoded operation-specific request body —
	// the same bytes the SPA sent to the follower's HTTP endpoint.
	// The leader decodes this with the operation's known schema.
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// forwarded_from is the follower's node id; the leader echoes it
	// into the audit log line for the operation so operators can
	// trace which follower carried the request (design Section 3.3.2
	// acceptance criteria 6).
	ForwardedFrom string `protobuf:"bytes,4,opt,name=forwarded_from,json=forwardedFrom,proto3" json:"forwarded_from,omitempty"`
	// contains filtered or unexported fields
}

type AdminForwardResponse struct {

	// status_code is the HTTP status the leader's handler would have
	// written. The follower returns this verbatim to the SPA so the
	// failure semantics (404 vs 409 vs 400) match a leader-direct
	// call exactly.
	StatusCode int32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// payload is the JSON-encoded response body. Empty when
	// status_code is 204 No Content (DELETE success).
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// content_type is the response content type the leader chose; in
	// practice always "application/json; charset=utf-8" but echoed
	// explicitly so the follower does not have to guess.
	ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// retry_after_seconds carries a Retry-After hint the follower's
	// bridge translates back into an HTTP Retry-After header. The
	// direct HTTP path sets Retry-After: 1 on 503 leader_unavailable
	// (mid-dispatch leadership churn); without this field the same
	// response shape would lose its retry timing once forwarded —
	// clients would see 503 with no Retry-After and fall back to
	// their default backoff. Codex P2 on PR #635 flagged the gap.
	// Zero means "no Retry-After header"; the field is only meaningful
	// for status codes that traditionally carry one (typically 503).
	RetryAfterSeconds int32 `protobuf:"varint,4,opt,name=retry_after_seconds,json=retryAfterSeconds,proto3" json:"retry_after_seconds,omitempty"`
	// contains filtered or unexported fields
}

type AdminForwardServer interface {
	// Forward dispatches an admin write operation on the leader's
	// behalf. Returns a structured response carrying the same JSON
	// payload the leader's handler would have written to the wire.
	Forward(context.Context, *AdminForwardRequest) (*AdminForwardResponse, error)
	// contains filtered or unexported methods
}

type AdminOperation int32

type AdminPrincipal struct {
	AccessKey string `protobuf:"bytes,1,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	Role      string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"` // "read_only" | "full"
	// contains filtered or unexported fields
}

type AdminServer interface {
	GetClusterOverview(context.Context, *GetClusterOverviewRequest) (*GetClusterOverviewResponse, error)
	GetRaftGroups(context.Context, *GetRaftGroupsRequest) (*GetRaftGroupsResponse, error)
	GetAdapterSummary(context.Context, *GetAdapterSummaryRequest) (*GetAdapterSummaryResponse, error)
	GetKeyVizMatrix(context.Context, *GetKeyVizMatrixRequest) (*GetKeyVizMatrixResponse, error)
	GetRouteDetail(context.Context, *GetRouteDetailRequest) (*GetRouteDetailResponse, error)
	StreamEvents(*StreamEventsRequest, grpc.ServerStreamingServer[StreamEventsEvent]) error
	// contains filtered or unexported methods
}

type Admin_StreamEventsClient = grpc.ServerStreamingClient[StreamEventsEvent]

type Admin_StreamEventsServer = grpc.ServerStreamingServer[StreamEventsEvent]

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 EtcdRaftAck struct {
	// contains filtered or unexported fields
}

type EtcdRaftClient interface {
	Send(ctx context.Context, in *EtcdRaftMessage, opts ...grpc.CallOption) (*EtcdRaftAck, error)
	SendSnapshot(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[EtcdRaftSnapshotChunk, EtcdRaftAck], error)
}

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

type EtcdRaftServer interface {
	Send(context.Context, *EtcdRaftMessage) (*EtcdRaftAck, error)
	SendSnapshot(grpc.ClientStreamingServer[EtcdRaftSnapshotChunk, EtcdRaftAck]) error
	// contains filtered or unexported methods
}

type EtcdRaftSnapshotChunk struct {
	Metadata []byte `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Chunk    []byte `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Final    bool   `protobuf:"varint,3,opt,name=final,proto3" json:"final,omitempty"`
	// contains filtered or unexported fields
}

type EtcdRaft_SendSnapshotClient = grpc.ClientStreamingClient[EtcdRaftSnapshotChunk, EtcdRaftAck]

type EtcdRaft_SendSnapshotServer = grpc.ClientStreamingServer[EtcdRaftSnapshotChunk, EtcdRaftAck]

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 GetAdapterSummaryRequest struct {
	// contains filtered or unexported fields
}

type GetAdapterSummaryResponse struct {
	Summaries []*AdapterSummary `protobuf:"bytes,1,rep,name=summaries,proto3" json:"summaries,omitempty"`
	// contains filtered or unexported fields
}

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

type GetClusterOverviewResponse struct {
	Self         *NodeIdentity   `protobuf:"bytes,1,opt,name=self,proto3" json:"self,omitempty"`
	Members      []*NodeIdentity `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"`
	GroupLeaders []*GroupLeader  `protobuf:"bytes,3,rep,name=group_leaders,json=groupLeaders,proto3" json:"group_leaders,omitempty"`
	AggregateQps uint64          `protobuf:"varint,4,opt,name=aggregate_qps,json=aggregateQps,proto3" json:"aggregate_qps,omitempty"`
	// contains filtered or unexported fields
}

type GetKeyVizMatrixRequest struct {
	Series     KeyVizSeries `protobuf:"varint,1,opt,name=series,proto3,enum=KeyVizSeries" json:"series,omitempty"`
	FromUnixMs int64        `protobuf:"varint,2,opt,name=from_unix_ms,json=fromUnixMs,proto3" json:"from_unix_ms,omitempty"`
	ToUnixMs   int64        `protobuf:"varint,3,opt,name=to_unix_ms,json=toUnixMs,proto3" json:"to_unix_ms,omitempty"`
	Rows       uint32       `protobuf:"varint,4,opt,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

type GetKeyVizMatrixResponse struct {
	ColumnUnixMs []int64      `protobuf:"varint,1,rep,packed,name=column_unix_ms,json=columnUnixMs,proto3" json:"column_unix_ms,omitempty"`
	Rows         []*KeyVizRow `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

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

type GetRaftGroupsResponse struct {
	Groups []*RaftGroupState `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,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 GetRouteDetailRequest struct {

	// Either a concrete route:<routeID> or a virtual:<id> emitted in a previous
	// GetKeyVizMatrix response.
	BucketId   string `protobuf:"bytes,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	FromUnixMs int64  `protobuf:"varint,2,opt,name=from_unix_ms,json=fromUnixMs,proto3" json:"from_unix_ms,omitempty"`
	ToUnixMs   int64  `protobuf:"varint,3,opt,name=to_unix_ms,json=toUnixMs,proto3" json:"to_unix_ms,omitempty"`
	// contains filtered or unexported fields
}

type GetRouteDetailResponse struct {
	Row        *KeyVizRow        `protobuf:"bytes,1,opt,name=row,proto3" json:"row,omitempty"`
	PerAdapter []*AdapterSummary `protobuf:"bytes,2,rep,name=per_adapter,json=perAdapter,proto3" json:"per_adapter,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 GroupLeader struct {
	RaftGroupId  uint64 `protobuf:"varint,1,opt,name=raft_group_id,json=raftGroupId,proto3" json:"raft_group_id,omitempty"`
	LeaderNodeId string `protobuf:"bytes,2,opt,name=leader_node_id,json=leaderNodeId,proto3" json:"leader_node_id,omitempty"`
	LeaderTerm   uint64 `protobuf:"varint,3,opt,name=leader_term,json=leaderTerm,proto3" json:"leader_term,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 KeyVizColumn struct {
	ColumnUnixMs int64        `protobuf:"varint,1,opt,name=column_unix_ms,json=columnUnixMs,proto3" json:"column_unix_ms,omitempty"`
	Series       KeyVizSeries `protobuf:"varint,2,opt,name=series,proto3,enum=KeyVizSeries" json:"series,omitempty"`
	Rows         []*KeyVizRow `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

type KeyVizRow struct {

	// bucket_id is either "route:<routeID>" or "virtual:<lineageID-or-hash>".
	BucketId          string       `protobuf:"bytes,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_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"`
	Label             string       `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	Aggregate         bool         `protobuf:"varint,5,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
	RouteIds          []uint64     `protobuf:"varint,6,rep,packed,name=route_ids,json=routeIds,proto3" json:"route_ids,omitempty"`
	RouteIdsTruncated bool         `protobuf:"varint,7,opt,name=route_ids_truncated,json=routeIdsTruncated,proto3" json:"route_ids_truncated,omitempty"`
	RouteCount        uint64       `protobuf:"varint,8,opt,name=route_count,json=routeCount,proto3" json:"route_count,omitempty"`
	SampleRoles       []SampleRole `protobuf:"varint,9,rep,packed,name=sample_roles,json=sampleRoles,proto3,enum=SampleRole" json:"sample_roles,omitempty"`
	LineageId         string       `protobuf:"bytes,10,opt,name=lineage_id,json=lineageId,proto3" json:"lineage_id,omitempty"`
	// values[j] is the series value at time column j.
	Values []uint64 `protobuf:"varint,11,rep,packed,name=values,proto3" json:"values,omitempty"`
	// soft_columns[j] is true when the j-th column missed the estimator SLO.
	SoftColumns []bool `protobuf:"varint,12,rep,packed,name=soft_columns,json=softColumns,proto3" json:"soft_columns,omitempty"`
	// raft_group_ids[j] and leader_terms[j] carry the route's Raft
	// identity at the time column j was flushed. Phase 2-C+ fan-out
	// uses (bucket_id, raft_group_id, leader_term, column) as the
	// dedupe key, so writes from a leader and the previous leader of
	// the same group can be summed across terms instead of
	// conservatively max-merged. Per-cell representation (parallel to
	// values[] and soft_columns[]) is required because leadership can
	// flip within the requested window; a single row-level scalar
	// would only capture the first column's identity and cause
	// incorrect dedupe for later columns (Gemini HIGH on PR #720).
	// Zero values mean "term not tracked" (single-group legacy
	// deployments, virtual aggregate buckets, or nodes that have not
	// yet wired the leader-term publisher) — the aggregator falls
	// back to the legacy max-merge for those cells.
	//
	// Both slices are either empty (legacy server, no per-column
	// identity to share — older clients reading the response can
	// treat empty as "all zeros") or `len(raft_group_ids) ==
	// len(leader_terms) == len(values)`. The server never emits a
	// partial-length slice.
	RaftGroupIds []uint64 `protobuf:"varint,13,rep,packed,name=raft_group_ids,json=raftGroupIds,proto3" json:"raft_group_ids,omitempty"`
	LeaderTerms  []uint64 `protobuf:"varint,14,rep,packed,name=leader_terms,json=leaderTerms,proto3" json:"leader_terms,omitempty"`
	// contains filtered or unexported fields
}

type KeyVizSeries int32

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
}