Versions in this module Expand all Collapse all v1 v1.0.1 Jan 12, 2023 Changes in this version + const TimestampFormat + type Client struct + func NewClient(client thrift.TClient, log *log.Logger, opts *Options) *Client + func (c *Client) OpenSession(ctx context.Context) (*Session, error) + type ColDesc struct + ColumnTypeLength int64 + ColumnTypeNullable bool + ColumnTypePrecision int64 + ColumnTypeScale int64 + DatabaseTypeName string + Name string + ScanType reflect.Type + type Operation struct + func (op *Operation) Close(ctx context.Context) error + func (op *Operation) FetchResults(ctx context.Context, schema *TableSchema) (*ResultSet, error) + func (op *Operation) GetResultSetMetadata(ctx context.Context) (*TableSchema, error) + func (op *Operation) HasResultSet() bool + func (op *Operation) RowsAffected() float64 + type Options struct + MaxRows int64 + MemLimit string + QueryTimeout int + type RPCResponse interface + GetStatus func() *cli_service.TStatus + type ResultSet struct + func (rs *ResultSet) Next(dest []driver.Value) error + type Session struct + func (s *Session) Close(ctx context.Context) error + func (s *Session) ExecuteStatement(ctx context.Context, stmt string) (*Operation, error) + func (s *Session) Ping(ctx context.Context) error + type TableSchema struct + Columns []*ColDesc Other modules containing this package github.com/n0dev/go-impala/v2