sql

Documentation

Index

• func GetLookupSource() api.Source
• func GetSink() api.Sink
• func GetSource() api.Source
• type SQLConf
• type SQLSinkConnector
  • func (s *SQLSinkConnector) Close(ctx api.StreamContext) error
  • func (s *SQLSinkConnector) Collect(ctx api.StreamContext, item api.MessageTuple) (err error)
  • func (s *SQLSinkConnector) CollectList(ctx api.StreamContext, items api.MessageTupleList) (err error)
  • func (s *SQLSinkConnector) Connect(ctx api.StreamContext) error
  • func (s *SQLSinkConnector) Provision(ctx api.StreamContext, configs map[string]any) error
• type SQLSourceConnector
  • func (s *SQLSourceConnector) Close(ctx api.StreamContext) error
  • func (s *SQLSourceConnector) Connect(ctx api.StreamContext) error
  • func (s *SQLSourceConnector) GetOffset() (interface{}, error)
  • func (s *SQLSourceConnector) Provision(ctx api.StreamContext, props map[string]any) error
  • func (s *SQLSourceConnector) Pull(ctx api.StreamContext, recvTime time.Time, ingest api.TupleIngest, ...)
  • func (s *SQLSourceConnector) ResetOffset(input map[string]interface{}) error
  • func (s *SQLSourceConnector) Rewind(offset interface{}) error
• type SqlLookupSource
  • func (s *SqlLookupSource) Close(ctx api.StreamContext) error
  • func (s *SqlLookupSource) Connect(ctx api.StreamContext) error
  • func (s *SqlLookupSource) Lookup(ctx api.StreamContext, fields []string, keys []string, values []any) ([]map[string]any, error)
  • func (s *SqlLookupSource) Ping(_ string, m map[string]interface{}) error
  • func (s *SqlLookupSource) Provision(ctx api.StreamContext, configs map[string]any) error

Functions

func GetLookupSource

func GetLookupSource() api.Source

func GetSink

func GetSink() api.Sink

func GetSource

func GetSource() api.Source

Types

type SQLConf

type SQLConf struct {
	Interval   cast.DurationConf `json:"interval"`
	DBUrl      string            `json:"dburl"`
	URL        string            `json:"url,omitempty"`
	Datasource string            `json:"datasource"`
}

type SQLSinkConnector

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

func (*SQLSinkConnector) Close

func (s *SQLSinkConnector) Close(ctx api.StreamContext) error

func (*SQLSinkConnector) Collect

func (s *SQLSinkConnector) Collect(ctx api.StreamContext, item api.MessageTuple) (err error)

func (*SQLSinkConnector) CollectList

func (s *SQLSinkConnector) CollectList(ctx api.StreamContext, items api.MessageTupleList) (err error)

func (*SQLSinkConnector) Connect

func (s *SQLSinkConnector) Connect(ctx api.StreamContext) error

func (*SQLSinkConnector) Provision

func (s *SQLSinkConnector) Provision(ctx api.StreamContext, configs map[string]any) error

type SQLSourceConnector

type SQLSourceConnector struct {
	Query sqlgen.SqlQueryGenerator
	// contains filtered or unexported fields
}

func (*SQLSourceConnector) Close

func (s *SQLSourceConnector) Close(ctx api.StreamContext) error

func (*SQLSourceConnector) Connect

func (s *SQLSourceConnector) Connect(ctx api.StreamContext) error

func (*SQLSourceConnector) GetOffset

func (s *SQLSourceConnector) GetOffset() (interface{}, error)

func (*SQLSourceConnector) Provision

func (s *SQLSourceConnector) Provision(ctx api.StreamContext, props map[string]any) error

func (*SQLSourceConnector) Pull

func (s *SQLSourceConnector) Pull(ctx api.StreamContext, recvTime time.Time, ingest api.TupleIngest, ingestError api.ErrorIngest)

func (*SQLSourceConnector) ResetOffset

func (s *SQLSourceConnector) ResetOffset(input map[string]interface{}) error

func (*SQLSourceConnector) Rewind

func (s *SQLSourceConnector) Rewind(offset interface{}) error

type SqlLookupSource

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

func (*SqlLookupSource) Close

func (s *SqlLookupSource) Close(ctx api.StreamContext) error

func (*SqlLookupSource) Connect

func (s *SqlLookupSource) Connect(ctx api.StreamContext) error

func (*SqlLookupSource) Lookup

func (s *SqlLookupSource) Lookup(ctx api.StreamContext, fields []string, keys []string, values []any) ([]map[string]any, error)

func (*SqlLookupSource) Ping

func (s *SqlLookupSource) Ping(_ string, m map[string]interface{}) error

func (*SqlLookupSource) Provision

func (s *SqlLookupSource) Provision(ctx api.StreamContext, configs map[string]any) error