Skip to content

Commit 5c5cc95

Browse files
oioojoiooj
committed
add more API
1 parent c13d6f5 commit 5c5cc95

17 files changed

+857
-5
lines changed

‎README.md

+13
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ import (
1212
)
1313
1414
func main() {
15+
// Your flink server HTTP API
1516
c, err := api.New("127.0.0.1:8081")
1617
if err != nil {
1718
panic(err)
@@ -38,3 +39,15 @@ More examples in [example](/example) dir.
3839
* upload jar file
3940
* list jar files
4041
* delete jar file
42+
* plan jar file
43+
* run jar file
44+
45+
### Job API
46+
47+
* job manager config
48+
* job manager metrics
49+
* list all jobs
50+
* stop a job
51+
* job overview
52+
* job detail
53+
* checkpoints

‎example/checkpoints.go

+22
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"os"
6+
7+
"github.com/flink-go/api"
8+
)
9+
10+
func main() {
11+
c, err := api.New(os.Getenv("FILNK_API"))
12+
if err != nil {
13+
panic(err)
14+
}
15+
16+
// Checkpoints test
17+
v, err := c.Checkpoints("8355c4efb63ddd4ea26a7829156a4c58")
18+
if err != nil {
19+
panic(err)
20+
}
21+
fmt.Println(v)
22+
}

‎example/config.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,13 @@ package main
22

33
import (
44
"fmt"
5+
"os"
56

67
"github.com/flink-go/api"
78
)
89

910
func main() {
10-
c, err := api.New("127.0.0.1:8081")
11+
c, err := api.New(os.Getenv("FILNK_API"))
1112
if err != nil {
1213
panic(err)
1314
}

‎example/deleteJar.go

+3-1
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,13 @@
11
package main
22

33
import (
4+
"os"
5+
46
"github.com/flink-go/api"
57
)
68

79
func main() {
8-
c, err := api.New("127.0.0.1:8081")
10+
c, err := api.New(os.Getenv("FILNK_API"))
911
if err != nil {
1012
panic(err)
1113
}

‎example/jobDetail.go

+22
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"os"
6+
7+
"github.com/flink-go/api"
8+
)
9+
10+
func main() {
11+
c, err := api.New(os.Getenv("FILNK_API"))
12+
if err != nil {
13+
panic(err)
14+
}
15+
16+
// jobs test
17+
jobs, err := c.Job("8ea123d2bdc3064f36b92889e43803ee")
18+
if err != nil {
19+
panic(err)
20+
}
21+
fmt.Println(jobs)
22+
}

‎example/jobManagerConfig.go

+22
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"os"
6+
7+
"github.com/flink-go/api"
8+
)
9+
10+
func main() {
11+
c, err := api.New(os.Getenv("FILNK_API"))
12+
if err != nil {
13+
panic(err)
14+
}
15+
16+
// job manager config test
17+
config, err := c.JobManagerConfig()
18+
if err != nil {
19+
panic(err)
20+
}
21+
fmt.Println(config)
22+
}

‎example/jobManagerMetrics.go

+22
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"os"
6+
7+
"github.com/flink-go/api"
8+
)
9+
10+
func main() {
11+
c, err := api.New(os.Getenv("FILNK_API"))
12+
if err != nil {
13+
panic(err)
14+
}
15+
16+
// job manager metrics test
17+
config, err := c.JobManagerMetrics()
18+
if err != nil {
19+
panic(err)
20+
}
21+
fmt.Println(config)
22+
}

‎example/jobs.go

+22
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"os"
6+
7+
"github.com/flink-go/api"
8+
)
9+
10+
func main() {
11+
c, err := api.New(os.Getenv("FILNK_API"))
12+
if err != nil {
13+
panic(err)
14+
}
15+
16+
// jobs test
17+
jobs, err := c.Jobs()
18+
if err != nil {
19+
panic(err)
20+
}
21+
fmt.Println(jobs)
22+
}

‎example/jobsOverview.go

+22
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"os"
6+
7+
"github.com/flink-go/api"
8+
)
9+
10+
func main() {
11+
c, err := api.New(os.Getenv("FILNK_API"))
12+
if err != nil {
13+
panic(err)
14+
}
15+
16+
// jobs overview test
17+
jobs, err := c.JobsOverview()
18+
if err != nil {
19+
panic(err)
20+
}
21+
fmt.Println(jobs)
22+
}

‎example/listJars.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,13 @@ package main
22

33
import (
44
"fmt"
5+
"os"
56

67
"github.com/flink-go/api"
78
)
89

910
func main() {
10-
c, err := api.New("127.0.0.1:8081")
11+
c, err := api.New(os.Getenv("FILNK_API"))
1112
if err != nil {
1213
panic(err)
1314
}

‎example/planJar.go

+22
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"os"
6+
7+
"github.com/flink-go/api"
8+
)
9+
10+
func main() {
11+
c, err := api.New(os.Getenv("FILNK_API"))
12+
if err != nil {
13+
panic(err)
14+
}
15+
16+
// plan test
17+
resp, err := c.PlanJar("8c0c2226-b532-4d9b-b698-8aa649694bb9_test.jar")
18+
if err != nil {
19+
panic(err)
20+
}
21+
fmt.Println(resp)
22+
}

‎example/runJar.go

+25
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
package main
2+
3+
import (
4+
"fmt"
5+
"os"
6+
7+
"github.com/flink-go/api"
8+
)
9+
10+
func main() {
11+
c, err := api.New(os.Getenv("FILNK_API"))
12+
if err != nil {
13+
panic(err)
14+
}
15+
16+
opts := api.RunOpts{
17+
JarID: "8c0c2226-b532-4d9b-b698-8aa649694bb9_test.jar",
18+
}
19+
// run test
20+
resp, err := c.RunJar(opts)
21+
if err != nil {
22+
panic(err)
23+
}
24+
fmt.Println(resp)
25+
}

‎example/shutdown.go

+3-1
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,13 @@
11
package main
22

33
import (
4+
"os"
5+
46
"github.com/flink-go/api"
57
)
68

79
func main() {
8-
c, err := api.New("127.0.0.1:8081")
10+
c, err := api.New(os.Getenv("FILNK_API"))
911
if err != nil {
1012
panic(err)
1113
}

‎example/stopJob.go

+20
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
package main
2+
3+
import (
4+
"os"
5+
6+
"github.com/flink-go/api"
7+
)
8+
9+
func main() {
10+
c, err := api.New(os.Getenv("FILNK_API"))
11+
if err != nil {
12+
panic(err)
13+
}
14+
15+
// stop job test
16+
err = c.StopJob("8ea123d2bdc3064f36b92889e43803ee")
17+
if err != nil {
18+
panic(err)
19+
}
20+
}

‎example/uploadJar.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,13 @@ package main
22

33
import (
44
"fmt"
5+
"os"
56

67
"github.com/flink-go/api"
78
)
89

910
func main() {
10-
c, err := api.New("127.0.0.1:8081")
11+
c, err := api.New(os.Getenv("FILNK_API"))
1112
if err != nil {
1213
panic(err)
1314
}

0 commit comments

Comments
 (0)