store

package

v1.1.0 Latest Latest Go to latest Published: Jul 25, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Package store owns the SQLite database: schema migrations, config entity CRUD, and the connection shared with the queue implementation.

This section is empty.

This section is empty.

This section is empty.

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

func Open(path string) (*Store, error)

func (s *Store) Close() error

func (s *Store) DB() *sql.DB

func (s *Store) DeleteConnector(ctx context.Context, id string) error

func (s *Store) DeleteSink(ctx context.Context, id string) error

func (s *Store) DeleteSource(ctx context.Context, id string) error

func (s *Store) IsEmpty(ctx context.Context) (bool, error)

func (s *Store) KnownConnectorIDs(ctx context.Context) ([]string, error)

KnownConnectorIDs returns every connector id that has queue or checkpoint rows — used to purge storage of connectors deleted from config.

func (s *Store) LoadConfig(ctx context.Context) (model.Config, error)

func (s *Store) PutConnector(ctx context.Context, v model.Connector) error

func (s *Store) PutSink(ctx context.Context, v model.Sink) error

func (s *Store) PutSource(ctx context.Context, v model.Source) error

func (s *Store) ReplaceConfig(ctx context.Context, cfg model.Config) error

ReplaceConfig transactionally replaces the whole configuration.