flinkapplication

Documentation

Index

• type ApplicationOut
• type ApplicationVersionIn
• type ApplicationVersionOut
• type ColumnOut
• type CurrentDeploymentOut
• type FlinkApplicationHandler
  • func NewHandler(doer doer) FlinkApplicationHandler
  • func (h *FlinkApplicationHandler) ServiceFlinkCreateApplication(ctx context.Context, project string, serviceName string, ...) (*ServiceFlinkCreateApplicationOut, error)
  • func (h *FlinkApplicationHandler) ServiceFlinkDeleteApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkDeleteApplicationOut, error)
  • func (h *FlinkApplicationHandler) ServiceFlinkGetApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkGetApplicationOut, error)
  • func (h *FlinkApplicationHandler) ServiceFlinkListApplications(ctx context.Context, project string, serviceName string) ([]ApplicationOut, error)
  • func (h *FlinkApplicationHandler) ServiceFlinkUpdateApplication(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkUpdateApplicationOut, error)
• type Handler
• type ServiceFlinkCreateApplicationIn
• type ServiceFlinkCreateApplicationOut
• type ServiceFlinkDeleteApplicationOut
• type ServiceFlinkGetApplicationOut
• type ServiceFlinkUpdateApplicationIn
• type ServiceFlinkUpdateApplicationOut
• type SinkIn
• type SinkOut
• type SourceIn
• type SourceOut

Types

type ApplicationOut

type ApplicationOut struct {
	CreatedAt *time.Time `json:"created_at,omitempty"`
	CreatedBy string     `json:"created_by,omitempty"`
	Id        string     `json:"id"`
	Name      string     `json:"name"`
	UpdatedAt *time.Time `json:"updated_at,omitempty"`
	UpdatedBy string     `json:"updated_by,omitempty"`
}

type ApplicationVersionIn

type ApplicationVersionIn struct {
	Sinks     []SinkIn   `json:"sinks"`
	Sources   []SourceIn `json:"sources"`
	Statement string     `json:"statement"`
}

type ApplicationVersionOut

type ApplicationVersionOut struct {
	CreatedAt time.Time   `json:"created_at"`
	CreatedBy string      `json:"created_by"`
	Id        string      `json:"id"`
	Sinks     []SinkOut   `json:"sinks"`
	Sources   []SourceOut `json:"sources"`
	Statement string      `json:"statement"`
	Version   int         `json:"version"`
}

type ColumnOut

type ColumnOut struct {
	DataType  string `json:"data_type"`
	Extras    string `json:"extras,omitempty"`
	Key       string `json:"key,omitempty"`
	Name      string `json:"name"`
	Nullable  bool   `json:"nullable"`
	Watermark string `json:"watermark,omitempty"`
}

type CurrentDeploymentOut

type CurrentDeploymentOut struct {
	CreatedAt         time.Time `json:"created_at"`
	CreatedBy         string    `json:"created_by"`
	ErrorMsg          string    `json:"error_msg,omitempty"`
	Id                string    `json:"id"`
	JobId             string    `json:"job_id,omitempty"`
	LastSavepoint     string    `json:"last_savepoint,omitempty"`
	Parallelism       int       `json:"parallelism"`
	RestartEnabled    bool      `json:"restart_enabled"`
	StartingSavepoint string    `json:"starting_savepoint,omitempty"`
	Status            string    `json:"status"`
	VersionId         string    `json:"version_id"`
}

type FlinkApplicationHandler

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

func NewHandler

func NewHandler(doer doer) FlinkApplicationHandler

func (*FlinkApplicationHandler) ServiceFlinkCreateApplication

func (h *FlinkApplicationHandler) ServiceFlinkCreateApplication(ctx context.Context, project string, serviceName string, in *ServiceFlinkCreateApplicationIn) (*ServiceFlinkCreateApplicationOut, error)

func (*FlinkApplicationHandler) ServiceFlinkDeleteApplication

func (h *FlinkApplicationHandler) ServiceFlinkDeleteApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkDeleteApplicationOut, error)

func (*FlinkApplicationHandler) ServiceFlinkGetApplication

func (h *FlinkApplicationHandler) ServiceFlinkGetApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkGetApplicationOut, error)

func (*FlinkApplicationHandler) ServiceFlinkListApplications

func (h *FlinkApplicationHandler) ServiceFlinkListApplications(ctx context.Context, project string, serviceName string) ([]ApplicationOut, error)

func (*FlinkApplicationHandler) ServiceFlinkUpdateApplication

func (h *FlinkApplicationHandler) ServiceFlinkUpdateApplication(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkUpdateApplicationIn) (*ServiceFlinkUpdateApplicationOut, error)

type Handler

type Handler interface {
	// ServiceFlinkCreateApplication create a Flink Application
	// POST /project/{project}/service/{service_name}/flink/application
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkCreateApplication
	ServiceFlinkCreateApplication(ctx context.Context, project string, serviceName string, in *ServiceFlinkCreateApplicationIn) (*ServiceFlinkCreateApplicationOut, error)

	// ServiceFlinkDeleteApplication delete a Flink Application
	// DELETE /project/{project}/service/{service_name}/flink/application/{application_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkDeleteApplication
	ServiceFlinkDeleteApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkDeleteApplicationOut, error)

	// ServiceFlinkGetApplication get a Flink Application
	// GET /project/{project}/service/{service_name}/flink/application/{application_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkGetApplication
	ServiceFlinkGetApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkGetApplicationOut, error)

	// ServiceFlinkListApplications get all Flink Applications
	// GET /project/{project}/service/{service_name}/flink/application
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkListApplications
	ServiceFlinkListApplications(ctx context.Context, project string, serviceName string) ([]ApplicationOut, error)

	// ServiceFlinkUpdateApplication update a Flink Application
	// PUT /project/{project}/service/{service_name}/flink/application/{application_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkUpdateApplication
	ServiceFlinkUpdateApplication(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkUpdateApplicationIn) (*ServiceFlinkUpdateApplicationOut, error)
}

type ServiceFlinkCreateApplicationIn

type ServiceFlinkCreateApplicationIn struct {
	ApplicationVersion *ApplicationVersionIn `json:"application_version,omitempty"`
	Name               string                `json:"name"`
}

type ServiceFlinkCreateApplicationOut

type ServiceFlinkCreateApplicationOut struct {
	ApplicationVersions []ApplicationVersionOut `json:"application_versions"`
	CreatedAt           time.Time               `json:"created_at"`
	CreatedBy           string                  `json:"created_by"`
	CurrentDeployment   *CurrentDeploymentOut   `json:"current_deployment,omitempty"`
	Id                  string                  `json:"id"`
	Name                string                  `json:"name"`
	UpdatedAt           time.Time               `json:"updated_at"`
	UpdatedBy           string                  `json:"updated_by"`
}

type ServiceFlinkDeleteApplicationOut

type ServiceFlinkDeleteApplicationOut struct {
	ApplicationVersions []ApplicationVersionOut `json:"application_versions"`
	CreatedAt           time.Time               `json:"created_at"`
	CreatedBy           string                  `json:"created_by"`
	CurrentDeployment   *CurrentDeploymentOut   `json:"current_deployment,omitempty"`
	Id                  string                  `json:"id"`
	Name                string                  `json:"name"`
	UpdatedAt           time.Time               `json:"updated_at"`
	UpdatedBy           string                  `json:"updated_by"`
}

type ServiceFlinkGetApplicationOut

type ServiceFlinkGetApplicationOut struct {
	ApplicationVersions []ApplicationVersionOut `json:"application_versions"`
	CreatedAt           time.Time               `json:"created_at"`
	CreatedBy           string                  `json:"created_by"`
	CurrentDeployment   *CurrentDeploymentOut   `json:"current_deployment,omitempty"`
	Id                  string                  `json:"id"`
	Name                string                  `json:"name"`
	UpdatedAt           time.Time               `json:"updated_at"`
	UpdatedBy           string                  `json:"updated_by"`
}

type ServiceFlinkUpdateApplicationIn

type ServiceFlinkUpdateApplicationIn struct {
	Name string `json:"name"`
}

type ServiceFlinkUpdateApplicationOut

type ServiceFlinkUpdateApplicationOut struct {
	ApplicationVersions []ApplicationVersionOut `json:"application_versions"`
	CreatedAt           time.Time               `json:"created_at"`
	CreatedBy           string                  `json:"created_by"`
	CurrentDeployment   *CurrentDeploymentOut   `json:"current_deployment,omitempty"`
	Id                  string                  `json:"id"`
	Name                string                  `json:"name"`
	UpdatedAt           time.Time               `json:"updated_at"`
	UpdatedBy           string                  `json:"updated_by"`
}

type SinkIn

type SinkIn struct {
	CreateTable   string `json:"create_table"`
	IntegrationId string `json:"integration_id,omitempty"`
}

type SinkOut

type SinkOut struct {
	Columns       []ColumnOut    `json:"columns"`
	CreateTable   string         `json:"create_table"`
	IntegrationId string         `json:"integration_id,omitempty"`
	Options       map[string]any `json:"options"`
	TableId       string         `json:"table_id"`
	TableName     string         `json:"table_name"`
}

type SourceIn

type SourceIn struct {
	CreateTable   string `json:"create_table"`
	IntegrationId string `json:"integration_id,omitempty"`
}

type SourceOut

type SourceOut struct {
	Columns       []ColumnOut    `json:"columns"`
	CreateTable   string         `json:"create_table"`
	IntegrationId string         `json:"integration_id,omitempty"`
	Options       map[string]any `json:"options"`
	TableId       string         `json:"table_id"`
	TableName     string         `json:"table_name"`
}