flinkapplicationversion

type ColumnOut struct {
	DataType  string  `json:"data_type"`           // The data type of the column
	Extras    *string `json:"extras,omitempty"`    // Column extra information
	Key       *string `json:"key,omitempty"`       // The key info of the column
	Name      string  `json:"name"`                // The name of the column
	Nullable  bool    `json:"nullable"`            // Whether the column is nullable, i.e. if true, the column is NOT NULL
	Watermark *string `json:"watermark,omitempty"` // Information of the watermark if the column is used for watermark.
}

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

type Handler interface {
	// ServiceFlinkCreateApplicationVersion create a Flink ApplicationVersion
	// POST /v1/project/{project}/service/{service_name}/flink/application/{application_id}/version
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkCreateApplicationVersion
	ServiceFlinkCreateApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkCreateApplicationVersionIn) (*ServiceFlinkCreateApplicationVersionOut, error)

	// ServiceFlinkDeleteApplicationVersion delete a Flink ApplicationVersion
	// DELETE /v1/project/{project}/service/{service_name}/flink/application/{application_id}/version/{application_version_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkDeleteApplicationVersion
	ServiceFlinkDeleteApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, applicationVersionId string) (*ServiceFlinkDeleteApplicationVersionOut, error)

	// ServiceFlinkGetApplicationVersion get a Flink ApplicationVersion
	// GET /v1/project/{project}/service/{service_name}/flink/application/{application_id}/version/{application_version_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkGetApplicationVersion
	ServiceFlinkGetApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, applicationVersionId string) (*ServiceFlinkGetApplicationVersionOut, error)

	// ServiceFlinkValidateApplicationVersion validate a Flink ApplicationVersion
	// POST /v1/project/{project}/service/{service_name}/flink/application/{application_id}/version/validate
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkValidateApplicationVersion
	ServiceFlinkValidateApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkValidateApplicationVersionIn) (*ServiceFlinkValidateApplicationVersionOut, error)
}

type PositionOut struct {
	CharacterNumber    int `json:"character_number"`     // Character number of where the error starts, starting from 1.
	EndCharacterNumber int `json:"end_character_number"` // Character number of where the error starts, starting from 1.
	EndLineNumber      int `json:"end_line_number"`      // Line number of where the error ends, starting from 1.
	LineNumber         int `json:"line_number"`          // Line number of where the error starts, starting from 1.
}

type ServiceFlinkCreateApplicationVersionIn struct {
	Sinks     []SinkIn   `json:"sinks"`
	Sources   []SourceIn `json:"sources"`
	Statement string     `json:"statement"` // Job SQL statement
}

type ServiceFlinkCreateApplicationVersionOut struct {
	CreatedAt time.Time   `json:"created_at"` // Created at
	CreatedBy string      `json:"created_by"` // Created by
	Id        string      `json:"id"`         // ApplicationVersion ID
	Sinks     []SinkOut   `json:"sinks"`
	Sources   []SourceOut `json:"sources"`
	Statement string      `json:"statement"` // Job SQL statement
	Version   int         `json:"version"`   // Version number
}

type ServiceFlinkDeleteApplicationVersionOut struct {
	CreatedAt time.Time   `json:"created_at"` // Created at
	CreatedBy string      `json:"created_by"` // Created by
	Id        string      `json:"id"`         // ApplicationVersion ID
	Sinks     []SinkOut   `json:"sinks"`
	Sources   []SourceOut `json:"sources"`
	Statement string      `json:"statement"` // Job SQL statement
	Version   int         `json:"version"`   // Version number
}

type ServiceFlinkGetApplicationVersionOut struct {
	CreatedAt time.Time   `json:"created_at"` // Created at
	CreatedBy string      `json:"created_by"` // Created by
	Id        string      `json:"id"`         // ApplicationVersion ID
	Sinks     []SinkOut   `json:"sinks"`
	Sources   []SourceOut `json:"sources"`
	Statement string      `json:"statement"` // Job SQL statement
	Version   int         `json:"version"`   // Version number
}

type ServiceFlinkValidateApplicationVersionIn struct {
	Sinks     []SinkIn   `json:"sinks"`
	Sources   []SourceIn `json:"sources"`
	Statement *string    `json:"statement,omitempty"` // Job SQL statement
}

type ServiceFlinkValidateApplicationVersionOut struct {
	Sinks          []SinkOutAlt       `json:"sinks"`                     // Sinks and sink validation errors
	Sources        []SourceOutAlt     `json:"sources"`                   // Sources and source validation errors
	Statement      *string            `json:"statement,omitempty"`       // Job SQL statement
	StatementError *StatementErrorOut `json:"statement_error,omitempty"` // Job validation error
}

type SinkIn struct {
	CreateTable   string  `json:"create_table"`             // The CREATE TABLE statement
	IntegrationId *string `json:"integration_id,omitempty"` // Integration ID
}

type SinkOut struct {
	Columns       []ColumnOut    `json:"columns"`
	CreateTable   string         `json:"create_table"`             // The CREATE TABLE statement
	IntegrationId *string        `json:"integration_id,omitempty"` // Integration ID
	Options       map[string]any `json:"options"`                  // Option
	TableId       string         `json:"table_id"`                 // Sink ID
	TableName     string         `json:"table_name"`               // Table name
}

type SinkOutAlt struct {
	Columns       []ColumnOut    `json:"columns,omitempty"`
	CreateTable   string         `json:"create_table"`             // The CREATE TABLE statement
	IntegrationId *string        `json:"integration_id,omitempty"` // Integration ID
	Message       *string        `json:"message,omitempty"`        // The error message.
	Options       map[string]any `json:"options,omitempty"`        // Option
	Position      *PositionOut   `json:"position,omitempty"`       // Error position in the SQL.
	TableName     *string        `json:"table_name,omitempty"`     // Table name
}

type SourceIn struct {
	CreateTable   string  `json:"create_table"`             // The CREATE TABLE statement
	IntegrationId *string `json:"integration_id,omitempty"` // Integration ID
}

type SourceOut struct {
	Columns       []ColumnOut    `json:"columns"`
	CreateTable   string         `json:"create_table"`             // The CREATE TABLE statement
	IntegrationId *string        `json:"integration_id,omitempty"` // Integration ID
	Options       map[string]any `json:"options"`                  // Option
	TableId       string         `json:"table_id"`                 // Source ID
	TableName     string         `json:"table_name"`               // Table name
}

type SourceOutAlt struct {
	Columns       []ColumnOut    `json:"columns,omitempty"`
	CreateTable   string         `json:"create_table"`             // The CREATE TABLE statement
	IntegrationId *string        `json:"integration_id,omitempty"` // Integration ID
	Message       *string        `json:"message,omitempty"`        // The error message.
	Options       map[string]any `json:"options,omitempty"`        // Option
	Position      *PositionOut   `json:"position,omitempty"`       // Error position in the SQL.
	TableName     *string        `json:"table_name,omitempty"`     // Table name
}

type StatementErrorOut struct {
	Message  string       `json:"message"`            // The error message.
	Position *PositionOut `json:"position,omitempty"` // Error position in the SQL.
}