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

package json

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


Package Files


func NewDataSourceBuilderFactory Uses

func NewDataSourceBuilderFactory() 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 json imports 12 packages (graph) and is imported by 1 packages. Updated 2019-11-30. Refresh now. Tools for package owners.