flinkjob

Documentation

Index

• func JobStatusTypeChoices() []string
• func ServiceFlinkJobDetailsStateTypeChoices() []string
• type FlinkJobHandler
  • func NewHandler(doer doer) FlinkJobHandler
  • func (h *FlinkJobHandler) ServiceFlinkJobDetails(ctx context.Context, project string, serviceName string, jobId string) (*ServiceFlinkJobDetailsOut, error)
  • func (h *FlinkJobHandler) ServiceFlinkJobsList(ctx context.Context, project string, serviceName string) ([]JobOut, error)
• type Handler
• type JobOut
• type JobStatusType
• type ServiceFlinkJobDetailsOut
• type ServiceFlinkJobDetailsStateType
• type StatusCountsOut

Functions

func JobStatusTypeChoices

func JobStatusTypeChoices() []string

func ServiceFlinkJobDetailsStateTypeChoices

func ServiceFlinkJobDetailsStateTypeChoices() []string

Types

type FlinkJobHandler

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

func NewHandler

func NewHandler(doer doer) FlinkJobHandler

func (*FlinkJobHandler) ServiceFlinkJobDetails

func (h *FlinkJobHandler) ServiceFlinkJobDetails(ctx context.Context, project string, serviceName string, jobId string) (*ServiceFlinkJobDetailsOut, error)

func (*FlinkJobHandler) ServiceFlinkJobsList

func (h *FlinkJobHandler) ServiceFlinkJobsList(ctx context.Context, project string, serviceName string) ([]JobOut, error)

type Handler

type Handler interface {
	// ServiceFlinkJobDetails get a Flink job info
	// GET /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 /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

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

type JobStatusType

type JobStatusType string

const (
	JobStatusTypeInitializing JobStatusType = "INITIALIZING"
	JobStatusTypeCreated      JobStatusType = "CREATED"
	JobStatusTypeRunning      JobStatusType = "RUNNING"
	JobStatusTypeFailing      JobStatusType = "FAILING"
	JobStatusTypeFailed       JobStatusType = "FAILED"
	JobStatusTypeCancelling   JobStatusType = "CANCELLING"
	JobStatusTypeCanceled     JobStatusType = "CANCELED"
	JobStatusTypeFinished     JobStatusType = "FINISHED"
	JobStatusTypeRestarting   JobStatusType = "RESTARTING"
	JobStatusTypeSuspended    JobStatusType = "SUSPENDED"
	JobStatusTypeReconciling  JobStatusType = "RECONCILING"
)

type ServiceFlinkJobDetailsOut

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

type ServiceFlinkJobDetailsStateType string

const (
	ServiceFlinkJobDetailsStateTypeInitializing ServiceFlinkJobDetailsStateType = "INITIALIZING"
	ServiceFlinkJobDetailsStateTypeCreated      ServiceFlinkJobDetailsStateType = "CREATED"
	ServiceFlinkJobDetailsStateTypeRunning      ServiceFlinkJobDetailsStateType = "RUNNING"
	ServiceFlinkJobDetailsStateTypeFailing      ServiceFlinkJobDetailsStateType = "FAILING"
	ServiceFlinkJobDetailsStateTypeFailed       ServiceFlinkJobDetailsStateType = "FAILED"
	ServiceFlinkJobDetailsStateTypeCancelling   ServiceFlinkJobDetailsStateType = "CANCELLING"
	ServiceFlinkJobDetailsStateTypeCanceled     ServiceFlinkJobDetailsStateType = "CANCELED"
	ServiceFlinkJobDetailsStateTypeFinished     ServiceFlinkJobDetailsStateType = "FINISHED"
	ServiceFlinkJobDetailsStateTypeRestarting   ServiceFlinkJobDetailsStateType = "RESTARTING"
	ServiceFlinkJobDetailsStateTypeSuspended    ServiceFlinkJobDetailsStateType = "SUSPENDED"
	ServiceFlinkJobDetailsStateTypeReconciling  ServiceFlinkJobDetailsStateType = "RECONCILING"
)

type StatusCountsOut

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"`
}