Documentation
¶
Index ¶
- func MigrateDown(ctx context.Context, conn *sql.DB, n int) error
- type AcknowledgeMessagesParams
- type CountRecentTodoItemsBySessionParams
- type CreateReviewSessionParams
- type CreateTodoItemParams
- type DB
- type DBTX
- type DeleteOldestMessagesInTopicParams
- type DeleteReviewSessionsByDocPathParams
- type FinalizeReviewSessionParams
- type GetAllActiveSessionsWithCountsRow
- type GetReviewSessionByDocPathAndHashParams
- type GetUnreadMessagesParams
- type InsertNotificationParams
- type KVSetParams
- type KvStore
- type Message
- type MessageRead
- type Migration
- type Notification
- type OpenOptions
- type PublishMessageParams
- type Queries
- func (q *Queries) AcknowledgeMessages(ctx context.Context, arg AcknowledgeMessagesParams) error
- func (q *Queries) CountMessagesInTopic(ctx context.Context, topic string) (int64, error)
- func (q *Queries) CountNotifications(ctx context.Context) (int64, error)
- func (q *Queries) CountOpenTodoItems(ctx context.Context) (int64, error)
- func (q *Queries) CountPendingTodoItems(ctx context.Context) (int64, error)
- func (q *Queries) CountPrunableMessages(ctx context.Context, createdAt int64) (int64, error)
- func (q *Queries) CountRecentTodoItemsBySession(ctx context.Context, arg CountRecentTodoItemsBySessionParams) (int64, error)
- func (q *Queries) CreateReviewSession(ctx context.Context, arg CreateReviewSessionParams) error
- func (q *Queries) CreateTodoItem(ctx context.Context, arg CreateTodoItemParams) error
- func (q *Queries) DeleteAllNotifications(ctx context.Context) error
- func (q *Queries) DeleteOldestMessagesInTopic(ctx context.Context, arg DeleteOldestMessagesInTopicParams) error
- func (q *Queries) DeleteReviewComment(ctx context.Context, id string) error
- func (q *Queries) DeleteReviewSession(ctx context.Context, id string) error
- func (q *Queries) DeleteReviewSessionsByDocPath(ctx context.Context, arg DeleteReviewSessionsByDocPathParams) error
- func (q *Queries) DeleteSession(ctx context.Context, id string) error
- func (q *Queries) DeleteTodoItem(ctx context.Context, id string) error
- func (q *Queries) FinalizeReviewSession(ctx context.Context, arg FinalizeReviewSessionParams) error
- func (q *Queries) FindRecyclableSession(ctx context.Context, remote string) (Session, error)
- func (q *Queries) GetAllActiveSessionsWithCounts(ctx context.Context) ([]GetAllActiveSessionsWithCountsRow, error)
- func (q *Queries) GetReviewSessionByDocPath(ctx context.Context, documentPath string) (ReviewSession, error)
- func (q *Queries) GetReviewSessionByDocPathAndHash(ctx context.Context, arg GetReviewSessionByDocPathAndHashParams) (ReviewSession, error)
- func (q *Queries) GetSession(ctx context.Context, id string) (Session, error)
- func (q *Queries) GetTodoItem(ctx context.Context, id string) (TodoItem, error)
- func (q *Queries) GetUnreadMessages(ctx context.Context, arg GetUnreadMessagesParams) ([]Message, error)
- func (q *Queries) InsertNotification(ctx context.Context, arg InsertNotificationParams) (int64, error)
- func (q *Queries) KVDelete(ctx context.Context, key string) error
- func (q *Queries) KVGet(ctx context.Context, key string) (KvStore, error)
- func (q *Queries) KVGetRaw(ctx context.Context, key string) (KvStore, error)
- func (q *Queries) KVHas(ctx context.Context, key string) (int64, error)
- func (q *Queries) KVListKeys(ctx context.Context, expiresAt sql.NullInt64) ([]string, error)
- func (q *Queries) KVSet(ctx context.Context, arg KVSetParams) error
- func (q *Queries) KVSweepExpired(ctx context.Context, expiresAt sql.NullInt64) error
- func (q *Queries) ListNotifications(ctx context.Context) ([]Notification, error)
- func (q *Queries) ListReviewComments(ctx context.Context, sessionID string) ([]ReviewComment, error)
- func (q *Queries) ListSessions(ctx context.Context) ([]Session, error)
- func (q *Queries) ListTodoItems(ctx context.Context) ([]TodoItem, error)
- func (q *Queries) ListTodoItemsByStatus(ctx context.Context, status string) ([]TodoItem, error)
- func (q *Queries) ListTopics(ctx context.Context) ([]string, error)
- func (q *Queries) PruneMessages(ctx context.Context, createdAt int64) error
- func (q *Queries) PublishMessage(ctx context.Context, arg PublishMessageParams) error
- func (q *Queries) SaveReviewComment(ctx context.Context, arg SaveReviewCommentParams) error
- func (q *Queries) SaveSession(ctx context.Context, arg SaveSessionParams) error
- func (q *Queries) SubscribeToTopic(ctx context.Context, arg SubscribeToTopicParams) ([]Message, error)
- func (q *Queries) UpdateReviewComment(ctx context.Context, arg UpdateReviewCommentParams) error
- func (q *Queries) UpdateTodoItemStatus(ctx context.Context, arg UpdateTodoItemStatusParams) error
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type ReviewComment
- type ReviewSession
- type SaveReviewCommentParams
- type SaveSessionParams
- type Session
- type SubscribeToTopicParams
- type TodoItem
- type Topic
- type UpdateReviewCommentParams
- type UpdateTodoItemStatusParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CountRecentTodoItemsBySessionParams ¶ added in v0.34.0
type CreateTodoItemParams ¶ added in v0.34.0
type DB ¶
type DB struct {
// contains filtered or unexported fields
}
DB wraps a SQL database connection with sqlc queries.
func Open ¶
func Open(dataDir string, opts OpenOptions) (*DB, error)
Open creates a new database connection with the given options. The database file is created in the specified data directory. Uses minimal connection pool (default 2) to prevent transaction deadlocks while avoiding unnecessary connection overhead. WAL mode and busy_timeout handle concurrent access at the SQLite level.
type GetUnreadMessagesParams ¶
type KVSetParams ¶
type Message ¶
type Message struct {
ID string `json:"id"`
Topic string `json:"topic"`
Payload string `json:"payload"`
Sender sql.NullString `json:"sender"`
SessionID sql.NullString `json:"session_id"`
CreatedAt int64 `json:"created_at"`
}
type MessageRead ¶
type Migration ¶ added in v0.34.0
Migration represents a single versioned migration with up and down SQL.
type Notification ¶
type OpenOptions ¶
type OpenOptions struct {
MaxOpenConns int // max open connections (default: 2)
MaxIdleConns int // max idle connections (default: 2)
BusyTimeout int // busy timeout in milliseconds (default: 5000)
}
OpenOptions configures database connection settings.
func DefaultOpenOptions ¶
func DefaultOpenOptions() OpenOptions
DefaultOpenOptions returns the recommended defaults for SQLite.
type PublishMessageParams ¶
type PublishMessageParams struct {
ID string `json:"id"`
Topic string `json:"topic"`
Payload string `json:"payload"`
Sender sql.NullString `json:"sender"`
SessionID sql.NullString `json:"session_id"`
CreatedAt int64 `json:"created_at"`
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AcknowledgeMessages ¶
func (q *Queries) AcknowledgeMessages(ctx context.Context, arg AcknowledgeMessagesParams) error
func (*Queries) CountMessagesInTopic ¶
func (*Queries) CountNotifications ¶
func (*Queries) CountOpenTodoItems ¶ added in v0.34.0
func (*Queries) CountPendingTodoItems ¶ added in v0.34.0
func (*Queries) CountPrunableMessages ¶
func (*Queries) CountRecentTodoItemsBySession ¶ added in v0.34.0
func (*Queries) CreateReviewSession ¶
func (q *Queries) CreateReviewSession(ctx context.Context, arg CreateReviewSessionParams) error
func (*Queries) CreateTodoItem ¶ added in v0.34.0
func (q *Queries) CreateTodoItem(ctx context.Context, arg CreateTodoItemParams) error
Todo Items
func (*Queries) DeleteAllNotifications ¶
func (*Queries) DeleteOldestMessagesInTopic ¶
func (q *Queries) DeleteOldestMessagesInTopic(ctx context.Context, arg DeleteOldestMessagesInTopicParams) error
func (*Queries) DeleteReviewComment ¶
func (*Queries) DeleteReviewSession ¶
func (*Queries) DeleteReviewSessionsByDocPath ¶
func (q *Queries) DeleteReviewSessionsByDocPath(ctx context.Context, arg DeleteReviewSessionsByDocPathParams) error
func (*Queries) DeleteSession ¶
func (*Queries) DeleteTodoItem ¶ added in v0.34.0
func (*Queries) FinalizeReviewSession ¶
func (q *Queries) FinalizeReviewSession(ctx context.Context, arg FinalizeReviewSessionParams) error
func (*Queries) FindRecyclableSession ¶
func (*Queries) GetAllActiveSessionsWithCounts ¶
func (q *Queries) GetAllActiveSessionsWithCounts(ctx context.Context) ([]GetAllActiveSessionsWithCountsRow, error)
func (*Queries) GetReviewSessionByDocPath ¶
func (*Queries) GetReviewSessionByDocPathAndHash ¶
func (q *Queries) GetReviewSessionByDocPathAndHash(ctx context.Context, arg GetReviewSessionByDocPathAndHashParams) (ReviewSession, error)
func (*Queries) GetSession ¶
func (*Queries) GetTodoItem ¶ added in v0.34.0
func (*Queries) GetUnreadMessages ¶
func (*Queries) InsertNotification ¶
func (*Queries) KVListKeys ¶
func (*Queries) KVSweepExpired ¶
func (*Queries) ListNotifications ¶
func (q *Queries) ListNotifications(ctx context.Context) ([]Notification, error)
func (*Queries) ListReviewComments ¶
func (*Queries) ListSessions ¶
func (*Queries) ListTodoItems ¶ added in v0.34.0
func (*Queries) ListTodoItemsByStatus ¶ added in v0.34.0
func (*Queries) PruneMessages ¶
func (*Queries) PublishMessage ¶
func (q *Queries) PublishMessage(ctx context.Context, arg PublishMessageParams) error
func (*Queries) SaveReviewComment ¶
func (q *Queries) SaveReviewComment(ctx context.Context, arg SaveReviewCommentParams) error
func (*Queries) SaveSession ¶
func (q *Queries) SaveSession(ctx context.Context, arg SaveSessionParams) error
func (*Queries) SubscribeToTopic ¶
func (*Queries) UpdateReviewComment ¶
func (q *Queries) UpdateReviewComment(ctx context.Context, arg UpdateReviewCommentParams) error
func (*Queries) UpdateTodoItemStatus ¶ added in v0.34.0
func (q *Queries) UpdateTodoItemStatus(ctx context.Context, arg UpdateTodoItemStatusParams) error
type ReviewComment ¶
type ReviewSession ¶
type SaveReviewCommentParams ¶
type SaveSessionParams ¶
type SaveSessionParams struct {
ID string `json:"id"`
Name string `json:"name"`
Slug string `json:"slug"`
Path string `json:"path"`
Remote string `json:"remote"`
State string `json:"state"`
Metadata sql.NullString `json:"metadata"`
CreatedAt int64 `json:"created_at"`
UpdatedAt int64 `json:"updated_at"`
}
type SubscribeToTopicParams ¶
type TodoItem ¶ added in v0.34.0
type TodoItem struct {
ID string `json:"id"`
SessionID string `json:"session_id"`
Source string `json:"source"`
Title string `json:"title"`
Uri string `json:"uri"`
Status string `json:"status"`
CreatedAt int64 `json:"created_at"`
UpdatedAt int64 `json:"updated_at"`
CompletedAt int64 `json:"completed_at"`
}
type Topic ¶
type Topic struct {
Name string `json:"name"`
UpdatedAt interface{} `json:"updated_at"`
}
Click to show internal directories.
Click to hide internal directories.