Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.

sqlite

package

v1.7.4 Latest Latest Go to latest Published: Sep 2, 2026 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gsoultan/hermod

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type SQLiteSink
- func NewSQLiteSink(dbPath string, tableName string, mappings []sqlutil.ColumnMapping, ...) *SQLiteSink

Constants ¶

View Source

const (
	QueryUpsert      = "Upsert"
	QueryDelete      = "Delete"
	QueryListTables  = "ListTables"
	QueryBrowse      = "Browse"
	QueryCreateTable = "CreateTable"
	QueryListColumns = "ListColumns"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type SQLiteSink ¶

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

SQLiteSink implements the hermod.Sink interface for SQLite.

func NewSQLiteSink ¶

func NewSQLiteSink(dbPath string, tableName string, mappings []sqlutil.ColumnMapping, useExistingTable bool, deleteStrategy string, softDeleteColumn string, softDeleteValue string, operationMode string, autoTruncate bool, autoSync bool) *SQLiteSink

func (*SQLiteSink) Browse ¶

func (s *SQLiteSink) Browse(ctx context.Context, table string, limit int) ([]hermod.Message, error)

func (*SQLiteSink) Close ¶

func (s *SQLiteSink) Close() error

func (*SQLiteSink) DiscoverColumns ¶

func (s *SQLiteSink) DiscoverColumns(ctx context.Context, table string) ([]hermod.ColumnInfo, error)

func (*SQLiteSink) DiscoverDatabases ¶

func (s *SQLiteSink) DiscoverDatabases(ctx context.Context) ([]string, error)

func (*SQLiteSink) DiscoverTables ¶

func (s *SQLiteSink) DiscoverTables(ctx context.Context) ([]string, error)

func (*SQLiteSink) Ping ¶

func (s *SQLiteSink) Ping(ctx context.Context) error

func (*SQLiteSink) Sample ¶

func (s *SQLiteSink) Sample(ctx context.Context, table string) (hermod.Message, error)

func (*SQLiteSink) Write ¶

func (s *SQLiteSink) Write(ctx context.Context, msg hermod.Message) error

func (*SQLiteSink) WriteBatch ¶

func (s *SQLiteSink) WriteBatch(ctx context.Context, msgs []hermod.Message) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL