flinkapplicationversion

Documentation

Index

• type ColumnOut
• type FlinkApplicationVersionHandler
  • func NewHandler(doer doer) FlinkApplicationVersionHandler
  • func (h *FlinkApplicationVersionHandler) ServiceFlinkCreateApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkCreateApplicationVersionOut, error)
  • func (h *FlinkApplicationVersionHandler) ServiceFlinkDeleteApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkDeleteApplicationVersionOut, error)
  • func (h *FlinkApplicationVersionHandler) ServiceFlinkGetApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkGetApplicationVersionOut, error)
  • func (h *FlinkApplicationVersionHandler) ServiceFlinkValidateApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkValidateApplicationVersionOut, error)
• type Handler
• type PositionOut
• type ServiceFlinkCreateApplicationVersionIn
• type ServiceFlinkCreateApplicationVersionOut
• type ServiceFlinkDeleteApplicationVersionOut
• type ServiceFlinkGetApplicationVersionOut
• type ServiceFlinkValidateApplicationVersionIn
• type ServiceFlinkValidateApplicationVersionOut
• type SinkIn
• type SinkOut
• type SinkOutAlt
• type SourceIn
• type SourceOut
• type SourceOutAlt
• type StatementErrorOut

Types

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 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"`
	EndCharacterNumber int `json:"end_character_number"`
	EndLineNumber      int `json:"end_line_number"`
	LineNumber         int `json:"line_number"`
}

type ServiceFlinkCreateApplicationVersionIn

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

type ServiceFlinkCreateApplicationVersionOut

type ServiceFlinkCreateApplicationVersionOut 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 ServiceFlinkDeleteApplicationVersionOut

type ServiceFlinkDeleteApplicationVersionOut 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 ServiceFlinkGetApplicationVersionOut

type ServiceFlinkGetApplicationVersionOut 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 ServiceFlinkValidateApplicationVersionIn

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

type ServiceFlinkValidateApplicationVersionOut

type ServiceFlinkValidateApplicationVersionOut struct {
	Sinks          []SinkOutAlt       `json:"sinks"`
	Sources        []SourceOutAlt     `json:"sources"`
	Statement      string             `json:"statement,omitempty"`
	StatementError *StatementErrorOut `json:"statement_error,omitempty"`
}

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 SinkOutAlt

type SinkOutAlt struct {
	Columns       []ColumnOut    `json:"columns,omitempty"`
	CreateTable   string         `json:"create_table"`
	IntegrationId string         `json:"integration_id,omitempty"`
	Message       string         `json:"message,omitempty"`
	Options       map[string]any `json:"options,omitempty"`
	Position      *PositionOut   `json:"position,omitempty"`
	TableName     string         `json:"table_name,omitempty"`
}

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

type SourceOutAlt

type SourceOutAlt struct {
	Columns       []ColumnOut    `json:"columns,omitempty"`
	CreateTable   string         `json:"create_table"`
	IntegrationId string         `json:"integration_id,omitempty"`
	Message       string         `json:"message,omitempty"`
	Options       map[string]any `json:"options,omitempty"`
	Position      *PositionOut   `json:"position,omitempty"`
	TableName     string         `json:"table_name,omitempty"`
}

type StatementErrorOut

type StatementErrorOut struct {
	Message  string       `json:"message"`
	Position *PositionOut `json:"position,omitempty"`
}