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

mssql

package

v1.8.0 Latest Latest Go to latest Published: Sep 3, 2026 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

MSSQLSource implements the hermod.Source interface for MSSQL CDC.

func NewMSSQLSource(connString string, tables []string, autoEnableCDC bool, useCDC bool) *MSSQLSource

func (m *MSSQLSource) Ack(ctx context.Context, msg hermod.Message) error

func (m *MSSQLSource) Close() error

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

func (m *MSSQLSource) DiscoverDatabases(ctx context.Context) ([]string, error)

func (m *MSSQLSource) DiscoverTables(ctx context.Context) ([]string, error)

func (m *MSSQLSource) GetState() map[string]string

func (m *MSSQLSource) IsReady(ctx context.Context) error

func (m *MSSQLSource) Ping(ctx context.Context) error

func (m *MSSQLSource) Read(ctx context.Context) (hermod.Message, error)

func (m *MSSQLSource) Sample(ctx context.Context, table string) (hermod.Message, error)

func (m *MSSQLSource) SetLogger(logger hermod.Logger)

func (m *MSSQLSource) SetState(state map[string]string)

func (m *MSSQLSource) Snapshot(ctx context.Context, tables ...string) error