Versions in this module Expand all Collapse all v1 v1.0.0 Apr 19, 2023 Changes in this version + var ErrCursorNotFound = errors.New("cursor not found") + type CursorError struct + type DSN struct + type Loader struct + EntriesCount uint64 + func NewLoader(psqlDsn string, logger *zap.Logger, tracer logging.Tracer) (*Loader, error) + func (l *Loader) Delete(tableName string, primaryKey string) error + func (l *Loader) Flush(ctx context.Context, moduleHash string, cursor *sink.Cursor) (err error) + func (l *Loader) GetAvailableTablesInSchema() string + func (l *Loader) GetCursor(ctx context.Context, outputModuleHash string) (*sink.Cursor, error) + func (l *Loader) GetIdentifier() string + func (l *Loader) GetSchema() string + func (l *Loader) HasTable(tableName string) bool + func (l *Loader) Insert(tableName string, primaryKey string, data map[string]string) error + func (l *Loader) LoadTables() error + func (l *Loader) MarshalLogObject(encoder zapcore.ObjectEncoder) error + func (l *Loader) Setup(ctx context.Context, schemaFile string) error + func (l *Loader) Update(tableName string, primaryKey string, data map[string]string) error + func (l *Loader) UpdateCursorQuery(moduleHash string, c *sink.Cursor) string + func (l *Loader) WriteCursor(ctx context.Context, moduleHash string, c *sink.Cursor) error + type Operation struct + func (o *Operation) String() string + type OperationType string + const OperationTypeDelete + const OperationTypeInsert + const OperationTypeUpdate + type Queryable interface + type TypeGetter func(tableName string, columnName string) (reflect.Type, error)
Go to main page