Affected by 
Documentation
¶
Index ¶
- Constants
- 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, sc api.StatusChangeHandler) error
- func (s *SQLSinkConnector) Ping(ctx api.StreamContext, props map[string]any) 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, sc api.StatusChangeHandler) error
- func (s *SQLSourceConnector) GetOffset() (interface{}, error)
- func (s *SQLSourceConnector) Ping(ctx api.StreamContext, m map[string]any) 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, sc api.StatusChangeHandler) error
- func (s *SqlLookupSource) Lookup(ctx api.StreamContext, fields []string, keys []string, values []any) ([]map[string]any, error)
- func (s *SqlLookupSource) Ping(ctx api.StreamContext, m map[string]any) error
- func (s *SqlLookupSource) Provision(ctx api.StreamContext, configs map[string]any) error
Constants ¶
View Source
const ( LblInsert = "insert" LblUpdate = "update" LblDel = "del" )
View Source
const ( LblSql = "sql" LblReq = "req" LblReconn = "reconn" LblException = "exception" LblRecv = "recv" )
Variables ¶
This section is empty.
Functions ¶
func GetLookupSource ¶
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, sc api.StatusChangeHandler) error
func (*SQLSinkConnector) Ping ¶
func (s *SQLSinkConnector) Ping(ctx api.StreamContext, props map[string]any) 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, sc api.StatusChangeHandler) error
func (*SQLSourceConnector) GetOffset ¶
func (s *SQLSourceConnector) GetOffset() (interface{}, error)
func (*SQLSourceConnector) Ping ¶
func (s *SQLSourceConnector) Ping(ctx api.StreamContext, m map[string]any) 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, sc api.StatusChangeHandler) 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(ctx api.StreamContext, m map[string]any) error
func (*SqlLookupSource) Provision ¶
func (s *SqlLookupSource) Provision(ctx api.StreamContext, configs map[string]any) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.