subscribe

var Module = &cobrather.Module{
	Use:   "subscribe",
	Short: "subscribe grpc echo server",
	Flags: []cobrather.Flag{
		flagURL,
		flagMessage,
		flagDuration,
		flagConcurrent,
	},
	RunE: func(ctx context.Context, cmd *cobra.Command, args []string) (err error) {
		logger.DefaultThrottler.SetContext(ctx)
		duration, err := time.ParseDuration(flagDuration.String())
		if err != nil {
			return
		}
		url := flagURL.String()
		message := flagMessage.String()
		concurrent := flagConcurrent.Int64()
		eg, ctx := errgroup.WithContext(ctx)
		for i := int64(0); i < concurrent; i++ {
			eg.Go(func() error {
				changeSubscriberCount(1)
				defer changeSubscriberCount(-1)
				return client.Subscribe(ctx, url, message, duration)
			})
		}
		return eg.Wait()
	},
}