network

type Command struct {
	ID          string          `json:"id"`
	Name        string          `json:"name"`
	Args        json.RawMessage `json:"args"`
	Timeout     time.Duration   `json:"timeout"`
	TargetGroup string          `json:"target_group"`
}

type CommandHandler func(ctx context.Context, runenv *runtime.RunEnv, initCtx *run.InitContext, args json.RawMessage) error

type Configurator func(nodes []RoleConfig) ([]RoleConfig, error)

type ConsensusNode struct {
	Name string

	CmtConfig *tmconfig.Config
	AppConfig *srvconfig.Config

	// AppOptions are the application options of the test node.
	AppOptions *testnode.KVAppOptions
	// AppCreator is used to create the application for the testnode.
	AppCreator srvtypes.AppCreator
	// SuppressLogs in testnode. This should be set to true when running
	// testground tests unless debugging.
	SuppressLogs bool
	// contains filtered or unexported fields
}

type Follower struct {
	*ConsensusNode
	// contains filtered or unexported fields
}

type GenesisWrapper struct {
	// Part is the index of the part of the genesis file. This is used to bypass
	// testground's 32Kb limit on messages.
	Part    int    `json:"part"`
	Genesis string `json:"genesis"`
}

type Leader struct {
	*ConsensusNode
	// contains filtered or unexported fields
}

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

type Params struct {
	ChainID           string
	Validators        int
	FullNodes         int
	HaltHeight        int
	Timeout           time.Duration
	Pex               bool
	Configurators     []Configurator
	GenesisModifiers  []genesis.Modifier
	PerPeerBandwidth  int
	BlobsPerSeq       int
	BlobSequences     int
	BlobSizes         int
	InboundPeerCount  int
	OutboundPeerCount int
	GovMaxSquareSize  int
	MaxBlockBytes     int
	TimeoutCommit     time.Duration
	TimeoutPropose    time.Duration
	Mempool           string
	BroadcastTxs      bool
	TracingParams
	Experiment string
}

type PeerPacket struct {
	PeerID          string          `json:"peer_id"`
	GroupID         string          `json:"group_id"`
	GlobalSequence  int64           `json:"global_sequence"`
	GenesisAccounts []string        `json:"genesis_accounts"`
	GenesisPubKeys  []string        `json:"pub_keys"`
	GenTx           json.RawMessage `json:"gen_tx"`
}

type Role interface {
	// Plan is the first function called in a test by each node. It is
	// responsible for creating the genesis block, configuring nodes, and
	// starting the network.
	Plan(ctx context.Context, runenv *runtime.RunEnv, initCtx *run.InitContext) error
	// Execute is the second function called in a test by each node. It is
	// responsible for running any experiments. This is phase where commands are
	// sent and received.
	Execute(ctx context.Context, runenv *runtime.RunEnv, initCtx *run.InitContext) error
	// Retro is the last function called in a test by each node. It is
	// responsible for collecting any data from the node and/or running any
	// retrospective tests or benchmarks.
	Retro(ctx context.Context, runenv *runtime.RunEnv, initCtx *run.InitContext) error
}

type RoleConfig struct {
	PeerID         string            `json:"peer_id"`
	GroupID        string            `json:"group_id"`
	GlobalSequence int64             `json:"global_sequence"`
	CmtConfig      *tmconfig.Config  `json:"cmt_config"`
	AppConfig      *srvconfig.Config `json:"app_config"`
}

type RunTxSimCommandArgs struct {
	// BlobSequences is the number of blob sequences to run
	BlobSequences int `json:"blob_sequences"`
	BlobSize      int `json:"blob_size"`
	BlobCount     int `json:"blob_count"`
}

type TracingParams struct {
	Nodes int
	URL   string
	Token string
}