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 BootstrapEncryptionRequest struct {
	WrappedStorageDek []byte                 `protobuf:"bytes,1,opt,name=wrapped_storage_dek,json=wrappedStorageDek,proto3" json:"wrapped_storage_dek,omitempty"`
	WrappedRaftDek    []byte                 `protobuf:"bytes,2,opt,name=wrapped_raft_dek,json=wrappedRaftDek,proto3" json:"wrapped_raft_dek,omitempty"`
	StorageDekId      uint32                 `protobuf:"varint,3,opt,name=storage_dek_id,json=storageDekId,proto3" json:"storage_dek_id,omitempty"`
	RaftDekId         uint32                 `protobuf:"varint,4,opt,name=raft_dek_id,json=raftDekId,proto3" json:"raft_dek_id,omitempty"`
	WriterBatch       []*WriterRegistryEntry `protobuf:"bytes,5,rep,name=writer_batch,json=writerBatch,proto3" json:"writer_batch,omitempty"`
	// contains filtered or unexported fields
}

type BootstrapEncryptionResponse struct {
	AppliedIndex uint64 `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	// contains filtered or unexported fields
}

type CapabilityReport struct {
	EncryptionCapable bool   `protobuf:"varint,1,opt,name=encryption_capable,json=encryptionCapable,proto3" json:"encryption_capable,omitempty"`
	BuildSha          string `protobuf:"bytes,2,opt,name=build_sha,json=buildSha,proto3" json:"build_sha,omitempty"`
	SidecarPresent    bool   `protobuf:"varint,3,opt,name=sidecar_present,json=sidecarPresent,proto3" json:"sidecar_present,omitempty"`
	FullNodeId        uint64 `protobuf:"varint,4,opt,name=full_node_id,json=fullNodeId,proto3" json:"full_node_id,omitempty"`
	LocalEpoch        uint32 `protobuf:"varint,5,opt,name=local_epoch,json=localEpoch,proto3" json:"local_epoch,omitempty"` // MUST be <= 0xFFFF on the wire.
	// contains filtered or unexported fields
}

type CapabilityVerdict struct {
	FullNodeId        uint64 `protobuf:"varint,1,opt,name=full_node_id,json=fullNodeId,proto3" json:"full_node_id,omitempty"`
	EncryptionCapable bool   `protobuf:"varint,2,opt,name=encryption_capable,json=encryptionCapable,proto3" json:"encryption_capable,omitempty"`
	BuildSha          string `protobuf:"bytes,3,opt,name=build_sha,json=buildSha,proto3" json:"build_sha,omitempty"`
	SidecarPresent    bool   `protobuf:"varint,4,opt,name=sidecar_present,json=sidecarPresent,proto3" json:"sidecar_present,omitempty"`
	// contains filtered or unexported fields
}

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

type EnableRaftEnvelopeRequest struct {
	ProposerNodeId     uint64 `protobuf:"varint,1,opt,name=proposer_node_id,json=proposerNodeId,proto3" json:"proposer_node_id,omitempty"`
	ProposerLocalEpoch uint32 `protobuf:"varint,2,opt,name=proposer_local_epoch,json=proposerLocalEpoch,proto3" json:"proposer_local_epoch,omitempty"` // MUST be <= 0xFFFF on the wire.
	// contains filtered or unexported fields
}

type EnableRaftEnvelopeResponse struct {
	AppliedIndex      uint64               `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	CapabilitySummary []*CapabilityVerdict `protobuf:"bytes,2,rep,name=capability_summary,json=capabilitySummary,proto3" json:"capability_summary,omitempty"`
	WasAlreadyActive  bool                 `protobuf:"varint,3,opt,name=was_already_active,json=wasAlreadyActive,proto3" json:"was_already_active,omitempty"`
	// contains filtered or unexported fields
}

type EnableStorageEnvelopeRequest struct {
	ProposerNodeId     uint64 `protobuf:"varint,1,opt,name=proposer_node_id,json=proposerNodeId,proto3" json:"proposer_node_id,omitempty"`
	ProposerLocalEpoch uint32 `protobuf:"varint,2,opt,name=proposer_local_epoch,json=proposerLocalEpoch,proto3" json:"proposer_local_epoch,omitempty"` // MUST be <= 0xFFFF on the wire.
	// contains filtered or unexported fields
}

type EnableStorageEnvelopeResponse struct {
	AppliedIndex        uint64               `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	CapabilitySummary   []*CapabilityVerdict `protobuf:"bytes,2,rep,name=capability_summary,json=capabilitySummary,proto3" json:"capability_summary,omitempty"`
	CutoverIndexUnknown bool                 `protobuf:"varint,3,opt,name=cutover_index_unknown,json=cutoverIndexUnknown,proto3" json:"cutover_index_unknown,omitempty"`
	WasAlreadyActive    bool                 `protobuf:"varint,4,opt,name=was_already_active,json=wasAlreadyActive,proto3" json:"was_already_active,omitempty"`
	// contains filtered or unexported fields
}

type EncryptionAdminClient interface {
	GetCapability(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*CapabilityReport, error)
	GetSidecarState(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*SidecarStateReport, error)
	BootstrapEncryption(ctx context.Context, in *BootstrapEncryptionRequest, opts ...grpc.CallOption) (*BootstrapEncryptionResponse, error)
	RotateDEK(ctx context.Context, in *RotateDEKRequest, opts ...grpc.CallOption) (*RotateDEKResponse, error)
	RegisterEncryptionWriter(ctx context.Context, in *RegisterEncryptionWriterRequest, opts ...grpc.CallOption) (*RegisterEncryptionWriterResponse, error)
	ResyncSidecar(ctx context.Context, in *ResyncSidecarRequest, opts ...grpc.CallOption) (*ResyncSidecarResponse, error)
	EnableStorageEnvelope(ctx context.Context, in *EnableStorageEnvelopeRequest, opts ...grpc.CallOption) (*EnableStorageEnvelopeResponse, error)
	EnableRaftEnvelope(ctx context.Context, in *EnableRaftEnvelopeRequest, opts ...grpc.CallOption) (*EnableRaftEnvelopeResponse, error)
}

type EncryptionAdminServer interface {
	GetCapability(context.Context, *Empty) (*CapabilityReport, error)
	GetSidecarState(context.Context, *Empty) (*SidecarStateReport, error)
	BootstrapEncryption(context.Context, *BootstrapEncryptionRequest) (*BootstrapEncryptionResponse, error)
	RotateDEK(context.Context, *RotateDEKRequest) (*RotateDEKResponse, error)
	RegisterEncryptionWriter(context.Context, *RegisterEncryptionWriterRequest) (*RegisterEncryptionWriterResponse, error)
	ResyncSidecar(context.Context, *ResyncSidecarRequest) (*ResyncSidecarResponse, error)
	EnableStorageEnvelope(context.Context, *EnableStorageEnvelopeRequest) (*EnableStorageEnvelopeResponse, error)
	EnableRaftEnvelope(context.Context, *EnableRaftEnvelopeRequest) (*EnableRaftEnvelopeResponse, error)
	// contains filtered or unexported methods
}

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
}