sqlstream

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

Functions

func NewSimpleSQLMapStream

func NewSimpleSQLMapStream(
	selectCtx drm.PreparedStatementCtx,
	insertContainer tableinsertioncontainer.TableInsertionContainer,
	drmCfg drm.Config,
	sqlEngine sqlengine.SQLEngine,
) 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