airflow

Documentation

Index

• Constants
• Variables
• func NewScheduler(bf airflow2.BucketFactory, httpClient HTTPClient, compiler models.JobCompiler) *scheduler
• type HTTPClient

Constants

const (
	JobsDir       = "dags"
	JobsExtension = ".py"
)

Variables

var SharedLib []byte

Functions

func NewScheduler

func NewScheduler(bf airflow2.BucketFactory, httpClient HTTPClient, compiler models.JobCompiler) *scheduler

Types

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}