Flink Monitoring API Golang library

Detail doc: https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/rest_api.html

Status: Beta

package main
import (
    "fmt"
    "github.com/flink-go/api"
)
func main() {
    // Your flink server HTTP API
    c, err := api.New("127.0.0.1:8081")
    if err != nil {
        panic(err)
    }
    // get cluster config
    config, err := c.Config()
    if err != nil {
        panic(err)
    }
    fmt.Println(config)
}

More examples in example dir.

Cluster API

• shutdown cluster
• list config

Jar File API

• upload jar file
• list jar files
• delete jar file
• plan jar file
• run jar file

Job API

• job manager config
• job manager metrics
• list all jobs
• stop a job
• job overview
• job detail

checkpoints

• get all checkpoints of a job
• stop a job with a savepoint

TODO:

• vertices
• checkpoints/config
• /jobs/:jobid/checkpoints/details/:checkpointid
• /jobs/:jobid/config
• /jobs/:jobid/exceptions
• /jobs/:jobid/execution-result
• /jobs/:jobid/metrics
• /jobs/:jobid/plan
• /jobs/:jobid/rescaling
• /jobs/:jobid/rescaling/:triggerid
• overview
• /savepoint-disposal
• /taskmanagers