Documentation
¶
Index ¶
- func MigrateDown(ctx context.Context, conn *sql.DB, n int) error
- 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 FinalizeReviewSessionParams
- type GetAllActiveSessionsWithCountsRow
- type GetReviewSessionByDocPathAndHashParams
- type GetUnreadMessagesParams
- type HcComment
- type HcItem
- type HcTaskBlocker
- type InsertHCCommentParams
- type InsertNotificationParams
- type KVSetParams
- type KvStore
- type ListHCItemsByEpicAndStatusParams
- type Message
- type MessageRead
- type Migration
- 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) 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) 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) 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) 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AddHCBlockerParams ¶ added in v0.39.0
type CountHCItemsByStatusOlderThanParams ¶ added in v0.37.0
type CountRecentTodoItemsBySessionParams ¶ added in v0.34.0
type CreateHCItemParams ¶ added in v0.37.0
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 ¶ 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 DeleteHCItemsByStatusOlderThanParams ¶ added in v0.37.0
type GetUnreadMessagesParams ¶
type HcItem ¶ added in v0.37.0
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 ¶ added in v0.39.0
type InsertHCCommentParams ¶ added in v0.37.0
type KVSetParams ¶
type ListHCItemsByEpicAndStatusParams ¶ added in v0.37.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 Migration ¶ added in v0.34.0
Migration represents a single versioned migration with up and down SQL.
type NextHCItemForSessionInEpicParams ¶ added in v0.37.0
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 PruneHCCommentsByStatusParams ¶ added in v0.37.0
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 ¶ added in v0.39.0
func (q *Queries) AddHCBlocker(ctx context.Context, arg AddHCBlockerParams) error
HC Task Blockers
func (*Queries) CountHCItemsByStatusOlderThan ¶ added in v0.37.0
func (*Queries) CountHCOpenChildren ¶ added in v0.37.0
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) CreateHCItem ¶ added in v0.37.0
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 ¶ added in v0.34.0
func (q *Queries) CreateTodoItem(ctx context.Context, arg CreateTodoItemParams) error
Todo Items
func (*Queries) DeleteAllNotifications ¶
func (*Queries) DeleteHCCommentsByItemID ¶ added in v0.37.0
func (*Queries) DeleteHCItem ¶ added in v0.37.0
func (*Queries) DeleteHCItemsByStatusOlderThan ¶ added in v0.37.0
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) 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) 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) InsertHCComment ¶ added in v0.37.0
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 ¶ added in v0.39.0
func (q *Queries) ListAllHCBlockerEdges(ctx context.Context) ([]HcTaskBlocker, error)
func (*Queries) ListAllHCItems ¶ added in v0.37.0
func (*Queries) ListAllHCItemsByStatus ¶ added in v0.37.0
func (*Queries) ListHCBlockedParentIDs ¶ added in v0.37.0
func (*Queries) ListHCBlockersForItem ¶ added in v0.39.0
func (*Queries) ListHCComments ¶ added in v0.37.0
func (*Queries) ListHCEpics ¶ added in v0.37.0
func (*Queries) ListHCEpicsByRepo ¶ added in v0.37.0
func (*Queries) ListHCExplicitlyBlockedIDs ¶ added in v0.39.0
func (*Queries) ListHCExplicitlyBlockedIDsWithBlockers ¶ added in v0.39.0
func (*Queries) ListHCItemsBlockedBy ¶ added in v0.39.0
func (*Queries) ListHCItemsByEpic ¶ added in v0.37.0
func (*Queries) ListHCItemsByEpicAndStatus ¶ added in v0.37.0
func (*Queries) ListHCItemsByRepo ¶ added in v0.37.0
func (*Queries) ListHCItemsBySession ¶ added in v0.37.0
func (*Queries) ListHCOpenBlockerIDsForItem ¶ added in v0.39.0
func (*Queries) ListHCRepoKeys ¶ added in v0.38.0
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) NextHCItemForSession ¶ added in v0.37.0
func (*Queries) NextHCItemForSessionInEpic ¶ added in v0.37.0
func (*Queries) PruneHCCommentsByStatus ¶ added in v0.37.0
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 ¶ added in v0.39.0
func (q *Queries) RemoveHCBlocker(ctx context.Context, arg RemoveHCBlockerParams) error
func (*Queries) ResumeHCItemForSession ¶ added in v0.37.0
func (*Queries) ResumeHCItemForSessionInEpic ¶ added in v0.37.0
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 ¶ added in v0.37.0
func (q *Queries) UpdateHCItem(ctx context.Context, arg UpdateHCItemParams) error
func (*Queries) UpdateHCItemStatusByEpicID ¶ added in v0.39.0
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 ¶ added in v0.34.0
func (q *Queries) UpdateTodoItemStatus(ctx context.Context, arg UpdateTodoItemStatusParams) error
type RemoveHCBlockerParams ¶ added in v0.39.0
type ResumeHCItemForSessionInEpicParams ¶ added in v0.37.0
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"`
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"`
}
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"`
}
type UpdateHCItemParams ¶ added in v0.37.0
type UpdateHCItemStatusByEpicIDParams ¶ added in v0.39.0
Click to show internal directories.
Click to hide internal directories.