workload

type BernoulliGenerator struct {
	Rnd         *rand.Rand
	Probability Probability
}

type BlockProfile struct {
	MaxSize       uint64        `mapstructure:"max-size" yaml:"max-size"`
	MinSize       uint64        `mapstructure:"min-size" yaml:"min-size"`
	PreferredRate time.Duration `mapstructure:"preferred-rate" yaml:"preferred-rate"`
}

type ByteArrayGenerator struct {
	Size   uint32
	Source io.Reader
}

type ConflictProfile struct {
	// Probability of invalid signatures [0,1] (default: 0)
	InvalidSignatures Probability `mapstructure:"invalid-signatures" yaml:"invalid-signatures"`
	// Dependencies list of dependencies
	Dependencies []DependencyDescription `mapstructure:"dependencies" yaml:"dependencies"`
}

type ConstGenerator[T any] struct {
	Const T
}

type ConsumeParameters struct {
	RequestedItems uint64
	MinItems       uint64
	SoftTimeout    time.Duration
}

type ConsumerRateController[T any] struct {
	// contains filtered or unexported fields
}

type DependencyDescription struct {
	// Probability of the dependency type [0,1] (default: 0)
	Probability Probability `mapstructure:"probability" yaml:"probability"`
	// Gap is the distance between the dependent TXs (default: 1)
	Gap *Distribution `mapstructure:"gap" yaml:"gap"`
	// Src dependency "read", "write", or "read-write"
	Src string `mapstructure:"src" yaml:"src"`
	// Dst dependency "read", "write", or "read-write"
	Dst string `mapstructure:"dst" yaml:"dst"`
}

type DiscreteGenerator[T any] struct {
	Rnd    *rand.Rand
	Values []DiscreteValue[T]
}

type DiscreteValue[T any] struct {
	Value       T           `mapstructure:"value"`
	Probability Probability `mapstructure:"probability"`
}

type Distribution struct {
	Const     float64                  `mapstructure:"const" yaml:"const,omitempty"`
	Uniform   *UniformDist             `mapstructure:"uniform" yaml:"uniform,omitempty"`
	Normal    *NormalDist              `mapstructure:"normal" yaml:"normal,omitempty"`
	Bernoulli Probability              `mapstructure:"bernoulli" yaml:"bernoulli,omitempty"`
	Discrete  []DiscreteValue[float64] `mapstructure:"discrete" yaml:"discrete,omitempty"`
}

type FloatToBooleanGenerator struct {
	FloatGen Generator[float64]
}

type FloatToIntGenerator struct {
	FloatGen Generator[float64]
}

type FloatToPositiveIntGenerator struct {
	FloatGen Generator[float64]
}

type Generator[T any] interface {
	Next() T
}

type IndependentTxGenerator struct {
	TxBuilder                *TxBuilder
	ReadOnlyKeyGenerator     *MultiGenerator[Key]
	ReadWriteKeyGenerator    *MultiGenerator[Key]
	BlindWriteKeyGenerator   *MultiGenerator[Key]
	ReadWriteValueGenerator  *ByteArrayGenerator
	BlindWriteValueGenerator *ByteArrayGenerator
	Modifiers                []Modifier
}

type Key = []byte

type KeyPath struct {
	SigningKey      string `mapstructure:"signing-key" yaml:"signing-key"`
	VerificationKey string `mapstructure:"verification-key" yaml:"verification-key"`
	SignCertificate string `mapstructure:"sign-certificate" yaml:"sign-certificate"`
}

type KeyProfile struct {
	// Size is the size of the key to generate.
	Size uint32 `mapstructure:"size" yaml:"size"`
}

type Modifier interface {
	Modify(*applicationpb.Tx)
}

type MultiGenerator[T any] struct {
	Count Generator[int]
	Gen   Generator[T]
}

type NormalDist struct {
	Mean float64 `mapstructure:"mean" yaml:"mean,omitempty"`
	Std  float64 `mapstructure:"std" yaml:"std,omitempty"`
}

type NormalGenerator struct {
	Rnd       *rand.Rand
	Mean, Std float64
}

type Policy struct {
	Scheme  signature.Scheme `mapstructure:"scheme" yaml:"scheme"`
	Seed    int64            `mapstructure:"seed" yaml:"seed"`
	KeyPath *KeyPath         `mapstructure:"key-path" yaml:"key-path"`
}

type PolicyProfile struct {
	// NamespacePolicies specifies the namespace policies.
	NamespacePolicies map[string]*Policy `mapstructure:"namespace-policies" yaml:"namespace-policies"`

	// OrdererEndpoints may specify the endpoints to add to the config block.
	// If this field is empty, no endpoints will be configured.
	// If ConfigBlockPath is specified, this value is ignored.
	OrdererEndpoints []*commontypes.OrdererEndpoint `mapstructure:"orderer-endpoints" yaml:"orderer-endpoints"`

	// ArtifactsPath may specify the path to the artifacts generated by CreateOrExtendConfigBlockWithCrypto().
	// If this field is empty, the artifacts will be generated into a temporary folder.
	// If this path does not exist, or it is empty, the artifacts will be generated into it.
	// The config block will be fetched from ArtifactsPath.
	ArtifactsPath string `mapstructure:"artifacts-path" yaml:"artifacts-path"`

	// ChannelID and Identity are used to create the TX envelop.
	ChannelID string                      `mapstructure:"channel-id"`
	Identity  *ordererconn.IdentityConfig `mapstructure:"identity"`

	// PeerOrganizationCount may specify the number of peer organizations to generate if the ArtifactsPath
	// is not provided.
	PeerOrganizationCount uint32 `mapstructure:"peer-organization-count"`
}

type Probability = float64

type Profile struct {
	Block       BlockProfile       `mapstructure:"block" yaml:"block"`
	Key         KeyProfile         `mapstructure:"key" yaml:"key"`
	Transaction TransactionProfile `mapstructure:"transaction" yaml:"transaction"`
	Query       QueryProfile       `mapstructure:"query" yaml:"query"`
	Policy      PolicyProfile      `mapstructure:"policy" yaml:"policy"`
	Conflicts   ConflictProfile    `mapstructure:"conflicts" yaml:"conflicts"`

	// The seed to generate the seeds for each worker
	Seed int64 `mapstructure:"seed" yaml:"seed"`

	// Workers is the number of independent producers.
	// Each worker uses a unique seed that is generated from the main seed.
	// To ensure responsibility of items between runs (e.g., for query)
	// the number of workers must be preserved.
	Workers uint32 `mapstructure:"workers" yaml:"workers"`
}

type QueryGenerator struct {
	ValidKeyGenerator   *ByteArrayGenerator
	InvalidKeyGenerator *ByteArrayGenerator
	Size                Generator[int]
	InvalidPortion      Generator[float64]
	ShuffleRnd          *rand.Rand
	Shuffle             bool
}

type QueryProfile struct {
	// The number of keys to query.
	QuerySize *Distribution `mapstructure:"query-size" yaml:"query-size"`
	// The minimal portion of invalid keys (1 => all keys are invalid).
	// This is a lower bound since some valid keys might have failed to commit due to conflicts.
	MinInvalidKeysPortion *Distribution `mapstructure:"min-invalid-keys-portion" yaml:"min-invalid-keys-portion"`
	// If Shuffle=false, the valid keys will be placed first.
	// Otherwise, they will be shuffled.
	Shuffle bool `mapstructure:"shuffle" yaml:"shuffle"`
}

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

type StreamOptions struct {
	// GenBatch impacts the rate by batching generated items before inserting then the channel.
	// This helps overcome the inherit rate limitation of Go channels.
	GenBatch uint32 `mapstructure:"gen-batch" yaml:"gen-batch"`
	// BuffersSize impact the rate by masking fluctuation in performance.
	BuffersSize int `mapstructure:"buffers-size" yaml:"buffers-size"`
	// RateLimit directly impacts the rate by limiting it.
	// TXs are released at RateLimit (default: unlimited).
	RateLimit uint64 `mapstructure:"rate-limit" yaml:"rate-limit"`
}

type StreamWithSetup struct {
	WorkloadSetupTXs channel.Reader[*servicepb.LoadGenTx]
	TxStream         *TxStream
}

type TransactionProfile struct {
	// The sizes of the values to generate (size=0 => value=nil)
	ReadWriteValueSize  uint32 `mapstructure:"read-write-value-size" yaml:"read-write-value-size"`
	BlindWriteValueSize uint32 `mapstructure:"blind-write-value-size" yaml:"blind-write-value-size"`
	// The number of keys to generate (read ver=nil)
	ReadOnlyCount *Distribution `mapstructure:"read-only-count" yaml:"read-only-count"`
	// The number of keys to generate (read ver=nil/write)
	ReadWriteCount *Distribution `mapstructure:"read-write-count" yaml:"read-write-count"`
	// The number of keys to generate (write)
	BlindWriteCount *Distribution `mapstructure:"write-count" yaml:"write-count"`
}

type TxBuilder struct {
	ChannelID   string
	EnvSigner   identity.Signer
	TxEndorser  *TxEndorser
	EnvCreator  []byte
	NonceSource io.Reader
}

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

type TxGeneratorWithSetup struct {
	WorkloadSetupTXs channel.Reader[*servicepb.LoadGenTx]
	TxGen            *ConsumerRateController[*servicepb.LoadGenTx]
}

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

type UniformDist struct {
	Min float64 `mapstructure:"min" yaml:"min,omitempty"`
	Max float64 `mapstructure:"max" yaml:"max,omitempty"`
}

type UniformGenerator struct {
	Rnd      *rand.Rand
	Min, Max float64
}