Versions in this module Expand all Collapse all v1 v1.0.0 Jun 24, 2020 Changes in this version + var ContextAPIKey = contextKey("apikey") + var ContextAccessToken = contextKey("accesstoken") + var ContextBasicAuth = contextKey("basic") + var ContextOAuth2 = contextKey("token") + func CacheExpires(r *http.Response) time.Time + type APIClient struct + ConfigApi *ConfigApiService + ConnectionApi *ConnectionApiService + DAGApi *DAGApiService + DAGRunApi *DAGRunApiService + EventLogApi *EventLogApiService + ImportErrorApi *ImportErrorApiService + MonitoringApi *MonitoringApiService + PoolApi *PoolApiService + TaskInstanceApi *TaskInstanceApiService + VariableApi *VariableApiService + XComApi *XComApiService + func NewAPIClient(cfg *Configuration) *APIClient + func (c *APIClient) ChangeBasePath(path string) + func (c *APIClient) GetConfig() *Configuration + type APIKey struct + Key string + Prefix string + type APIResponse struct + Message string + Method string + Operation string + Payload []byte + RequestURL string + func NewAPIResponse(r *http.Response) *APIResponse + func NewAPIResponseWithError(errorMessage string) *APIResponse + type BasicAuth struct + Password string + UserName string + type ClassReference struct + ClassName string + ModulePath string + type ClearTaskInstance struct + DryRun bool + EndDate string + IncludeParentdag bool + IncludeSubdags bool + OnlyFailed string + OnlyRunning string + ResetDagRuns bool + StartDate string + type CollectionInfo struct + TotalEntries int32 + type Config struct + Sections []ConfigSection + type ConfigApiService service + func (a *ConfigApiService) GetConfig(ctx _context.Context, localVarOptionals *GetConfigOpts) (Config, *_nethttp.Response, error) + type ConfigOption struct + Key string + Value string + type ConfigSection struct + Name string + Options []ConfigOption + type Configuration struct + BasePath string + Debug bool + DefaultHeader map[string]string + HTTPClient *http.Client + Host string + Scheme string + Servers []ServerConfiguration + UserAgent string + func NewConfiguration() *Configuration + func (c *Configuration) AddDefaultHeader(key string, value string) + func (c *Configuration) ServerUrl(index int, variables map[string]string) (string, error) + type Connection struct + ConnType string + ConnectionId string + Extra *string + Host *string + Login *string + Password string + Port *int32 + Schema *string + type ConnectionAllOf struct + Extra *string + Password string + type ConnectionApiService service + func (a *ConnectionApiService) DeleteConnection(ctx _context.Context, connectionId string) (*_nethttp.Response, error) + func (a *ConnectionApiService) GetConnection(ctx _context.Context, connectionId string) (Connection, *_nethttp.Response, error) + func (a *ConnectionApiService) GetConnections(ctx _context.Context, localVarOptionals *GetConnectionsOpts) (ConnectionCollection, *_nethttp.Response, error) + func (a *ConnectionApiService) PatchConnection(ctx _context.Context, connectionId string, connection Connection, ...) (Connection, *_nethttp.Response, error) + func (a *ConnectionApiService) PostConnection(ctx _context.Context, connection Connection) (Connection, *_nethttp.Response, error) + type ConnectionCollection struct + Connections []ConnectionCollectionItem + type ConnectionCollectionItem struct + ConnType string + ConnectionId string + Host *string + Login *string + Port *int32 + Schema *string + type CronExpression struct + Type string + Value string + type DAGApiService service + func (a *DAGApiService) GetDag(ctx _context.Context, dagId string) (Dag, *_nethttp.Response, error) + func (a *DAGApiService) GetDagDetails(ctx _context.Context, dagId string) (DagDetail, *_nethttp.Response, error) + func (a *DAGApiService) GetDagSource(ctx _context.Context, fileToken string) (InlineResponse2001, *_nethttp.Response, error) + func (a *DAGApiService) GetDags(ctx _context.Context, localVarOptionals *GetDagsOpts) (DagCollection, *_nethttp.Response, error) + func (a *DAGApiService) GetTask(ctx _context.Context, dagId string, taskId string) (Task, *_nethttp.Response, error) + func (a *DAGApiService) GetTasks(ctx _context.Context, dagId string) (TaskCollection, *_nethttp.Response, error) + func (a *DAGApiService) PatchDag(ctx _context.Context, dagId string, dag Dag) (Dag, *_nethttp.Response, error) + func (a *DAGApiService) PostClearTaskInstances(ctx _context.Context, dagId string, clearTaskInstance ClearTaskInstance) (TaskInstanceReferenceCollection, *_nethttp.Response, error) + type DAGRunApiService service + func (a *DAGRunApiService) DeleteDagRun(ctx _context.Context, dagId string, dagRunId string) (*_nethttp.Response, error) + func (a *DAGRunApiService) GetDagRun(ctx _context.Context, dagId string, dagRunId string) (DagRun, *_nethttp.Response, error) + func (a *DAGRunApiService) GetDagRuns(ctx _context.Context, dagId string, localVarOptionals *GetDagRunsOpts) (DagRunCollection, *_nethttp.Response, error) + func (a *DAGRunApiService) GetDagRunsBatch(ctx _context.Context, listDagRunsForm ListDagRunsForm) (DagRunCollection, *_nethttp.Response, error) + func (a *DAGRunApiService) PatchDagRun(ctx _context.Context, dagId string, dagRunId string, dagRun DagRun, ...) (DagRun, *_nethttp.Response, error) + func (a *DAGRunApiService) PostDagRun(ctx _context.Context, dagId string, dagRunId string, dagRun DagRun) (DagRun, *_nethttp.Response, error) + type Dag struct + DagId string + Description string + FileToken string + Fileloc string + IsPaused bool + IsSubdag bool + Owners []string + RootDagId string + ScheduleInterval ScheduleInterval + Tags []Tag + type DagCollection struct + Dags []Dag + type DagDetail struct + Catchup bool + Concurrency float32 + DagId string + DagRunTimeout TimeDelta + DefaultView string + Description string + DocMd string + FileToken string + Fileloc string + IsPaused bool + IsSubdag bool + Orientation string + Owners []string + RootDagId string + ScheduleInterval ScheduleInterval + StartDate time.Time + Tags []Tag + Timezone string + type DagDetailAllOf struct + Catchup bool + Concurrency float32 + DagRunTimeout TimeDelta + DefaultView string + DocMd string + Orientation string + StartDate time.Time + Timezone string + type DagRun struct + Conf map[string]interface{} + DagId string + DagRunId string + EndDate *time.Time + ExecutionDate time.Time + ExternalTrigger bool + StartDate time.Time + State DagState + type DagRunCollection struct + DagRuns []DagRun + type DagState string + const DAGSTATE_FAILED + const DAGSTATE_RUNNING + const DAGSTATE_SUCCESS + type Error struct + Detail string + Instance string + Status float32 + Title string + Type string + type EventLog struct + DagId string + Event string + EventLogId int32 + ExecutionDate string + Extra *string + Owner string + TaskId string + When string + type EventLogApiService service + func (a *EventLogApiService) GetEventLog(ctx _context.Context, eventLogId int32) (EventLog, *_nethttp.Response, error) + func (a *EventLogApiService) GetEventLogs(ctx _context.Context, localVarOptionals *GetEventLogsOpts) (EventLogCollection, *_nethttp.Response, error) + type EventLogCollection struct + EventLogs []EventLog + type ExtraLink struct + ClassRef ClassReference + Href string + Name string + type ExtraLinkCollection struct + ExtraLinks []ExtraLink + type GenericOpenAPIError struct + func (e GenericOpenAPIError) Body() []byte + func (e GenericOpenAPIError) Error() string + func (e GenericOpenAPIError) Model() interface{} + type GetConfigOpts struct + Limit optional.Int32 + Offset optional.Int32 + type GetConnectionsOpts struct + Limit optional.Int32 + Offset optional.Int32 + type GetDagRunsOpts struct + EndDateGte optional.Time + EndDateLte optional.Time + ExecutionDateGte optional.Time + ExecutionDateLte optional.Time + Limit optional.Int32 + Offset optional.Int32 + StartDateGte optional.Time + StartDateLte optional.Time + type GetDagsOpts struct + Limit optional.Int32 + Offset optional.Int32 + type GetEventLogsOpts struct + Limit optional.Int32 + Offset optional.Int32 + type GetImportErrorsOpts struct + Limit optional.Int32 + Offset optional.Int32 + type GetLogOpts struct + FullContent optional.Bool + Token optional.String + type GetPoolsOpts struct + Limit optional.Int32 + Offset optional.Int32 + type GetTaskInstancesOpts struct + DurationGte optional.Float32 + DurationLte optional.Float32 + EndDateGte optional.Time + EndDateLte optional.Time + ExecutionDateGte optional.Time + ExecutionDateLte optional.Time + Limit optional.Int32 + Offset optional.Int32 + Pool optional.Interface + Queue optional.Interface + StartDateGte optional.Time + StartDateLte optional.Time + State optional.Interface + type GetVariablesOpts struct + Limit optional.Int32 + Offset optional.Int32 + type GetXcomEntriesOpts struct + Limit optional.Int32 + Offset optional.Int32 + type ImportError struct + Filename string + ImportErrorId int32 + StackTrace string + Timestamp string + type ImportErrorApiService service + func (a *ImportErrorApiService) GetImportError(ctx _context.Context, importErrorId int32) (ImportError, *_nethttp.Response, error) + func (a *ImportErrorApiService) GetImportErrors(ctx _context.Context, localVarOptionals *GetImportErrorsOpts) (ImportErrorCollection, *_nethttp.Response, error) + type ImportErrorCollection struct + ImportErrors []ImportError + type InlineResponse200 struct + Content string + ContinuationToken string + type InlineResponse2001 struct + Content string + type ListDagRunsForm struct + DagIds []string + EndDateGte time.Time + EndDateLte time.Time + ExecutionDateGte time.Time + ExecutionDateLte time.Time + PageLimit int32 + PageOffset int32 + StartDateGte time.Time + StartDateLte time.Time + type ListTaskInstanceForm struct + DagIds []string + DurationGte float32 + DurationLte float32 + EndDateGte time.Time + EndDateLte time.Time + ExecutionDateGte time.Time + ExecutionDateLte time.Time + Pool []string + Queue []string + StartDateGte time.Time + StartDateLte time.Time + State []string + type MonitoringApiService service + func (a *MonitoringApiService) GetHealth(ctx _context.Context) (string, *_nethttp.Response, error) + func (a *MonitoringApiService) GetVersion(ctx _context.Context) (VersionInfo, *_nethttp.Response, error) + type PatchConnectionOpts struct + UpdateMask optional.Interface + type PatchDagRunOpts struct + UpdateMask optional.Interface + type PatchPoolOpts struct + UpdateMask optional.Interface + type PatchVariableOpts struct + UpdateMask optional.Interface + type PatchXcomEntryOpts struct + UpdateMask optional.Interface + type Pool struct + Name string + OccupiedSlots int32 + OpenSlots int32 + QueuedSlots int32 + Slots int32 + UsedSlots int32 + type PoolApiService service + func (a *PoolApiService) DeletePool(ctx _context.Context, poolName string) (*_nethttp.Response, error) + func (a *PoolApiService) GetPool(ctx _context.Context, poolName string) (Pool, *_nethttp.Response, error) + func (a *PoolApiService) GetPools(ctx _context.Context, localVarOptionals *GetPoolsOpts) (PoolCollection, *_nethttp.Response, error) + func (a *PoolApiService) PatchPool(ctx _context.Context, poolName string, pool Pool, ...) (Pool, *_nethttp.Response, error) + func (a *PoolApiService) PostPool(ctx _context.Context, pool Pool) (Pool, *_nethttp.Response, error) + type PoolCollection struct + Pools []Pool + type RelativeDelta struct + Day int32 + Days int32 + Hour int32 + Hours int32 + Leapdays int32 + Microsecond int32 + Microseconds int32 + Minute int32 + Minutes int32 + Month int32 + Months int32 + Second int32 + Seconds int32 + Type string + Year int32 + Years int32 + type ScheduleInterval struct + Day int32 + Days int32 + Hour int32 + Hours int32 + Leapdays int32 + Microsecond int32 + Microseconds int32 + Minute int32 + Minutes int32 + Month int32 + Months int32 + Second int32 + Seconds int32 + Type string + Value string + Year int32 + Years int32 + type ServerConfiguration struct + Description string + Url string + Variables map[string]ServerVariable + type ServerVariable struct + DefaultValue string + Description string + EnumValues []string + type SlaMiss struct + DagId string + Description string + EmailSent bool + ExecutionDate string + NotificationSent bool + TaskId string + Timestamp string + type SlaMissCollection struct + SlaMisses []SlaMiss + type Tag struct + Name string + type Task struct + ClassRef ClassReference + DependsOnPast bool + DownstreamTaskIds []string + EndDate time.Time + ExecutionTimeout TimeDelta + ExtraLinks []TaskExtraLinks + Owner string + Pool string + PoolSlots float32 + PriorityWeight float32 + Queue string + Retries float32 + RetryDelay TimeDelta + RetryExponentialBackoff bool + StartDate time.Time + SubDag Dag + TaskId string + TemplateFields []string + TriggerRule TriggerRule + UiColor string + UiFgcolor string + WaitForDownstream bool + WeightRule WeightRule + type TaskCollection struct + Tasks []Task + type TaskExtraLinks struct + ClassRef ClassReference + type TaskFail struct + DagId string + Duration int32 + EndDate string + ExecutionDate string + StartDate string + TaskId string + type TaskInstance struct + DagId string + Duration float32 + EndDate string + ExecutionDate string + ExecutorConfig string + Hostname string + MaxTries int32 + Operator string + Pid int32 + Pool string + PoolSlots int32 + PriorityWeight int32 + Queue string + QueuedWhen string + SlaMiss SlaMiss + StartDate string + State TaskState + TaskId string + TryNumber int32 + Unixname string + type TaskInstanceApiService service + func (a *TaskInstanceApiService) GetExtraLinks(ctx _context.Context, dagId string, dagRunId string, taskId string) (ExtraLinkCollection, *_nethttp.Response, error) + func (a *TaskInstanceApiService) GetLog(ctx _context.Context, dagId string, dagRunId string, taskId string, ...) (InlineResponse200, *_nethttp.Response, error) + func (a *TaskInstanceApiService) GetTaskInstance(ctx _context.Context, dagId string, dagRunId string, taskId string) (TaskInstance, *_nethttp.Response, error) + func (a *TaskInstanceApiService) GetTaskInstances(ctx _context.Context, dagId string, dagRunId string, ...) (TaskInstanceCollection, *_nethttp.Response, error) + func (a *TaskInstanceApiService) GetTaskInstancesBatch(ctx _context.Context, listTaskInstanceForm ListTaskInstanceForm) (TaskInstanceCollection, *_nethttp.Response, error) + type TaskInstanceCollection struct + TaskInstances []TaskInstance + type TaskInstanceReference struct + DagId string + DagRunId string + ExecutionDate string + TaskId string + type TaskInstanceReferenceCollection struct + TaskInstances []TaskInstanceReference + type TaskState string + const TASKSTATE_FAILED + const TASKSTATE_NONE + const TASKSTATE_QUEUED + const TASKSTATE_RUNNING + const TASKSTATE_SCHEDULED + const TASKSTATE_SKIPPED + const TASKSTATE_SUCCCESS + const TASKSTATE_UPSTREAM_FAILED + const TASKSTATE_UP_FOR_RESCHEDULE + const TASKSTATE_UP_FOR_RETRY + type TimeDelta struct + Days int32 + Microsecond int32 + Seconds int32 + Type string + type TriggerRule string + const TRIGGERRULE_ALL_DONE + const TRIGGERRULE_ALL_FAILED + const TRIGGERRULE_ALL_SUCCESS + const TRIGGERRULE_DUMMY + const TRIGGERRULE_NONE_FAILED + const TRIGGERRULE_NONE_FAILED_OR_SKIPPED + const TRIGGERRULE_NONE_SKIPPED + const TRIGGERRULE_ONE_FAILED + const TRIGGERRULE_ONE_SUCCESS + type Variable struct + Key string + Value string + type VariableAllOf struct + Value string + type VariableApiService service + func (a *VariableApiService) DeleteVariable(ctx _context.Context, variableKey string) (*_nethttp.Response, error) + func (a *VariableApiService) GetVariable(ctx _context.Context, variableKey string) (Variable, *_nethttp.Response, error) + func (a *VariableApiService) GetVariables(ctx _context.Context, localVarOptionals *GetVariablesOpts) (VariableCollection, *_nethttp.Response, error) + func (a *VariableApiService) PatchVariable(ctx _context.Context, variableKey string, variable Variable, ...) (Variable, *_nethttp.Response, error) + func (a *VariableApiService) PostVariables(ctx _context.Context, variable Variable) (Variable, *_nethttp.Response, error) + type VariableCollection struct + Variables []VariableCollectionItem + type VariableCollectionItem struct + Key string + type VersionInfo struct + GitVersion *string + Version string + type WeightRule string + const WEIGHTRULE_ABSOLUTE + const WEIGHTRULE_DOWNSTREAM + const WEIGHTRULE_UPSTREAM + type XCom struct + DagId string + ExecutionDate string + Key string + TaskId string + Timestamp string + Value string + type XComApiService service + func (a *XComApiService) DeleteXcomEntry(ctx _context.Context, dagId string, dagRunId string, taskId string, ...) (*_nethttp.Response, error) + func (a *XComApiService) GetXcomEntries(ctx _context.Context, dagId string, dagRunId string, taskId string, ...) (XComCollection, *_nethttp.Response, error) + func (a *XComApiService) GetXcomEntry(ctx _context.Context, dagId string, dagRunId string, taskId string, ...) (XCom, *_nethttp.Response, error) + func (a *XComApiService) PatchXcomEntry(ctx _context.Context, dagId string, dagRunId string, taskId string, ...) (XCom, *_nethttp.Response, error) + func (a *XComApiService) PostXcomEntries(ctx _context.Context, dagId string, dagRunId string, taskId string, xCom XCom) (XCom, *_nethttp.Response, error) + type XComCollection struct + XcomEntries []XComCollectionItem + type XComCollectionItem struct + DagId string + ExecutionDate string + Key string + TaskId string + Timestamp string