storage

Documentation

Index

• type SQLiteStore
  • func NewSQLiteStore(dsn string) (*SQLiteStore, error)
  • func (s *SQLiteStore) Close() error
  • func (s *SQLiteStore) InsertEvent(ctx context.Context, e *history.Event) error
  • func (s *SQLiteStore) InsertEvents(ctx context.Context, events []*history.Event) error

Types

type SQLiteStore

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

SQLiteStore represents the SQLite database storage for history events.

func NewSQLiteStore

func NewSQLiteStore(dsn string) (*SQLiteStore, error)

NewSQLiteStore initializes a new SQLite connection and schema.

func (*SQLiteStore) Close

func (s *SQLiteStore) Close() error

Close closes the database connection.

func (*SQLiteStore) InsertEvent

func (s *SQLiteStore) InsertEvent(ctx context.Context, e *history.Event) error

InsertEvent inserts a single history event with retry logic.

func (*SQLiteStore) InsertEvents

func (s *SQLiteStore) InsertEvents(ctx context.Context, events []*history.Event) error

InsertEvents performs a batch insert wrapped in a transaction.