flink

Documentation

Index

• type FlinkHandler
  • func NewHandler(doer doer) FlinkHandler
  • func (h *FlinkHandler) ServiceFlinkOverview(ctx context.Context, project string, serviceName string) (*ServiceFlinkOverviewOut, error)
• type Handler
• type ServiceFlinkOverviewOut

Types

type FlinkHandler

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

func NewHandler

func NewHandler(doer doer) FlinkHandler

func (*FlinkHandler) ServiceFlinkOverview

func (h *FlinkHandler) ServiceFlinkOverview(ctx context.Context, project string, serviceName string) (*ServiceFlinkOverviewOut, error)

type Handler

type Handler interface {
	// ServiceFlinkOverview get a cluster overview
	// GET /v1/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

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

ServiceFlinkOverviewOut ServiceFlinkOverviewResponse