flink

type FlinkHandler struct {
	// contains filtered or unexported fields
}

type Handler interface {
	// ServiceFlinkOverview get a cluster overview
	// GET /project/{project}/service/{service_name}/flink/overview
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkOverview
	ServiceFlinkOverview(ctx context.Context, project string, serviceName string) (*ServiceFlinkOverviewOut, error)
}

type ServiceFlinkOverviewOut struct {
	FlinkCommit    string `json:"flink-commit,omitempty"`
	FlinkVersion   string `json:"flink-version,omitempty"`
	JobsCancelled  *int   `json:"jobs-cancelled,omitempty"`
	JobsFailed     *int   `json:"jobs-failed,omitempty"`
	JobsFinished   *int   `json:"jobs-finished,omitempty"`
	JobsRunning    *int   `json:"jobs-running,omitempty"`
	SlotsAvailable *int   `json:"slots-available,omitempty"`
	SlotsTotal     *int   `json:"slots-total,omitempty"`
	Taskmanagers   *int   `json:"taskmanagers,omitempty"`
}