reposwrappers

package
v0.0.0-...-77c9f96 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 9, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

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

ByID implements _sourceRepos.Activity

func (ActivityWithPrometheus) ByName

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

Create implements _sourceRepos.Activity

func (ActivityWithPrometheus) Delete

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

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

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

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

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

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

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

Update implements _sourceRepos.Activity

type ActivityWithTimeoutConfig

type ActivityWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	ByNameTimeout time.Duration

	ByProjectIDTimeout time.Duration

	CreateTimeout time.Duration

	DeleteTimeout time.Duration

	RestoreTimeout time.Duration

	UpdateTimeout time.Duration
}

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

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

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

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

ByID implements _sourceRepos.DemoTwoWorkItem

func (DemoTwoWorkItemWithPrometheus) Create

Create implements _sourceRepos.DemoTwoWorkItem

func (DemoTwoWorkItemWithPrometheus) Update

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

ByID implements _sourceRepos.DemoTwoWorkItem

func (DemoTwoWorkItemWithRetry) Create

Create implements _sourceRepos.DemoTwoWorkItem

func (DemoTwoWorkItemWithRetry) Update

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

NewDemoTwoWorkItemWithTimeout returns DemoTwoWorkItemWithTimeout

func (DemoTwoWorkItemWithTimeout) ByID

ByID implements _sourceRepos.DemoTwoWorkItem

func (DemoTwoWorkItemWithTimeout) Create

Create implements _sourceRepos.DemoTwoWorkItem

func (DemoTwoWorkItemWithTimeout) Update

Update implements _sourceRepos.DemoTwoWorkItem

type DemoTwoWorkItemWithTimeoutConfig

type DemoTwoWorkItemWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	CreateTimeout time.Duration

	UpdateTimeout time.Duration
}

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

ByID implements _sourceRepos.DemoTwoWorkItem

func (DemoTwoWorkItemWithTracing) Create

Create implements _sourceRepos.DemoTwoWorkItem

func (DemoTwoWorkItemWithTracing) Update

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

ByID implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithPrometheus) Create

Create implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithPrometheus) Paginated

Paginated implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithPrometheus) Update

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

ByID implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithRetry) Create

Create implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithRetry) Paginated

Paginated implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithRetry) Update

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

ByID implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithTimeout) Create

Create implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithTimeout) Paginated

Paginated implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithTimeout) Update

Update implements _sourceRepos.DemoWorkItem

type DemoWorkItemWithTimeoutConfig

type DemoWorkItemWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	CreateTimeout time.Duration

	PaginatedTimeout time.Duration

	UpdateTimeout time.Duration
}

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

ByID implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithTracing) Create

Create implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithTracing) Paginated

Paginated implements _sourceRepos.DemoWorkItem

func (DemoWorkItemWithTracing) Update

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

ByID implements _sourceRepos.KanbanStep

func (KanbanStepWithPrometheus) ByProject

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

ByID implements _sourceRepos.KanbanStep

func (KanbanStepWithRetry) ByProject

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

ByID implements _sourceRepos.KanbanStep

func (KanbanStepWithTimeout) ByProject

ByProject implements _sourceRepos.KanbanStep

type KanbanStepWithTimeoutConfig

type KanbanStepWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	ByProjectTimeout time.Duration
}

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

ByID implements _sourceRepos.KanbanStep

func (KanbanStepWithTracing) ByProject

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

Create implements _sourceRepos.Notification

func (NotificationWithPrometheus) Delete

Delete implements _sourceRepos.Notification

func (NotificationWithPrometheus) LatestNotifications

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

Create implements _sourceRepos.Notification

func (NotificationWithRetry) Delete

Delete implements _sourceRepos.Notification

func (NotificationWithRetry) LatestNotifications

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

Create implements _sourceRepos.Notification

func (NotificationWithTimeout) Delete

Delete implements _sourceRepos.Notification

func (NotificationWithTimeout) LatestNotifications

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 NotificationWithTimeoutConfig

type NotificationWithTimeoutConfig struct {
	CreateTimeout time.Duration

	DeleteTimeout time.Duration

	LatestNotificationsTimeout time.Duration

	PaginatedUserNotificationsTimeout time.Duration
}

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

Create implements _sourceRepos.Notification

func (NotificationWithTracing) Delete

Delete implements _sourceRepos.Notification

func (NotificationWithTracing) LatestNotifications

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

ByID implements _sourceRepos.Project

func (ProjectWithPrometheus) ByName

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

ByID implements _sourceRepos.Project

func (ProjectWithRetry) ByName

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

ByID implements _sourceRepos.Project

func (ProjectWithTimeout) ByName

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 ProjectWithTimeoutConfig

type ProjectWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	ByNameTimeout time.Duration

	IsTeamInProjectTimeout time.Duration
}

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

ByID implements _sourceRepos.Project

func (ProjectWithTracing) ByName

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

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

func (TeamWithPrometheus) Delete

func (_d TeamWithPrometheus) Delete(ctx context.Context, d models.DBTX, id models.TeamID) (tp1 *models.Team, err error)

Delete implements _sourceRepos.Team

func (TeamWithPrometheus) Update

func (_d TeamWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.TeamID, params *models.TeamUpdateParams) (tp1 *models.Team, err error)

Update 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

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

func (TeamWithRetry) Delete

func (_d TeamWithRetry) Delete(ctx context.Context, d models.DBTX, id models.TeamID) (tp1 *models.Team, err error)

Delete implements _sourceRepos.Team

func (TeamWithRetry) Update

func (_d TeamWithRetry) Update(ctx context.Context, d models.DBTX, id models.TeamID, params *models.TeamUpdateParams) (tp1 *models.Team, err error)

Update 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

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

func (TeamWithTimeout) Delete

func (_d TeamWithTimeout) Delete(ctx context.Context, d models.DBTX, id models.TeamID) (tp1 *models.Team, err error)

Delete implements _sourceRepos.Team

func (TeamWithTimeout) Update

func (_d TeamWithTimeout) Update(ctx context.Context, d models.DBTX, id models.TeamID, params *models.TeamUpdateParams) (tp1 *models.Team, err error)

Update implements _sourceRepos.Team

type TeamWithTimeoutConfig

type TeamWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	ByNameTimeout time.Duration

	CreateTimeout time.Duration

	DeleteTimeout time.Duration

	UpdateTimeout time.Duration
}

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

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

func (TeamWithTracing) Delete

func (_d TeamWithTracing) Delete(ctx context.Context, d models.DBTX, id models.TeamID) (tp1 *models.Team, err error)

Delete implements _sourceRepos.Team

func (TeamWithTracing) Update

func (_d TeamWithTracing) Update(ctx context.Context, d models.DBTX, id models.TeamID, params *models.TeamUpdateParams) (tp1 *models.Team, err error)

Update 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

ByID implements _sourceRepos.TimeEntry

func (TimeEntryWithPrometheus) Create

Create implements _sourceRepos.TimeEntry

func (TimeEntryWithPrometheus) Delete

Delete implements _sourceRepos.TimeEntry

func (TimeEntryWithPrometheus) Update

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

ByID implements _sourceRepos.TimeEntry

func (TimeEntryWithRetry) Create

Create implements _sourceRepos.TimeEntry

func (TimeEntryWithRetry) Delete

Delete implements _sourceRepos.TimeEntry

func (TimeEntryWithRetry) Update

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

ByID implements _sourceRepos.TimeEntry

func (TimeEntryWithTimeout) Create

Create implements _sourceRepos.TimeEntry

func (TimeEntryWithTimeout) Delete

Delete implements _sourceRepos.TimeEntry

func (TimeEntryWithTimeout) Update

Update implements _sourceRepos.TimeEntry

type TimeEntryWithTimeoutConfig

type TimeEntryWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	CreateTimeout time.Duration

	DeleteTimeout time.Duration

	UpdateTimeout time.Duration
}

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

ByID implements _sourceRepos.TimeEntry

func (TimeEntryWithTracing) Create

Create implements _sourceRepos.TimeEntry

func (TimeEntryWithTracing) Delete

Delete implements _sourceRepos.TimeEntry

func (TimeEntryWithTracing) Update

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

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

Paginated implements _sourceRepos.User

func (UserWithPrometheus) Update

func (_d UserWithPrometheus) Update(ctx context.Context, d models.DBTX, id models.UserID, params *models.UserUpdateParams) (up1 *models.User, err error)

Update 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

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

func (UserWithRetry) Update

func (_d UserWithRetry) Update(ctx context.Context, d models.DBTX, id models.UserID, params *models.UserUpdateParams) (up1 *models.User, err error)

Update 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

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

func (UserWithTimeout) Update

func (_d UserWithTimeout) Update(ctx context.Context, d models.DBTX, id models.UserID, params *models.UserUpdateParams) (up1 *models.User, err error)

Update 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

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

func (UserWithTracing) Update

func (_d UserWithTracing) Update(ctx context.Context, d models.DBTX, id models.UserID, params *models.UserUpdateParams) (up1 *models.User, err error)

Update 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

ByID implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithPrometheus) Create

Create implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithPrometheus) Delete

Delete implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithPrometheus) Update

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

ByID implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithRetry) Create

Create implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithRetry) Delete

Delete implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithRetry) Update

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

NewWorkItemCommentWithTimeout returns WorkItemCommentWithTimeout

func (WorkItemCommentWithTimeout) ByID

ByID implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithTimeout) Create

Create implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithTimeout) Delete

Delete implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithTimeout) Update

Update implements _sourceRepos.WorkItemComment

type WorkItemCommentWithTimeoutConfig

type WorkItemCommentWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	CreateTimeout time.Duration

	DeleteTimeout time.Duration

	UpdateTimeout time.Duration
}

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

ByID implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithTracing) Create

Create implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithTracing) Delete

Delete implements _sourceRepos.WorkItemComment

func (WorkItemCommentWithTracing) Update

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

ByID implements _sourceRepos.WorkItemTag

func (WorkItemTagWithPrometheus) ByName

ByName implements _sourceRepos.WorkItemTag

func (WorkItemTagWithPrometheus) Create

Create implements _sourceRepos.WorkItemTag

func (WorkItemTagWithPrometheus) Delete

Delete implements _sourceRepos.WorkItemTag

func (WorkItemTagWithPrometheus) Update

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

ByID implements _sourceRepos.WorkItemTag

func (WorkItemTagWithRetry) ByName

ByName implements _sourceRepos.WorkItemTag

func (WorkItemTagWithRetry) Create

Create implements _sourceRepos.WorkItemTag

func (WorkItemTagWithRetry) Delete

Delete implements _sourceRepos.WorkItemTag

func (WorkItemTagWithRetry) Update

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

ByID implements _sourceRepos.WorkItemTag

func (WorkItemTagWithTimeout) ByName

ByName implements _sourceRepos.WorkItemTag

func (WorkItemTagWithTimeout) Create

Create implements _sourceRepos.WorkItemTag

func (WorkItemTagWithTimeout) Delete

Delete implements _sourceRepos.WorkItemTag

func (WorkItemTagWithTimeout) Update

Update implements _sourceRepos.WorkItemTag

type WorkItemTagWithTimeoutConfig

type WorkItemTagWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	ByNameTimeout time.Duration

	CreateTimeout time.Duration

	DeleteTimeout time.Duration

	UpdateTimeout time.Duration
}

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

ByID implements _sourceRepos.WorkItemTag

func (WorkItemTagWithTracing) ByName

ByName implements _sourceRepos.WorkItemTag

func (WorkItemTagWithTracing) Create

Create implements _sourceRepos.WorkItemTag

func (WorkItemTagWithTracing) Delete

Delete implements _sourceRepos.WorkItemTag

func (WorkItemTagWithTracing) Update

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

ByID implements _sourceRepos.WorkItemType

func (WorkItemTypeWithPrometheus) ByName

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

ByID implements _sourceRepos.WorkItemType

func (WorkItemTypeWithRetry) ByName

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

ByID implements _sourceRepos.WorkItemType

func (WorkItemTypeWithTimeout) ByName

ByName implements _sourceRepos.WorkItemType

type WorkItemTypeWithTimeoutConfig

type WorkItemTypeWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	ByNameTimeout time.Duration
}

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

ByID implements _sourceRepos.WorkItemType

func (WorkItemTypeWithTracing) ByName

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

AssignTag implements _sourceRepos.WorkItem

func (WorkItemWithPrometheus) AssignUser

AssignUser implements _sourceRepos.WorkItem

func (WorkItemWithPrometheus) ByID

ByID implements _sourceRepos.WorkItem

func (WorkItemWithPrometheus) Delete

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

func (WorkItemWithPrometheus) Restore

Restore 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

AssignTag implements _sourceRepos.WorkItem

func (WorkItemWithRetry) AssignUser

AssignUser implements _sourceRepos.WorkItem

func (WorkItemWithRetry) ByID

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

func (WorkItemWithRetry) Restore

func (_d WorkItemWithRetry) Restore(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)

Restore 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

AssignTag implements _sourceRepos.WorkItem

func (WorkItemWithTimeout) AssignUser

AssignUser implements _sourceRepos.WorkItem

func (WorkItemWithTimeout) ByID

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

func (WorkItemWithTimeout) Restore

func (_d WorkItemWithTimeout) Restore(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)

Restore implements _sourceRepos.WorkItem

type WorkItemWithTimeoutConfig

type WorkItemWithTimeoutConfig struct {
	AssignTagTimeout time.Duration

	AssignUserTimeout time.Duration

	ByIDTimeout time.Duration

	DeleteTimeout time.Duration

	RemoveAssignedUserTimeout time.Duration

	RemoveTagTimeout time.Duration

	RestoreTimeout time.Duration
}

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

AssignTag implements _sourceRepos.WorkItem

func (WorkItemWithTracing) AssignUser

AssignUser implements _sourceRepos.WorkItem

func (WorkItemWithTracing) ByID

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

func (WorkItemWithTracing) Restore

func (_d WorkItemWithTracing) Restore(ctx context.Context, d models.DBTX, id models.WorkItemID) (wp1 *models.WorkItem, err error)

Restore implements _sourceRepos.WorkItem

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL