protocoordinatorservice

type Block struct {
	Number   uint64             `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`                      // The block number.
	Txs      []*protoblocktx.Tx `protobuf:"bytes,2,rep,name=txs,proto3" json:"txs,omitempty"`                             // List of transactions within the block.
	TxsNum   []uint32           `protobuf:"varint,3,rep,packed,name=txs_num,json=txsNum,proto3" json:"txs_num,omitempty"` // Transaction number within the block generated by the orderer.
	Rejected []*TxStatusInfo    `protobuf:"bytes,4,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) (*Empty, error)
	GetLastCommittedBlockNumber(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*protoblocktx.LastCommittedBlock, error)
	GetNextExpectedBlockNumber(ctx context.Context, in *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 *Empty, opts ...grpc.CallOption) (*protoblocktx.ConfigTransaction, error)
	NumberOfWaitingTransactionsForStatus(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*WaitingTransactions, error)
}

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

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

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

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

type TxStatusInfo struct {
	TxNum  uint32              `protobuf:"varint,1,opt,name=tx_num,json=txNum,proto3" json:"tx_num,omitempty"`               // Transaction number within the block generated by the orderer.
	Id     string              `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                   // Transaction ID.
	Status protoblocktx.Status `protobuf:"varint,3,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
}