add client-provided-name

Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>

Author: Gsantomaggio

perfTest/cmd/commands.go

@@ -47,6 +47,7 @@ var (
 	runDuration         int
 	initialCredits      int
 	isBatchSend         bool
+	clientProvidedName  string
 )
 
 func init() {
@@ -78,6 +79,7 @@ func setupCli(baseCmd *cobra.Command) {
 	baseCmd.PersistentFlags().StringVarP(&consumerOffset, "consumer-offset", "", "first", "Staring consuming, ex: first,last,next or random")
 	baseCmd.PersistentFlags().IntVarP(&initialCredits, "initial-credits", "", 10, "Consumer initial credits")
 	baseCmd.PersistentFlags().BoolVarP(&isBatchSend, "batch-send", "", false, "Enable batch send")
+	baseCmd.PersistentFlags().StringVarP(&clientProvidedName, "client-provided-name", "", "", "Client provided name")
 	baseCmd.AddCommand(versionCmd)
 	baseCmd.AddCommand(newSilent())
 }

perfTest/cmd/silent.go

@@ -271,12 +271,11 @@ func startPublisher(streamName string) error {
 		if compression == "zstd" {
 			cp = stream.Compression{}.Zstd()
 		}
-
 		producerOptions.SetSubEntrySize(subEntrySize).SetCompression(cp)
-
 		logInfo("Enable SubEntrySize: %d, compression: %s", subEntrySize, cp)
 	}
 
+	producerOptions.SetClientProvidedName(clientProvidedName)
 	rPublisher, err := ha.NewReliableProducer(simulEnvironment,
 		streamName,
 		producerOptions,
@@ -420,6 +419,7 @@ func startConsumer(consumerName string, streamName string) error {
 		handleMessages,
 		stream.NewConsumerOptions().
 			SetConsumerName(consumerName).
+			SetClientProvidedName(clientProvidedName).
 			SetOffset(offsetSpec).
 			SetCRCCheck(crcCheck).
 			SetInitialCredits(int16(initialCredits)))