Documentation
¶
Index ¶
- type AcknowledgeMessagesParams
- type AddHCBlockerParams
- type CountHCItemsByStatusOlderThanParams
- type CountRecentTodoItemsBySessionParams
- type CreateHCItemParams
- type CreateReviewSessionParams
- type CreateTodoItemParams
- type DB
- type DBTX
- type DeleteHCItemsByStatusOlderThanParams
- type DeleteOldestMessagesInTopicParams
- type DeleteReviewSessionsByDocPathParams
- type DriveUpload
- type FinalizeReviewSessionParams
- type GetAllActiveSessionsWithCountsRow
- type GetReviewSessionByDocPathAndHashParams
- type GetUnreadMessagesParams
- type HCFingerprintRow
- type HcComment
- type HcItem
- type HcTaskBlocker
- type InsertHCCommentParams
- type InsertNotificationParams
- type KVSetParams
- type KvStore
- type ListDriveUploadsParams
- type ListHCItemsByEpicAndStatusParams
- type Message
- type MessageRead
- type NextHCItemForSessionInEpicParams
- type Notification
- type OpenOptions
- type PruneHCCommentsByStatusParams
- type PublishMessageParams
- type Queries
- func (q *Queries) AcknowledgeMessages(ctx context.Context, arg AcknowledgeMessagesParams) error
- func (q *Queries) AddHCBlocker(ctx context.Context, arg AddHCBlockerParams) error
- func (q *Queries) CountHCItemsByStatusOlderThan(ctx context.Context, arg CountHCItemsByStatusOlderThanParams) (int64, error)
- func (q *Queries) CountHCOpenChildren(ctx context.Context, parentID string) (int64, 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) CreateHCItem(ctx context.Context, arg CreateHCItemParams) 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) DeleteHCCommentsByItemID(ctx context.Context, itemID string) error
- func (q *Queries) DeleteHCItem(ctx context.Context, id string) error
- func (q *Queries) DeleteHCItemsByStatusOlderThan(ctx context.Context, arg DeleteHCItemsByStatusOlderThanParams) error
- func (q *Queries) DeleteOldestMessagesInTopic(ctx context.Context, arg DeleteOldestMessagesInTopicParams) error
- func (q *Queries) DeleteRecycledSession(ctx context.Context, id string) (int64, 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) GetAllActiveSessionsWithCounts(ctx context.Context) ([]GetAllActiveSessionsWithCountsRow, error)
- func (q *Queries) GetHCItem(ctx context.Context, id string) (HcItem, 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) HCFingerprint(ctx context.Context) (HCFingerprintRow, error)
- func (q *Queries) InsertHCComment(ctx context.Context, arg InsertHCCommentParams) (HcComment, 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) ListAllHCBlockerEdges(ctx context.Context) ([]HcTaskBlocker, error)
- func (q *Queries) ListAllHCItems(ctx context.Context) ([]HcItem, error)
- func (q *Queries) ListAllHCItemsByStatus(ctx context.Context, status hc.Status) ([]HcItem, error)
- func (q *Queries) ListDriveUploads(ctx context.Context, arg ListDriveUploadsParams) ([]DriveUpload, error)
- func (q *Queries) ListHCBlockedParentIDs(ctx context.Context) ([]string, error)
- func (q *Queries) ListHCBlockersForItem(ctx context.Context, blockedID string) ([]string, error)
- func (q *Queries) ListHCComments(ctx context.Context, itemID string) ([]HcComment, error)
- func (q *Queries) ListHCEpics(ctx context.Context) ([]HcItem, error)
- func (q *Queries) ListHCEpicsByRepo(ctx context.Context, repoKey string) ([]HcItem, error)
- func (q *Queries) ListHCExplicitlyBlockedIDs(ctx context.Context) ([]string, error)
- func (q *Queries) ListHCExplicitlyBlockedIDsWithBlockers(ctx context.Context, ids []string) ([]string, error)
- func (q *Queries) ListHCItemsBlockedBy(ctx context.Context, blockerID string) ([]string, error)
- func (q *Queries) ListHCItemsByEpic(ctx context.Context, epicID string) ([]HcItem, error)
- func (q *Queries) ListHCItemsByEpicAndStatus(ctx context.Context, arg ListHCItemsByEpicAndStatusParams) ([]HcItem, error)
- func (q *Queries) ListHCItemsByRepo(ctx context.Context, repoKey string) ([]HcItem, error)
- func (q *Queries) ListHCItemsBySession(ctx context.Context, sessionID string) ([]HcItem, error)
- func (q *Queries) ListHCOpenBlockerIDsForItem(ctx context.Context, blockedID string) ([]string, error)
- func (q *Queries) ListHCRepoKeys(ctx context.Context) ([]string, 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) NextHCItemForSession(ctx context.Context, sessionID string) (HcItem, error)
- func (q *Queries) NextHCItemForSessionInEpic(ctx context.Context, arg NextHCItemForSessionInEpicParams) (HcItem, error)
- func (q *Queries) PruneHCCommentsByStatus(ctx context.Context, arg PruneHCCommentsByStatusParams) error
- func (q *Queries) PruneMessages(ctx context.Context, createdAt int64) error
- func (q *Queries) PublishMessage(ctx context.Context, arg PublishMessageParams) error
- func (q *Queries) RemoveHCBlocker(ctx context.Context, arg RemoveHCBlockerParams) error
- func (q *Queries) ResumeHCItemForSession(ctx context.Context, sessionID string) (HcItem, error)
- func (q *Queries) ResumeHCItemForSessionInEpic(ctx context.Context, arg ResumeHCItemForSessionInEpicParams) (HcItem, 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) UpdateHCItem(ctx context.Context, arg UpdateHCItemParams) error
- func (q *Queries) UpdateHCItemStatusByEpicID(ctx context.Context, arg UpdateHCItemStatusByEpicIDParams) error
- func (q *Queries) UpdateReviewComment(ctx context.Context, arg UpdateReviewCommentParams) error
- func (q *Queries) UpdateTodoItemStatus(ctx context.Context, arg UpdateTodoItemStatusParams) error
- func (q *Queries) UpsertDriveUpload(ctx context.Context, arg UpsertDriveUploadParams) error
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type RemoveHCBlockerParams
- type ResumeHCItemForSessionInEpicParams
- type ReviewComment
- type ReviewSession
- type SaveReviewCommentParams
- type SaveSessionParams
- type Session
- type SubscribeToTopicParams
- type TodoItem
- type Topic
- type UpdateHCItemParams
- type UpdateHCItemStatusByEpicIDParams
- type UpdateReviewCommentParams
- type UpdateTodoItemStatusParams
- type UpsertDriveUploadParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddHCBlockerParams ¶
type CreateHCItemParams ¶
type CreateHCItemParams struct {
ID string `json:"id"`
RepoKey string `json:"repo_key"`
EpicID string `json:"epic_id"`
ParentID string `json:"parent_id"`
SessionID string `json:"session_id"`
Title string `json:"title"`
Desc string `json:"desc"`
Type hc.ItemType `json:"type"`
Status hc.Status `json:"status"`
Depth int64 `json:"depth"`
CreatedAt int64 `json:"created_at"`
UpdatedAt int64 `json:"updated_at"`
}
type CreateTodoItemParams ¶
type DB ¶
type DB struct {
*Queries
// contains filtered or unexported fields
}
DB wraps a SQL database connection with sqlc queries.
*Queries is embedded so a store can call a generated query on the DB it holds, including the transaction-bound DB that Ctx returns.
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.
func OpenForTest ¶ added in v0.69.0
OpenForTest opens a migrated database of the test's own, closed with the test. A test of the migrations themselves must use Open.
func (*DB) Conn ¶
Conn returns the underlying connection pool, even on a transaction-bound DB. Use WithinTx and the generated queries for transactional work rather than running raw SQL through this.
type DriveUpload ¶ added in v0.66.0
type GetUnreadMessagesParams ¶
type HCFingerprintRow ¶
type HcItem ¶
type HcItem struct {
ID string `json:"id"`
RepoKey string `json:"repo_key"`
EpicID string `json:"epic_id"`
ParentID string `json:"parent_id"`
SessionID string `json:"session_id"`
Title string `json:"title"`
Desc string `json:"desc"`
Type hc.ItemType `json:"type"`
Status hc.Status `json:"status"`
Depth int64 `json:"depth"`
CreatedAt int64 `json:"created_at"`
UpdatedAt int64 `json:"updated_at"`
}
type HcTaskBlocker ¶
type InsertHCCommentParams ¶
type KVSetParams ¶
type ListDriveUploadsParams ¶ added in v0.66.0
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 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) AddHCBlocker ¶
func (q *Queries) AddHCBlocker(ctx context.Context, arg AddHCBlockerParams) error
HC Task Blockers
func (*Queries) CountHCItemsByStatusOlderThan ¶
func (*Queries) CountHCOpenChildren ¶
func (*Queries) CountMessagesInTopic ¶
func (*Queries) CountNotifications ¶
func (*Queries) CountOpenTodoItems ¶
func (*Queries) CountPendingTodoItems ¶
func (*Queries) CountPrunableMessages ¶
func (*Queries) CountRecentTodoItemsBySession ¶
func (*Queries) CreateHCItem ¶
func (q *Queries) CreateHCItem(ctx context.Context, arg CreateHCItemParams) error
HC Items
func (*Queries) CreateReviewSession ¶
func (q *Queries) CreateReviewSession(ctx context.Context, arg CreateReviewSessionParams) error
func (*Queries) CreateTodoItem ¶
func (q *Queries) CreateTodoItem(ctx context.Context, arg CreateTodoItemParams) error
Todo Items
func (*Queries) DeleteAllNotifications ¶
func (*Queries) DeleteHCCommentsByItemID ¶
func (*Queries) DeleteHCItemsByStatusOlderThan ¶
func (q *Queries) DeleteHCItemsByStatusOlderThan(ctx context.Context, arg DeleteHCItemsByStatusOlderThanParams) error
func (*Queries) DeleteOldestMessagesInTopic ¶
func (q *Queries) DeleteOldestMessagesInTopic(ctx context.Context, arg DeleteOldestMessagesInTopicParams) error
func (*Queries) DeleteRecycledSession ¶ added in v0.68.0
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 ¶
func (*Queries) FinalizeReviewSession ¶
func (q *Queries) FinalizeReviewSession(ctx context.Context, arg FinalizeReviewSessionParams) error
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 ¶
func (*Queries) GetUnreadMessages ¶
func (*Queries) HCFingerprint ¶
func (q *Queries) HCFingerprint(ctx context.Context) (HCFingerprintRow, error)
func (*Queries) InsertHCComment ¶
func (q *Queries) InsertHCComment(ctx context.Context, arg InsertHCCommentParams) (HcComment, error)
HC Comments
func (*Queries) InsertNotification ¶
func (*Queries) KVListKeys ¶
func (*Queries) KVSweepExpired ¶
func (*Queries) ListAllHCBlockerEdges ¶
func (q *Queries) ListAllHCBlockerEdges(ctx context.Context) ([]HcTaskBlocker, error)
func (*Queries) ListAllHCItems ¶
func (*Queries) ListAllHCItemsByStatus ¶
func (*Queries) ListDriveUploads ¶ added in v0.66.0
func (q *Queries) ListDriveUploads(ctx context.Context, arg ListDriveUploadsParams) ([]DriveUpload, error)
func (*Queries) ListHCBlockedParentIDs ¶
func (*Queries) ListHCBlockersForItem ¶
func (*Queries) ListHCComments ¶
func (*Queries) ListHCEpicsByRepo ¶
func (*Queries) ListHCExplicitlyBlockedIDs ¶
func (*Queries) ListHCExplicitlyBlockedIDsWithBlockers ¶
func (*Queries) ListHCItemsBlockedBy ¶
func (*Queries) ListHCItemsByEpic ¶
func (*Queries) ListHCItemsByEpicAndStatus ¶
func (*Queries) ListHCItemsByRepo ¶
func (*Queries) ListHCItemsBySession ¶
func (*Queries) ListHCOpenBlockerIDsForItem ¶
func (*Queries) ListHCRepoKeys ¶
func (*Queries) ListNotifications ¶
func (q *Queries) ListNotifications(ctx context.Context) ([]Notification, error)
func (*Queries) ListReviewComments ¶
func (*Queries) ListSessions ¶
func (*Queries) ListTodoItems ¶
func (*Queries) ListTodoItemsByStatus ¶
func (*Queries) NextHCItemForSession ¶
func (*Queries) NextHCItemForSessionInEpic ¶
func (*Queries) PruneHCCommentsByStatus ¶
func (q *Queries) PruneHCCommentsByStatus(ctx context.Context, arg PruneHCCommentsByStatusParams) error
func (*Queries) PruneMessages ¶
func (*Queries) PublishMessage ¶
func (q *Queries) PublishMessage(ctx context.Context, arg PublishMessageParams) error
func (*Queries) RemoveHCBlocker ¶
func (q *Queries) RemoveHCBlocker(ctx context.Context, arg RemoveHCBlockerParams) error
func (*Queries) ResumeHCItemForSession ¶
func (*Queries) ResumeHCItemForSessionInEpic ¶
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) UpdateHCItem ¶
func (q *Queries) UpdateHCItem(ctx context.Context, arg UpdateHCItemParams) error
func (*Queries) UpdateHCItemStatusByEpicID ¶
func (q *Queries) UpdateHCItemStatusByEpicID(ctx context.Context, arg UpdateHCItemStatusByEpicIDParams) error
func (*Queries) UpdateReviewComment ¶
func (q *Queries) UpdateReviewComment(ctx context.Context, arg UpdateReviewCommentParams) error
func (*Queries) UpdateTodoItemStatus ¶
func (q *Queries) UpdateTodoItemStatus(ctx context.Context, arg UpdateTodoItemStatusParams) error
func (*Queries) UpsertDriveUpload ¶ added in v0.66.0
func (q *Queries) UpsertDriveUpload(ctx context.Context, arg UpsertDriveUploadParams) error
Drive uploads
type RemoveHCBlockerParams ¶
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"`
CloneStrategy string `json:"clone_strategy"`
Metadata sql.NullString `json:"metadata"`
Tags sql.NullString `json:"tags"`
CreatedAt int64 `json:"created_at"`
UpdatedAt int64 `json:"updated_at"`
}
type Session ¶
type Session 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"`
CloneStrategy string `json:"clone_strategy"`
Tags sql.NullString `json:"tags"`
}
type SubscribeToTopicParams ¶
type TodoItem ¶
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"`
}