Versions in this module Expand all Collapse all v1 v1.0.10 Aug 21, 2024 v1.0.9 Oct 24, 2022 Changes in this version + type CSVSink struct + func NewCSVSink(w io.Writer) *CSVSink + func NewCSVSinkWithDelimiter(w io.Writer, delimiter rune) *CSVSink + func (s *CSVSink) Close(ctx context.Context) error + func (s *CSVSink) Flush(ctx context.Context) error + func (s *CSVSink) WriteRow(ctx context.Context, values ...interface{}) error + type ConcurrentSink struct + func NewConcurrentSink(downStreamBuilder func(idx int) Sink, concurrency int) *ConcurrentSink + func (c *ConcurrentSink) Close(ctx context.Context) error + func (c *ConcurrentSink) Flush(ctx context.Context) error + func (c *ConcurrentSink) WriteRow(ctx context.Context, values ...interface{}) error + type SQLSink struct + func NewSQLSink(db *sql.DB, hint string, retryCount int, retryInterval time.Duration) *SQLSink + func (s *SQLSink) Close(ctx context.Context) error + func (s *SQLSink) Flush(ctx context.Context) error + func (s *SQLSink) WriteRow(ctx context.Context, values ...interface{}) error + type Sink interface + Close func(ctx context.Context) error + Flush func(ctx context.Context) error + WriteRow func(ctx context.Context, values ...interface{}) error
Go to main page