flinkjob

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

type Handler interface {
	// ServiceFlinkJobDetails get a Flink job info
	// GET /v1/project/{project}/service/{service_name}/flink/job/{job_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkJobDetails
	ServiceFlinkJobDetails(ctx context.Context, project string, serviceName string, jobId string) (*ServiceFlinkJobDetailsOut, error)

	// ServiceFlinkJobsList get all Flink jobs
	// GET /v1/project/{project}/service/{service_name}/flink/job
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkJobsList
	ServiceFlinkJobsList(ctx context.Context, project string, serviceName string) ([]JobOut, error)
}

type JobOut struct {
	Id     string        `json:"id,omitempty"`
	Status JobStatusType `json:"status,omitempty"`
}

type JobStatusType string

type ServiceFlinkJobDetailsOut struct {
	Duration       *int                            `json:"duration,omitempty"`
	EndTime        *int                            `json:"end-time,omitempty"`
	IsStoppable    *bool                           `json:"isStoppable,omitempty"`
	Jid            string                          `json:"jid,omitempty"`
	MaxParallelism *int                            `json:"maxParallelism,omitempty"`
	Name           string                          `json:"name,omitempty"`
	Now            *int                            `json:"now,omitempty"`
	Plan           map[string]any                  `json:"plan,omitempty"`
	StartTime      *int                            `json:"start-time,omitempty"`
	State          ServiceFlinkJobDetailsStateType `json:"state,omitempty"`
	StatusCounts   *StatusCountsOut                `json:"status-counts,omitempty"`
	Timestamps     map[string]any                  `json:"timestamps,omitempty"`
	Vertices       []map[string]any                `json:"vertices,omitempty"`
}

type ServiceFlinkJobDetailsStateType string

type StatusCountsOut struct {
	Canceled     *int `json:"CANCELED,omitempty"`
	Canceling    *int `json:"CANCELING,omitempty"`
	Created      *int `json:"CREATED,omitempty"`
	Deploying    *int `json:"DEPLOYING,omitempty"`
	Failed       *int `json:"FAILED,omitempty"`
	Finished     *int `json:"FINISHED,omitempty"`
	Initializing *int `json:"INITIALIZING,omitempty"`
	Reconciling  *int `json:"RECONCILING,omitempty"`
	Running      *int `json:"RUNNING,omitempty"`
	Scheduled    *int `json:"SCHEDULED,omitempty"`
}