Function NewSQLiteStore

internal/storage/sqlite.go:32–34

(db *sql.DB)

}

func NewSQLiteStore(db *sql.DB) *SQLiteStore {
	return &SQLiteStore{db: db}
}

func (s *SQLiteStore) Store(ctx context.Context, ev event.Event) error {
	payload, _ := json.Marshal(json.RawMessage(ev.Payload))