setup

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 15, 2023

Changes in this version

+ func UpdateUser(t *testing.T, s *Server, operatingUserId string, userRead *types.UserRead, ...) error

v0.2.7

Dec 12, 2022

Changes in this version

type Config

+ DisableStateMPTrie bool

v0.2.6

Sep 1, 2022

Changes in this version

type Server

+ func (s *Server) UserWriteDataTx(t *testing.T, db, key string, value []byte, user string) (string, *types.TxReceipt, *types.DataTxEnvelope, error)

v0.2.5

Jul 26, 2022

Changes in this version

type Config

+ BlockCreationOverride *config.BlockCreationConf

+ ClusterTLSEnabled bool

+ DisableProvenanceServers []int

+ ServersQueryLimit uint64

type Server

+ func (s *Server) CreateNewCryptoMaterials(rootCAPemCert, caPrivKey []byte) (string, string, string, error)

+ func (s *Server) DeleteDataTx(t *testing.T, db, key string) (string, *types.TxReceipt, *types.DataTxEnvelope, error)

+ func (s *Server) GetDataProof(t *testing.T, db, key, userID string, blockNumber uint64, isDeleted bool) (*types.GetDataProofResponseEnvelope, error)

+ func (s *Server) QueryDataRange(t *testing.T, userID, dbName, startKey, endKey string, limit uint64) (*types.GetDataRangeResponseEnvelope, error)

+ func (s *Server) QueryTxReceipt(t *testing.T, txID, user string) (*types.TxReceiptResponseEnvelope, error)

+ func (s *Server) SubmitTransactionAsync(t *testing.T, urlPath string, tx interface{}) error

+ func (s *Server) WriteDataTxAsync(t *testing.T, db, key string, value []byte) (string, *types.DataTxEnvelope, error)

v0.2.4

Jul 3, 2022

Changes in this version

+ func CreateDatabases(t *testing.T, s *Server, dbNames []string, dbsIndex map[string]*types.DBIndex)

+ func CreateUsers(t *testing.T, s *Server, users []*types.UserWrite)

type Cluster

+ func (c *Cluster) AddNewServerToCluster(server *Server)

+ func (c *Cluster) CreateAdditionalUserCryptoMaterials(user string, certRootCA []byte, caPrivKey []byte) error

+ func (c *Cluster) GetKeyAndCA() ([]byte, []byte)

+ func (c *Cluster) GetUser(user string) ([]byte, []byte, error)

+ func (c *Cluster) UpdateServersAdmin(newAdmin string, newAdminKeyPath string, newAdminCertPath string) error

type Server

+ func (s *Server) AdminCertPath() string

+ func (s *Server) AdminKeyPath() string

+ func (s *Server) BootstrapFilePath() string

+ func (s *Server) ConfigFilePath() string

+ func (s *Server) CreateConfigFile() error

+ func (s *Server) CreateCryptoMaterials(rootCAPemCert, caPrivKey []byte) error

+ func (s *Server) ExecuteJSONQuery(t *testing.T, userID, dbName, query string) (*types.DataQueryResponseEnvelope, error)

+ func (s *Server) GetAllValues(t *testing.T, db, key, userID string) (*types.GetHistoricalDataResponseEnvelope, error)

+ func (s *Server) GetDeletedValues(t *testing.T, db, key, userID string) (*types.GetHistoricalDataResponseEnvelope, error)

+ func (s *Server) GetMostRecentValueAtOrBelow(t *testing.T, db, key, userID string, ver *types.Version) (*types.GetHistoricalDataResponseEnvelope, error)

+ func (s *Server) GetNextValues(t *testing.T, db, key, userID string, ver *types.Version) (*types.GetHistoricalDataResponseEnvelope, error)

+ func (s *Server) GetPreviousValues(t *testing.T, db, key, userID string, ver *types.Version) (*types.GetHistoricalDataResponseEnvelope, error)

+ func (s *Server) GetReaders(t *testing.T, dbName, key, userID string) (*types.GetDataReadersResponseEnvelope, error)

+ func (s *Server) GetTxIDsSubmittedBy(t *testing.T, userID string) (*types.GetTxIDsSubmittedByResponseEnvelope, error)

+ func (s *Server) GetTxProof(t *testing.T, userID string, blockNumber, txIndex uint64) (*types.GetTxProofResponseEnvelope, error)

+ func (s *Server) GetValueAt(t *testing.T, db, key, userID string, ver *types.Version) (*types.GetHistoricalDataResponseEnvelope, error)

+ func (s *Server) GetValuesDeletedByUser(t *testing.T, userID string) (*types.GetDataProvenanceResponseEnvelope, error)

+ func (s *Server) GetValuesReadByUser(t *testing.T, userID string) (*types.GetDataProvenanceResponseEnvelope, error)

+ func (s *Server) GetValuesWrittenByUser(t *testing.T, userID string) (*types.GetDataProvenanceResponseEnvelope, error)

+ func (s *Server) GetWriters(t *testing.T, dbName, key, userID string) (*types.GetDataWritersResponseEnvelope, error)

+ func (s *Server) QueryAugmentedBlockHeader(t *testing.T, number uint64, user string) (*types.GetAugmentedBlockHeaderResponseEnvelope, error)

+ func (s *Server) QueryBlockHeader(t *testing.T, number uint64, forceParam bool, user string) (*types.GetBlockResponseEnvelope, error)

+ func (s *Server) QueryConfigBlockStatus(t *testing.T) (*types.GetConfigBlockResponseEnvelope, error)

+ func (s *Server) QueryLastBlockStatus(t *testing.T) (*types.GetBlockResponseEnvelope, error)

+ func (s *Server) QueryLedgerPath(t *testing.T, startNum, endNum uint64, user string) (*types.GetLedgerPathResponseEnvelope, error)

+ func (s *Server) SetAdmin(newAdminID string, newAdminCertPath string, newAdminKeyPath string, ...)

+ func (s *Server) SetAdminSigner(newAdminSigner crypto.Signer)

v0.2.3

Mar 30, 2022

Changes in this version

type Cluster

+ func (c *Cluster) CreateUserCerts(user string, keyPair tls.Certificate) error

+ func (c *Cluster) GetLogger() *logger.SugarLogger

+ func (c *Cluster) GetSigner(userID string) (crypto.Signer, error)

+ func (c *Cluster) GetUserCertDir() string

+ func (c *Cluster) GetUserCertKeyPath(userID string) (string, string)

+ func (c *Cluster) GetX509KeyPair() (tls.Certificate, error)

type Server

+ func (s *Server) ConfigDir() string

+ func (s *Server) CreateUsers(t *testing.T, users []*types.UserWrite) (*types.TxReceipt, error)

+ func (s *Server) GetDBIndex(t *testing.T, dbName string, userID string) (*types.GetDBIndexResponseEnvelope, error)

+ func (s *Server) GetDBStatus(t *testing.T, dbName string) (*types.GetDBStatusResponseEnvelope, error)

+ func (s *Server) QueryUser(t *testing.T, userID string) (*types.GetUserResponseEnvelope, error)

+ func (s *Server) SetConfigTx(t *testing.T, newConfig *types.ClusterConfig, version *types.Version, ...) (string, *types.TxReceipt, error)

+ func (s *Server) Signer(userID string) (crypto.Signer, error)

+ func (s *Server) SubmitTransaction(t *testing.T, urlPath string, tx interface{}) (*types.TxReceipt, error)

v0.2.2

Mar 1, 2022

Changes in this version

type Cluster

+ func (c *Cluster) AgreedHeight(t *testing.T, expectedBlockHeight uint64, activeServers ...int) bool

+ func (c *Cluster) AgreedLeader(t *testing.T, activeServers ...int) int

+ func (c *Cluster) GetServerByID(serverID string) (*Server, int)

type Server

+ func (s *Server) ID() string

+ func (s *Server) QueryBlockStatus(t *testing.T) (*types.GetBlockResponseEnvelope, error)

+ func (s *Server) QueryClusterStatus(t *testing.T) (*types.GetClusterStatusResponseEnvelope, error)

v0.2.1

Jan 13, 2022

Changes in this version

+ func WriteConfigAsYaml(configObject interface{}, configYamlFile string) error

+ func WriteLocalConfig(localConfig *config.LocalConfiguration, localConfigYamlFile string) error

+ func WriteSharedConfig(sharedConfig *config.SharedConfiguration, sharedConfigYamlFile string) error

+ type Cluster struct

+ Servers []*Server

+ Users []string

+ func NewCluster(conf *Config) (*Cluster, error)

+ func (c *Cluster) Restart() error

+ func (c *Cluster) RestartServer(s *Server) error

+ func (c *Cluster) Shutdown() error

+ func (c *Cluster) ShutdownAndCleanup() error

+ func (c *Cluster) ShutdownServer(s *Server) error

+ func (c *Cluster) Start() error

+ func (c *Cluster) StartServer(s *Server) error

+ type Config struct

+ BDBBinaryPath string

+ BaseNodePort uint32

+ BasePeerPort uint32

+ CheckRedirectFunc func(req *http.Request, via []*http.Request) error

+ CmdTimeout time.Duration

+ NumberOfServers int

+ TestDirAbsolutePath string

+ type Server struct

+ func NewServer(id uint64, clusterBaseDir string, baseNodePort, basePeerPort uint32, ...) (*Server, error)

+ func (s *Server) AdminID() string

+ func (s *Server) AdminSigner() crypto.Signer

+ func (s *Server) NewRESTClient(checkRedirect func(req *http.Request, via []*http.Request) error) (*mock.Client, error)

+ func (s *Server) QueryConfig(t *testing.T) (*types.GetConfigResponseEnvelope, error)

+ func (s *Server) QueryData(t *testing.T, db, key string) (*types.GetDataResponseEnvelope, error)

+ func (s *Server) URL() string

+ func (s *Server) WriteDataTx(t *testing.T, db, key string, value []byte) (string, *types.TxReceipt, error)

v0.2.0-fix-docker

Nov 22, 2021

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