Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

flink

package module

Go to main page

Versions in this module

v0

v0.1.4

Feb 3, 2026

v0.1.3

Sep 20, 2025

v0.1.2

Sep 18, 2025

Changes in this version

+ const ResultKindSuccess

+ const ResultKindSuccessWithContent

+ const ResultTypeEOS

+ const ResultTypeNotReady

+ const ResultTypePayload

+ func NewConnector(options ...ConnOption) (driver.Connector, error)

+ type APIResponse struct

+ Versions []string

+ type Client struct

+ APIVersion string

+ BaseURL *url.URL

+ HTTPClient *http.Client

+ func NewClient(baseURL string, httpClient *http.Client, apiVersion string) (*Client, error)

+ func (c *Client) CancelOperation(ctx context.Context, sessionHandle, operationHandle string) (string, error)

+ func (c *Client) CloseOperation(ctx context.Context, sessionHandle, operationHandle string) (string, error)

+ func (c *Client) CloseSession(ctx context.Context, sessionHandle string) error

+ func (c *Client) CompleteStatement(ctx context.Context, sessionHandle string, reqBody *CompleteStatementRequest) ([]string, error)

+ func (c *Client) ConfigureSession(ctx context.Context, sessionHandle string, reqBody *ConfigureSessionRequest) error

+ func (c *Client) ExecuteStatement(ctx context.Context, sessionHandle string, reqBody *ExecuteStatementRequest) (string, error)

+ func (c *Client) FetchResults(ctx context.Context, sessionHandle, operationHandle, token string, ...) (*FetchResultsResponseBody, error)

+ func (c *Client) GetAPIVersions(ctx context.Context) ([]string, error)

+ func (c *Client) GetInfo(ctx context.Context) (*InfoResponse, error)

+ func (c *Client) GetOperationStatus(ctx context.Context, sessionHandle, operationHandle string) (string, error)

+ func (c *Client) GetSessionConfig(ctx context.Context, sessionHandle string) (map[string]string, error)

+ func (c *Client) Heartbeat(ctx context.Context, sessionHandle string) error

+ func (c *Client) OpenSession(ctx context.Context, reqBody *OpenSessionRequest) (string, error)

+ func (c *Client) RefreshMaterializedTable(ctx context.Context, sessionHandle, identifier string, ...) (string, error)

+ type ColumnInfo struct

+ Comment string

+ LogicalType LogicalType

+ Name string

+ type CompleteStatementRequest struct

+ Position int

+ Statement string

+ type CompleteStatementResponse struct

+ Candidates []string

+ type ConfigureSessionRequest struct

+ ExecutionTimeout int64

+ Statement string

+ type ConnConfig struct

+ APIVersion string

+ Client *http.Client

+ GatewayURL string

+ Properties map[string]string

+ func WithDefaults() *ConnConfig

+ type ConnOption func(c *ConnConfig)

+ func WithAPIVersion(apiVersion string) ConnOption

+ func WithClient(client *http.Client) ConnOption

+ func WithGatewayURL(gatewayUrl string) ConnOption

+ func WithProperties(properties map[string]string) ConnOption

+ type ExecuteStatementRequest struct

+ ExecutionConfig map[string]string

+ ExecutionTimeout int64

+ Statement string

+ type ExecuteStatementResponse struct

+ OperationHandle string

+ type FetchResultsResponseBody struct

+ IsQueryResult bool

+ JobID string

+ NextResultUri string

+ ResultKind ResultKind

+ ResultType ResultType

+ Results struct{ ... }

+ func (r *FetchResultsResponseBody) NextToken() string

+ type GatewayClient interface

+ CancelOperation func(ctx context.Context, sessionHandle, operationHandle string) (string, error)

+ CloseOperation func(ctx context.Context, sessionHandle, operationHandle string) (string, error)

+ CloseSession func(ctx context.Context, sessionHandle string) error

+ CompleteStatement func(ctx context.Context, sessionHandle string, reqBody *CompleteStatementRequest) ([]string, error)

+ ConfigureSession func(ctx context.Context, sessionHandle string, reqBody *ConfigureSessionRequest) error

+ ExecuteStatement func(ctx context.Context, sessionHandle string, reqBody *ExecuteStatementRequest) (string, error)

+ FetchResults func(ctx context.Context, sessionHandle, operationHandle, token string, ...) (*FetchResultsResponseBody, error)

+ GetAPIVersions func(ctx context.Context) ([]string, error)

+ GetInfo func(ctx context.Context) (*InfoResponse, error)

+ GetOperationStatus func(ctx context.Context, sessionHandle, operationHandle string) (string, error)

+ GetSessionConfig func(ctx context.Context, sessionHandle string) (map[string]string, error)

+ Heartbeat func(ctx context.Context, sessionHandle string) error

+ OpenSession func(ctx context.Context, reqBody *OpenSessionRequest) (string, error)

+ RefreshMaterializedTable func(ctx context.Context, sessionHandle, identifier string, ...) (string, error)

+ type InfoResponse struct

+ ProductName string

+ Version string

+ type LogicalType struct

+ Length *int64

+ Nullable bool

+ Precision *int

+ Resolution *string

+ Scale *int

+ Type string

+ func (lt *LogicalType) UnmarshalJSON(data []byte) error

+ type OpenSessionRequest struct

+ Properties map[string]string

+ SessionName string

+ type OpenSessionResponse struct

+ SessionHandle string

+ type OperationStatusResponse struct

+ Status string

+ type RefreshMaterializedTableRequest struct

+ DynamicOptions map[string]string

+ ExecutionConfig map[string]string

+ IsPeriodic bool

+ Periodic bool

+ ScheduleTime string

+ StaticPartitions map[string]string

+ type RefreshMaterializedTableResponse struct

+ OperationHandle string

+ type ResultKind string

+ type ResultType string

+ type RowData struct

+ Fields []json.RawMessage

+ Kind string

+ type Rows struct

+ func (r *Rows) Close() error

+ func (r *Rows) ColumnTypeDatabaseTypeName(index int) string

+ func (r *Rows) ColumnTypeLength(index int) (length int64, ok bool)

+ func (r *Rows) ColumnTypePrecisionScale(index int) (precision, scale int64, ok bool)

+ func (r *Rows) ColumnTypeScanType(index int) reflect.Type

+ func (r *Rows) Columns() []string

+ func (r *Rows) Next(dest []driver.Value) error

+ func (r *Rows) RowsColumnTypeNullable(index int) (nullable, ok bool)