airflow

Documentation

Index

• func Deploy(path, name, wsId string, prompt bool) error
• func Init(path string, airflowImageTag string) error
• func Kill(airflowHome string) error
• func Logs(airflowHome string, webserver, scheduler, follow bool) error
• func PS(airflowHome string) error
• func Run(airflowHome string, args []string) error
• func Start(airflowHome string, envFile string) error
• func Stop(airflowHome string) error
• type ComposeConfig

Functions

func Deploy

func Deploy(path, name, wsId string, prompt bool) error

Deploy pushes a new docker image

func Init

func Init(path string, airflowImageTag string) error

Init will scaffold out a new airflow project

func Kill

func Kill(airflowHome string) error

Kill stops a local airflow development cluster

func Logs

func Logs(airflowHome string, webserver, scheduler, follow bool) error

Logs out airflow webserver or scheduler logs

func PS

func PS(airflowHome string) error

PS prints the running airflow containers

func Run

func Run(airflowHome string, args []string) error

Run creates using docker exec inspired from https://github.com/docker/cli/tree/master/cli/command/container

func Start

func Start(airflowHome string, envFile string) error

Start starts a local airflow development cluster

func Stop

func Stop(airflowHome string) error

Stop a running docker project

Types

type ComposeConfig

type ComposeConfig struct {
	PostgresUser         string
	PostgresPassword     string
	PostgresHost         string
	PostgresPort         string
	AirflowEnvFile       string
	AirflowImage         string
	AirflowHome          string
	AirflowUser          string
	AirflowWebserverPort string
	MountLabel           string
}

ComposeConfig is input data to docker compose yaml template