custom_storage

Documentation

Index

• func NewDataSourceBuilderFactory() physical.DataSourceBuilderFactory
• func NewDataSourceBuilderFactoryFromConfig(dbConfig map[string]interface{}) (physical.DataSourceBuilderFactory, error)
• type DataSource
  • func (ds *DataSource) Get(variables octosql.Variables) (execution.RecordStream, error)
• type RecordStream
  • func (rs *RecordStream) Close() error
  • func (rs *RecordStream) Next() (*execution.Record, error)

Functions

func NewDataSourceBuilderFactory

func NewDataSourceBuilderFactory() physical.DataSourceBuilderFactory

func NewDataSourceBuilderFactoryFromConfig

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

NewDataSourceBuilderFactoryFromConfig creates a data source builder factory using the configuration.

Types

type DataSource

type DataSource struct {
	// contains filtered or unexported fields
}

func (*DataSource) Get

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

type RecordStream

type RecordStream struct {
	// contains filtered or unexported fields
}

func (*RecordStream) Close

func (rs *RecordStream) Close() error

func (*RecordStream) Next

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