servicepb

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

type CoordinatorBatch struct {
	Txs      []*TxWithRef            `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`           // List of transactions within the block.
	Rejected []*committerpb.TxStatus `protobuf:"bytes,2,rep,name=rejected,proto3" json:"rejected,omitempty"` // Rejected transactions.
	// contains filtered or unexported fields
}

type CoordinatorClient interface {
	BlockProcessing(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[CoordinatorBatch, committerpb.TxStatusBatch], error)
	SetLastCommittedBlockNumber(ctx context.Context, in *BlockRef, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetNextBlockNumberToCommit(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*BlockRef, error)
	GetTransactionsStatus(ctx context.Context, in *committerpb.TxIDsBatch, opts ...grpc.CallOption) (*committerpb.TxStatusBatch, error)
	GetConfigTransaction(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*applicationpb.ConfigTransaction, error)
	NumberOfWaitingTransactionsForStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*WaitingTransactions, error)
}

type CoordinatorServer interface {
	BlockProcessing(grpc.BidiStreamingServer[CoordinatorBatch, committerpb.TxStatusBatch]) error
	SetLastCommittedBlockNumber(context.Context, *BlockRef) (*emptypb.Empty, error)
	GetNextBlockNumberToCommit(context.Context, *emptypb.Empty) (*BlockRef, error)
	GetTransactionsStatus(context.Context, *committerpb.TxIDsBatch) (*committerpb.TxStatusBatch, error)
	GetConfigTransaction(context.Context, *emptypb.Empty) (*applicationpb.ConfigTransaction, error)
	NumberOfWaitingTransactionsForStatus(context.Context, *emptypb.Empty) (*WaitingTransactions, error)
	// contains filtered or unexported methods
}

type Coordinator_BlockProcessingClient = grpc.BidiStreamingClient[CoordinatorBatch, committerpb.TxStatusBatch]

type Coordinator_BlockProcessingServer = grpc.BidiStreamingServer[CoordinatorBatch, committerpb.TxStatusBatch]

type Height struct {
	BlockNum uint64
	TxNum    uint32
}

type LoadGenBatch struct {
	Tx []*LoadGenTx `protobuf:"bytes,1,rep,name=tx,proto3" json:"tx,omitempty"`
	// contains filtered or unexported fields
}

type LoadGenServiceClient interface {
	AppendBatch(ctx context.Context, in *LoadGenBatch, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetRateLimit(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RateLimit, error)
	SetRateLimit(ctx context.Context, in *RateLimit, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type LoadGenServiceServer interface {
	AppendBatch(context.Context, *LoadGenBatch) (*emptypb.Empty, error)
	GetRateLimit(context.Context, *emptypb.Empty) (*RateLimit, error)
	SetRateLimit(context.Context, *RateLimit) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type LoadGenTx struct {
	Id                 string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Tx                 *applicationpb.Tx `protobuf:"bytes,2,opt,name=tx,proto3" json:"tx,omitempty"`
	EnvelopePayload    []byte            `protobuf:"bytes,3,opt,name=envelope_payload,json=envelopePayload,proto3" json:"envelope_payload,omitempty"`
	EnvelopeSignature  []byte            `protobuf:"bytes,4,opt,name=envelope_signature,json=envelopeSignature,proto3" json:"envelope_signature,omitempty"`
	SerializedEnvelope []byte            `protobuf:"bytes,5,opt,name=serialized_envelope,json=serializedEnvelope,proto3" json:"serialized_envelope,omitempty"`
	// contains filtered or unexported fields
}

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

type TxWithRef struct {
	Ref     *committerpb.TxRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`         // The TX reference.
	Content *applicationpb.Tx  `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // The TX content.
	// contains filtered or unexported fields
}

type UnimplementedCoordinatorServer struct{}

type UnimplementedLoadGenServiceServer struct{}

type UnimplementedValidationAndCommitServiceServer struct{}

type UnimplementedVerifierServer struct{}

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

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

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

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

type ValidationAndCommitServiceClient interface {
	StartValidateAndCommitStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[VcBatch, committerpb.TxStatusBatch], error)
	SetLastCommittedBlockNumber(ctx context.Context, in *BlockRef, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetNextBlockNumberToCommit(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*BlockRef, error)
	GetTransactionsStatus(ctx context.Context, in *committerpb.TxIDsBatch, opts ...grpc.CallOption) (*committerpb.TxStatusBatch, 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)
	SetupSystemTablesAndNamespaces(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type ValidationAndCommitServiceServer interface {
	StartValidateAndCommitStream(grpc.BidiStreamingServer[VcBatch, committerpb.TxStatusBatch]) error
	SetLastCommittedBlockNumber(context.Context, *BlockRef) (*emptypb.Empty, error)
	GetNextBlockNumberToCommit(context.Context, *emptypb.Empty) (*BlockRef, error)
	GetTransactionsStatus(context.Context, *committerpb.TxIDsBatch) (*committerpb.TxStatusBatch, error)
	GetNamespacePolicies(context.Context, *emptypb.Empty) (*applicationpb.NamespacePolicies, error)
	GetConfigTransaction(context.Context, *emptypb.Empty) (*applicationpb.ConfigTransaction, error)
	SetupSystemTablesAndNamespaces(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type ValidationAndCommitService_StartValidateAndCommitStreamClient = grpc.BidiStreamingClient[VcBatch, committerpb.TxStatusBatch]

type ValidationAndCommitService_StartValidateAndCommitStreamServer = grpc.BidiStreamingServer[VcBatch, committerpb.TxStatusBatch]

type VcBatch struct {
	Transactions []*VcTx `protobuf:"bytes,1,rep,name=transactions,proto3" json:"transactions,omitempty"`
	// contains filtered or unexported fields
}

type VcTx struct {
	Ref                   *committerpb.TxRef           `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Namespaces            []*applicationpb.TxNamespace `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	PrelimInvalidTxStatus *committerpb.Status          `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

type VerifierBatch struct {
	Update   *VerifierUpdates `protobuf:"bytes,1,opt,name=update,proto3,oneof" json:"update,omitempty"`
	Requests []*TxWithRef     `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

type VerifierClient interface {
	StartStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[VerifierBatch, committerpb.TxStatusBatch], error)
}

type VerifierServer interface {
	StartStream(grpc.BidiStreamingServer[VerifierBatch, committerpb.TxStatusBatch]) error
	// contains filtered or unexported methods
}

type VerifierUpdates struct {
	Config            *applicationpb.ConfigTransaction `protobuf:"bytes,1,opt,name=config,proto3,oneof" json:"config,omitempty"`
	NamespacePolicies *applicationpb.NamespacePolicies `protobuf:"bytes,2,opt,name=namespace_policies,json=namespacePolicies,proto3,oneof" json:"namespace_policies,omitempty"`
	// contains filtered or unexported fields
}

type Verifier_StartStreamClient = grpc.BidiStreamingClient[VerifierBatch, committerpb.TxStatusBatch]

type Verifier_StartStreamServer = grpc.BidiStreamingServer[VerifierBatch, committerpb.TxStatusBatch]

type WaitingTransactions struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}