chore: update pt-testnet-load check (#455)

* chore: update pt-testnet-load check

* chore: update pt-testnet-load check

* fix: increase timeout for pt-testnet-load

* chore(load): increase load duration to month and add postage label

Author: gacevicljubisa

config/public-testnet.yaml

@@ -131,21 +131,21 @@ checks:
   pt-testnet-load:
     options:
       content-size: 50000000
-      postage-amount: 1000000000 # 1024/15*60*60*24*7
+      postage-amount: 6120360000 # (28335/12)*60*60*24*30
       postage-depth: 24
-      duration: 12h
+      postage-label: test-label
+      duration: 720h
       uploader-count: 2
       downloader-count: 0
-      max-use-batch: 1h
-      max-committed-depth: 3
+      max-committed-depth: 2
       committed-depth-check-wait: 5m
       upload-groups:
         - bee-1
         - bee-2
       download-groups:
         - bee-3
         - bee-4
-    timeout: 12h
+    timeout: 721h
     type: load
   pt-feed:
     options:

pkg/check/smoke/load.go

@@ -54,7 +54,6 @@ func (c *LoadCheck) Run(ctx context.Context, cluster orchestration.Cluster, opts
 
 	c.logger.Infof("random seed: %v", o.RndSeed)
 	c.logger.Infof("content size: %v", o.ContentSize)
-	c.logger.Infof("max batch lifespan: %v", o.MaxUseBatch)
 	c.logger.Infof("max committed depth: %v", o.MaxCommittedDepth)
 	c.logger.Infof("committed depth check wait time: %v", o.CommittedDepthCheckWait)
 
@@ -124,7 +123,7 @@ func (c *LoadCheck) Run(ctx context.Context, cluster orchestration.Cluster, opts
 					var duration time.Duration
 					c.logger.Infof("uploading to: %s", txName)
 
-					batchID, err := clients[txName].GetOrCreateMutableBatch(ctx, o.PostageAmount, o.PostageDepth, "load-test")
+					batchID, err := clients[txName].GetOrCreateMutableBatch(ctx, o.PostageAmount, o.PostageDepth, o.PostageLabel)
 					if err != nil {
 						c.logger.Errorf("create new batch: %v", err)
 						return

pkg/check/smoke/smoke.go

@@ -22,6 +22,7 @@ type Options struct {
 	RndSeed         int64
 	PostageAmount   int64
 	PostageDepth    uint64
+	PostageLabel    string
 	TxOnErrWait     time.Duration
 	RxOnErrWait     time.Duration
 	NodesSyncWait   time.Duration
@@ -33,7 +34,6 @@ type Options struct {
 	UploadGroups            []string
 	DownloaderCount         int
 	DownloadGroups          []string
-	MaxUseBatch             time.Duration
 	MaxCommittedDepth       uint8
 	CommittedDepthCheckWait time.Duration
 	IterationWait           time.Duration
@@ -46,13 +46,13 @@ func NewDefaultOptions() Options {
 		RndSeed:                 time.Now().UnixNano(),
 		PostageAmount:           50_000_000,
 		PostageDepth:            24,
+		PostageLabel:            "test-label",
 		TxOnErrWait:             10 * time.Second,
 		RxOnErrWait:             10 * time.Second,
 		NodesSyncWait:           time.Minute,
 		Duration:                12 * time.Hour,
 		UploadTimeout:           60 * time.Minute,
 		DownloadTimeout:         60 * time.Minute,
-		MaxUseBatch:             12 * time.Hour,
 		MaxCommittedDepth:       2,
 		CommittedDepthCheckWait: 5 * time.Minute,
 		IterationWait:           5 * time.Minute,
@@ -160,7 +160,7 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, opts int
 
 			c.metrics.BatchCreateAttempts.Inc()
 
-			batchID, err = clients[txName].GetOrCreateMutableBatch(txCtx, o.PostageAmount, o.PostageDepth, "smoke-test")
+			batchID, err = clients[txName].GetOrCreateMutableBatch(txCtx, o.PostageAmount, o.PostageDepth, o.PostageLabel)
 			if err != nil {
 				c.logger.Errorf("create new batch: %v", err)
 				c.metrics.BatchCreateErrors.Inc()

pkg/config/check.go

@@ -411,6 +411,7 @@ var Checks = map[string]CheckType{
 				RndSeed                 *int64         `yaml:"rnd-seed"`
 				PostageAmount           *int64         `yaml:"postage-amount"`
 				PostageDepth            *uint64        `yaml:"postage-depth"`
+				PostageLabel            *string        `yaml:"postage-label"`
 				GasPrice                *string        `yaml:"gas-price"`
 				TxOnErrWait             *time.Duration `yaml:"tx-on-err-wait"`
 				RxOnErrWait             *time.Duration `yaml:"rx-on-err-wait"`
@@ -420,7 +421,6 @@ var Checks = map[string]CheckType{
 				UploadGroups            *[]string      `yaml:"upload-groups"`
 				DownloaderCount         *int           `yaml:"downloader-count"`
 				DownloadGroups          *[]string      `yaml:"download-groups"`
-				MaxUseBatch             *time.Duration `yaml:"max-use-batch"`
 				MaxCommittedDepth       *uint8         `yaml:"max-committed-depth"`
 				CommittedDepthCheckWait *time.Duration `yaml:"committed-depth-check-wait"`
 			})