cmd

func ArtifactsCmd ¶

func ArtifactsCmd(artifacts embed.FS) *ishell.Cmd

ArtifactsCmd returns an interactive shell command that lists all embedded artifacts (.zip for Lambda, .tar for Docker). It reads the embedded filesystem under the predefined artifact path and prints the artifact names with their type.

func AuthCmd ¶

func AuthCmd() *ishell.Cmd

AuthCmd returns an interactive shell command that handles AWS authentication. The user is prompted to authenticate either using a named profile or direct access/secret keys. After selecting the authentication method and region, the credentials are saved locally and tested using the STS GetCallerIdentity call. On success, the authenticated identity is displayed.

func BenchmarkCmd ¶

func BenchmarkCmd() *ishell.Cmd

BenchmarkCmd returns an interactive CLI command that runs the ingestion benchmark using one of the supported execution environments: ECS (Go) or Glue (PySpark).

Usage:

benchmark --run <ecs|glue>

Parameters:

--run: Required flag specifying the implementation to execute.
  - ecs: Executes the benchmark using a Go binary running on ECS.
  - glue: Executes the benchmark using a PySpark script on AWS Glue.

Example:

benchmark --run ecs

The command prompts for confirmation before launching the benchmark. After execution, it prints the result or any error encountered.

func CatalogCmd ¶

func CatalogCmd() *ishell.Cmd

CatalogCmd returns an interactive shell command that creates or updates AWS Glue catalog tables. The user can optionally specify a data lake layer (--layer) and a comma-separated list of table names (--tables). If no flags are provided, all tables in all layers (bronze, silver, gold) will be processed.

func ClearCmd ¶

func ClearCmd(shell *ishell.Shell) *ishell.Cmd

ClearCmd returns an interactive shell command that clears the screen output. It invokes the ClearScreen method from the provided shell instance.

func CustomReadlineConfig ¶

func CustomReadlineConfig() *readline.Config

CustomReadlineConfig returns a readline.Config with specific settings for interactive shells using ishell.

It disables Meta key sequences that commonly interfere with normal input, especially on buggy terminals that send ESC-prefixed characters by default.

Blocked runes include:

• MetaBackward (Alt+b): moves backward by word
• MetaForward (Alt+f): moves forward by word
• MetaDelete (Alt+d): deletes forward word
• MetaBackspace (Alt+Backspace): deletes backward word
• MetaTranspose (Alt+t): transposes characters

Returns:

• *readline.Config: customized configuration for readline shell input.

func DeployCmd ¶

func DeployCmd(templates, artifacts, scripts embed.FS) *ishell.Cmd

DeployCmd returns an interactive shell command that deploys infrastructure stacks using embedded CloudFormation templates. The user can deploy a specific stack via the --stack flag, optionally passing parameters with --params (key=value pairs). If no stack is specified, all stacks will be deployed.

func ECRCmd ¶

func ECRCmd(artifacts embed.FS) *ishell.Cmd

ECRCmd returns an interactive shell command that publishes one or all Docker images to ECR from embedded .tar artifacts. The user can specify an image name with --name, or publish all available .tar artifacts if not provided.

func ExitCmd ¶

func ExitCmd(shell *ishell.Shell) *ishell.Cmd

ExitCmd returns an interactive shell command that terminates the program. When executed, it prints a goodbye message and stops the shell session.

func GrafanaCmd ¶

func GrafanaCmd(dashboards embed.FS) *ishell.Cmd

GrafanaCmd returns an interactive shell command that creates or updates Grafana dashboards. The user can optionally specify a single dashboard name with the --dashboard flag. If no dashboard is specified, all available dashboards embedded in the filesystem will be pushed.

func Help ¶

func Help(helps embed.FS) *ishell.Cmd

Help returns an interactive shell command that displays help information for available commands. When run without arguments, it lists all registered commands and their short descriptions. When a specific command is provided (e.g. "help deploy"), it tries to load a detailed help template from the embedded filesystem. If not found, it falls back to the built-in help description.

func LambdaCmd ¶

func LambdaCmd(artifacts embed.FS) *ishell.Cmd

LambdaCmd returns an interactive shell command that deploys one or all Lambda functions from embedded artifacts. The user can specify a function name with --name, or deploy all available .zip artifacts if not provided. Optional flags include --memory (in MB) and --timeout (in seconds).

func MigrationCmd ¶

func MigrationCmd(migrations embed.FS) *ishell.Cmd

MigrationCmd returns an interactive shell command that runs database migration scripts. The user can optionally specify a script name using --script to run a single migration, or omit it to run all available migration scripts in order. The scripts are read from the embedded filesystem.

func ParseShellFlags ¶

func ParseShellFlags(c *ishell.Context, fs *flag.FlagSet) bool

ParseShellFlags parses shell flags and returns true if parsing was successful. It also prints errors in a consistent format using the misc.Red wrapper.

func ProcessCmd ¶

func ProcessCmd() *ishell.Cmd

ProcessCmd triggers the processing pipeline for a specific layer (e.g. silver, gold) with optional filtering by table names.

func SeedCmd ¶

func SeedCmd() *ishell.Cmd

SeedCmd returns an interactive shell command that seeds datasets into Aurora or S3. The user can optionally specify a dataset file with --file to seed a single dataset, or omit it to seed all datasets from the default source (GitHub).

func StacksCmd ¶

func StacksCmd(templates embed.FS) *ishell.Cmd

StacksCmd returns an interactive shell command that lists all available infrastructure stacks. It reads the embedded templates directory and extracts stack names based on the configured template extension.

func StreamCmd ¶

func StreamCmd() *ishell.Cmd

func Welcome ¶

func Welcome(shell *ishell.Shell)

Welcome prints the welcome banner and message for the CLI.

func WhoAmICmd ¶

func WhoAmICmd() *ishell.Cmd

WhoAmICmd returns an interactive shell command that displays the current AWS identity. It uses the AWS STS GetCallerIdentity API to retrieve and print the UserId, Account, and ARN. AWS authentication is required and handled by the WithAuth middleware.

func WithAuth ¶

func WithAuth(f WrapperFunc) func(c *ishell.Context)

WithAuth wraps a command handler with AWS auth validation logic.