bcdb

package

Go to main page

Versions in this module

v0

v0.2.10

Feb 28, 2023

v0.2.9

Feb 19, 2023

v0.2.8

Jan 19, 2023

Changes in this version

type Ledger

+ GetTxContent func(blockNum, txIndex uint64) (*types.GetTxResponse, error)

v0.2.7

Dec 14, 2022

Changes in this version

type QueryExecutor

+ func (t QueryExecutor) TxID() string

type TxContext

+ TxID func() string

v0.2.6

Sep 1, 2022

v0.2.5

Jul 28, 2022

Changes in this version

+ const GenesisBlockNumber

+ var ErrTxNotFinalized = errors.New("can't access tx envelope, transaction not finalized")

+ var ErrTxSpent = errors.New("transaction committed or aborted")

+ func AdminExists(adminID string, adminSet []*types.Admin) (bool, int)

+ func CalculateValueHash(dbName, key string, value []byte) ([]byte, error)

+ func NodeExists(nodeID string, nodeSet []*types.NodeConfig) (bool, int)

+ func PeerExists(nodeID string, peerSet []*types.PeerConfig) (bool, int)

+ type BCDB interface

+ Session func(config *config.SessionConfig) (DBSession, error)

+ func Create(connectionConfig *config.ConnectionConfig) (BCDB, error)

+ type BlockHeaderDelivererService interface

+ Error func() error

+ Receive func() interface{}

+ Stop func()

+ type BlockHeaderDeliveryConfig struct

+ Capacity int

+ IncludeTxIDs bool

+ RetryInterval time.Duration

+ StartBlockNumber uint64

+ type ConfigTxContext interface

+ AddAdmin func(admin *types.Admin) error

+ AddClusterNode func(node *types.NodeConfig, peer *types.PeerConfig) error

+ DeleteAdmin func(adminID string) error

+ DeleteClusterNode func(nodeID string) error

+ GetClusterConfig func() (*types.ClusterConfig, error)

+ SetClusterConfig func(newConfig *types.ClusterConfig) error

+ UpdateAdmin func(admin *types.Admin) error

+ UpdateCAConfig func(caConfig *types.CAConfig) error

+ UpdateClusterNode func(node *types.NodeConfig, peer *types.PeerConfig) error

+ UpdateRaftConfig func(raftConfig *types.RaftConfig) error

+ type DBSession interface

+ ConfigTx func() (ConfigTxContext, error)

+ DBsTx func() (DBsTxContext, error)

+ DataTx func(options ...TxContextOption) (DataTxContext, error)

+ Ledger func() (Ledger, error)

+ LoadDataTx func(*types.DataTxEnvelope) (LoadedDataTxContext, error)

+ Provenance func() (Provenance, error)

+ Query func() (Query, error)

+ ReplicaSet func(refresh bool) ([]*config.Replica, error)

+ UsersTx func() (UsersTxContext, error)

+ type DBsTxContext interface

+ CreateDB func(dbName string, index map[string]types.IndexAttributeType) error

+ DeleteDB func(dbName string) error

+ Exists func(dbName string) (bool, error)

+ GetDBIndex func(dbName string) (map[string]types.IndexAttributeType, error)

+ type DataTxContext interface

+ AddMustSignUser func(userID string)

+ AssertRead func(dbName string, key string, version *types.Version) error

+ Delete func(dbName, key string) error

+ Get func(dbName, key string) ([]byte, *types.Metadata, error)

+ Put func(dbName string, key string, value []byte, acl *types.AccessControl) error

+ SignConstructedTxEnvelopeAndCloseTx func() (proto.Message, error)

+ type ErrorNotFound struct

+ Message string

+ func (e *ErrorNotFound) Error() string

+ type ErrorTxValidation struct

+ Flag string

+ Reason string

+ TxID string

+ func (e *ErrorTxValidation) Error() string

+ type HttpClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ type Iterator interface

+ Next func() (*types.KVWithMetadata, bool, error)

+ type Ledger interface

+ GetBlockHeader func(blockNum uint64) (*types.BlockHeader, error)

+ GetDataProof func(blockNum uint64, dbName, key string, isDeleted bool) (*state.Proof, error)

+ GetFullTxProofAndVerify func(txReceipt *types.TxReceipt, lastKnownBlockHeader *types.BlockHeader, ...) (*TxProof, *LedgerPath, error)

+ GetLastBlockHeader func() (*types.BlockHeader, error)

+ GetLedgerPath func(startBlock, endBlock uint64) (*LedgerPath, error)

+ GetTransactionProof func(blockNum uint64, txIndex int) (*TxProof, error)

+ GetTransactionReceipt func(txId string) (*types.TxReceipt, error)

+ NewBlockHeaderDeliveryService func(conf *BlockHeaderDeliveryConfig) BlockHeaderDelivererService

+ type LedgerPath struct

+ Path []*types.BlockHeader

+ func (lp *LedgerPath) Verify(begin, end *types.BlockHeader) (bool, error)

+ type LoadedDataTxContext interface

+ CoSignTxEnvelopeAndCloseTx func() (proto.Message, error)

+ Deletes func() map[string][]*types.DataDelete

+ MustSignUsers func() []string

+ Reads func() map[string][]*types.DataRead

+ SignedUsers func() []string

+ VerifySignatures func() error

+ Writes func() map[string][]*types.DataWrite

+ type ProofVerificationError struct

+ func (e *ProofVerificationError) Error() string

+ type Provenance interface

+ GetDataReadByUser func(userID string) (map[string]*types.KVsWithMetadata, error)

+ GetDataWrittenByUser func(userID string) (map[string]*types.KVsWithMetadata, error)

+ GetHistoricalData func(dbName, key string) ([]*types.ValueWithMetadata, error)

+ GetHistoricalDataAt func(dbName, key string, version *types.Version) (*types.ValueWithMetadata, error)

+ GetNextHistoricalData func(dbName, key string, version *types.Version) ([]*types.ValueWithMetadata, error)

+ GetPreviousHistoricalData func(dbName, key string, version *types.Version) ([]*types.ValueWithMetadata, error)

+ GetReaders func(dbName, key string) ([]string, error)

+ GetTxIDsSubmittedByUser func(userID string) ([]string, error)

+ GetWriters func(dbName, key string) ([]string, error)

+ type Query interface

+ ExecuteJSONQuery func(dbName, query string) ([]*types.KVWithMetadata, error)

+ GetDataByRange func(dbName, startKey, endKey string, limit uint64) (Iterator, error)

+ type QueryExecutor struct

+ func (q *QueryExecutor) ExecuteJSONQuery(dbName, query string) ([]*types.KVWithMetadata, error)

+ func (q *QueryExecutor) GetDataByRange(dbName, startKey, endKey string, limit uint64) (Iterator, error)

+ func (t QueryExecutor) CommittedTxEnvelope() (proto.Message, error)

+ type RangeQueryIterator struct

+ func (i *RangeQueryIterator) Next() (*types.KVWithMetadata, bool, error)

+ type RangeQueryResponse struct

+ KVs []*types.KVWithMetadata

+ NextStartKey string

+ PendingResults bool

+ type ResponseEnvelop interface

+ GetSignature func() []byte

+ type ResponseWithHeader interface

+ GetHeader func() *types.ResponseHeader

+ func ResponseSelector(envelop ResponseEnvelop) (ResponseWithHeader, error)

+ type RestClient interface

+ Query func(ctx context.Context, endpoint, httpMethod string, postData, signature []byte) (*http.Response, error)

+ Submit func(ctx context.Context, endpoint string, msg proto.Message, ...) (*http.Response, error)

+ func NewRestClient(userID string, httpClient HttpClient, signer Signer) RestClient

+ type ServerTimeout struct

+ TxID string

+ func (e *ServerTimeout) Error() string

+ type SignatureVerifier interface

+ Verify func(entityID string, payload, signature []byte) error

+ func NewVerifier(certs map[string]*x509.Certificate, logger *logger.SugarLogger) (SignatureVerifier, error)

+ type Signer interface

+ type TxContext interface

+ Abort func() error

+ Commit func(sync bool) (string, *types.TxReceiptResponseEnvelope, error)

+ CommittedTxEnvelope func() (proto.Message, error)

+ type TxContextOption func(svc *commonTxContext) error

+ func WithTxID(txID string) TxContextOption

+ type TxProof struct

+ IntermediateHashes [][]byte

+ func (p *TxProof) Verify(receipt *types.TxReceipt, tx proto.Message) (bool, error)

+ type UsersTxContext interface

+ GetUser func(userID string) (*types.User, error)

+ PutUser func(user *types.User, acl *types.AccessControl) error

+ RemoveUser func(userID string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL