func run()

in get-started-with-redis/main.go [26:94]
51 lines of code
15 McCabe index (conditional complexity)

func run() error {
	// Create a new client from a connection string and a database number (0-15)
	client := newClient(dbconn, 0)

	if len(os.Args) < 2 {
		usage()
		return nil
	}

	switch os.Args[1] {
	case "ping":
		// Ping the redis server and fetch some database information.
		fmt.Printf("\nPing: Test the connection\n")
		ping(client)

	case "getset":
		// Get and set a string value.
		fmt.Printf("\nGet/Set: Update the quest to title case\n")
		err := getAndSet(client)
		if err != nil {
			return fmt.Errorf("getAndSet failed: %w", err)
		}

	case "expire":
		// Set an expiring key and wait for it to expire
		fmt.Printf("\nExpire: Add a player temporarily\n")
		err := expiringKeys(client)
		if err != nil {
			return fmt.Errorf("expiringKeys failed: %w", err)
		}

	case "pipeline":
		// Run a batch of commands.
		fmt.Printf("\nPipeline: Update score and challenges_completed for team Snarkdumbthimble\n")
		err := pipeline(client)
		if err != nil {
			return fmt.Errorf("pipeline failed: %w", err)
		}

	case "transaction":
		// Run several commands that must all succeed.
		// If any of them fails, the transaction will be canceled.
		fmt.Printf("\nTransaction: Rearrange the teams\n")
		err := transaction(client)
		if err != nil {
			return fmt.Errorf("transaction failed: %w", err)
		}

	case "pubsub":
		// Send messages to a publish/receive channel.
		// Listen to the channel and receive the messages.
		fmt.Printf("\nPub/Sub: Publish challenges to subscribed teams\n")
		err := pubsub(client)
		if err != nil {
			return fmt.Errorf("pubsub stopped: %w", err)
		}

	case "reset":
		// Reset the database
		fmt.Printf("\nReset the database\n")
		err := resetdata(client)
		if err != nil {
			return fmt.Errorf("cannot reset database: %w", err)
		}
	default:
		usage()
	}
	return nil
}