Documentation
¶
Index ¶
- type ActivityWithPrometheus
- func (_d ActivityWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.ActivityID, ...) (ap1 *models.Activity, err error)
- func (_d ActivityWithPrometheus) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (ap1 *models.Activity, err error)
- func (_d ActivityWithPrometheus) ByProjectID(ctx context.Context, d models.DBTX, projectID models.ProjectID, ...) (aa1 []models.Activity, err error)
- func (_d ActivityWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.ActivityCreateParams) (ap1 *models.Activity, err error)
- func (_d ActivityWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.ActivityID) (ap1 *models.Activity, err error)
- func (_d ActivityWithPrometheus) Restore(ctx context.Context, d models.DBTX, id models.ActivityID) (err error)
- func (_d ActivityWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.ActivityID, ...) (ap1 *models.Activity, err error)
- type ActivityWithRetry
- func (_d ActivityWithRetry) ByID(ctx context.Context, d models.DBTX, id models.ActivityID, ...) (ap1 *models.Activity, err error)
- func (_d ActivityWithRetry) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (ap1 *models.Activity, err error)
- func (_d ActivityWithRetry) ByProjectID(ctx context.Context, d models.DBTX, projectID models.ProjectID, ...) (aa1 []models.Activity, err error)
- func (_d ActivityWithRetry) Create(ctx context.Context, d models.DBTX, params *models.ActivityCreateParams) (ap1 *models.Activity, err error)
- func (_d ActivityWithRetry) Delete(ctx context.Context, d models.DBTX, id models.ActivityID) (ap1 *models.Activity, err error)
- func (_d ActivityWithRetry) Restore(ctx context.Context, d models.DBTX, id models.ActivityID) (err error)
- func (_d ActivityWithRetry) Update(ctx context.Context, d models.DBTX, id models.ActivityID, ...) (ap1 *models.Activity, err error)
- type ActivityWithTimeout
- func (_d ActivityWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.ActivityID, ...) (ap1 *models.Activity, err error)
- func (_d ActivityWithTimeout) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (ap1 *models.Activity, err error)
- func (_d ActivityWithTimeout) ByProjectID(ctx context.Context, d models.DBTX, projectID models.ProjectID, ...) (aa1 []models.Activity, err error)
- func (_d ActivityWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.ActivityCreateParams) (ap1 *models.Activity, err error)
- func (_d ActivityWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.ActivityID) (ap1 *models.Activity, err error)
- func (_d ActivityWithTimeout) Restore(ctx context.Context, d models.DBTX, id models.ActivityID) (err error)
- func (_d ActivityWithTimeout) Update(ctx context.Context, d models.DBTX, id models.ActivityID, ...) (ap1 *models.Activity, err error)
- type ActivityWithTimeoutConfig
- type ActivityWithTracing
- func (_d ActivityWithTracing) ByID(ctx context.Context, d models.DBTX, id models.ActivityID, ...) (ap1 *models.Activity, err error)
- func (_d ActivityWithTracing) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (ap1 *models.Activity, err error)
- func (_d ActivityWithTracing) ByProjectID(ctx context.Context, d models.DBTX, projectID models.ProjectID, ...) (aa1 []models.Activity, err error)
- func (_d ActivityWithTracing) Create(ctx context.Context, d models.DBTX, params *models.ActivityCreateParams) (ap1 *models.Activity, err error)
- func (_d ActivityWithTracing) Delete(ctx context.Context, d models.DBTX, id models.ActivityID) (ap1 *models.Activity, err error)
- func (_d ActivityWithTracing) Restore(ctx context.Context, d models.DBTX, id models.ActivityID) (err error)
- func (_d ActivityWithTracing) Update(ctx context.Context, d models.DBTX, id models.ActivityID, ...) (ap1 *models.Activity, err error)
- type DemoTwoWorkItemWithPrometheus
- func (_d DemoTwoWorkItemWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoTwoWorkItemWithPrometheus) Create(ctx context.Context, d models.DBTX, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoTwoWorkItemWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- type DemoTwoWorkItemWithRetry
- func (_d DemoTwoWorkItemWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoTwoWorkItemWithRetry) Create(ctx context.Context, d models.DBTX, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoTwoWorkItemWithRetry) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- type DemoTwoWorkItemWithTimeout
- func (_d DemoTwoWorkItemWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoTwoWorkItemWithTimeout) Create(ctx context.Context, d models.DBTX, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoTwoWorkItemWithTimeout) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- type DemoTwoWorkItemWithTimeoutConfig
- type DemoTwoWorkItemWithTracing
- func (_d DemoTwoWorkItemWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoTwoWorkItemWithTracing) Create(ctx context.Context, d models.DBTX, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoTwoWorkItemWithTracing) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- type DemoWorkItemWithPrometheus
- func (_d DemoWorkItemWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoWorkItemWithPrometheus) Create(ctx context.Context, d models.DBTX, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoWorkItemWithPrometheus) Paginated(ctx context.Context, d models.DBTX, cursor models.WorkItemID, ...) (ca1 []models.CacheDemoWorkItem, err error)
- func (_d DemoWorkItemWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- type DemoWorkItemWithRetry
- func (_d DemoWorkItemWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoWorkItemWithRetry) Create(ctx context.Context, d models.DBTX, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoWorkItemWithRetry) Paginated(ctx context.Context, d models.DBTX, cursor models.WorkItemID, ...) (ca1 []models.CacheDemoWorkItem, err error)
- func (_d DemoWorkItemWithRetry) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- type DemoWorkItemWithTimeout
- func (_d DemoWorkItemWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoWorkItemWithTimeout) Create(ctx context.Context, d models.DBTX, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoWorkItemWithTimeout) Paginated(ctx context.Context, d models.DBTX, cursor models.WorkItemID, ...) (ca1 []models.CacheDemoWorkItem, err error)
- func (_d DemoWorkItemWithTimeout) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- type DemoWorkItemWithTimeoutConfig
- type DemoWorkItemWithTracing
- func (_d DemoWorkItemWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoWorkItemWithTracing) Create(ctx context.Context, d models.DBTX, ...) (wp1 *models.WorkItem, err error)
- func (_d DemoWorkItemWithTracing) Paginated(ctx context.Context, d models.DBTX, cursor models.WorkItemID, ...) (ca1 []models.CacheDemoWorkItem, err error)
- func (_d DemoWorkItemWithTracing) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- type KanbanStepWithPrometheus
- type KanbanStepWithRetry
- type KanbanStepWithTimeout
- type KanbanStepWithTimeoutConfig
- type KanbanStepWithTracing
- type NotificationWithPrometheus
- func (_d NotificationWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.NotificationCreateParams) (up1 *models.UserNotification, err error)
- func (_d NotificationWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.NotificationID) (np1 *models.Notification, err error)
- func (_d NotificationWithPrometheus) LatestNotifications(ctx context.Context, d models.DBTX, params *models.GetUserNotificationsParams) (ga1 []models.GetUserNotificationsRow, err error)
- func (_d NotificationWithPrometheus) PaginatedUserNotifications(ctx context.Context, d models.DBTX, userID models.UserID, ...) (ua1 []models.UserNotification, err error)
- type NotificationWithRetry
- func (_d NotificationWithRetry) Create(ctx context.Context, d models.DBTX, params *models.NotificationCreateParams) (up1 *models.UserNotification, err error)
- func (_d NotificationWithRetry) Delete(ctx context.Context, d models.DBTX, id models.NotificationID) (np1 *models.Notification, err error)
- func (_d NotificationWithRetry) LatestNotifications(ctx context.Context, d models.DBTX, params *models.GetUserNotificationsParams) (ga1 []models.GetUserNotificationsRow, err error)
- func (_d NotificationWithRetry) PaginatedUserNotifications(ctx context.Context, d models.DBTX, userID models.UserID, ...) (ua1 []models.UserNotification, err error)
- type NotificationWithTimeout
- func (_d NotificationWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.NotificationCreateParams) (up1 *models.UserNotification, err error)
- func (_d NotificationWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.NotificationID) (np1 *models.Notification, err error)
- func (_d NotificationWithTimeout) LatestNotifications(ctx context.Context, d models.DBTX, params *models.GetUserNotificationsParams) (ga1 []models.GetUserNotificationsRow, err error)
- func (_d NotificationWithTimeout) PaginatedUserNotifications(ctx context.Context, d models.DBTX, userID models.UserID, ...) (ua1 []models.UserNotification, err error)
- type NotificationWithTimeoutConfig
- type NotificationWithTracing
- func (_d NotificationWithTracing) Create(ctx context.Context, d models.DBTX, params *models.NotificationCreateParams) (up1 *models.UserNotification, err error)
- func (_d NotificationWithTracing) Delete(ctx context.Context, d models.DBTX, id models.NotificationID) (np1 *models.Notification, err error)
- func (_d NotificationWithTracing) LatestNotifications(ctx context.Context, d models.DBTX, params *models.GetUserNotificationsParams) (ga1 []models.GetUserNotificationsRow, err error)
- func (_d NotificationWithTracing) PaginatedUserNotifications(ctx context.Context, d models.DBTX, userID models.UserID, ...) (ua1 []models.UserNotification, err error)
- type ProjectWithPrometheus
- func (_d ProjectWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.ProjectID, ...) (pp1 *models.Project, err error)
- func (_d ProjectWithPrometheus) ByName(ctx context.Context, d models.DBTX, name models.ProjectName, ...) (pp1 *models.Project, err error)
- func (_d ProjectWithPrometheus) IsTeamInProject(ctx context.Context, d models.DBTX, arg models.IsTeamInProjectParams) (b1 bool, err error)
- type ProjectWithRetry
- func (_d ProjectWithRetry) ByID(ctx context.Context, d models.DBTX, id models.ProjectID, ...) (pp1 *models.Project, err error)
- func (_d ProjectWithRetry) ByName(ctx context.Context, d models.DBTX, name models.ProjectName, ...) (pp1 *models.Project, err error)
- func (_d ProjectWithRetry) IsTeamInProject(ctx context.Context, d models.DBTX, arg models.IsTeamInProjectParams) (b1 bool, err error)
- type ProjectWithTimeout
- func (_d ProjectWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.ProjectID, ...) (pp1 *models.Project, err error)
- func (_d ProjectWithTimeout) ByName(ctx context.Context, d models.DBTX, name models.ProjectName, ...) (pp1 *models.Project, err error)
- func (_d ProjectWithTimeout) IsTeamInProject(ctx context.Context, d models.DBTX, arg models.IsTeamInProjectParams) (b1 bool, err error)
- type ProjectWithTimeoutConfig
- type ProjectWithTracing
- func (_d ProjectWithTracing) ByID(ctx context.Context, d models.DBTX, id models.ProjectID, ...) (pp1 *models.Project, err error)
- func (_d ProjectWithTracing) ByName(ctx context.Context, d models.DBTX, name models.ProjectName, ...) (pp1 *models.Project, err error)
- func (_d ProjectWithTracing) IsTeamInProject(ctx context.Context, d models.DBTX, arg models.IsTeamInProjectParams) (b1 bool, err error)
- type TeamWithPrometheus
- func (_d TeamWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.TeamID, ...) (tp1 *models.Team, err error)
- func (_d TeamWithPrometheus) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (tp1 *models.Team, err error)
- func (_d TeamWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.TeamCreateParams) (tp1 *models.Team, err error)
- func (_d TeamWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.TeamID) (tp1 *models.Team, err error)
- func (_d TeamWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.TeamID, ...) (tp1 *models.Team, err error)
- type TeamWithRetry
- func (_d TeamWithRetry) ByID(ctx context.Context, d models.DBTX, id models.TeamID, ...) (tp1 *models.Team, err error)
- func (_d TeamWithRetry) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (tp1 *models.Team, err error)
- func (_d TeamWithRetry) Create(ctx context.Context, d models.DBTX, params *models.TeamCreateParams) (tp1 *models.Team, err error)
- func (_d TeamWithRetry) Delete(ctx context.Context, d models.DBTX, id models.TeamID) (tp1 *models.Team, err error)
- func (_d TeamWithRetry) Update(ctx context.Context, d models.DBTX, id models.TeamID, ...) (tp1 *models.Team, err error)
- type TeamWithTimeout
- func (_d TeamWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.TeamID, ...) (tp1 *models.Team, err error)
- func (_d TeamWithTimeout) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (tp1 *models.Team, err error)
- func (_d TeamWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.TeamCreateParams) (tp1 *models.Team, err error)
- func (_d TeamWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.TeamID) (tp1 *models.Team, err error)
- func (_d TeamWithTimeout) Update(ctx context.Context, d models.DBTX, id models.TeamID, ...) (tp1 *models.Team, err error)
- type TeamWithTimeoutConfig
- type TeamWithTracing
- func (_d TeamWithTracing) ByID(ctx context.Context, d models.DBTX, id models.TeamID, ...) (tp1 *models.Team, err error)
- func (_d TeamWithTracing) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (tp1 *models.Team, err error)
- func (_d TeamWithTracing) Create(ctx context.Context, d models.DBTX, params *models.TeamCreateParams) (tp1 *models.Team, err error)
- func (_d TeamWithTracing) Delete(ctx context.Context, d models.DBTX, id models.TeamID) (tp1 *models.Team, err error)
- func (_d TeamWithTracing) Update(ctx context.Context, d models.DBTX, id models.TeamID, ...) (tp1 *models.Team, err error)
- type TimeEntryWithPrometheus
- func (_d TimeEntryWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.TimeEntryID, ...) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.TimeEntryCreateParams) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.TimeEntryID) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.TimeEntryID, ...) (tp1 *models.TimeEntry, err error)
- type TimeEntryWithRetry
- func (_d TimeEntryWithRetry) ByID(ctx context.Context, d models.DBTX, id models.TimeEntryID, ...) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithRetry) Create(ctx context.Context, d models.DBTX, params *models.TimeEntryCreateParams) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithRetry) Delete(ctx context.Context, d models.DBTX, id models.TimeEntryID) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithRetry) Update(ctx context.Context, d models.DBTX, id models.TimeEntryID, ...) (tp1 *models.TimeEntry, err error)
- type TimeEntryWithTimeout
- func (_d TimeEntryWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.TimeEntryID, ...) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.TimeEntryCreateParams) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.TimeEntryID) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithTimeout) Update(ctx context.Context, d models.DBTX, id models.TimeEntryID, ...) (tp1 *models.TimeEntry, err error)
- type TimeEntryWithTimeoutConfig
- type TimeEntryWithTracing
- func (_d TimeEntryWithTracing) ByID(ctx context.Context, d models.DBTX, id models.TimeEntryID, ...) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithTracing) Create(ctx context.Context, d models.DBTX, params *models.TimeEntryCreateParams) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithTracing) Delete(ctx context.Context, d models.DBTX, id models.TimeEntryID) (tp1 *models.TimeEntry, err error)
- func (_d TimeEntryWithTracing) Update(ctx context.Context, d models.DBTX, id models.TimeEntryID, ...) (tp1 *models.TimeEntry, err error)
- type UserWithPrometheus
- func (_d UserWithPrometheus) ByAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.User, err error)
- func (_d UserWithPrometheus) ByEmail(ctx context.Context, d models.DBTX, email string, ...) (up1 *models.User, err error)
- func (_d UserWithPrometheus) ByExternalID(ctx context.Context, d models.DBTX, extID string, ...) (up1 *models.User, err error)
- func (_d UserWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.UserID, ...) (up1 *models.User, err error)
- func (_d UserWithPrometheus) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID) (ua1 []models.User, err error)
- func (_d UserWithPrometheus) ByTeam(ctx context.Context, d models.DBTX, teamID models.TeamID) (ua1 []models.User, err error)
- func (_d UserWithPrometheus) ByUsername(ctx context.Context, d models.DBTX, username string, ...) (up1 *models.User, err error)
- func (_d UserWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.UserCreateParams) (up1 *models.User, err error)
- func (_d UserWithPrometheus) CreateAPIKey(ctx context.Context, d models.DBTX, user *models.User) (up1 *models.UserAPIKey, err error)
- func (_d UserWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.UserID) (up1 *models.User, err error)
- func (_d UserWithPrometheus) DeleteAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.UserAPIKey, err error)
- func (_d UserWithPrometheus) Paginated(ctx context.Context, d models.DBTX, ...) (ua1 []models.User, err error)
- func (_d UserWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.UserID, ...) (up1 *models.User, err error)
- type UserWithRetry
- func (_d UserWithRetry) ByAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.User, err error)
- func (_d UserWithRetry) ByEmail(ctx context.Context, d models.DBTX, email string, ...) (up1 *models.User, err error)
- func (_d UserWithRetry) ByExternalID(ctx context.Context, d models.DBTX, extID string, ...) (up1 *models.User, err error)
- func (_d UserWithRetry) ByID(ctx context.Context, d models.DBTX, id models.UserID, ...) (up1 *models.User, err error)
- func (_d UserWithRetry) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID) (ua1 []models.User, err error)
- func (_d UserWithRetry) ByTeam(ctx context.Context, d models.DBTX, teamID models.TeamID) (ua1 []models.User, err error)
- func (_d UserWithRetry) ByUsername(ctx context.Context, d models.DBTX, username string, ...) (up1 *models.User, err error)
- func (_d UserWithRetry) Create(ctx context.Context, d models.DBTX, params *models.UserCreateParams) (up1 *models.User, err error)
- func (_d UserWithRetry) CreateAPIKey(ctx context.Context, d models.DBTX, user *models.User) (up1 *models.UserAPIKey, err error)
- func (_d UserWithRetry) Delete(ctx context.Context, d models.DBTX, id models.UserID) (up1 *models.User, err error)
- func (_d UserWithRetry) DeleteAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.UserAPIKey, err error)
- func (_d UserWithRetry) Paginated(ctx context.Context, d models.DBTX, ...) (ua1 []models.User, err error)
- func (_d UserWithRetry) Update(ctx context.Context, d models.DBTX, id models.UserID, ...) (up1 *models.User, err error)
- type UserWithTimeout
- func (_d UserWithTimeout) ByAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.User, err error)
- func (_d UserWithTimeout) ByEmail(ctx context.Context, d models.DBTX, email string, ...) (up1 *models.User, err error)
- func (_d UserWithTimeout) ByExternalID(ctx context.Context, d models.DBTX, extID string, ...) (up1 *models.User, err error)
- func (_d UserWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.UserID, ...) (up1 *models.User, err error)
- func (_d UserWithTimeout) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID) (ua1 []models.User, err error)
- func (_d UserWithTimeout) ByTeam(ctx context.Context, d models.DBTX, teamID models.TeamID) (ua1 []models.User, err error)
- func (_d UserWithTimeout) ByUsername(ctx context.Context, d models.DBTX, username string, ...) (up1 *models.User, err error)
- func (_d UserWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.UserCreateParams) (up1 *models.User, err error)
- func (_d UserWithTimeout) CreateAPIKey(ctx context.Context, d models.DBTX, user *models.User) (up1 *models.UserAPIKey, err error)
- func (_d UserWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.UserID) (up1 *models.User, err error)
- func (_d UserWithTimeout) DeleteAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.UserAPIKey, err error)
- func (_d UserWithTimeout) Paginated(ctx context.Context, d models.DBTX, ...) (ua1 []models.User, err error)
- func (_d UserWithTimeout) Update(ctx context.Context, d models.DBTX, id models.UserID, ...) (up1 *models.User, err error)
- type UserWithTimeoutConfig
- type UserWithTracing
- func (_d UserWithTracing) ByAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.User, err error)
- func (_d UserWithTracing) ByEmail(ctx context.Context, d models.DBTX, email string, ...) (up1 *models.User, err error)
- func (_d UserWithTracing) ByExternalID(ctx context.Context, d models.DBTX, extID string, ...) (up1 *models.User, err error)
- func (_d UserWithTracing) ByID(ctx context.Context, d models.DBTX, id models.UserID, ...) (up1 *models.User, err error)
- func (_d UserWithTracing) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID) (ua1 []models.User, err error)
- func (_d UserWithTracing) ByTeam(ctx context.Context, d models.DBTX, teamID models.TeamID) (ua1 []models.User, err error)
- func (_d UserWithTracing) ByUsername(ctx context.Context, d models.DBTX, username string, ...) (up1 *models.User, err error)
- func (_d UserWithTracing) Create(ctx context.Context, d models.DBTX, params *models.UserCreateParams) (up1 *models.User, err error)
- func (_d UserWithTracing) CreateAPIKey(ctx context.Context, d models.DBTX, user *models.User) (up1 *models.UserAPIKey, err error)
- func (_d UserWithTracing) Delete(ctx context.Context, d models.DBTX, id models.UserID) (up1 *models.User, err error)
- func (_d UserWithTracing) DeleteAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.UserAPIKey, err error)
- func (_d UserWithTracing) Paginated(ctx context.Context, d models.DBTX, ...) (ua1 []models.User, err error)
- func (_d UserWithTracing) Update(ctx context.Context, d models.DBTX, id models.UserID, ...) (up1 *models.User, err error)
- type WorkItemCommentWithPrometheus
- func (_d WorkItemCommentWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, ...) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.WorkItemCommentCreateParams) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.WorkItemCommentID) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, ...) (wp1 *models.WorkItemComment, err error)
- type WorkItemCommentWithRetry
- func (_d WorkItemCommentWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, ...) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithRetry) Create(ctx context.Context, d models.DBTX, params *models.WorkItemCommentCreateParams) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithRetry) Delete(ctx context.Context, d models.DBTX, id models.WorkItemCommentID) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithRetry) Update(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, ...) (wp1 *models.WorkItemComment, err error)
- type WorkItemCommentWithTimeout
- func (_d WorkItemCommentWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, ...) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.WorkItemCommentCreateParams) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.WorkItemCommentID) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithTimeout) Update(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, ...) (wp1 *models.WorkItemComment, err error)
- type WorkItemCommentWithTimeoutConfig
- type WorkItemCommentWithTracing
- func (_d WorkItemCommentWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, ...) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithTracing) Create(ctx context.Context, d models.DBTX, params *models.WorkItemCommentCreateParams) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithTracing) Delete(ctx context.Context, d models.DBTX, id models.WorkItemCommentID) (wp1 *models.WorkItemComment, err error)
- func (_d WorkItemCommentWithTracing) Update(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, ...) (wp1 *models.WorkItemComment, err error)
- type WorkItemTagWithPrometheus
- func (_d WorkItemTagWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTagID, ...) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithPrometheus) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.WorkItemTagCreateParams) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.WorkItemTagID) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.WorkItemTagID, ...) (wp1 *models.WorkItemTag, err error)
- type WorkItemTagWithRetry
- func (_d WorkItemTagWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTagID, ...) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithRetry) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithRetry) Create(ctx context.Context, d models.DBTX, params *models.WorkItemTagCreateParams) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithRetry) Delete(ctx context.Context, d models.DBTX, id models.WorkItemTagID) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithRetry) Update(ctx context.Context, d models.DBTX, id models.WorkItemTagID, ...) (wp1 *models.WorkItemTag, err error)
- type WorkItemTagWithTimeout
- func (_d WorkItemTagWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTagID, ...) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithTimeout) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.WorkItemTagCreateParams) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.WorkItemTagID) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithTimeout) Update(ctx context.Context, d models.DBTX, id models.WorkItemTagID, ...) (wp1 *models.WorkItemTag, err error)
- type WorkItemTagWithTimeoutConfig
- type WorkItemTagWithTracing
- func (_d WorkItemTagWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTagID, ...) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithTracing) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithTracing) Create(ctx context.Context, d models.DBTX, params *models.WorkItemTagCreateParams) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithTracing) Delete(ctx context.Context, d models.DBTX, id models.WorkItemTagID) (wp1 *models.WorkItemTag, err error)
- func (_d WorkItemTagWithTracing) Update(ctx context.Context, d models.DBTX, id models.WorkItemTagID, ...) (wp1 *models.WorkItemTag, err error)
- type WorkItemTypeWithPrometheus
- func (_d WorkItemTypeWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTypeID, ...) (wp1 *models.WorkItemType, err error)
- func (_d WorkItemTypeWithPrometheus) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (wp1 *models.WorkItemType, err error)
- type WorkItemTypeWithRetry
- func (_d WorkItemTypeWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTypeID, ...) (wp1 *models.WorkItemType, err error)
- func (_d WorkItemTypeWithRetry) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (wp1 *models.WorkItemType, err error)
- type WorkItemTypeWithTimeout
- func (_d WorkItemTypeWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTypeID, ...) (wp1 *models.WorkItemType, err error)
- func (_d WorkItemTypeWithTimeout) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (wp1 *models.WorkItemType, err error)
- type WorkItemTypeWithTimeoutConfig
- type WorkItemTypeWithTracing
- func (_d WorkItemTypeWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTypeID, ...) (wp1 *models.WorkItemType, err error)
- func (_d WorkItemTypeWithTracing) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, ...) (wp1 *models.WorkItemType, err error)
- type WorkItemWithPrometheus
- func (_d WorkItemWithPrometheus) AssignTag(ctx context.Context, d models.DBTX, ...) (err error)
- func (_d WorkItemWithPrometheus) AssignUser(ctx context.Context, d models.DBTX, ...) (err error)
- func (_d WorkItemWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d WorkItemWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
- func (_d WorkItemWithPrometheus) RemoveAssignedUser(ctx context.Context, d models.DBTX, memberID models.UserID, ...) (err error)
- func (_d WorkItemWithPrometheus) RemoveTag(ctx context.Context, d models.DBTX, tagID models.WorkItemTagID, ...) (err error)
- func (_d WorkItemWithPrometheus) Restore(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
- type WorkItemWithRetry
- func (_d WorkItemWithRetry) AssignTag(ctx context.Context, d models.DBTX, ...) (err error)
- func (_d WorkItemWithRetry) AssignUser(ctx context.Context, d models.DBTX, ...) (err error)
- func (_d WorkItemWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d WorkItemWithRetry) Delete(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
- func (_d WorkItemWithRetry) RemoveAssignedUser(ctx context.Context, d models.DBTX, memberID models.UserID, ...) (err error)
- func (_d WorkItemWithRetry) RemoveTag(ctx context.Context, d models.DBTX, tagID models.WorkItemTagID, ...) (err error)
- func (_d WorkItemWithRetry) Restore(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
- type WorkItemWithTimeout
- func (_d WorkItemWithTimeout) AssignTag(ctx context.Context, d models.DBTX, ...) (err error)
- func (_d WorkItemWithTimeout) AssignUser(ctx context.Context, d models.DBTX, ...) (err error)
- func (_d WorkItemWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d WorkItemWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
- func (_d WorkItemWithTimeout) RemoveAssignedUser(ctx context.Context, d models.DBTX, memberID models.UserID, ...) (err error)
- func (_d WorkItemWithTimeout) RemoveTag(ctx context.Context, d models.DBTX, tagID models.WorkItemTagID, ...) (err error)
- func (_d WorkItemWithTimeout) Restore(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
- type WorkItemWithTimeoutConfig
- type WorkItemWithTracing
- func (_d WorkItemWithTracing) AssignTag(ctx context.Context, d models.DBTX, ...) (err error)
- func (_d WorkItemWithTracing) AssignUser(ctx context.Context, d models.DBTX, ...) (err error)
- func (_d WorkItemWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, ...) (wp1 *models.WorkItem, err error)
- func (_d WorkItemWithTracing) Delete(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
- func (_d WorkItemWithTracing) RemoveAssignedUser(ctx context.Context, d models.DBTX, memberID models.UserID, ...) (err error)
- func (_d WorkItemWithTracing) RemoveTag(ctx context.Context, d models.DBTX, tagID models.WorkItemTagID, ...) (err error)
- func (_d WorkItemWithTracing) Restore(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActivityWithPrometheus ¶
type ActivityWithPrometheus struct {
// contains filtered or unexported fields
}
ActivityWithPrometheus implements _sourceRepos.Activity interface with all methods wrapped with Prometheus metrics
func NewActivityWithPrometheus ¶
func NewActivityWithPrometheus(base _sourceRepos.Activity, instanceName string) ActivityWithPrometheus
NewActivityWithPrometheus returns an instance of the _sourceRepos.Activity decorated with prometheus summary metric
func (ActivityWithPrometheus) ByID ¶
func (_d ActivityWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.ActivityID, opts ...models.ActivitySelectConfigOption) (ap1 *models.Activity, err error)
ByID implements _sourceRepos.Activity
func (ActivityWithPrometheus) ByName ¶
func (_d ActivityWithPrometheus) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.ActivitySelectConfigOption) (ap1 *models.Activity, err error)
ByName implements _sourceRepos.Activity
func (ActivityWithPrometheus) ByProjectID ¶
func (_d ActivityWithPrometheus) ByProjectID(ctx context.Context, d models.DBTX, projectID models.ProjectID, opts ...models.ActivitySelectConfigOption) (aa1 []models.Activity, err error)
ByProjectID implements _sourceRepos.Activity
func (ActivityWithPrometheus) Create ¶
func (_d ActivityWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.ActivityCreateParams) (ap1 *models.Activity, err error)
Create implements _sourceRepos.Activity
func (ActivityWithPrometheus) Delete ¶
func (_d ActivityWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.ActivityID) (ap1 *models.Activity, err error)
Delete implements _sourceRepos.Activity
func (ActivityWithPrometheus) Restore ¶
func (_d ActivityWithPrometheus) Restore(ctx context.Context, d models.DBTX, id models.ActivityID) (err error)
Restore implements _sourceRepos.Activity
func (ActivityWithPrometheus) Update ¶
func (_d ActivityWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.ActivityID, params *models.ActivityUpdateParams) (ap1 *models.Activity, err error)
Update implements _sourceRepos.Activity
type ActivityWithRetry ¶
type ActivityWithRetry struct { _sourceRepos.Activity // contains filtered or unexported fields }
ActivityWithRetry implements _sourceRepos.Activity interface instrumented with retries
func NewActivityWithRetry ¶
func NewActivityWithRetry(base _sourceRepos.Activity, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) ActivityWithRetry
NewActivityWithRetry returns ActivityWithRetry
func (ActivityWithRetry) ByID ¶
func (_d ActivityWithRetry) ByID(ctx context.Context, d models.DBTX, id models.ActivityID, opts ...models.ActivitySelectConfigOption) (ap1 *models.Activity, err error)
ByID implements _sourceRepos.Activity
func (ActivityWithRetry) ByName ¶
func (_d ActivityWithRetry) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.ActivitySelectConfigOption) (ap1 *models.Activity, err error)
ByName implements _sourceRepos.Activity
func (ActivityWithRetry) ByProjectID ¶
func (_d ActivityWithRetry) ByProjectID(ctx context.Context, d models.DBTX, projectID models.ProjectID, opts ...models.ActivitySelectConfigOption) (aa1 []models.Activity, err error)
ByProjectID implements _sourceRepos.Activity
func (ActivityWithRetry) Create ¶
func (_d ActivityWithRetry) Create(ctx context.Context, d models.DBTX, params *models.ActivityCreateParams) (ap1 *models.Activity, err error)
Create implements _sourceRepos.Activity
func (ActivityWithRetry) Delete ¶
func (_d ActivityWithRetry) Delete(ctx context.Context, d models.DBTX, id models.ActivityID) (ap1 *models.Activity, err error)
Delete implements _sourceRepos.Activity
func (ActivityWithRetry) Restore ¶
func (_d ActivityWithRetry) Restore(ctx context.Context, d models.DBTX, id models.ActivityID) (err error)
Restore implements _sourceRepos.Activity
func (ActivityWithRetry) Update ¶
func (_d ActivityWithRetry) Update(ctx context.Context, d models.DBTX, id models.ActivityID, params *models.ActivityUpdateParams) (ap1 *models.Activity, err error)
Update implements _sourceRepos.Activity
type ActivityWithTimeout ¶
type ActivityWithTimeout struct { _sourceRepos.Activity // contains filtered or unexported fields }
ActivityWithTimeout implements _sourceRepos.Activity interface instrumented with timeouts
func NewActivityWithTimeout ¶
func NewActivityWithTimeout(base _sourceRepos.Activity, config ActivityWithTimeoutConfig) ActivityWithTimeout
NewActivityWithTimeout returns ActivityWithTimeout
func (ActivityWithTimeout) ByID ¶
func (_d ActivityWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.ActivityID, opts ...models.ActivitySelectConfigOption) (ap1 *models.Activity, err error)
ByID implements _sourceRepos.Activity
func (ActivityWithTimeout) ByName ¶
func (_d ActivityWithTimeout) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.ActivitySelectConfigOption) (ap1 *models.Activity, err error)
ByName implements _sourceRepos.Activity
func (ActivityWithTimeout) ByProjectID ¶
func (_d ActivityWithTimeout) ByProjectID(ctx context.Context, d models.DBTX, projectID models.ProjectID, opts ...models.ActivitySelectConfigOption) (aa1 []models.Activity, err error)
ByProjectID implements _sourceRepos.Activity
func (ActivityWithTimeout) Create ¶
func (_d ActivityWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.ActivityCreateParams) (ap1 *models.Activity, err error)
Create implements _sourceRepos.Activity
func (ActivityWithTimeout) Delete ¶
func (_d ActivityWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.ActivityID) (ap1 *models.Activity, err error)
Delete implements _sourceRepos.Activity
func (ActivityWithTimeout) Restore ¶
func (_d ActivityWithTimeout) Restore(ctx context.Context, d models.DBTX, id models.ActivityID) (err error)
Restore implements _sourceRepos.Activity
func (ActivityWithTimeout) Update ¶
func (_d ActivityWithTimeout) Update(ctx context.Context, d models.DBTX, id models.ActivityID, params *models.ActivityUpdateParams) (ap1 *models.Activity, err error)
Update implements _sourceRepos.Activity
type ActivityWithTracing ¶
type ActivityWithTracing struct { _sourceRepos.Activity // contains filtered or unexported fields }
ActivityWithTracing implements _sourceRepos.Activity interface instrumented with opentracing spans
func NewActivityWithTracing ¶
func NewActivityWithTracing(base _sourceRepos.Activity, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) ActivityWithTracing
NewActivityWithTracing returns ActivityWithTracing
func (ActivityWithTracing) ByID ¶
func (_d ActivityWithTracing) ByID(ctx context.Context, d models.DBTX, id models.ActivityID, opts ...models.ActivitySelectConfigOption) (ap1 *models.Activity, err error)
ByID implements _sourceRepos.Activity
func (ActivityWithTracing) ByName ¶
func (_d ActivityWithTracing) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.ActivitySelectConfigOption) (ap1 *models.Activity, err error)
ByName implements _sourceRepos.Activity
func (ActivityWithTracing) ByProjectID ¶
func (_d ActivityWithTracing) ByProjectID(ctx context.Context, d models.DBTX, projectID models.ProjectID, opts ...models.ActivitySelectConfigOption) (aa1 []models.Activity, err error)
ByProjectID implements _sourceRepos.Activity
func (ActivityWithTracing) Create ¶
func (_d ActivityWithTracing) Create(ctx context.Context, d models.DBTX, params *models.ActivityCreateParams) (ap1 *models.Activity, err error)
Create implements _sourceRepos.Activity
func (ActivityWithTracing) Delete ¶
func (_d ActivityWithTracing) Delete(ctx context.Context, d models.DBTX, id models.ActivityID) (ap1 *models.Activity, err error)
Delete implements _sourceRepos.Activity
func (ActivityWithTracing) Restore ¶
func (_d ActivityWithTracing) Restore(ctx context.Context, d models.DBTX, id models.ActivityID) (err error)
Restore implements _sourceRepos.Activity
func (ActivityWithTracing) Update ¶
func (_d ActivityWithTracing) Update(ctx context.Context, d models.DBTX, id models.ActivityID, params *models.ActivityUpdateParams) (ap1 *models.Activity, err error)
Update implements _sourceRepos.Activity
type DemoTwoWorkItemWithPrometheus ¶
type DemoTwoWorkItemWithPrometheus struct {
// contains filtered or unexported fields
}
DemoTwoWorkItemWithPrometheus implements _sourceRepos.DemoTwoWorkItem interface with all methods wrapped with Prometheus metrics
func NewDemoTwoWorkItemWithPrometheus ¶
func NewDemoTwoWorkItemWithPrometheus(base _sourceRepos.DemoTwoWorkItem, instanceName string) DemoTwoWorkItemWithPrometheus
NewDemoTwoWorkItemWithPrometheus returns an instance of the _sourceRepos.DemoTwoWorkItem decorated with prometheus summary metric
func (DemoTwoWorkItemWithPrometheus) ByID ¶
func (_d DemoTwoWorkItemWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.DemoTwoWorkItem
func (DemoTwoWorkItemWithPrometheus) Create ¶
func (_d DemoTwoWorkItemWithPrometheus) Create(ctx context.Context, d models.DBTX, params _sourceRepos.DemoTwoWorkItemCreateParams) (wp1 *models.WorkItem, err error)
Create implements _sourceRepos.DemoTwoWorkItem
func (DemoTwoWorkItemWithPrometheus) Update ¶
func (_d DemoTwoWorkItemWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, params _sourceRepos.DemoTwoWorkItemUpdateParams) (wp1 *models.WorkItem, err error)
Update implements _sourceRepos.DemoTwoWorkItem
type DemoTwoWorkItemWithRetry ¶
type DemoTwoWorkItemWithRetry struct { _sourceRepos.DemoTwoWorkItem // contains filtered or unexported fields }
DemoTwoWorkItemWithRetry implements _sourceRepos.DemoTwoWorkItem interface instrumented with retries
func NewDemoTwoWorkItemWithRetry ¶
func NewDemoTwoWorkItemWithRetry(base _sourceRepos.DemoTwoWorkItem, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) DemoTwoWorkItemWithRetry
NewDemoTwoWorkItemWithRetry returns DemoTwoWorkItemWithRetry
func (DemoTwoWorkItemWithRetry) ByID ¶
func (_d DemoTwoWorkItemWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.DemoTwoWorkItem
func (DemoTwoWorkItemWithRetry) Create ¶
func (_d DemoTwoWorkItemWithRetry) Create(ctx context.Context, d models.DBTX, params _sourceRepos.DemoTwoWorkItemCreateParams) (wp1 *models.WorkItem, err error)
Create implements _sourceRepos.DemoTwoWorkItem
func (DemoTwoWorkItemWithRetry) Update ¶
func (_d DemoTwoWorkItemWithRetry) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, params _sourceRepos.DemoTwoWorkItemUpdateParams) (wp1 *models.WorkItem, err error)
Update implements _sourceRepos.DemoTwoWorkItem
type DemoTwoWorkItemWithTimeout ¶
type DemoTwoWorkItemWithTimeout struct { _sourceRepos.DemoTwoWorkItem // contains filtered or unexported fields }
DemoTwoWorkItemWithTimeout implements _sourceRepos.DemoTwoWorkItem interface instrumented with timeouts
func NewDemoTwoWorkItemWithTimeout ¶
func NewDemoTwoWorkItemWithTimeout(base _sourceRepos.DemoTwoWorkItem, config DemoTwoWorkItemWithTimeoutConfig) DemoTwoWorkItemWithTimeout
NewDemoTwoWorkItemWithTimeout returns DemoTwoWorkItemWithTimeout
func (DemoTwoWorkItemWithTimeout) ByID ¶
func (_d DemoTwoWorkItemWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.DemoTwoWorkItem
func (DemoTwoWorkItemWithTimeout) Create ¶
func (_d DemoTwoWorkItemWithTimeout) Create(ctx context.Context, d models.DBTX, params _sourceRepos.DemoTwoWorkItemCreateParams) (wp1 *models.WorkItem, err error)
Create implements _sourceRepos.DemoTwoWorkItem
func (DemoTwoWorkItemWithTimeout) Update ¶
func (_d DemoTwoWorkItemWithTimeout) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, params _sourceRepos.DemoTwoWorkItemUpdateParams) (wp1 *models.WorkItem, err error)
Update implements _sourceRepos.DemoTwoWorkItem
type DemoTwoWorkItemWithTracing ¶
type DemoTwoWorkItemWithTracing struct { _sourceRepos.DemoTwoWorkItem // contains filtered or unexported fields }
DemoTwoWorkItemWithTracing implements _sourceRepos.DemoTwoWorkItem interface instrumented with opentracing spans
func NewDemoTwoWorkItemWithTracing ¶
func NewDemoTwoWorkItemWithTracing(base _sourceRepos.DemoTwoWorkItem, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) DemoTwoWorkItemWithTracing
NewDemoTwoWorkItemWithTracing returns DemoTwoWorkItemWithTracing
func (DemoTwoWorkItemWithTracing) ByID ¶
func (_d DemoTwoWorkItemWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.DemoTwoWorkItem
func (DemoTwoWorkItemWithTracing) Create ¶
func (_d DemoTwoWorkItemWithTracing) Create(ctx context.Context, d models.DBTX, params _sourceRepos.DemoTwoWorkItemCreateParams) (wp1 *models.WorkItem, err error)
Create implements _sourceRepos.DemoTwoWorkItem
func (DemoTwoWorkItemWithTracing) Update ¶
func (_d DemoTwoWorkItemWithTracing) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, params _sourceRepos.DemoTwoWorkItemUpdateParams) (wp1 *models.WorkItem, err error)
Update implements _sourceRepos.DemoTwoWorkItem
type DemoWorkItemWithPrometheus ¶
type DemoWorkItemWithPrometheus struct {
// contains filtered or unexported fields
}
DemoWorkItemWithPrometheus implements _sourceRepos.DemoWorkItem interface with all methods wrapped with Prometheus metrics
func NewDemoWorkItemWithPrometheus ¶
func NewDemoWorkItemWithPrometheus(base _sourceRepos.DemoWorkItem, instanceName string) DemoWorkItemWithPrometheus
NewDemoWorkItemWithPrometheus returns an instance of the _sourceRepos.DemoWorkItem decorated with prometheus summary metric
func (DemoWorkItemWithPrometheus) ByID ¶
func (_d DemoWorkItemWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithPrometheus) Create ¶
func (_d DemoWorkItemWithPrometheus) Create(ctx context.Context, d models.DBTX, params _sourceRepos.DemoWorkItemCreateParams) (wp1 *models.WorkItem, err error)
Create implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithPrometheus) Paginated ¶
func (_d DemoWorkItemWithPrometheus) Paginated(ctx context.Context, d models.DBTX, cursor models.WorkItemID, opts ...models.CacheDemoWorkItemSelectConfigOption) (ca1 []models.CacheDemoWorkItem, err error)
Paginated implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithPrometheus) Update ¶
func (_d DemoWorkItemWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, params _sourceRepos.DemoWorkItemUpdateParams) (wp1 *models.WorkItem, err error)
Update implements _sourceRepos.DemoWorkItem
type DemoWorkItemWithRetry ¶
type DemoWorkItemWithRetry struct { _sourceRepos.DemoWorkItem // contains filtered or unexported fields }
DemoWorkItemWithRetry implements _sourceRepos.DemoWorkItem interface instrumented with retries
func NewDemoWorkItemWithRetry ¶
func NewDemoWorkItemWithRetry(base _sourceRepos.DemoWorkItem, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) DemoWorkItemWithRetry
NewDemoWorkItemWithRetry returns DemoWorkItemWithRetry
func (DemoWorkItemWithRetry) ByID ¶
func (_d DemoWorkItemWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithRetry) Create ¶
func (_d DemoWorkItemWithRetry) Create(ctx context.Context, d models.DBTX, params _sourceRepos.DemoWorkItemCreateParams) (wp1 *models.WorkItem, err error)
Create implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithRetry) Paginated ¶
func (_d DemoWorkItemWithRetry) Paginated(ctx context.Context, d models.DBTX, cursor models.WorkItemID, opts ...models.CacheDemoWorkItemSelectConfigOption) (ca1 []models.CacheDemoWorkItem, err error)
Paginated implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithRetry) Update ¶
func (_d DemoWorkItemWithRetry) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, params _sourceRepos.DemoWorkItemUpdateParams) (wp1 *models.WorkItem, err error)
Update implements _sourceRepos.DemoWorkItem
type DemoWorkItemWithTimeout ¶
type DemoWorkItemWithTimeout struct { _sourceRepos.DemoWorkItem // contains filtered or unexported fields }
DemoWorkItemWithTimeout implements _sourceRepos.DemoWorkItem interface instrumented with timeouts
func NewDemoWorkItemWithTimeout ¶
func NewDemoWorkItemWithTimeout(base _sourceRepos.DemoWorkItem, config DemoWorkItemWithTimeoutConfig) DemoWorkItemWithTimeout
NewDemoWorkItemWithTimeout returns DemoWorkItemWithTimeout
func (DemoWorkItemWithTimeout) ByID ¶
func (_d DemoWorkItemWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithTimeout) Create ¶
func (_d DemoWorkItemWithTimeout) Create(ctx context.Context, d models.DBTX, params _sourceRepos.DemoWorkItemCreateParams) (wp1 *models.WorkItem, err error)
Create implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithTimeout) Paginated ¶
func (_d DemoWorkItemWithTimeout) Paginated(ctx context.Context, d models.DBTX, cursor models.WorkItemID, opts ...models.CacheDemoWorkItemSelectConfigOption) (ca1 []models.CacheDemoWorkItem, err error)
Paginated implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithTimeout) Update ¶
func (_d DemoWorkItemWithTimeout) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, params _sourceRepos.DemoWorkItemUpdateParams) (wp1 *models.WorkItem, err error)
Update implements _sourceRepos.DemoWorkItem
type DemoWorkItemWithTracing ¶
type DemoWorkItemWithTracing struct { _sourceRepos.DemoWorkItem // contains filtered or unexported fields }
DemoWorkItemWithTracing implements _sourceRepos.DemoWorkItem interface instrumented with opentracing spans
func NewDemoWorkItemWithTracing ¶
func NewDemoWorkItemWithTracing(base _sourceRepos.DemoWorkItem, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) DemoWorkItemWithTracing
NewDemoWorkItemWithTracing returns DemoWorkItemWithTracing
func (DemoWorkItemWithTracing) ByID ¶
func (_d DemoWorkItemWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithTracing) Create ¶
func (_d DemoWorkItemWithTracing) Create(ctx context.Context, d models.DBTX, params _sourceRepos.DemoWorkItemCreateParams) (wp1 *models.WorkItem, err error)
Create implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithTracing) Paginated ¶
func (_d DemoWorkItemWithTracing) Paginated(ctx context.Context, d models.DBTX, cursor models.WorkItemID, opts ...models.CacheDemoWorkItemSelectConfigOption) (ca1 []models.CacheDemoWorkItem, err error)
Paginated implements _sourceRepos.DemoWorkItem
func (DemoWorkItemWithTracing) Update ¶
func (_d DemoWorkItemWithTracing) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, params _sourceRepos.DemoWorkItemUpdateParams) (wp1 *models.WorkItem, err error)
Update implements _sourceRepos.DemoWorkItem
type KanbanStepWithPrometheus ¶
type KanbanStepWithPrometheus struct {
// contains filtered or unexported fields
}
KanbanStepWithPrometheus implements _sourceRepos.KanbanStep interface with all methods wrapped with Prometheus metrics
func NewKanbanStepWithPrometheus ¶
func NewKanbanStepWithPrometheus(base _sourceRepos.KanbanStep, instanceName string) KanbanStepWithPrometheus
NewKanbanStepWithPrometheus returns an instance of the _sourceRepos.KanbanStep decorated with prometheus summary metric
func (KanbanStepWithPrometheus) ByID ¶
func (_d KanbanStepWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.KanbanStepID, opts ...models.KanbanStepSelectConfigOption) (kp1 *models.KanbanStep, err error)
ByID implements _sourceRepos.KanbanStep
func (KanbanStepWithPrometheus) ByProject ¶
func (_d KanbanStepWithPrometheus) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID, opts ...models.KanbanStepSelectConfigOption) (ka1 []models.KanbanStep, err error)
ByProject implements _sourceRepos.KanbanStep
type KanbanStepWithRetry ¶
type KanbanStepWithRetry struct { _sourceRepos.KanbanStep // contains filtered or unexported fields }
KanbanStepWithRetry implements _sourceRepos.KanbanStep interface instrumented with retries
func NewKanbanStepWithRetry ¶
func NewKanbanStepWithRetry(base _sourceRepos.KanbanStep, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) KanbanStepWithRetry
NewKanbanStepWithRetry returns KanbanStepWithRetry
func (KanbanStepWithRetry) ByID ¶
func (_d KanbanStepWithRetry) ByID(ctx context.Context, d models.DBTX, id models.KanbanStepID, opts ...models.KanbanStepSelectConfigOption) (kp1 *models.KanbanStep, err error)
ByID implements _sourceRepos.KanbanStep
func (KanbanStepWithRetry) ByProject ¶
func (_d KanbanStepWithRetry) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID, opts ...models.KanbanStepSelectConfigOption) (ka1 []models.KanbanStep, err error)
ByProject implements _sourceRepos.KanbanStep
type KanbanStepWithTimeout ¶
type KanbanStepWithTimeout struct { _sourceRepos.KanbanStep // contains filtered or unexported fields }
KanbanStepWithTimeout implements _sourceRepos.KanbanStep interface instrumented with timeouts
func NewKanbanStepWithTimeout ¶
func NewKanbanStepWithTimeout(base _sourceRepos.KanbanStep, config KanbanStepWithTimeoutConfig) KanbanStepWithTimeout
NewKanbanStepWithTimeout returns KanbanStepWithTimeout
func (KanbanStepWithTimeout) ByID ¶
func (_d KanbanStepWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.KanbanStepID, opts ...models.KanbanStepSelectConfigOption) (kp1 *models.KanbanStep, err error)
ByID implements _sourceRepos.KanbanStep
func (KanbanStepWithTimeout) ByProject ¶
func (_d KanbanStepWithTimeout) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID, opts ...models.KanbanStepSelectConfigOption) (ka1 []models.KanbanStep, err error)
ByProject implements _sourceRepos.KanbanStep
type KanbanStepWithTracing ¶
type KanbanStepWithTracing struct { _sourceRepos.KanbanStep // contains filtered or unexported fields }
KanbanStepWithTracing implements _sourceRepos.KanbanStep interface instrumented with opentracing spans
func NewKanbanStepWithTracing ¶
func NewKanbanStepWithTracing(base _sourceRepos.KanbanStep, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) KanbanStepWithTracing
NewKanbanStepWithTracing returns KanbanStepWithTracing
func (KanbanStepWithTracing) ByID ¶
func (_d KanbanStepWithTracing) ByID(ctx context.Context, d models.DBTX, id models.KanbanStepID, opts ...models.KanbanStepSelectConfigOption) (kp1 *models.KanbanStep, err error)
ByID implements _sourceRepos.KanbanStep
func (KanbanStepWithTracing) ByProject ¶
func (_d KanbanStepWithTracing) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID, opts ...models.KanbanStepSelectConfigOption) (ka1 []models.KanbanStep, err error)
ByProject implements _sourceRepos.KanbanStep
type NotificationWithPrometheus ¶
type NotificationWithPrometheus struct {
// contains filtered or unexported fields
}
NotificationWithPrometheus implements _sourceRepos.Notification interface with all methods wrapped with Prometheus metrics
func NewNotificationWithPrometheus ¶
func NewNotificationWithPrometheus(base _sourceRepos.Notification, instanceName string) NotificationWithPrometheus
NewNotificationWithPrometheus returns an instance of the _sourceRepos.Notification decorated with prometheus summary metric
func (NotificationWithPrometheus) Create ¶
func (_d NotificationWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.NotificationCreateParams) (up1 *models.UserNotification, err error)
Create implements _sourceRepos.Notification
func (NotificationWithPrometheus) Delete ¶
func (_d NotificationWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.NotificationID) (np1 *models.Notification, err error)
Delete implements _sourceRepos.Notification
func (NotificationWithPrometheus) LatestNotifications ¶
func (_d NotificationWithPrometheus) LatestNotifications(ctx context.Context, d models.DBTX, params *models.GetUserNotificationsParams) (ga1 []models.GetUserNotificationsRow, err error)
LatestNotifications implements _sourceRepos.Notification
func (NotificationWithPrometheus) PaginatedUserNotifications ¶
func (_d NotificationWithPrometheus) PaginatedUserNotifications(ctx context.Context, d models.DBTX, userID models.UserID, params models.GetPaginatedNotificationsParams) (ua1 []models.UserNotification, err error)
PaginatedUserNotifications implements _sourceRepos.Notification
type NotificationWithRetry ¶
type NotificationWithRetry struct { _sourceRepos.Notification // contains filtered or unexported fields }
NotificationWithRetry implements _sourceRepos.Notification interface instrumented with retries
func NewNotificationWithRetry ¶
func NewNotificationWithRetry(base _sourceRepos.Notification, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) NotificationWithRetry
NewNotificationWithRetry returns NotificationWithRetry
func (NotificationWithRetry) Create ¶
func (_d NotificationWithRetry) Create(ctx context.Context, d models.DBTX, params *models.NotificationCreateParams) (up1 *models.UserNotification, err error)
Create implements _sourceRepos.Notification
func (NotificationWithRetry) Delete ¶
func (_d NotificationWithRetry) Delete(ctx context.Context, d models.DBTX, id models.NotificationID) (np1 *models.Notification, err error)
Delete implements _sourceRepos.Notification
func (NotificationWithRetry) LatestNotifications ¶
func (_d NotificationWithRetry) LatestNotifications(ctx context.Context, d models.DBTX, params *models.GetUserNotificationsParams) (ga1 []models.GetUserNotificationsRow, err error)
LatestNotifications implements _sourceRepos.Notification
func (NotificationWithRetry) PaginatedUserNotifications ¶
func (_d NotificationWithRetry) PaginatedUserNotifications(ctx context.Context, d models.DBTX, userID models.UserID, params models.GetPaginatedNotificationsParams) (ua1 []models.UserNotification, err error)
PaginatedUserNotifications implements _sourceRepos.Notification
type NotificationWithTimeout ¶
type NotificationWithTimeout struct { _sourceRepos.Notification // contains filtered or unexported fields }
NotificationWithTimeout implements _sourceRepos.Notification interface instrumented with timeouts
func NewNotificationWithTimeout ¶
func NewNotificationWithTimeout(base _sourceRepos.Notification, config NotificationWithTimeoutConfig) NotificationWithTimeout
NewNotificationWithTimeout returns NotificationWithTimeout
func (NotificationWithTimeout) Create ¶
func (_d NotificationWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.NotificationCreateParams) (up1 *models.UserNotification, err error)
Create implements _sourceRepos.Notification
func (NotificationWithTimeout) Delete ¶
func (_d NotificationWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.NotificationID) (np1 *models.Notification, err error)
Delete implements _sourceRepos.Notification
func (NotificationWithTimeout) LatestNotifications ¶
func (_d NotificationWithTimeout) LatestNotifications(ctx context.Context, d models.DBTX, params *models.GetUserNotificationsParams) (ga1 []models.GetUserNotificationsRow, err error)
LatestNotifications implements _sourceRepos.Notification
func (NotificationWithTimeout) PaginatedUserNotifications ¶
func (_d NotificationWithTimeout) PaginatedUserNotifications(ctx context.Context, d models.DBTX, userID models.UserID, params models.GetPaginatedNotificationsParams) (ua1 []models.UserNotification, err error)
PaginatedUserNotifications implements _sourceRepos.Notification
type NotificationWithTracing ¶
type NotificationWithTracing struct { _sourceRepos.Notification // contains filtered or unexported fields }
NotificationWithTracing implements _sourceRepos.Notification interface instrumented with opentracing spans
func NewNotificationWithTracing ¶
func NewNotificationWithTracing(base _sourceRepos.Notification, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) NotificationWithTracing
NewNotificationWithTracing returns NotificationWithTracing
func (NotificationWithTracing) Create ¶
func (_d NotificationWithTracing) Create(ctx context.Context, d models.DBTX, params *models.NotificationCreateParams) (up1 *models.UserNotification, err error)
Create implements _sourceRepos.Notification
func (NotificationWithTracing) Delete ¶
func (_d NotificationWithTracing) Delete(ctx context.Context, d models.DBTX, id models.NotificationID) (np1 *models.Notification, err error)
Delete implements _sourceRepos.Notification
func (NotificationWithTracing) LatestNotifications ¶
func (_d NotificationWithTracing) LatestNotifications(ctx context.Context, d models.DBTX, params *models.GetUserNotificationsParams) (ga1 []models.GetUserNotificationsRow, err error)
LatestNotifications implements _sourceRepos.Notification
func (NotificationWithTracing) PaginatedUserNotifications ¶
func (_d NotificationWithTracing) PaginatedUserNotifications(ctx context.Context, d models.DBTX, userID models.UserID, params models.GetPaginatedNotificationsParams) (ua1 []models.UserNotification, err error)
PaginatedUserNotifications implements _sourceRepos.Notification
type ProjectWithPrometheus ¶
type ProjectWithPrometheus struct {
// contains filtered or unexported fields
}
ProjectWithPrometheus implements _sourceRepos.Project interface with all methods wrapped with Prometheus metrics
func NewProjectWithPrometheus ¶
func NewProjectWithPrometheus(base _sourceRepos.Project, instanceName string) ProjectWithPrometheus
NewProjectWithPrometheus returns an instance of the _sourceRepos.Project decorated with prometheus summary metric
func (ProjectWithPrometheus) ByID ¶
func (_d ProjectWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.ProjectID, opts ...models.ProjectSelectConfigOption) (pp1 *models.Project, err error)
ByID implements _sourceRepos.Project
func (ProjectWithPrometheus) ByName ¶
func (_d ProjectWithPrometheus) ByName(ctx context.Context, d models.DBTX, name models.ProjectName, opts ...models.ProjectSelectConfigOption) (pp1 *models.Project, err error)
ByName implements _sourceRepos.Project
func (ProjectWithPrometheus) IsTeamInProject ¶
func (_d ProjectWithPrometheus) IsTeamInProject(ctx context.Context, d models.DBTX, arg models.IsTeamInProjectParams) (b1 bool, err error)
IsTeamInProject implements _sourceRepos.Project
type ProjectWithRetry ¶
type ProjectWithRetry struct { _sourceRepos.Project // contains filtered or unexported fields }
ProjectWithRetry implements _sourceRepos.Project interface instrumented with retries
func NewProjectWithRetry ¶
func NewProjectWithRetry(base _sourceRepos.Project, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) ProjectWithRetry
NewProjectWithRetry returns ProjectWithRetry
func (ProjectWithRetry) ByID ¶
func (_d ProjectWithRetry) ByID(ctx context.Context, d models.DBTX, id models.ProjectID, opts ...models.ProjectSelectConfigOption) (pp1 *models.Project, err error)
ByID implements _sourceRepos.Project
func (ProjectWithRetry) ByName ¶
func (_d ProjectWithRetry) ByName(ctx context.Context, d models.DBTX, name models.ProjectName, opts ...models.ProjectSelectConfigOption) (pp1 *models.Project, err error)
ByName implements _sourceRepos.Project
func (ProjectWithRetry) IsTeamInProject ¶
func (_d ProjectWithRetry) IsTeamInProject(ctx context.Context, d models.DBTX, arg models.IsTeamInProjectParams) (b1 bool, err error)
IsTeamInProject implements _sourceRepos.Project
type ProjectWithTimeout ¶
type ProjectWithTimeout struct { _sourceRepos.Project // contains filtered or unexported fields }
ProjectWithTimeout implements _sourceRepos.Project interface instrumented with timeouts
func NewProjectWithTimeout ¶
func NewProjectWithTimeout(base _sourceRepos.Project, config ProjectWithTimeoutConfig) ProjectWithTimeout
NewProjectWithTimeout returns ProjectWithTimeout
func (ProjectWithTimeout) ByID ¶
func (_d ProjectWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.ProjectID, opts ...models.ProjectSelectConfigOption) (pp1 *models.Project, err error)
ByID implements _sourceRepos.Project
func (ProjectWithTimeout) ByName ¶
func (_d ProjectWithTimeout) ByName(ctx context.Context, d models.DBTX, name models.ProjectName, opts ...models.ProjectSelectConfigOption) (pp1 *models.Project, err error)
ByName implements _sourceRepos.Project
func (ProjectWithTimeout) IsTeamInProject ¶
func (_d ProjectWithTimeout) IsTeamInProject(ctx context.Context, d models.DBTX, arg models.IsTeamInProjectParams) (b1 bool, err error)
IsTeamInProject implements _sourceRepos.Project
type ProjectWithTracing ¶
type ProjectWithTracing struct { _sourceRepos.Project // contains filtered or unexported fields }
ProjectWithTracing implements _sourceRepos.Project interface instrumented with opentracing spans
func NewProjectWithTracing ¶
func NewProjectWithTracing(base _sourceRepos.Project, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) ProjectWithTracing
NewProjectWithTracing returns ProjectWithTracing
func (ProjectWithTracing) ByID ¶
func (_d ProjectWithTracing) ByID(ctx context.Context, d models.DBTX, id models.ProjectID, opts ...models.ProjectSelectConfigOption) (pp1 *models.Project, err error)
ByID implements _sourceRepos.Project
func (ProjectWithTracing) ByName ¶
func (_d ProjectWithTracing) ByName(ctx context.Context, d models.DBTX, name models.ProjectName, opts ...models.ProjectSelectConfigOption) (pp1 *models.Project, err error)
ByName implements _sourceRepos.Project
func (ProjectWithTracing) IsTeamInProject ¶
func (_d ProjectWithTracing) IsTeamInProject(ctx context.Context, d models.DBTX, arg models.IsTeamInProjectParams) (b1 bool, err error)
IsTeamInProject implements _sourceRepos.Project
type TeamWithPrometheus ¶
type TeamWithPrometheus struct {
// contains filtered or unexported fields
}
TeamWithPrometheus implements _sourceRepos.Team interface with all methods wrapped with Prometheus metrics
func NewTeamWithPrometheus ¶
func NewTeamWithPrometheus(base _sourceRepos.Team, instanceName string) TeamWithPrometheus
NewTeamWithPrometheus returns an instance of the _sourceRepos.Team decorated with prometheus summary metric
func (TeamWithPrometheus) ByID ¶
func (_d TeamWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.TeamID, opts ...models.TeamSelectConfigOption) (tp1 *models.Team, err error)
ByID implements _sourceRepos.Team
func (TeamWithPrometheus) ByName ¶
func (_d TeamWithPrometheus) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.TeamSelectConfigOption) (tp1 *models.Team, err error)
ByName implements _sourceRepos.Team
func (TeamWithPrometheus) Create ¶
func (_d TeamWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.TeamCreateParams) (tp1 *models.Team, err error)
Create implements _sourceRepos.Team
type TeamWithRetry ¶
type TeamWithRetry struct { _sourceRepos.Team // contains filtered or unexported fields }
TeamWithRetry implements _sourceRepos.Team interface instrumented with retries
func NewTeamWithRetry ¶
func NewTeamWithRetry(base _sourceRepos.Team, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) TeamWithRetry
NewTeamWithRetry returns TeamWithRetry
func (TeamWithRetry) ByID ¶
func (_d TeamWithRetry) ByID(ctx context.Context, d models.DBTX, id models.TeamID, opts ...models.TeamSelectConfigOption) (tp1 *models.Team, err error)
ByID implements _sourceRepos.Team
func (TeamWithRetry) ByName ¶
func (_d TeamWithRetry) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.TeamSelectConfigOption) (tp1 *models.Team, err error)
ByName implements _sourceRepos.Team
func (TeamWithRetry) Create ¶
func (_d TeamWithRetry) Create(ctx context.Context, d models.DBTX, params *models.TeamCreateParams) (tp1 *models.Team, err error)
Create implements _sourceRepos.Team
type TeamWithTimeout ¶
type TeamWithTimeout struct { _sourceRepos.Team // contains filtered or unexported fields }
TeamWithTimeout implements _sourceRepos.Team interface instrumented with timeouts
func NewTeamWithTimeout ¶
func NewTeamWithTimeout(base _sourceRepos.Team, config TeamWithTimeoutConfig) TeamWithTimeout
NewTeamWithTimeout returns TeamWithTimeout
func (TeamWithTimeout) ByID ¶
func (_d TeamWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.TeamID, opts ...models.TeamSelectConfigOption) (tp1 *models.Team, err error)
ByID implements _sourceRepos.Team
func (TeamWithTimeout) ByName ¶
func (_d TeamWithTimeout) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.TeamSelectConfigOption) (tp1 *models.Team, err error)
ByName implements _sourceRepos.Team
func (TeamWithTimeout) Create ¶
func (_d TeamWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.TeamCreateParams) (tp1 *models.Team, err error)
Create implements _sourceRepos.Team
type TeamWithTimeoutConfig ¶
type TeamWithTracing ¶
type TeamWithTracing struct { _sourceRepos.Team // contains filtered or unexported fields }
TeamWithTracing implements _sourceRepos.Team interface instrumented with opentracing spans
func NewTeamWithTracing ¶
func NewTeamWithTracing(base _sourceRepos.Team, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) TeamWithTracing
NewTeamWithTracing returns TeamWithTracing
func (TeamWithTracing) ByID ¶
func (_d TeamWithTracing) ByID(ctx context.Context, d models.DBTX, id models.TeamID, opts ...models.TeamSelectConfigOption) (tp1 *models.Team, err error)
ByID implements _sourceRepos.Team
func (TeamWithTracing) ByName ¶
func (_d TeamWithTracing) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.TeamSelectConfigOption) (tp1 *models.Team, err error)
ByName implements _sourceRepos.Team
func (TeamWithTracing) Create ¶
func (_d TeamWithTracing) Create(ctx context.Context, d models.DBTX, params *models.TeamCreateParams) (tp1 *models.Team, err error)
Create implements _sourceRepos.Team
type TimeEntryWithPrometheus ¶
type TimeEntryWithPrometheus struct {
// contains filtered or unexported fields
}
TimeEntryWithPrometheus implements _sourceRepos.TimeEntry interface with all methods wrapped with Prometheus metrics
func NewTimeEntryWithPrometheus ¶
func NewTimeEntryWithPrometheus(base _sourceRepos.TimeEntry, instanceName string) TimeEntryWithPrometheus
NewTimeEntryWithPrometheus returns an instance of the _sourceRepos.TimeEntry decorated with prometheus summary metric
func (TimeEntryWithPrometheus) ByID ¶
func (_d TimeEntryWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.TimeEntryID, opts ...models.TimeEntrySelectConfigOption) (tp1 *models.TimeEntry, err error)
ByID implements _sourceRepos.TimeEntry
func (TimeEntryWithPrometheus) Create ¶
func (_d TimeEntryWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.TimeEntryCreateParams) (tp1 *models.TimeEntry, err error)
Create implements _sourceRepos.TimeEntry
func (TimeEntryWithPrometheus) Delete ¶
func (_d TimeEntryWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.TimeEntryID) (tp1 *models.TimeEntry, err error)
Delete implements _sourceRepos.TimeEntry
func (TimeEntryWithPrometheus) Update ¶
func (_d TimeEntryWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.TimeEntryID, params *models.TimeEntryUpdateParams) (tp1 *models.TimeEntry, err error)
Update implements _sourceRepos.TimeEntry
type TimeEntryWithRetry ¶
type TimeEntryWithRetry struct { _sourceRepos.TimeEntry // contains filtered or unexported fields }
TimeEntryWithRetry implements _sourceRepos.TimeEntry interface instrumented with retries
func NewTimeEntryWithRetry ¶
func NewTimeEntryWithRetry(base _sourceRepos.TimeEntry, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) TimeEntryWithRetry
NewTimeEntryWithRetry returns TimeEntryWithRetry
func (TimeEntryWithRetry) ByID ¶
func (_d TimeEntryWithRetry) ByID(ctx context.Context, d models.DBTX, id models.TimeEntryID, opts ...models.TimeEntrySelectConfigOption) (tp1 *models.TimeEntry, err error)
ByID implements _sourceRepos.TimeEntry
func (TimeEntryWithRetry) Create ¶
func (_d TimeEntryWithRetry) Create(ctx context.Context, d models.DBTX, params *models.TimeEntryCreateParams) (tp1 *models.TimeEntry, err error)
Create implements _sourceRepos.TimeEntry
func (TimeEntryWithRetry) Delete ¶
func (_d TimeEntryWithRetry) Delete(ctx context.Context, d models.DBTX, id models.TimeEntryID) (tp1 *models.TimeEntry, err error)
Delete implements _sourceRepos.TimeEntry
func (TimeEntryWithRetry) Update ¶
func (_d TimeEntryWithRetry) Update(ctx context.Context, d models.DBTX, id models.TimeEntryID, params *models.TimeEntryUpdateParams) (tp1 *models.TimeEntry, err error)
Update implements _sourceRepos.TimeEntry
type TimeEntryWithTimeout ¶
type TimeEntryWithTimeout struct { _sourceRepos.TimeEntry // contains filtered or unexported fields }
TimeEntryWithTimeout implements _sourceRepos.TimeEntry interface instrumented with timeouts
func NewTimeEntryWithTimeout ¶
func NewTimeEntryWithTimeout(base _sourceRepos.TimeEntry, config TimeEntryWithTimeoutConfig) TimeEntryWithTimeout
NewTimeEntryWithTimeout returns TimeEntryWithTimeout
func (TimeEntryWithTimeout) ByID ¶
func (_d TimeEntryWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.TimeEntryID, opts ...models.TimeEntrySelectConfigOption) (tp1 *models.TimeEntry, err error)
ByID implements _sourceRepos.TimeEntry
func (TimeEntryWithTimeout) Create ¶
func (_d TimeEntryWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.TimeEntryCreateParams) (tp1 *models.TimeEntry, err error)
Create implements _sourceRepos.TimeEntry
func (TimeEntryWithTimeout) Delete ¶
func (_d TimeEntryWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.TimeEntryID) (tp1 *models.TimeEntry, err error)
Delete implements _sourceRepos.TimeEntry
func (TimeEntryWithTimeout) Update ¶
func (_d TimeEntryWithTimeout) Update(ctx context.Context, d models.DBTX, id models.TimeEntryID, params *models.TimeEntryUpdateParams) (tp1 *models.TimeEntry, err error)
Update implements _sourceRepos.TimeEntry
type TimeEntryWithTracing ¶
type TimeEntryWithTracing struct { _sourceRepos.TimeEntry // contains filtered or unexported fields }
TimeEntryWithTracing implements _sourceRepos.TimeEntry interface instrumented with opentracing spans
func NewTimeEntryWithTracing ¶
func NewTimeEntryWithTracing(base _sourceRepos.TimeEntry, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) TimeEntryWithTracing
NewTimeEntryWithTracing returns TimeEntryWithTracing
func (TimeEntryWithTracing) ByID ¶
func (_d TimeEntryWithTracing) ByID(ctx context.Context, d models.DBTX, id models.TimeEntryID, opts ...models.TimeEntrySelectConfigOption) (tp1 *models.TimeEntry, err error)
ByID implements _sourceRepos.TimeEntry
func (TimeEntryWithTracing) Create ¶
func (_d TimeEntryWithTracing) Create(ctx context.Context, d models.DBTX, params *models.TimeEntryCreateParams) (tp1 *models.TimeEntry, err error)
Create implements _sourceRepos.TimeEntry
func (TimeEntryWithTracing) Delete ¶
func (_d TimeEntryWithTracing) Delete(ctx context.Context, d models.DBTX, id models.TimeEntryID) (tp1 *models.TimeEntry, err error)
Delete implements _sourceRepos.TimeEntry
func (TimeEntryWithTracing) Update ¶
func (_d TimeEntryWithTracing) Update(ctx context.Context, d models.DBTX, id models.TimeEntryID, params *models.TimeEntryUpdateParams) (tp1 *models.TimeEntry, err error)
Update implements _sourceRepos.TimeEntry
type UserWithPrometheus ¶
type UserWithPrometheus struct {
// contains filtered or unexported fields
}
UserWithPrometheus implements _sourceRepos.User interface with all methods wrapped with Prometheus metrics
func NewUserWithPrometheus ¶
func NewUserWithPrometheus(base _sourceRepos.User, instanceName string) UserWithPrometheus
NewUserWithPrometheus returns an instance of the _sourceRepos.User decorated with prometheus summary metric
func (UserWithPrometheus) ByAPIKey ¶
func (_d UserWithPrometheus) ByAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.User, err error)
ByAPIKey implements _sourceRepos.User
func (UserWithPrometheus) ByEmail ¶
func (_d UserWithPrometheus) ByEmail(ctx context.Context, d models.DBTX, email string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByEmail implements _sourceRepos.User
func (UserWithPrometheus) ByExternalID ¶
func (_d UserWithPrometheus) ByExternalID(ctx context.Context, d models.DBTX, extID string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByExternalID implements _sourceRepos.User
func (UserWithPrometheus) ByID ¶
func (_d UserWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.UserID, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByID implements _sourceRepos.User
func (UserWithPrometheus) ByProject ¶
func (_d UserWithPrometheus) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID) (ua1 []models.User, err error)
ByProject implements _sourceRepos.User
func (UserWithPrometheus) ByTeam ¶
func (_d UserWithPrometheus) ByTeam(ctx context.Context, d models.DBTX, teamID models.TeamID) (ua1 []models.User, err error)
ByTeam implements _sourceRepos.User
func (UserWithPrometheus) ByUsername ¶
func (_d UserWithPrometheus) ByUsername(ctx context.Context, d models.DBTX, username string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByUsername implements _sourceRepos.User
func (UserWithPrometheus) Create ¶
func (_d UserWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.UserCreateParams) (up1 *models.User, err error)
Create implements _sourceRepos.User
func (UserWithPrometheus) CreateAPIKey ¶
func (_d UserWithPrometheus) CreateAPIKey(ctx context.Context, d models.DBTX, user *models.User) (up1 *models.UserAPIKey, err error)
CreateAPIKey implements _sourceRepos.User
func (UserWithPrometheus) Delete ¶
func (_d UserWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.UserID) (up1 *models.User, err error)
Delete implements _sourceRepos.User
func (UserWithPrometheus) DeleteAPIKey ¶
func (_d UserWithPrometheus) DeleteAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.UserAPIKey, err error)
DeleteAPIKey implements _sourceRepos.User
func (UserWithPrometheus) Paginated ¶
func (_d UserWithPrometheus) Paginated(ctx context.Context, d models.DBTX, params _sourceRepos.GetPaginatedUsersParams) (ua1 []models.User, err error)
Paginated implements _sourceRepos.User
type UserWithRetry ¶
type UserWithRetry struct { _sourceRepos.User // contains filtered or unexported fields }
UserWithRetry implements _sourceRepos.User interface instrumented with retries
func NewUserWithRetry ¶
func NewUserWithRetry(base _sourceRepos.User, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) UserWithRetry
NewUserWithRetry returns UserWithRetry
func (UserWithRetry) ByAPIKey ¶
func (_d UserWithRetry) ByAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.User, err error)
ByAPIKey implements _sourceRepos.User
func (UserWithRetry) ByEmail ¶
func (_d UserWithRetry) ByEmail(ctx context.Context, d models.DBTX, email string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByEmail implements _sourceRepos.User
func (UserWithRetry) ByExternalID ¶
func (_d UserWithRetry) ByExternalID(ctx context.Context, d models.DBTX, extID string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByExternalID implements _sourceRepos.User
func (UserWithRetry) ByID ¶
func (_d UserWithRetry) ByID(ctx context.Context, d models.DBTX, id models.UserID, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByID implements _sourceRepos.User
func (UserWithRetry) ByProject ¶
func (_d UserWithRetry) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID) (ua1 []models.User, err error)
ByProject implements _sourceRepos.User
func (UserWithRetry) ByTeam ¶
func (_d UserWithRetry) ByTeam(ctx context.Context, d models.DBTX, teamID models.TeamID) (ua1 []models.User, err error)
ByTeam implements _sourceRepos.User
func (UserWithRetry) ByUsername ¶
func (_d UserWithRetry) ByUsername(ctx context.Context, d models.DBTX, username string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByUsername implements _sourceRepos.User
func (UserWithRetry) Create ¶
func (_d UserWithRetry) Create(ctx context.Context, d models.DBTX, params *models.UserCreateParams) (up1 *models.User, err error)
Create implements _sourceRepos.User
func (UserWithRetry) CreateAPIKey ¶
func (_d UserWithRetry) CreateAPIKey(ctx context.Context, d models.DBTX, user *models.User) (up1 *models.UserAPIKey, err error)
CreateAPIKey implements _sourceRepos.User
func (UserWithRetry) Delete ¶
func (_d UserWithRetry) Delete(ctx context.Context, d models.DBTX, id models.UserID) (up1 *models.User, err error)
Delete implements _sourceRepos.User
func (UserWithRetry) DeleteAPIKey ¶
func (_d UserWithRetry) DeleteAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.UserAPIKey, err error)
DeleteAPIKey implements _sourceRepos.User
func (UserWithRetry) Paginated ¶
func (_d UserWithRetry) Paginated(ctx context.Context, d models.DBTX, params _sourceRepos.GetPaginatedUsersParams) (ua1 []models.User, err error)
Paginated implements _sourceRepos.User
type UserWithTimeout ¶
type UserWithTimeout struct { _sourceRepos.User // contains filtered or unexported fields }
UserWithTimeout implements _sourceRepos.User interface instrumented with timeouts
func NewUserWithTimeout ¶
func NewUserWithTimeout(base _sourceRepos.User, config UserWithTimeoutConfig) UserWithTimeout
NewUserWithTimeout returns UserWithTimeout
func (UserWithTimeout) ByAPIKey ¶
func (_d UserWithTimeout) ByAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.User, err error)
ByAPIKey implements _sourceRepos.User
func (UserWithTimeout) ByEmail ¶
func (_d UserWithTimeout) ByEmail(ctx context.Context, d models.DBTX, email string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByEmail implements _sourceRepos.User
func (UserWithTimeout) ByExternalID ¶
func (_d UserWithTimeout) ByExternalID(ctx context.Context, d models.DBTX, extID string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByExternalID implements _sourceRepos.User
func (UserWithTimeout) ByID ¶
func (_d UserWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.UserID, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByID implements _sourceRepos.User
func (UserWithTimeout) ByProject ¶
func (_d UserWithTimeout) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID) (ua1 []models.User, err error)
ByProject implements _sourceRepos.User
func (UserWithTimeout) ByTeam ¶
func (_d UserWithTimeout) ByTeam(ctx context.Context, d models.DBTX, teamID models.TeamID) (ua1 []models.User, err error)
ByTeam implements _sourceRepos.User
func (UserWithTimeout) ByUsername ¶
func (_d UserWithTimeout) ByUsername(ctx context.Context, d models.DBTX, username string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByUsername implements _sourceRepos.User
func (UserWithTimeout) Create ¶
func (_d UserWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.UserCreateParams) (up1 *models.User, err error)
Create implements _sourceRepos.User
func (UserWithTimeout) CreateAPIKey ¶
func (_d UserWithTimeout) CreateAPIKey(ctx context.Context, d models.DBTX, user *models.User) (up1 *models.UserAPIKey, err error)
CreateAPIKey implements _sourceRepos.User
func (UserWithTimeout) Delete ¶
func (_d UserWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.UserID) (up1 *models.User, err error)
Delete implements _sourceRepos.User
func (UserWithTimeout) DeleteAPIKey ¶
func (_d UserWithTimeout) DeleteAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.UserAPIKey, err error)
DeleteAPIKey implements _sourceRepos.User
func (UserWithTimeout) Paginated ¶
func (_d UserWithTimeout) Paginated(ctx context.Context, d models.DBTX, params _sourceRepos.GetPaginatedUsersParams) (ua1 []models.User, err error)
Paginated implements _sourceRepos.User
type UserWithTimeoutConfig ¶
type UserWithTimeoutConfig struct { ByAPIKeyTimeout time.Duration ByEmailTimeout time.Duration ByExternalIDTimeout time.Duration ByIDTimeout time.Duration ByProjectTimeout time.Duration ByTeamTimeout time.Duration ByUsernameTimeout time.Duration CreateTimeout time.Duration CreateAPIKeyTimeout time.Duration DeleteTimeout time.Duration DeleteAPIKeyTimeout time.Duration PaginatedTimeout time.Duration UpdateTimeout time.Duration }
type UserWithTracing ¶
type UserWithTracing struct { _sourceRepos.User // contains filtered or unexported fields }
UserWithTracing implements _sourceRepos.User interface instrumented with opentracing spans
func NewUserWithTracing ¶
func NewUserWithTracing(base _sourceRepos.User, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) UserWithTracing
NewUserWithTracing returns UserWithTracing
func (UserWithTracing) ByAPIKey ¶
func (_d UserWithTracing) ByAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.User, err error)
ByAPIKey implements _sourceRepos.User
func (UserWithTracing) ByEmail ¶
func (_d UserWithTracing) ByEmail(ctx context.Context, d models.DBTX, email string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByEmail implements _sourceRepos.User
func (UserWithTracing) ByExternalID ¶
func (_d UserWithTracing) ByExternalID(ctx context.Context, d models.DBTX, extID string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByExternalID implements _sourceRepos.User
func (UserWithTracing) ByID ¶
func (_d UserWithTracing) ByID(ctx context.Context, d models.DBTX, id models.UserID, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByID implements _sourceRepos.User
func (UserWithTracing) ByProject ¶
func (_d UserWithTracing) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID) (ua1 []models.User, err error)
ByProject implements _sourceRepos.User
func (UserWithTracing) ByTeam ¶
func (_d UserWithTracing) ByTeam(ctx context.Context, d models.DBTX, teamID models.TeamID) (ua1 []models.User, err error)
ByTeam implements _sourceRepos.User
func (UserWithTracing) ByUsername ¶
func (_d UserWithTracing) ByUsername(ctx context.Context, d models.DBTX, username string, opts ...models.UserSelectConfigOption) (up1 *models.User, err error)
ByUsername implements _sourceRepos.User
func (UserWithTracing) Create ¶
func (_d UserWithTracing) Create(ctx context.Context, d models.DBTX, params *models.UserCreateParams) (up1 *models.User, err error)
Create implements _sourceRepos.User
func (UserWithTracing) CreateAPIKey ¶
func (_d UserWithTracing) CreateAPIKey(ctx context.Context, d models.DBTX, user *models.User) (up1 *models.UserAPIKey, err error)
CreateAPIKey implements _sourceRepos.User
func (UserWithTracing) Delete ¶
func (_d UserWithTracing) Delete(ctx context.Context, d models.DBTX, id models.UserID) (up1 *models.User, err error)
Delete implements _sourceRepos.User
func (UserWithTracing) DeleteAPIKey ¶
func (_d UserWithTracing) DeleteAPIKey(ctx context.Context, d models.DBTX, apiKey string) (up1 *models.UserAPIKey, err error)
DeleteAPIKey implements _sourceRepos.User
func (UserWithTracing) Paginated ¶
func (_d UserWithTracing) Paginated(ctx context.Context, d models.DBTX, params _sourceRepos.GetPaginatedUsersParams) (ua1 []models.User, err error)
Paginated implements _sourceRepos.User
type WorkItemCommentWithPrometheus ¶
type WorkItemCommentWithPrometheus struct {
// contains filtered or unexported fields
}
WorkItemCommentWithPrometheus implements _sourceRepos.WorkItemComment interface with all methods wrapped with Prometheus metrics
func NewWorkItemCommentWithPrometheus ¶
func NewWorkItemCommentWithPrometheus(base _sourceRepos.WorkItemComment, instanceName string) WorkItemCommentWithPrometheus
NewWorkItemCommentWithPrometheus returns an instance of the _sourceRepos.WorkItemComment decorated with prometheus summary metric
func (WorkItemCommentWithPrometheus) ByID ¶
func (_d WorkItemCommentWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, opts ...models.WorkItemCommentSelectConfigOption) (wp1 *models.WorkItemComment, err error)
ByID implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithPrometheus) Create ¶
func (_d WorkItemCommentWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.WorkItemCommentCreateParams) (wp1 *models.WorkItemComment, err error)
Create implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithPrometheus) Delete ¶
func (_d WorkItemCommentWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.WorkItemCommentID) (wp1 *models.WorkItemComment, err error)
Delete implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithPrometheus) Update ¶
func (_d WorkItemCommentWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, params *models.WorkItemCommentUpdateParams) (wp1 *models.WorkItemComment, err error)
Update implements _sourceRepos.WorkItemComment
type WorkItemCommentWithRetry ¶
type WorkItemCommentWithRetry struct { _sourceRepos.WorkItemComment // contains filtered or unexported fields }
WorkItemCommentWithRetry implements _sourceRepos.WorkItemComment interface instrumented with retries
func NewWorkItemCommentWithRetry ¶
func NewWorkItemCommentWithRetry(base _sourceRepos.WorkItemComment, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) WorkItemCommentWithRetry
NewWorkItemCommentWithRetry returns WorkItemCommentWithRetry
func (WorkItemCommentWithRetry) ByID ¶
func (_d WorkItemCommentWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, opts ...models.WorkItemCommentSelectConfigOption) (wp1 *models.WorkItemComment, err error)
ByID implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithRetry) Create ¶
func (_d WorkItemCommentWithRetry) Create(ctx context.Context, d models.DBTX, params *models.WorkItemCommentCreateParams) (wp1 *models.WorkItemComment, err error)
Create implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithRetry) Delete ¶
func (_d WorkItemCommentWithRetry) Delete(ctx context.Context, d models.DBTX, id models.WorkItemCommentID) (wp1 *models.WorkItemComment, err error)
Delete implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithRetry) Update ¶
func (_d WorkItemCommentWithRetry) Update(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, params *models.WorkItemCommentUpdateParams) (wp1 *models.WorkItemComment, err error)
Update implements _sourceRepos.WorkItemComment
type WorkItemCommentWithTimeout ¶
type WorkItemCommentWithTimeout struct { _sourceRepos.WorkItemComment // contains filtered or unexported fields }
WorkItemCommentWithTimeout implements _sourceRepos.WorkItemComment interface instrumented with timeouts
func NewWorkItemCommentWithTimeout ¶
func NewWorkItemCommentWithTimeout(base _sourceRepos.WorkItemComment, config WorkItemCommentWithTimeoutConfig) WorkItemCommentWithTimeout
NewWorkItemCommentWithTimeout returns WorkItemCommentWithTimeout
func (WorkItemCommentWithTimeout) ByID ¶
func (_d WorkItemCommentWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, opts ...models.WorkItemCommentSelectConfigOption) (wp1 *models.WorkItemComment, err error)
ByID implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithTimeout) Create ¶
func (_d WorkItemCommentWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.WorkItemCommentCreateParams) (wp1 *models.WorkItemComment, err error)
Create implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithTimeout) Delete ¶
func (_d WorkItemCommentWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.WorkItemCommentID) (wp1 *models.WorkItemComment, err error)
Delete implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithTimeout) Update ¶
func (_d WorkItemCommentWithTimeout) Update(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, params *models.WorkItemCommentUpdateParams) (wp1 *models.WorkItemComment, err error)
Update implements _sourceRepos.WorkItemComment
type WorkItemCommentWithTracing ¶
type WorkItemCommentWithTracing struct { _sourceRepos.WorkItemComment // contains filtered or unexported fields }
WorkItemCommentWithTracing implements _sourceRepos.WorkItemComment interface instrumented with opentracing spans
func NewWorkItemCommentWithTracing ¶
func NewWorkItemCommentWithTracing(base _sourceRepos.WorkItemComment, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) WorkItemCommentWithTracing
NewWorkItemCommentWithTracing returns WorkItemCommentWithTracing
func (WorkItemCommentWithTracing) ByID ¶
func (_d WorkItemCommentWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, opts ...models.WorkItemCommentSelectConfigOption) (wp1 *models.WorkItemComment, err error)
ByID implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithTracing) Create ¶
func (_d WorkItemCommentWithTracing) Create(ctx context.Context, d models.DBTX, params *models.WorkItemCommentCreateParams) (wp1 *models.WorkItemComment, err error)
Create implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithTracing) Delete ¶
func (_d WorkItemCommentWithTracing) Delete(ctx context.Context, d models.DBTX, id models.WorkItemCommentID) (wp1 *models.WorkItemComment, err error)
Delete implements _sourceRepos.WorkItemComment
func (WorkItemCommentWithTracing) Update ¶
func (_d WorkItemCommentWithTracing) Update(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, params *models.WorkItemCommentUpdateParams) (wp1 *models.WorkItemComment, err error)
Update implements _sourceRepos.WorkItemComment
type WorkItemTagWithPrometheus ¶
type WorkItemTagWithPrometheus struct {
// contains filtered or unexported fields
}
WorkItemTagWithPrometheus implements _sourceRepos.WorkItemTag interface with all methods wrapped with Prometheus metrics
func NewWorkItemTagWithPrometheus ¶
func NewWorkItemTagWithPrometheus(base _sourceRepos.WorkItemTag, instanceName string) WorkItemTagWithPrometheus
NewWorkItemTagWithPrometheus returns an instance of the _sourceRepos.WorkItemTag decorated with prometheus summary metric
func (WorkItemTagWithPrometheus) ByID ¶
func (_d WorkItemTagWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTagID, opts ...models.WorkItemTagSelectConfigOption) (wp1 *models.WorkItemTag, err error)
ByID implements _sourceRepos.WorkItemTag
func (WorkItemTagWithPrometheus) ByName ¶
func (_d WorkItemTagWithPrometheus) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.WorkItemTagSelectConfigOption) (wp1 *models.WorkItemTag, err error)
ByName implements _sourceRepos.WorkItemTag
func (WorkItemTagWithPrometheus) Create ¶
func (_d WorkItemTagWithPrometheus) Create(ctx context.Context, d models.DBTX, params *models.WorkItemTagCreateParams) (wp1 *models.WorkItemTag, err error)
Create implements _sourceRepos.WorkItemTag
func (WorkItemTagWithPrometheus) Delete ¶
func (_d WorkItemTagWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.WorkItemTagID) (wp1 *models.WorkItemTag, err error)
Delete implements _sourceRepos.WorkItemTag
func (WorkItemTagWithPrometheus) Update ¶
func (_d WorkItemTagWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.WorkItemTagID, params *models.WorkItemTagUpdateParams) (wp1 *models.WorkItemTag, err error)
Update implements _sourceRepos.WorkItemTag
type WorkItemTagWithRetry ¶
type WorkItemTagWithRetry struct { _sourceRepos.WorkItemTag // contains filtered or unexported fields }
WorkItemTagWithRetry implements _sourceRepos.WorkItemTag interface instrumented with retries
func NewWorkItemTagWithRetry ¶
func NewWorkItemTagWithRetry(base _sourceRepos.WorkItemTag, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) WorkItemTagWithRetry
NewWorkItemTagWithRetry returns WorkItemTagWithRetry
func (WorkItemTagWithRetry) ByID ¶
func (_d WorkItemTagWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTagID, opts ...models.WorkItemTagSelectConfigOption) (wp1 *models.WorkItemTag, err error)
ByID implements _sourceRepos.WorkItemTag
func (WorkItemTagWithRetry) ByName ¶
func (_d WorkItemTagWithRetry) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.WorkItemTagSelectConfigOption) (wp1 *models.WorkItemTag, err error)
ByName implements _sourceRepos.WorkItemTag
func (WorkItemTagWithRetry) Create ¶
func (_d WorkItemTagWithRetry) Create(ctx context.Context, d models.DBTX, params *models.WorkItemTagCreateParams) (wp1 *models.WorkItemTag, err error)
Create implements _sourceRepos.WorkItemTag
func (WorkItemTagWithRetry) Delete ¶
func (_d WorkItemTagWithRetry) Delete(ctx context.Context, d models.DBTX, id models.WorkItemTagID) (wp1 *models.WorkItemTag, err error)
Delete implements _sourceRepos.WorkItemTag
func (WorkItemTagWithRetry) Update ¶
func (_d WorkItemTagWithRetry) Update(ctx context.Context, d models.DBTX, id models.WorkItemTagID, params *models.WorkItemTagUpdateParams) (wp1 *models.WorkItemTag, err error)
Update implements _sourceRepos.WorkItemTag
type WorkItemTagWithTimeout ¶
type WorkItemTagWithTimeout struct { _sourceRepos.WorkItemTag // contains filtered or unexported fields }
WorkItemTagWithTimeout implements _sourceRepos.WorkItemTag interface instrumented with timeouts
func NewWorkItemTagWithTimeout ¶
func NewWorkItemTagWithTimeout(base _sourceRepos.WorkItemTag, config WorkItemTagWithTimeoutConfig) WorkItemTagWithTimeout
NewWorkItemTagWithTimeout returns WorkItemTagWithTimeout
func (WorkItemTagWithTimeout) ByID ¶
func (_d WorkItemTagWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTagID, opts ...models.WorkItemTagSelectConfigOption) (wp1 *models.WorkItemTag, err error)
ByID implements _sourceRepos.WorkItemTag
func (WorkItemTagWithTimeout) ByName ¶
func (_d WorkItemTagWithTimeout) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.WorkItemTagSelectConfigOption) (wp1 *models.WorkItemTag, err error)
ByName implements _sourceRepos.WorkItemTag
func (WorkItemTagWithTimeout) Create ¶
func (_d WorkItemTagWithTimeout) Create(ctx context.Context, d models.DBTX, params *models.WorkItemTagCreateParams) (wp1 *models.WorkItemTag, err error)
Create implements _sourceRepos.WorkItemTag
func (WorkItemTagWithTimeout) Delete ¶
func (_d WorkItemTagWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.WorkItemTagID) (wp1 *models.WorkItemTag, err error)
Delete implements _sourceRepos.WorkItemTag
func (WorkItemTagWithTimeout) Update ¶
func (_d WorkItemTagWithTimeout) Update(ctx context.Context, d models.DBTX, id models.WorkItemTagID, params *models.WorkItemTagUpdateParams) (wp1 *models.WorkItemTag, err error)
Update implements _sourceRepos.WorkItemTag
type WorkItemTagWithTracing ¶
type WorkItemTagWithTracing struct { _sourceRepos.WorkItemTag // contains filtered or unexported fields }
WorkItemTagWithTracing implements _sourceRepos.WorkItemTag interface instrumented with opentracing spans
func NewWorkItemTagWithTracing ¶
func NewWorkItemTagWithTracing(base _sourceRepos.WorkItemTag, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) WorkItemTagWithTracing
NewWorkItemTagWithTracing returns WorkItemTagWithTracing
func (WorkItemTagWithTracing) ByID ¶
func (_d WorkItemTagWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTagID, opts ...models.WorkItemTagSelectConfigOption) (wp1 *models.WorkItemTag, err error)
ByID implements _sourceRepos.WorkItemTag
func (WorkItemTagWithTracing) ByName ¶
func (_d WorkItemTagWithTracing) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.WorkItemTagSelectConfigOption) (wp1 *models.WorkItemTag, err error)
ByName implements _sourceRepos.WorkItemTag
func (WorkItemTagWithTracing) Create ¶
func (_d WorkItemTagWithTracing) Create(ctx context.Context, d models.DBTX, params *models.WorkItemTagCreateParams) (wp1 *models.WorkItemTag, err error)
Create implements _sourceRepos.WorkItemTag
func (WorkItemTagWithTracing) Delete ¶
func (_d WorkItemTagWithTracing) Delete(ctx context.Context, d models.DBTX, id models.WorkItemTagID) (wp1 *models.WorkItemTag, err error)
Delete implements _sourceRepos.WorkItemTag
func (WorkItemTagWithTracing) Update ¶
func (_d WorkItemTagWithTracing) Update(ctx context.Context, d models.DBTX, id models.WorkItemTagID, params *models.WorkItemTagUpdateParams) (wp1 *models.WorkItemTag, err error)
Update implements _sourceRepos.WorkItemTag
type WorkItemTypeWithPrometheus ¶
type WorkItemTypeWithPrometheus struct {
// contains filtered or unexported fields
}
WorkItemTypeWithPrometheus implements _sourceRepos.WorkItemType interface with all methods wrapped with Prometheus metrics
func NewWorkItemTypeWithPrometheus ¶
func NewWorkItemTypeWithPrometheus(base _sourceRepos.WorkItemType, instanceName string) WorkItemTypeWithPrometheus
NewWorkItemTypeWithPrometheus returns an instance of the _sourceRepos.WorkItemType decorated with prometheus summary metric
func (WorkItemTypeWithPrometheus) ByID ¶
func (_d WorkItemTypeWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTypeID, opts ...models.WorkItemTypeSelectConfigOption) (wp1 *models.WorkItemType, err error)
ByID implements _sourceRepos.WorkItemType
func (WorkItemTypeWithPrometheus) ByName ¶
func (_d WorkItemTypeWithPrometheus) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.WorkItemTypeSelectConfigOption) (wp1 *models.WorkItemType, err error)
ByName implements _sourceRepos.WorkItemType
type WorkItemTypeWithRetry ¶
type WorkItemTypeWithRetry struct { _sourceRepos.WorkItemType // contains filtered or unexported fields }
WorkItemTypeWithRetry implements _sourceRepos.WorkItemType interface instrumented with retries
func NewWorkItemTypeWithRetry ¶
func NewWorkItemTypeWithRetry(base _sourceRepos.WorkItemType, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) WorkItemTypeWithRetry
NewWorkItemTypeWithRetry returns WorkItemTypeWithRetry
func (WorkItemTypeWithRetry) ByID ¶
func (_d WorkItemTypeWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTypeID, opts ...models.WorkItemTypeSelectConfigOption) (wp1 *models.WorkItemType, err error)
ByID implements _sourceRepos.WorkItemType
func (WorkItemTypeWithRetry) ByName ¶
func (_d WorkItemTypeWithRetry) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.WorkItemTypeSelectConfigOption) (wp1 *models.WorkItemType, err error)
ByName implements _sourceRepos.WorkItemType
type WorkItemTypeWithTimeout ¶
type WorkItemTypeWithTimeout struct { _sourceRepos.WorkItemType // contains filtered or unexported fields }
WorkItemTypeWithTimeout implements _sourceRepos.WorkItemType interface instrumented with timeouts
func NewWorkItemTypeWithTimeout ¶
func NewWorkItemTypeWithTimeout(base _sourceRepos.WorkItemType, config WorkItemTypeWithTimeoutConfig) WorkItemTypeWithTimeout
NewWorkItemTypeWithTimeout returns WorkItemTypeWithTimeout
func (WorkItemTypeWithTimeout) ByID ¶
func (_d WorkItemTypeWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTypeID, opts ...models.WorkItemTypeSelectConfigOption) (wp1 *models.WorkItemType, err error)
ByID implements _sourceRepos.WorkItemType
func (WorkItemTypeWithTimeout) ByName ¶
func (_d WorkItemTypeWithTimeout) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.WorkItemTypeSelectConfigOption) (wp1 *models.WorkItemType, err error)
ByName implements _sourceRepos.WorkItemType
type WorkItemTypeWithTracing ¶
type WorkItemTypeWithTracing struct { _sourceRepos.WorkItemType // contains filtered or unexported fields }
WorkItemTypeWithTracing implements _sourceRepos.WorkItemType interface instrumented with opentracing spans
func NewWorkItemTypeWithTracing ¶
func NewWorkItemTypeWithTracing(base _sourceRepos.WorkItemType, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) WorkItemTypeWithTracing
NewWorkItemTypeWithTracing returns WorkItemTypeWithTracing
func (WorkItemTypeWithTracing) ByID ¶
func (_d WorkItemTypeWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTypeID, opts ...models.WorkItemTypeSelectConfigOption) (wp1 *models.WorkItemType, err error)
ByID implements _sourceRepos.WorkItemType
func (WorkItemTypeWithTracing) ByName ¶
func (_d WorkItemTypeWithTracing) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.WorkItemTypeSelectConfigOption) (wp1 *models.WorkItemType, err error)
ByName implements _sourceRepos.WorkItemType
type WorkItemWithPrometheus ¶
type WorkItemWithPrometheus struct {
// contains filtered or unexported fields
}
WorkItemWithPrometheus implements _sourceRepos.WorkItem interface with all methods wrapped with Prometheus metrics
func NewWorkItemWithPrometheus ¶
func NewWorkItemWithPrometheus(base _sourceRepos.WorkItem, instanceName string) WorkItemWithPrometheus
NewWorkItemWithPrometheus returns an instance of the _sourceRepos.WorkItem decorated with prometheus summary metric
func (WorkItemWithPrometheus) AssignTag ¶
func (_d WorkItemWithPrometheus) AssignTag(ctx context.Context, d models.DBTX, params *models.WorkItemWorkItemTagCreateParams) (err error)
AssignTag implements _sourceRepos.WorkItem
func (WorkItemWithPrometheus) AssignUser ¶
func (_d WorkItemWithPrometheus) AssignUser(ctx context.Context, d models.DBTX, params *models.WorkItemAssigneeCreateParams) (err error)
AssignUser implements _sourceRepos.WorkItem
func (WorkItemWithPrometheus) ByID ¶
func (_d WorkItemWithPrometheus) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.WorkItem
func (WorkItemWithPrometheus) Delete ¶
func (_d WorkItemWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
Delete implements _sourceRepos.WorkItem
func (WorkItemWithPrometheus) RemoveAssignedUser ¶
func (_d WorkItemWithPrometheus) RemoveAssignedUser(ctx context.Context, d models.DBTX, memberID models.UserID, workItemID models.WorkItemID) (err error)
RemoveAssignedUser implements _sourceRepos.WorkItem
func (WorkItemWithPrometheus) RemoveTag ¶
func (_d WorkItemWithPrometheus) RemoveTag(ctx context.Context, d models.DBTX, tagID models.WorkItemTagID, workItemID models.WorkItemID) (err error)
RemoveTag implements _sourceRepos.WorkItem
type WorkItemWithRetry ¶
type WorkItemWithRetry struct { _sourceRepos.WorkItem // contains filtered or unexported fields }
WorkItemWithRetry implements _sourceRepos.WorkItem interface instrumented with retries
func NewWorkItemWithRetry ¶
func NewWorkItemWithRetry(base _sourceRepos.WorkItem, logger *zap.SugaredLogger, retryCount int, retryInterval time.Duration) WorkItemWithRetry
NewWorkItemWithRetry returns WorkItemWithRetry
func (WorkItemWithRetry) AssignTag ¶
func (_d WorkItemWithRetry) AssignTag(ctx context.Context, d models.DBTX, params *models.WorkItemWorkItemTagCreateParams) (err error)
AssignTag implements _sourceRepos.WorkItem
func (WorkItemWithRetry) AssignUser ¶
func (_d WorkItemWithRetry) AssignUser(ctx context.Context, d models.DBTX, params *models.WorkItemAssigneeCreateParams) (err error)
AssignUser implements _sourceRepos.WorkItem
func (WorkItemWithRetry) ByID ¶
func (_d WorkItemWithRetry) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.WorkItem
func (WorkItemWithRetry) Delete ¶
func (_d WorkItemWithRetry) Delete(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
Delete implements _sourceRepos.WorkItem
func (WorkItemWithRetry) RemoveAssignedUser ¶
func (_d WorkItemWithRetry) RemoveAssignedUser(ctx context.Context, d models.DBTX, memberID models.UserID, workItemID models.WorkItemID) (err error)
RemoveAssignedUser implements _sourceRepos.WorkItem
func (WorkItemWithRetry) RemoveTag ¶
func (_d WorkItemWithRetry) RemoveTag(ctx context.Context, d models.DBTX, tagID models.WorkItemTagID, workItemID models.WorkItemID) (err error)
RemoveTag implements _sourceRepos.WorkItem
type WorkItemWithTimeout ¶
type WorkItemWithTimeout struct { _sourceRepos.WorkItem // contains filtered or unexported fields }
WorkItemWithTimeout implements _sourceRepos.WorkItem interface instrumented with timeouts
func NewWorkItemWithTimeout ¶
func NewWorkItemWithTimeout(base _sourceRepos.WorkItem, config WorkItemWithTimeoutConfig) WorkItemWithTimeout
NewWorkItemWithTimeout returns WorkItemWithTimeout
func (WorkItemWithTimeout) AssignTag ¶
func (_d WorkItemWithTimeout) AssignTag(ctx context.Context, d models.DBTX, params *models.WorkItemWorkItemTagCreateParams) (err error)
AssignTag implements _sourceRepos.WorkItem
func (WorkItemWithTimeout) AssignUser ¶
func (_d WorkItemWithTimeout) AssignUser(ctx context.Context, d models.DBTX, params *models.WorkItemAssigneeCreateParams) (err error)
AssignUser implements _sourceRepos.WorkItem
func (WorkItemWithTimeout) ByID ¶
func (_d WorkItemWithTimeout) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.WorkItem
func (WorkItemWithTimeout) Delete ¶
func (_d WorkItemWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
Delete implements _sourceRepos.WorkItem
func (WorkItemWithTimeout) RemoveAssignedUser ¶
func (_d WorkItemWithTimeout) RemoveAssignedUser(ctx context.Context, d models.DBTX, memberID models.UserID, workItemID models.WorkItemID) (err error)
RemoveAssignedUser implements _sourceRepos.WorkItem
func (WorkItemWithTimeout) RemoveTag ¶
func (_d WorkItemWithTimeout) RemoveTag(ctx context.Context, d models.DBTX, tagID models.WorkItemTagID, workItemID models.WorkItemID) (err error)
RemoveTag implements _sourceRepos.WorkItem
type WorkItemWithTracing ¶
type WorkItemWithTracing struct { _sourceRepos.WorkItem // contains filtered or unexported fields }
WorkItemWithTracing implements _sourceRepos.WorkItem interface instrumented with opentracing spans
func NewWorkItemWithTracing ¶
func NewWorkItemWithTracing(base _sourceRepos.WorkItem, instance string, spanDecorator ...func(span trace.Span, params, results map[string]interface{})) WorkItemWithTracing
NewWorkItemWithTracing returns WorkItemWithTracing
func (WorkItemWithTracing) AssignTag ¶
func (_d WorkItemWithTracing) AssignTag(ctx context.Context, d models.DBTX, params *models.WorkItemWorkItemTagCreateParams) (err error)
AssignTag implements _sourceRepos.WorkItem
func (WorkItemWithTracing) AssignUser ¶
func (_d WorkItemWithTracing) AssignUser(ctx context.Context, d models.DBTX, params *models.WorkItemAssigneeCreateParams) (err error)
AssignUser implements _sourceRepos.WorkItem
func (WorkItemWithTracing) ByID ¶
func (_d WorkItemWithTracing) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (wp1 *models.WorkItem, err error)
ByID implements _sourceRepos.WorkItem
func (WorkItemWithTracing) Delete ¶
func (_d WorkItemWithTracing) Delete(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)
Delete implements _sourceRepos.WorkItem
func (WorkItemWithTracing) RemoveAssignedUser ¶
func (_d WorkItemWithTracing) RemoveAssignedUser(ctx context.Context, d models.DBTX, memberID models.UserID, workItemID models.WorkItemID) (err error)
RemoveAssignedUser implements _sourceRepos.WorkItem
func (WorkItemWithTracing) RemoveTag ¶
func (_d WorkItemWithTracing) RemoveTag(ctx context.Context, d models.DBTX, tagID models.WorkItemTagID, workItemID models.WorkItemID) (err error)
RemoveTag implements _sourceRepos.WorkItem
Source Files
¶
- activity_with_otel.gen.go
- activity_with_prometheus.gen.go
- activity_with_retry.gen.go
- activity_with_timeout.gen.go
- demotwoworkitem_with_otel.gen.go
- demotwoworkitem_with_prometheus.gen.go
- demotwoworkitem_with_retry.gen.go
- demotwoworkitem_with_timeout.gen.go
- demoworkitem_with_otel.gen.go
- demoworkitem_with_prometheus.gen.go
- demoworkitem_with_retry.gen.go
- demoworkitem_with_timeout.gen.go
- kanbanstep_with_otel.gen.go
- kanbanstep_with_prometheus.gen.go
- kanbanstep_with_retry.gen.go
- kanbanstep_with_timeout.gen.go
- notification_with_otel.gen.go
- notification_with_prometheus.gen.go
- notification_with_retry.gen.go
- notification_with_timeout.gen.go
- project_with_otel.gen.go
- project_with_prometheus.gen.go
- project_with_retry.gen.go
- project_with_timeout.gen.go
- team_with_otel.gen.go
- team_with_prometheus.gen.go
- team_with_retry.gen.go
- team_with_timeout.gen.go
- timeentry_with_otel.gen.go
- timeentry_with_prometheus.gen.go
- timeentry_with_retry.gen.go
- timeentry_with_timeout.gen.go
- user_with_otel.gen.go
- user_with_prometheus.gen.go
- user_with_retry.gen.go
- user_with_timeout.gen.go
- workitem_with_otel.gen.go
- workitem_with_prometheus.gen.go
- workitem_with_retry.gen.go
- workitem_with_timeout.gen.go
- workitemcomment_with_otel.gen.go
- workitemcomment_with_prometheus.gen.go
- workitemcomment_with_retry.gen.go
- workitemcomment_with_timeout.gen.go
- workitemtag_with_otel.gen.go
- workitemtag_with_prometheus.gen.go
- workitemtag_with_retry.gen.go
- workitemtag_with_timeout.gen.go
- workitemtype_with_otel.gen.go
- workitemtype_with_prometheus.gen.go
- workitemtype_with_retry.gen.go
- workitemtype_with_timeout.gen.go