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