codegen

Documentation

Index

• func BoolTitle(b bool) string
• func CheckDeps(deps []string) bool
• func CreateDagGen(g GenData, directory string) (string, error)
• func MapToPythonDict(m map[string]interface{}) (string, error)
• func ToJSONString(v interface{}) (string, error)
• func ToMap(v interface{}) (map[string]interface{}, error)
• func TransformTaskID(taskID string) string
• type Args
• type Connection
• type Dag
• type GenData
• type HttpTask
• type PythonTask
• type StartDate

Functions

func BoolTitle

func BoolTitle(b bool) string

func CheckDeps

func CheckDeps(deps []string) bool

func CreateDagGen

func CreateDagGen(g GenData, directory string) (string, error)

func MapToPythonDict

func MapToPythonDict(m map[string]interface{}) (string, error)

Function to convert a Go map to a Python dictionary string

func ToJSONString

func ToJSONString(v interface{}) (string, error)

Function to convert an interface to a JSON string

func ToMap

func ToMap(v interface{}) (map[string]interface{}, error)

func TransformTaskID

func TransformTaskID(taskID string) string

Function to transform the task ID

Types

type Args

type Args struct {
	Email         string
	DependsOnPast bool
	Retries       int
	RetryDelay    int
}

type Connection

type Connection struct {
	ConnectionID string
	Host         string
	Port         int
	Downstream   []string
}

type Dag

type Dag struct {
	ID          string
	Description string
	StartDate   StartDate
	Tags        []string
	DefaultArgs Args
}

type GenData

type GenData struct {
	DagDef        Dag
	Connections   []Connection
	PythonImports []string
	Tasks         []HttpTask
	PythonTask    []PythonTask
}

type HttpTask

type HttpTask struct {
	TaskID       string
	ConnectionId string
	Name         string
	Endpoint     string
	Data         interface{}
	Downstream   []string
	Upstream     []string
}

type PythonTask

type PythonTask struct {
	TaskID     string
	Name       string
	Data       interface{}
	Downstream []string
	Upstream   []string
}

type StartDate

type StartDate struct {
	Day   int
	Month int
	Year  int
}