sqlstream

package

v0.12.718 Latest Latest Go to latest Published: Sep 22, 2026 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/stackql/stackql

Links

Open Source Insights

Documentation ¶

Index ¶

func NewSimpleSQLMapStream(selectCtx drm.PreparedStatementCtx, ...) streaming.MapStream
func NewStaticMapStream(payload []map[string]interface{}) streaming.MapStream
type SimpleSQLMapStream
- func (ss *SimpleSQLMapStream) Read() ([]map[string]interface{}, error)
- func (ss *SimpleSQLMapStream) Write(_ []map[string]interface{}) error
type StaticMapStream
- func (ss *StaticMapStream) Read() ([]map[string]interface{}, error)
- func (ss *StaticMapStream) Write(_ []map[string]interface{}) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewSimpleSQLMapStream ¶

func NewSimpleSQLMapStream(
	selectCtx drm.PreparedStatementCtx,
	insertContainer tableinsertioncontainer.TableInsertionContainer,
	drmCfg drm.Config,
	sqlEngine sqlengine.SQLEngine,
	staticParams map[string]interface{},
) streaming.MapStream

func NewStaticMapStream ¶

func NewStaticMapStream(
	payload []map[string]interface{},
) streaming.MapStream

Types ¶

type SimpleSQLMapStream ¶

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

func (*SimpleSQLMapStream) Read ¶

func (ss *SimpleSQLMapStream) Read() ([]map[string]interface{}, error)

func (*SimpleSQLMapStream) Write ¶

func (ss *SimpleSQLMapStream) Write(_ []map[string]interface{}) error

type StaticMapStream ¶

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

func (*StaticMapStream) Read ¶

func (ss *StaticMapStream) Read() ([]map[string]interface{}, error)

func (*StaticMapStream) Write ¶

func (ss *StaticMapStream) Write(_ []map[string]interface{}) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL