workload

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 ConsumeParameters struct {
	RequestedItems uint64
	MinItems       uint64
	SoftTimeout    time.Duration
}

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

type IndependentTxGenerator struct {
	TransactionProfile

	TxBuilder *TxBuilder
	// contains filtered or unexported fields
}

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 KeyStats struct {
	KeyFrontier         uint64 // keys introduced so far, including ones read or written but never committed
	ReferencedReadKeys  uint64 // read-only slots that reused an existing key
	ReferencedWriteKeys uint64 // write slots that reused an existing key
}

type Policy struct {
	Scheme        signature.Scheme              `mapstructure:"scheme" yaml:"scheme"`
	Seed          int64                         `mapstructure:"seed" yaml:"seed"`
	KeyPath       *KeyPath                      `mapstructure:"key-path" yaml:"key-path"`
	MSPIdentities []*ordererdial.IdentityConfig `mapstructure:"msp-identities" yaml:"msp-identities"`
}

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  *ordererdial.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"`
	Transaction TransactionProfile `mapstructure:"transaction" yaml:"transaction"`
	Policy      PolicyProfile      `mapstructure:"policy" yaml:"policy"`

	// Seed is the single PRF root for the whole workload. Every generated item (keys, values, nonce,
	// metadata, and the new-vs-existing layout) is a pure function of this seed and the item's global
	// transaction index, so the same Seed reproduces the same items.
	Seed int64 `mapstructure:"seed" yaml:"seed"`

	// Workers is the number of parallel producers. They share one global transaction-index counter and
	// the same Seed, so the multiset of generated transactions is independent of the worker count —
	// workers are pure parallelism. The count therefore does not need to be preserved between runs to
	// reproduce items.
	Workers uint32 `mapstructure:"workers" yaml:"workers"`
}

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 byte sizes of the generated key/values/metadata (size=0 => nil), ordered key, value, metadata.
	KeySize             uint32 `mapstructure:"key-size" yaml:"key-size"`
	ReadWriteValueSize  uint32 `mapstructure:"read-write-value-size" yaml:"read-write-value-size"`
	BlindWriteValueSize uint32 `mapstructure:"blind-write-value-size" yaml:"blind-write-value-size"`
	MetadataSize        uint32 `mapstructure:"metadata-size" yaml:"metadata-size"`

	// The number of keys to generate (read ver=nil)
	ReadOnlyCount uint32 `mapstructure:"read-only-count" yaml:"read-only-count"`
	// The number of keys to generate (read ver=nil/write)
	ReadWriteCount uint32 `mapstructure:"read-write-count" yaml:"read-write-count"`
	// The number of keys to generate (write)
	BlindWriteCount uint32 `mapstructure:"write-count" yaml:"write-count"`

	// KeyBackrefRate is the average number of BACKWARD REFERENCES (reused keys) per transaction: slots that
	// reference a key created by an earlier transaction instead of creating a fresh one, so keys are reused
	// and the coordinator sees commit-time contention. The remaining slots create fresh keys, so the
	// average number of NEW keys per transaction is the total slot count minus this rate.
	// 0 (default) means no references — every slot gets a fresh unique key, the historical contention-free
	// workload. Below 1 it acts as a probability: the fraction of transactions that get a single reference
	// (e.g. 0.3 ≈ 30% of transactions reference one existing key). 1 or more is roughly a fixed count of
	// references per transaction, and a fractional part adds that sub-1 probability on top (e.g. 2.5 ≈ two
	// or three references). It must not exceed the total slot count (read-only + read-write + write); at the
	// maximum every slot is a reference (a fully static working set, no new keys). References fill slots
	// after the fresh keys, in layout order: read-write, then blind-write, then read-only.
	KeyBackrefRate float64 `mapstructure:"key-backref-rate" yaml:"key-backref-rate" validate:"gte=0"`
	// TxReferenceGap and KeyLookbackWindow shape where backward references point; both are optional, both
	// default to 0, and both are irrelevant when key-backref-rate is 0. A reference is drawn from the
	// KeyLookbackWindow newest keys that existed TxReferenceGap transactions ago.
	//
	// TxReferenceGap is how far back, in transactions, references reach. 0 (default) draws the newest keys,
	// which may still be in flight — so conflicting transactions can land in the same block (a live
	// dependency); larger values draw older, already-committed keys.
	TxReferenceGap uint64 `mapstructure:"tx-reference-gap" yaml:"tx-reference-gap"`
	// KeyLookbackWindow is how many of the newest keys a reference is drawn from. 0 (default) means no
	// window: references step straight back from the gap position (the newest key, then the one before it,
	// and so on) — a fixed, most-contended pattern. A positive value spreads references across that many
	// keys (larger = less contention); it has no minimum, and when a transaction needs more distinct
	// references than the window holds, the surplus simply steps back beyond the window.
	KeyLookbackWindow uint64 `mapstructure:"key-lookback-window" yaml:"key-lookback-window"`

	// InvalidSignatures is the probability [0,1] that a transaction is stamped with a bad signature
	// (default: 0). The decision is derived deterministically from the transaction index.
	InvalidSignatures Probability `mapstructure:"invalid-signatures" yaml:"invalid-signatures" validate:"gte=0,lte=1"`
}

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

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

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
}