flinkapplicationversion

package
v0.36.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 4, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ColumnOut 

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 

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

func NewHandler 

func NewHandler(doer doer) FlinkApplicationVersionHandler

func (*FlinkApplicationVersionHandler) ServiceFlinkCreateApplicationVersion 

func (h *FlinkApplicationVersionHandler) ServiceFlinkCreateApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkCreateApplicationVersionIn) (*ServiceFlinkCreateApplicationVersionOut, error)

func (*FlinkApplicationVersionHandler) ServiceFlinkDeleteApplicationVersion 

func (h *FlinkApplicationVersionHandler) ServiceFlinkDeleteApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, applicationVersionId string) (*ServiceFlinkDeleteApplicationVersionOut, error)

func (*FlinkApplicationVersionHandler) ServiceFlinkGetApplicationVersion 

func (h *FlinkApplicationVersionHandler) ServiceFlinkGetApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, applicationVersionId string) (*ServiceFlinkGetApplicationVersionOut, error)

func (*FlinkApplicationVersionHandler) ServiceFlinkValidateApplicationVersion 

func (h *FlinkApplicationVersionHandler) ServiceFlinkValidateApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkValidateApplicationVersionIn) (*ServiceFlinkValidateApplicationVersionOut, error)

type Handler 

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 

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.
}

PositionOut Error position in the SQL.

type ServiceFlinkCreateApplicationVersionIn 

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

ServiceFlinkCreateApplicationVersionIn ServiceFlinkCreateApplicationVersionRequestBody

type ServiceFlinkCreateApplicationVersionOut 

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
}

ServiceFlinkCreateApplicationVersionOut ServiceFlinkCreateApplicationVersionResponse

type ServiceFlinkDeleteApplicationVersionOut 

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
}

ServiceFlinkDeleteApplicationVersionOut ServiceFlinkDeleteApplicationVersionResponse

type ServiceFlinkGetApplicationVersionOut 

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
}

ServiceFlinkGetApplicationVersionOut ServiceFlinkGetApplicationVersionResponse

type ServiceFlinkValidateApplicationVersionIn 

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

ServiceFlinkValidateApplicationVersionIn ServiceFlinkValidateApplicationVersionRequestBody

type ServiceFlinkValidateApplicationVersionOut 

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

ServiceFlinkValidateApplicationVersionOut ServiceFlinkValidateApplicationVersionResponse

type ServiceFlinkValidateApplicationVersionSinkOut added in v0.36.0 

type ServiceFlinkValidateApplicationVersionSinkOut 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 ServiceFlinkValidateApplicationVersionSourceOut added in v0.36.0 

type ServiceFlinkValidateApplicationVersionSourceOut 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 SinkIn 

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

type SinkOut 

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 SourceIn 

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

type SourceOut 

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 StatementErrorOut 

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

StatementErrorOut Job validation error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.