flinkapplication

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 struct {
	Sinks     []SinkIn   `json:"sinks"`
	Sources   []SourceIn `json:"sources"`
	Statement string     `json:"statement"`
}

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 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 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            CurrentDeploymentStatusType `json:"status"`
	VersionId         string                      `json:"version_id"`
}

type CurrentDeploymentStatusType string

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

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 struct {
	ApplicationVersion *ApplicationVersionIn `json:"application_version,omitempty"`
	Name               string                `json:"name"`
}

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 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 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 struct {
	Name string `json:"name"`
}

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 struct {
	CreateTable   string `json:"create_table"`
	IntegrationId string `json:"integration_id,omitempty"`
}

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 struct {
	CreateTable   string `json:"create_table"`
	IntegrationId string `json:"integration_id,omitempty"`
}

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