| <!-- |
| Licensed to the Apache Software Foundation (ASF) under one |
| or more contributor license agreements. See the NOTICE file |
| distributed with this work for additional information |
| regarding copyright ownership. The ASF licenses this file |
| to you under the Apache License, Version 2.0 (the |
| "License"); you may not use this file except in compliance |
| with the License. You may obtain a copy of the License at |
| |
| http://www.apache.org/licenses/LICENSE-2.0 |
| |
| Unless required by applicable law or agreed to in writing, |
| software distributed under the License is distributed on an |
| "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| KIND, either express or implied. See the License for the |
| specific language governing permissions and limitations |
| under the License. |
| --> |
| Airflow Go client |
| ================= |
| |
| Go Airflow OpenAPI client generated from [openapi |
| spec](https://github.com/apache/airflow/blob/master/clients/gen/go.sh). |
| |
| |
| Install |
| ------- |
| |
| ``` |
| go get github.com/apache/airflow-client-go/airflow@latest |
| ``` |
| |
| Usage |
| ----- |
| |
| ```go |
| package main |
| |
| import ( |
| "context" |
| "fmt" |
| "github.com/apache/airflow-client-go/airflow" |
| ) |
| |
| func main() { |
| conf := airflow.NewConfiguration() |
| conf.Host = "localhost:8080" |
| conf.Scheme = "http" |
| cli := airflow.NewAPIClient(conf) |
| |
| cred := airflow.BasicAuth{ |
| UserName: "username", |
| Password: "password", |
| } |
| ctx := context.WithValue(context.Background(), airflow.ContextBasicAuth, cred) |
| |
| variable, _, err := cli.VariableApi.GetVariable(ctx, "foo").Execute() |
| if err != nil { |
| fmt.Println(err) |
| } else { |
| fmt.Println(variable) |
| } |
| } |
| ``` |
| |
| See [README](./airflow/README.md#documentation-for-api-endpoints) for full client API documentation. |
| |