store

package

v0.3.14 Latest Latest Go to latest Published: Mar 28, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Store persists events to a local SQLite database.

func New(dbPath string) (*Store, error)

New opens (or creates) a SQLite database at the given path.

func (s *Store) Close() error

Close closes the database.

func (s *Store) EventCounts() (map[string]int, error)

EventCounts returns the count of each event type.

func (s *Store) GetState(key string) (string, error)

GetState retrieves a value from the state table.

func (s *Store) InsertEvent(evt events.Event) (int64, error)

InsertEvent stores a parsed event.

func (s *Store) MarkSynced(upToID int64) error

MarkSynced marks events as synced up to the given ID.

func (s *Store) SetState(key, value string) error

SetState upserts a key-value pair in the state table.

func (s *Store) TotalEvents() (int, error)

TotalEvents returns the total number of stored events.

func (s *Store) UnsyncedEvents(limit int) ([]StoredEvent, error)

UnsyncedEvents returns events that haven't been synced to SC Bridge yet.

type StoredEvent struct {
	ID        int64
	Type      string
	Source    string
	Timestamp string
	DataJSON  string
}

StoredEvent represents an event row from the database.