lines

Documentation

Index

• func Creator(ctx context.Context, name string, options map[string]string) (physical.DatasourceImplementation, physical.Schema, error)
• type DatasourceExecuting
  • func (d *DatasourceExecuting) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

Functions

func Creator

func Creator(ctx context.Context, name string, options map[string]string) (physical.DatasourceImplementation, physical.Schema, error)

Types

type DatasourceExecuting

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

func (*DatasourceExecuting) Run

func (d *DatasourceExecuting) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error