protocoordinatorservice

type Batch struct {
	Txs      []*Tx           `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`           // List of transactions within the block.
	Rejected []*TxStatusInfo `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) (Coordinator_BlockProcessingClient, error)
	SetLastCommittedBlockNumber(ctx context.Context, in *protoblocktx.BlockInfo, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetLastCommittedBlockNumber(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*protoblocktx.LastCommittedBlock, error)
	GetNextExpectedBlockNumber(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*protoblocktx.BlockInfo, error)
	GetTransactionsStatus(ctx context.Context, in *protoblocktx.QueryStatus, opts ...grpc.CallOption) (*protoblocktx.TransactionsStatus, error)
	GetConfigTransaction(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*protoblocktx.ConfigTransaction, error)
	NumberOfWaitingTransactionsForStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*WaitingTransactions, error)
}

type CoordinatorServer interface {
	BlockProcessing(Coordinator_BlockProcessingServer) error
	SetLastCommittedBlockNumber(context.Context, *protoblocktx.BlockInfo) (*emptypb.Empty, error)
	GetLastCommittedBlockNumber(context.Context, *emptypb.Empty) (*protoblocktx.LastCommittedBlock, error)
	GetNextExpectedBlockNumber(context.Context, *emptypb.Empty) (*protoblocktx.BlockInfo, error)
	GetTransactionsStatus(context.Context, *protoblocktx.QueryStatus) (*protoblocktx.TransactionsStatus, error)
	GetConfigTransaction(context.Context, *emptypb.Empty) (*protoblocktx.ConfigTransaction, error)
	NumberOfWaitingTransactionsForStatus(context.Context, *emptypb.Empty) (*WaitingTransactions, error)
	// contains filtered or unexported methods
}

type Coordinator_BlockProcessingClient interface {
	Send(*Batch) error
	Recv() (*protoblocktx.TransactionsStatus, error)
	grpc.ClientStream
}

type Coordinator_BlockProcessingServer interface {
	Send(*protoblocktx.TransactionsStatus) error
	Recv() (*Batch, error)
	grpc.ServerStream
}

type Tx struct {
	Ref     *TxRef           `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`         // The TX reference.
	Content *protoblocktx.Tx `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // The TX content.
	// 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 TxStatusInfo struct {
	Ref    *TxRef              `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`                                 // The TX reference.
	Status protoblocktx.Status `protobuf:"varint,2,opt,name=status,proto3,enum=protoblocktx.Status" json:"status,omitempty"` // The reject reason.
	// contains filtered or unexported fields
}

type UnimplementedCoordinatorServer struct {
}

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

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