Versions in this module Expand all Collapse all v1 v1.2.1 Feb 16, 2022 v1.2.0 Feb 2, 2022 v1.1.0 May 11, 2021 Changes in this version type Connection + Timeout time.Duration v1.0.0 May 6, 2020 Changes in this version + var DefaultOptions = Options + type Connection struct + Host string + Port int + func Connect(ctx context.Context, host string, port int, options Options) (*Connection, error) + func (c *Connection) Close() error + func (c *Connection) CloseInsert(ctx context.Context, handle *beeswax.QueryHandle) (map[string]int64, error) + func (c *Connection) CloseQuery(ctx context.Context, handle *beeswax.QueryHandle) error + func (c *Connection) ExecuteAndWait(ctx context.Context, query string) (RowSet, error) + func (c *Connection) Query(ctx context.Context, query string) (RowSet, error) + type Options struct + BatchSize int64 + PollIntervalSeconds float64 + type RowSet interface + Cancel func() error + Columns func() []string + FetchAll func() []map[string]interface{} + GetRow func() ([]string, error) + Handle func() *beeswax.QueryHandle + MapScan func(dest map[string]interface{}) error + Next func() bool + Poll func() (*Status, error) + Scan func(dest ...interface{}) error + Wait func() (*Status, error) + type Status struct + Error error + func (s *Status) IsComplete() bool + func (s *Status) IsSuccess() bool
Go to main page