runner

type CmdParameters ¶

type CmdParameters struct {
	Name     string
	Bin      string
	Arg      string
	Template string
}

CmdParameters holds the parameters for a command.

type CommitterRuntime ¶

type CommitterRuntime struct {
	SystemConfig config.SystemConfig

	MockOrderer  *ProcessWithConfig
	Sidecar      *ProcessWithConfig
	Coordinator  *ProcessWithConfig
	QueryService *ProcessWithConfig
	Verifier     []*ProcessWithConfig
	VcService    []*ProcessWithConfig

	CoordinatorClient  protocoordinatorservice.CoordinatorClient
	QueryServiceClient protoqueryservice.QueryServiceClient

	CommittedBlock chan *common.Block

	LastReceivedBlockNumber uint64
	// contains filtered or unexported fields
}

CommitterRuntime represents a test system of Coordinator, SigVerifier, VCService and Query processes.

func NewRuntime(t *testing.T, conf *Config) *CommitterRuntime

func (c *CommitterRuntime) AddSignatures(t *testing.T, tx *protoblocktx.Tx)

func (c *CommitterRuntime) CountAlternateStatus(t *testing.T, status protoblocktx.Status) int

func (c *CommitterRuntime) CountStatus(t *testing.T, status protoblocktx.Status) int

func (c *CommitterRuntime) CreateCryptoForNs(t *testing.T, nsID string, schema signature.Scheme) *Crypto

func (c *CommitterRuntime) CreateMetaTX(t *testing.T, namespaces ...string) *protoblocktx.Tx

func (c *CommitterRuntime) CreateNamespacesAndCommit(t *testing.T, namespaces ...string)

func (c *CommitterRuntime) GerOrCreateCryptoForNs(t *testing.T, nsID string, schema signature.Scheme) *Crypto

func (c *CommitterRuntime) GetAllCrypto() []*Crypto

func (c *CommitterRuntime) GetCryptoForNs(t *testing.T, nsID string) *Crypto

func (c *CommitterRuntime) SendTransactionsToOrderer(t *testing.T, txs []*protoblocktx.Tx)

func (c *CommitterRuntime) Start(t *testing.T, serviceFlags int)

func (c *CommitterRuntime) UpdateCryptoForNs(t *testing.T, nsID string, schema signature.Scheme) *Crypto

func (c *CommitterRuntime) ValidateExpectedResultsInCommittedBlock(t *testing.T, expected *ExpectedStatusInBlock)

type Config ¶

type Config struct {
	NumVerifiers      int
	NumVCService      int
	BlockSize         uint64
	BlockTimeout      time.Duration
	LoadgenBlockLimit uint64

	// DBCluster configures the cluster to operate in DB cluster mode.
	DBCluster *dbtest.Connection
}

Config represents the runtime configuration.

type Crypto ¶

type Crypto struct {
	Namespace  string
	Profile    *workload.Policy
	HashSigner *workload.HashSignerVerifier
	NsSigner   *sigtest.NsSigner
	PubKey     []byte
	PubKeyPath string
}

Crypto holds crypto material for a namespace.

type DBClusterController ¶

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

DBClusterController is a class that facilitates the manipulation of a DB cluster, with its nodes running in Docker containers.

func (cc *DBClusterController) GetClusterSize() int

func (cc *DBClusterController) GetNodesContainerID(t *testing.T) []string

func (cc *DBClusterController) StopAndRemoveNodeWithRole(t *testing.T, role string)

type ExpectedStatusInBlock ¶

type ExpectedStatusInBlock struct {
	TxIDs    []string
	Statuses []protoblocktx.Status
}

ExpectedStatusInBlock holds pairs of expected txID and the corresponding status in a block. The order of statuses is expected to be the same as in the committed block.

type PostgresClusterController ¶

type PostgresClusterController struct {
	DBClusterController
}

PostgresClusterController is a struct that facilitates the manipulation of postgres cluster, with its nodes running in Docker containers. We create a cluster of size 2; one primary and one secondary.

func StartPostgresCluster(ctx context.Context, t *testing.T) (*PostgresClusterController, *dbtest.Connection)

func (cc *PostgresClusterController) PromoteFollowerNode(t *testing.T)

type ProcessWithConfig ¶

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

ProcessWithConfig holds the ifrit process and the corresponding configuration.

func (p *ProcessWithConfig) Restart(t *testing.T)

func (p *ProcessWithConfig) Stop(t *testing.T)

type YugaClusterController ¶

type YugaClusterController struct {
	DBClusterController
}

YugaClusterController is a struct that facilitates the manipulation of a DB cluster, with its nodes running in Docker containers.

To create the cluster, we are using Yugabyte's preconfigured tool, which is set up as follows: 1. If the cluster size is greater than or equal to 3, the replication factor (RF) is set to 3; otherwise, RF is set to 1. 2. The cluster supports a maximum of 3 master nodes. Therefore, a cluster with more than 3 master nodes cannot be created. Any additional node will act as a tserver node.

In addition, RF=3 supports the failure of one master node, while RF=1 does not provide resilience to node failures. There are some bugs in YugaDB that prevent the cluster behavior from functioning as expected: 1. After a master-node is deleted, a new master-node cannot be added to the cluster as a replacement. 2. If the leader node is failing, the whole db connectivity will stop functioning.

func StartYugaCluster(ctx context.Context, t *testing.T, clusterSize uint) (
	*YugaClusterController, *dbtest.Connection,
)

func (cc *YugaClusterController) AddNode(ctx context.Context, t *testing.T) *dbtest.DatabaseContainer