committerpb

type BlockEvent struct {

	// The header of the block from which these transactions originated.
	// It carries the block number, the previous block hash and the data hash.
	// The block hash can be computed from it with protoutil.BlockHeaderHash.
	Header *common.BlockHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// List of transaction events (may be filtered based on request).
	Events []*TxEvent `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

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

type DeleteDBCloneForSnapshotRequest struct {

	// Transaction ID of the snapshot transaction, the _snapshot namespace row key.
	TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// contains filtered or unexported fields
}

type IsoLevel int32

type NotificationRequest struct {
	TxStatusRequest *TxIDsBatch `protobuf:"bytes,1,opt,name=tx_status_request,json=txStatusRequest,proto3,oneof" json:"tx_status_request,omitempty"`
	// The timeout duration that applies to ALL the subscriptions in this request.
	// It is non-strict, i.e., it is possible to receive notifications for this request
	// after the timeout has passed.
	// If this field is not set or has a default value (zero), the default would be applied as
	// per the committer's configuration.
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

type NotificationResponse struct {
	TxStatusEvents []*TxStatus    `protobuf:"bytes,1,rep,name=tx_status_events,json=txStatusEvents,proto3" json:"tx_status_events,omitempty"` // List of transaction status events.
	TimeoutTxIds   []string       `protobuf:"bytes,2,rep,name=timeout_tx_ids,json=timeoutTxIds,proto3" json:"timeout_tx_ids,omitempty"`       // List of timeout events.
	RejectedTxIds  *RejectedTxIds `protobuf:"bytes,3,opt,name=rejected_tx_ids,json=rejectedTxIds,proto3" json:"rejected_tx_ids,omitempty"`    // List of rejected transaction IDs with a reason.
	// contains filtered or unexported fields
}

type Query struct {
	View       *View             `protobuf:"bytes,1,opt,name=view,proto3,oneof" json:"view,omitempty"`
	Namespaces []*QueryNamespace `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

type QueryNamespace struct {
	NsId string   `protobuf:"bytes,1,opt,name=ns_id,json=nsId,proto3" json:"ns_id,omitempty"`
	Keys [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

type QueryServiceClient interface {
	GetRows(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Rows, error)
	BeginView(ctx context.Context, in *ViewParameters, opts ...grpc.CallOption) (*View, error)
	EndView(ctx context.Context, in *View, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetNamespacePolicies(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*applicationpb.NamespacePolicies, error)
	GetConfigTransaction(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*applicationpb.ConfigTransaction, error)
	GetTransactionStatus(ctx context.Context, in *TxStatusQuery, opts ...grpc.CallOption) (*TxStatusResponse, error)
}

type QueryServiceServer interface {
	GetRows(context.Context, *Query) (*Rows, error)
	BeginView(context.Context, *ViewParameters) (*View, error)
	EndView(context.Context, *View) (*emptypb.Empty, error)
	GetNamespacePolicies(context.Context, *emptypb.Empty) (*applicationpb.NamespacePolicies, error)
	GetConfigTransaction(context.Context, *emptypb.Empty) (*applicationpb.ConfigTransaction, error)
	GetTransactionStatus(context.Context, *TxStatusQuery) (*TxStatusResponse, error)
	// contains filtered or unexported methods
}

type RejectedTxIds struct {
	TxIds  []string `protobuf:"bytes,1,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"` // List of rejected transaction IDs.
	Reason string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`            // The reason for rejection.
	// contains filtered or unexported fields
}

type Row 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"`
	Version uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type Rows struct {
	Namespaces []*RowsNamespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

type RowsNamespace struct {
	NsId string `protobuf:"bytes,1,opt,name=ns_id,json=nsId,proto3" json:"ns_id,omitempty"`
	Rows []*Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

type SidecarServiceClient interface {
	// Block store reads. Previously BlockQueryService.
	GetBlockchainInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*common.BlockchainInfo, error)
	GetBlockByNumber(ctx context.Context, in *BlockNumber, opts ...grpc.CallOption) (*common.Block, error)
	GetBlockByTxID(ctx context.Context, in *TxID, opts ...grpc.CallOption) (*common.Block, error)
	GetTxByID(ctx context.Context, in *TxID, opts ...grpc.CallOption) (*common.Envelope, error)
	// Event subscriptions. Previously Notifier.
	OpenNotificationStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[NotificationRequest, NotificationResponse], error)
	StreamBlocks(ctx context.Context, in *StreamBlocksRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[BlockEvent], error)
	// Snapshot-clone administration. The committer answers UNIMPLEMENTED until
	// the clone-deletion pipeline lands.
	DeleteDBCloneForSnapshot(ctx context.Context, in *DeleteDBCloneForSnapshotRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type SidecarServiceServer interface {
	// Block store reads. Previously BlockQueryService.
	GetBlockchainInfo(context.Context, *emptypb.Empty) (*common.BlockchainInfo, error)
	GetBlockByNumber(context.Context, *BlockNumber) (*common.Block, error)
	GetBlockByTxID(context.Context, *TxID) (*common.Block, error)
	GetTxByID(context.Context, *TxID) (*common.Envelope, error)
	// Event subscriptions. Previously Notifier.
	OpenNotificationStream(grpc.BidiStreamingServer[NotificationRequest, NotificationResponse]) error
	StreamBlocks(*StreamBlocksRequest, grpc.ServerStreamingServer[BlockEvent]) error
	// Snapshot-clone administration. The committer answers UNIMPLEMENTED until
	// the clone-deletion pipeline lands.
	DeleteDBCloneForSnapshot(context.Context, *DeleteDBCloneForSnapshotRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type SidecarService_OpenNotificationStreamClient = grpc.BidiStreamingClient[NotificationRequest, NotificationResponse]

type SidecarService_OpenNotificationStreamServer = grpc.BidiStreamingServer[NotificationRequest, NotificationResponse]

type SidecarService_StreamBlocksClient = grpc.ServerStreamingClient[BlockEvent]

type SidecarService_StreamBlocksServer = grpc.ServerStreamingServer[BlockEvent]

type SnapshotState struct {

	// Reference identifying snapshot transaction and its position in the block.
	TxRef *TxRef `protobuf:"bytes,1,opt,name=tx_ref,json=txRef,proto3" json:"tx_ref,omitempty"`
	// Current snapshot lifecycle status.
	Status SnapshotState_Status `protobuf:"varint,2,opt,name=status,proto3,enum=committerpb.SnapshotState_Status" json:"status,omitempty"`
	// Deterministic hash computed from snapshot database contents.
	Hash []byte `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
	// Diagnostic context for a recoverable snapshot failure.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// Name of the database clone used to compute the snapshot hash.
	CloneDatabase string `protobuf:"bytes,5,opt,name=clone_database,json=cloneDatabase,proto3" json:"clone_database,omitempty"`
	// Checkpoint hash that differed from the local snapshot hash.
	// Empty when no checkpoint mismatch has been recorded.
	CheckpointHash []byte `protobuf:"bytes,6,opt,name=checkpoint_hash,json=checkpointHash,proto3" json:"checkpoint_hash,omitempty"`
	// contains filtered or unexported fields
}

type SnapshotState_Status int32

type Status int32

type StreamBlocksRequest struct {

	// Filter by namespace IDs (OR logic: transaction touches ANY of these namespaces).
	// Empty list means no namespace filtering (all namespaces included).
	FilterNamespaces []string `protobuf:"bytes,1,rep,name=filter_namespaces,json=filterNamespaces,proto3" json:"filter_namespaces,omitempty"`
	// Filter by transaction status (multiple statuses can be specified).
	// Empty list means no status filtering (all statuses included).
	FilterStatus []Status `` /* 129-byte string literal not displayed */
	// Include transaction content (read/write sets) in the response.
	// Default: false (only transaction reference and status).
	IncludeReadWriteSets bool `` /* 126-byte string literal not displayed */
	// Include endorsements in the response.
	// Default: false (only transaction reference and status).
	IncludeEndorsements bool `protobuf:"varint,4,opt,name=include_endorsements,json=includeEndorsements,proto3" json:"include_endorsements,omitempty"`
	// Include metadata in the response.
	// Default: false (only transaction reference and status).
	IncludeMetadata bool `protobuf:"varint,5,opt,name=include_metadata,json=includeMetadata,proto3" json:"include_metadata,omitempty"`
	// contains filtered or unexported fields
}

type TxEvent struct {

	// Transaction reference (ID, block number, transaction index).
	Ref *TxRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Transaction commit status.
	Status Status `protobuf:"varint,2,opt,name=status,proto3,enum=committerpb.Status" json:"status,omitempty"`
	// Transaction namespaces (included only if include_read_write_sets is true).
	// If namespace filtering is active, only matching namespaces are included.
	// Empty if not requested or if transaction has no namespaces.
	Namespaces []*applicationpb.TxNamespace `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// Transaction endorsements (included only if include_endorsements is true).
	// Empty if not requested or if transaction has no endorsements.
	Endorsements []*applicationpb.Endorsements `protobuf:"bytes,4,rep,name=endorsements,proto3" json:"endorsements,omitempty"`
	// Transaction metadata (included only if include_metadata is true).
	// Empty if not requested or if transaction has no metadata.
	Metadata [][]byte `protobuf:"bytes,5,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type TxID struct {
	TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// contains filtered or unexported fields
}

type TxIDsBatch struct {
	TxIds []string `protobuf:"bytes,1,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"` // List of transaction IDs.
	// contains filtered or unexported fields
}

type TxRef struct {
	BlockNum uint64 `protobuf:"varint,1,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"` // The block number.
	TxNum    uint32 `protobuf:"varint,2,opt,name=tx_num,json=txNum,proto3" json:"tx_num,omitempty"`          // Transaction number within the block
	TxId     string `protobuf:"bytes,3,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`              // Transaction ID within the block.
	// contains filtered or unexported fields
}

type TxStatus struct {
	Ref    *TxRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Status Status `protobuf:"varint,2,opt,name=status,proto3,enum=committerpb.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type TxStatusQuery struct {
	View  *View    `protobuf:"bytes,1,opt,name=view,proto3,oneof" json:"view,omitempty"`
	TxIds []string `protobuf:"bytes,2,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"` // List of transaction IDs.
	// contains filtered or unexported fields
}

type TxStatusResponse struct {
	Statuses []*TxStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedQueryServiceServer struct{}

type UnimplementedSidecarServiceServer struct{}

type UnsafeQueryServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeSidecarServiceServer interface {
	// contains filtered or unexported methods
}

type View struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type ViewParameters struct {
	IsoLevel            IsoLevel `protobuf:"varint,1,opt,name=iso_level,json=isoLevel,proto3,enum=committerpb.IsoLevel" json:"iso_level,omitempty"`        // View's isolation level. Defaults to serializable.
	NonDeferrable       bool     `protobuf:"varint,2,opt,name=non_deferrable,json=nonDeferrable,proto3" json:"non_deferrable,omitempty"`                   // Do not defer errors. Defaults deferrable.
	TimeoutMilliseconds uint64   `protobuf:"varint,3,opt,name=timeout_milliseconds,json=timeoutMilliseconds,proto3" json:"timeout_milliseconds,omitempty"` // View's timeout. Zero => maximal value
	// contains filtered or unexported fields
}