octosql: github.com/cube2222/octosql/storage/postgres Index | Files

package postgres

import "github.com/cube2222/octosql/storage/postgres"


Package Files

datasource.go translator.go

func NewDataSourceBuilderFactory Uses

func NewDataSourceBuilderFactory(primaryKeys []octosql.VariableName) physical.DataSourceBuilderFactory

func NewDataSourceBuilderFactoryFromConfig Uses

func NewDataSourceBuilderFactoryFromConfig(dbConfig map[string]interface{}) (physical.DataSourceBuilderFactory, error)

NewDataSourceBuilderFactoryFromConfig creates a data source builder factory using the configuration.

type DataSource Uses

type DataSource struct {
    // contains filtered or unexported fields

func (*DataSource) Get Uses

func (ds *DataSource) Get(ctx context.Context, variables octosql.Variables) (execution.RecordStream, error)

type RecordStream Uses

type RecordStream struct {
    // contains filtered or unexported fields

func (*RecordStream) Close Uses

func (rs *RecordStream) Close() error

func (*RecordStream) Next Uses

func (rs *RecordStream) Next(ctx context.Context) (*execution.Record, error)

Package postgres imports 12 packages (graph) and is imported by 1 packages. Updated 2020-01-20. Refresh now. Tools for package owners.