reposwrappers

package
v0.0.0-...-5905bd6 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2023 License: Apache-2.0 Imports: 10 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 repos.Activity interface with all methods wrapped with Prometheus metrics

func NewActivityWithPrometheus 

func NewActivityWithPrometheus(base repos.Activity, instanceName string) ActivityWithPrometheus

NewActivityWithPrometheus returns an instance of the repos.Activity decorated with prometheus summary metric

func (ActivityWithPrometheus) ByID 

func (_d ActivityWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.ActivityID, opts ...db.ActivitySelectConfigOption) (ap1 *db.Activity, err error)

ByID implements repos.Activity

func (ActivityWithPrometheus) ByName 

func (_d ActivityWithPrometheus) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.ActivitySelectConfigOption) (ap1 *db.Activity, err error)

ByName implements repos.Activity

func (ActivityWithPrometheus) ByProjectID 

func (_d ActivityWithPrometheus) ByProjectID(ctx context.Context, d db.DBTX, projectID db.ProjectID, opts ...db.ActivitySelectConfigOption) (aa1 []db.Activity, err error)

ByProjectID implements repos.Activity

func (ActivityWithPrometheus) Create 

func (_d ActivityWithPrometheus) Create(ctx context.Context, d db.DBTX, params *db.ActivityCreateParams) (ap1 *db.Activity, err error)

Create implements repos.Activity

func (ActivityWithPrometheus) Delete 

func (_d ActivityWithPrometheus) Delete(ctx context.Context, d db.DBTX, id db.ActivityID) (ap1 *db.Activity, err error)

Delete implements repos.Activity

func (ActivityWithPrometheus) Update 

func (_d ActivityWithPrometheus) Update(ctx context.Context, d db.DBTX, id db.ActivityID, params *db.ActivityUpdateParams) (ap1 *db.Activity, err error)

Update implements repos.Activity

type ActivityWithRetry 

type ActivityWithRetry struct {
	repos.Activity
	// contains filtered or unexported fields
}

ActivityWithRetry implements repos.Activity interface instrumented with retries

func NewActivityWithRetry 

func NewActivityWithRetry(base repos.Activity, retryCount int, retryInterval time.Duration) ActivityWithRetry

NewActivityWithRetry returns ActivityWithRetry

func (ActivityWithRetry) ByID 

func (_d ActivityWithRetry) ByID(ctx context.Context, d db.DBTX, id db.ActivityID, opts ...db.ActivitySelectConfigOption) (ap1 *db.Activity, err error)

ByID implements repos.Activity

func (ActivityWithRetry) ByName 

func (_d ActivityWithRetry) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.ActivitySelectConfigOption) (ap1 *db.Activity, err error)

ByName implements repos.Activity

func (ActivityWithRetry) ByProjectID 

func (_d ActivityWithRetry) ByProjectID(ctx context.Context, d db.DBTX, projectID db.ProjectID, opts ...db.ActivitySelectConfigOption) (aa1 []db.Activity, err error)

ByProjectID implements repos.Activity

func (ActivityWithRetry) Create 

func (_d ActivityWithRetry) Create(ctx context.Context, d db.DBTX, params *db.ActivityCreateParams) (ap1 *db.Activity, err error)

Create implements repos.Activity

func (ActivityWithRetry) Delete 

func (_d ActivityWithRetry) Delete(ctx context.Context, d db.DBTX, id db.ActivityID) (ap1 *db.Activity, err error)

Delete implements repos.Activity

func (ActivityWithRetry) Update 

func (_d ActivityWithRetry) Update(ctx context.Context, d db.DBTX, id db.ActivityID, params *db.ActivityUpdateParams) (ap1 *db.Activity, err error)

Update implements repos.Activity

type ActivityWithTimeout 

type ActivityWithTimeout struct {
	repos.Activity
	// contains filtered or unexported fields
}

ActivityWithTimeout implements repos.Activity interface instrumented with timeouts

func NewActivityWithTimeout 

func NewActivityWithTimeout(base repos.Activity, config ActivityWithTimeoutConfig) ActivityWithTimeout

NewActivityWithTimeout returns ActivityWithTimeout

func (ActivityWithTimeout) ByID 

func (_d ActivityWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.ActivityID, opts ...db.ActivitySelectConfigOption) (ap1 *db.Activity, err error)

ByID implements repos.Activity

func (ActivityWithTimeout) ByName 

func (_d ActivityWithTimeout) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.ActivitySelectConfigOption) (ap1 *db.Activity, err error)

ByName implements repos.Activity

func (ActivityWithTimeout) ByProjectID 

func (_d ActivityWithTimeout) ByProjectID(ctx context.Context, d db.DBTX, projectID db.ProjectID, opts ...db.ActivitySelectConfigOption) (aa1 []db.Activity, err error)

ByProjectID implements repos.Activity

func (ActivityWithTimeout) Create 

func (_d ActivityWithTimeout) Create(ctx context.Context, d db.DBTX, params *db.ActivityCreateParams) (ap1 *db.Activity, err error)

Create implements repos.Activity

func (ActivityWithTimeout) Delete 

func (_d ActivityWithTimeout) Delete(ctx context.Context, d db.DBTX, id db.ActivityID) (ap1 *db.Activity, err error)

Delete implements repos.Activity

func (ActivityWithTimeout) Update 

func (_d ActivityWithTimeout) Update(ctx context.Context, d db.DBTX, id db.ActivityID, params *db.ActivityUpdateParams) (ap1 *db.Activity, err error)

Update implements repos.Activity

type ActivityWithTimeoutConfig 

type ActivityWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	ByNameTimeout time.Duration

	ByProjectIDTimeout time.Duration

	CreateTimeout time.Duration

	DeleteTimeout time.Duration

	UpdateTimeout time.Duration
}

type ActivityWithTracing 

type ActivityWithTracing struct {
	repos.Activity
	// contains filtered or unexported fields
}

ActivityWithTracing implements repos.Activity interface instrumented with opentracing spans

func NewActivityWithTracing 

func NewActivityWithTracing(base repos.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 db.DBTX, id db.ActivityID, opts ...db.ActivitySelectConfigOption) (ap1 *db.Activity, err error)

ByID implements repos.Activity

func (ActivityWithTracing) ByName 

func (_d ActivityWithTracing) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.ActivitySelectConfigOption) (ap1 *db.Activity, err error)

ByName implements repos.Activity

func (ActivityWithTracing) ByProjectID 

func (_d ActivityWithTracing) ByProjectID(ctx context.Context, d db.DBTX, projectID db.ProjectID, opts ...db.ActivitySelectConfigOption) (aa1 []db.Activity, err error)

ByProjectID implements repos.Activity

func (ActivityWithTracing) Create 

func (_d ActivityWithTracing) Create(ctx context.Context, d db.DBTX, params *db.ActivityCreateParams) (ap1 *db.Activity, err error)

Create implements repos.Activity

func (ActivityWithTracing) Delete 

func (_d ActivityWithTracing) Delete(ctx context.Context, d db.DBTX, id db.ActivityID) (ap1 *db.Activity, err error)

Delete implements repos.Activity

func (ActivityWithTracing) Update 

func (_d ActivityWithTracing) Update(ctx context.Context, d db.DBTX, id db.ActivityID, params *db.ActivityUpdateParams) (ap1 *db.Activity, err error)

Update implements repos.Activity

type DemoTwoWorkItemWithPrometheus 

type DemoTwoWorkItemWithPrometheus struct {
	// contains filtered or unexported fields
}

DemoTwoWorkItemWithPrometheus implements repos.DemoTwoWorkItem interface with all methods wrapped with Prometheus metrics

func NewDemoTwoWorkItemWithPrometheus 

func NewDemoTwoWorkItemWithPrometheus(base repos.DemoTwoWorkItem, instanceName string) DemoTwoWorkItemWithPrometheus

NewDemoTwoWorkItemWithPrometheus returns an instance of the repos.DemoTwoWorkItem decorated with prometheus summary metric

func (DemoTwoWorkItemWithPrometheus) ByID 

func (_d DemoTwoWorkItemWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.DemoTwoWorkItem

func (DemoTwoWorkItemWithPrometheus) Create 

func (_d DemoTwoWorkItemWithPrometheus) Create(ctx context.Context, d db.DBTX, params repos.DemoTwoWorkItemCreateParams) (wp1 *db.WorkItem, err error)

Create implements repos.DemoTwoWorkItem

func (DemoTwoWorkItemWithPrometheus) Update 

func (_d DemoTwoWorkItemWithPrometheus) Update(ctx context.Context, d db.DBTX, id db.WorkItemID, params repos.DemoTwoWorkItemUpdateParams) (wp1 *db.WorkItem, err error)

Update implements repos.DemoTwoWorkItem

type DemoTwoWorkItemWithRetry 

type DemoTwoWorkItemWithRetry struct {
	repos.DemoTwoWorkItem
	// contains filtered or unexported fields
}

DemoTwoWorkItemWithRetry implements repos.DemoTwoWorkItem interface instrumented with retries

func NewDemoTwoWorkItemWithRetry 

func NewDemoTwoWorkItemWithRetry(base repos.DemoTwoWorkItem, retryCount int, retryInterval time.Duration) DemoTwoWorkItemWithRetry

NewDemoTwoWorkItemWithRetry returns DemoTwoWorkItemWithRetry

func (DemoTwoWorkItemWithRetry) ByID 

func (_d DemoTwoWorkItemWithRetry) ByID(ctx context.Context, d db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.DemoTwoWorkItem

func (DemoTwoWorkItemWithRetry) Create 

func (_d DemoTwoWorkItemWithRetry) Create(ctx context.Context, d db.DBTX, params repos.DemoTwoWorkItemCreateParams) (wp1 *db.WorkItem, err error)

Create implements repos.DemoTwoWorkItem

func (DemoTwoWorkItemWithRetry) Update 

func (_d DemoTwoWorkItemWithRetry) Update(ctx context.Context, d db.DBTX, id db.WorkItemID, params repos.DemoTwoWorkItemUpdateParams) (wp1 *db.WorkItem, err error)

Update implements repos.DemoTwoWorkItem

type DemoTwoWorkItemWithTimeout 

type DemoTwoWorkItemWithTimeout struct {
	repos.DemoTwoWorkItem
	// contains filtered or unexported fields
}

DemoTwoWorkItemWithTimeout implements repos.DemoTwoWorkItem interface instrumented with timeouts

func NewDemoTwoWorkItemWithTimeout 

func NewDemoTwoWorkItemWithTimeout(base repos.DemoTwoWorkItem, config DemoTwoWorkItemWithTimeoutConfig) DemoTwoWorkItemWithTimeout

NewDemoTwoWorkItemWithTimeout returns DemoTwoWorkItemWithTimeout

func (DemoTwoWorkItemWithTimeout) ByID 

func (_d DemoTwoWorkItemWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.DemoTwoWorkItem

func (DemoTwoWorkItemWithTimeout) Create 

func (_d DemoTwoWorkItemWithTimeout) Create(ctx context.Context, d db.DBTX, params repos.DemoTwoWorkItemCreateParams) (wp1 *db.WorkItem, err error)

Create implements repos.DemoTwoWorkItem

func (DemoTwoWorkItemWithTimeout) Update 

func (_d DemoTwoWorkItemWithTimeout) Update(ctx context.Context, d db.DBTX, id db.WorkItemID, params repos.DemoTwoWorkItemUpdateParams) (wp1 *db.WorkItem, err error)

Update implements repos.DemoTwoWorkItem

type DemoTwoWorkItemWithTimeoutConfig 

type DemoTwoWorkItemWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	CreateTimeout time.Duration

	UpdateTimeout time.Duration
}

type DemoTwoWorkItemWithTracing 

type DemoTwoWorkItemWithTracing struct {
	repos.DemoTwoWorkItem
	// contains filtered or unexported fields
}

DemoTwoWorkItemWithTracing implements repos.DemoTwoWorkItem interface instrumented with opentracing spans

func NewDemoTwoWorkItemWithTracing 

func NewDemoTwoWorkItemWithTracing(base repos.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 db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.DemoTwoWorkItem

func (DemoTwoWorkItemWithTracing) Create 

func (_d DemoTwoWorkItemWithTracing) Create(ctx context.Context, d db.DBTX, params repos.DemoTwoWorkItemCreateParams) (wp1 *db.WorkItem, err error)

Create implements repos.DemoTwoWorkItem

func (DemoTwoWorkItemWithTracing) Update 

func (_d DemoTwoWorkItemWithTracing) Update(ctx context.Context, d db.DBTX, id db.WorkItemID, params repos.DemoTwoWorkItemUpdateParams) (wp1 *db.WorkItem, err error)

Update implements repos.DemoTwoWorkItem

type DemoWorkItemWithPrometheus 

type DemoWorkItemWithPrometheus struct {
	// contains filtered or unexported fields
}

DemoWorkItemWithPrometheus implements repos.DemoWorkItem interface with all methods wrapped with Prometheus metrics

func NewDemoWorkItemWithPrometheus 

func NewDemoWorkItemWithPrometheus(base repos.DemoWorkItem, instanceName string) DemoWorkItemWithPrometheus

NewDemoWorkItemWithPrometheus returns an instance of the repos.DemoWorkItem decorated with prometheus summary metric

func (DemoWorkItemWithPrometheus) ByID 

func (_d DemoWorkItemWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.DemoWorkItem

func (DemoWorkItemWithPrometheus) Create 

func (_d DemoWorkItemWithPrometheus) Create(ctx context.Context, d db.DBTX, params repos.DemoWorkItemCreateParams) (wp1 *db.WorkItem, err error)

Create implements repos.DemoWorkItem

func (DemoWorkItemWithPrometheus) Update 

func (_d DemoWorkItemWithPrometheus) Update(ctx context.Context, d db.DBTX, id db.WorkItemID, params repos.DemoWorkItemUpdateParams) (wp1 *db.WorkItem, err error)

Update implements repos.DemoWorkItem

type DemoWorkItemWithRetry 

type DemoWorkItemWithRetry struct {
	repos.DemoWorkItem
	// contains filtered or unexported fields
}

DemoWorkItemWithRetry implements repos.DemoWorkItem interface instrumented with retries

func NewDemoWorkItemWithRetry 

func NewDemoWorkItemWithRetry(base repos.DemoWorkItem, retryCount int, retryInterval time.Duration) DemoWorkItemWithRetry

NewDemoWorkItemWithRetry returns DemoWorkItemWithRetry

func (DemoWorkItemWithRetry) ByID 

func (_d DemoWorkItemWithRetry) ByID(ctx context.Context, d db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.DemoWorkItem

func (DemoWorkItemWithRetry) Create 

func (_d DemoWorkItemWithRetry) Create(ctx context.Context, d db.DBTX, params repos.DemoWorkItemCreateParams) (wp1 *db.WorkItem, err error)

Create implements repos.DemoWorkItem

func (DemoWorkItemWithRetry) Update 

func (_d DemoWorkItemWithRetry) Update(ctx context.Context, d db.DBTX, id db.WorkItemID, params repos.DemoWorkItemUpdateParams) (wp1 *db.WorkItem, err error)

Update implements repos.DemoWorkItem

type DemoWorkItemWithTimeout 

type DemoWorkItemWithTimeout struct {
	repos.DemoWorkItem
	// contains filtered or unexported fields
}

DemoWorkItemWithTimeout implements repos.DemoWorkItem interface instrumented with timeouts

func NewDemoWorkItemWithTimeout 

func NewDemoWorkItemWithTimeout(base repos.DemoWorkItem, config DemoWorkItemWithTimeoutConfig) DemoWorkItemWithTimeout

NewDemoWorkItemWithTimeout returns DemoWorkItemWithTimeout

func (DemoWorkItemWithTimeout) ByID 

func (_d DemoWorkItemWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.DemoWorkItem

func (DemoWorkItemWithTimeout) Create 

func (_d DemoWorkItemWithTimeout) Create(ctx context.Context, d db.DBTX, params repos.DemoWorkItemCreateParams) (wp1 *db.WorkItem, err error)

Create implements repos.DemoWorkItem

func (DemoWorkItemWithTimeout) Update 

func (_d DemoWorkItemWithTimeout) Update(ctx context.Context, d db.DBTX, id db.WorkItemID, params repos.DemoWorkItemUpdateParams) (wp1 *db.WorkItem, err error)

Update implements repos.DemoWorkItem

type DemoWorkItemWithTimeoutConfig 

type DemoWorkItemWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	CreateTimeout time.Duration

	UpdateTimeout time.Duration
}

type DemoWorkItemWithTracing 

type DemoWorkItemWithTracing struct {
	repos.DemoWorkItem
	// contains filtered or unexported fields
}

DemoWorkItemWithTracing implements repos.DemoWorkItem interface instrumented with opentracing spans

func NewDemoWorkItemWithTracing 

func NewDemoWorkItemWithTracing(base repos.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 db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.DemoWorkItem

func (DemoWorkItemWithTracing) Create 

func (_d DemoWorkItemWithTracing) Create(ctx context.Context, d db.DBTX, params repos.DemoWorkItemCreateParams) (wp1 *db.WorkItem, err error)

Create implements repos.DemoWorkItem

func (DemoWorkItemWithTracing) Update 

func (_d DemoWorkItemWithTracing) Update(ctx context.Context, d db.DBTX, id db.WorkItemID, params repos.DemoWorkItemUpdateParams) (wp1 *db.WorkItem, err error)

Update implements repos.DemoWorkItem

type KanbanStepWithPrometheus 

type KanbanStepWithPrometheus struct {
	// contains filtered or unexported fields
}

KanbanStepWithPrometheus implements repos.KanbanStep interface with all methods wrapped with Prometheus metrics

func NewKanbanStepWithPrometheus 

func NewKanbanStepWithPrometheus(base repos.KanbanStep, instanceName string) KanbanStepWithPrometheus

NewKanbanStepWithPrometheus returns an instance of the repos.KanbanStep decorated with prometheus summary metric

func (KanbanStepWithPrometheus) ByID 

func (_d KanbanStepWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.KanbanStepID, opts ...db.KanbanStepSelectConfigOption) (kp1 *db.KanbanStep, err error)

ByID implements repos.KanbanStep

func (KanbanStepWithPrometheus) ByProject 

func (_d KanbanStepWithPrometheus) ByProject(ctx context.Context, d db.DBTX, projectID db.ProjectID, opts ...db.KanbanStepSelectConfigOption) (ka1 []db.KanbanStep, err error)

ByProject implements repos.KanbanStep

type KanbanStepWithRetry 

type KanbanStepWithRetry struct {
	repos.KanbanStep
	// contains filtered or unexported fields
}

KanbanStepWithRetry implements repos.KanbanStep interface instrumented with retries

func NewKanbanStepWithRetry 

func NewKanbanStepWithRetry(base repos.KanbanStep, retryCount int, retryInterval time.Duration) KanbanStepWithRetry

NewKanbanStepWithRetry returns KanbanStepWithRetry

func (KanbanStepWithRetry) ByID 

func (_d KanbanStepWithRetry) ByID(ctx context.Context, d db.DBTX, id db.KanbanStepID, opts ...db.KanbanStepSelectConfigOption) (kp1 *db.KanbanStep, err error)

ByID implements repos.KanbanStep

func (KanbanStepWithRetry) ByProject 

func (_d KanbanStepWithRetry) ByProject(ctx context.Context, d db.DBTX, projectID db.ProjectID, opts ...db.KanbanStepSelectConfigOption) (ka1 []db.KanbanStep, err error)

ByProject implements repos.KanbanStep

type KanbanStepWithTimeout 

type KanbanStepWithTimeout struct {
	repos.KanbanStep
	// contains filtered or unexported fields
}

KanbanStepWithTimeout implements repos.KanbanStep interface instrumented with timeouts

func NewKanbanStepWithTimeout 

func NewKanbanStepWithTimeout(base repos.KanbanStep, config KanbanStepWithTimeoutConfig) KanbanStepWithTimeout

NewKanbanStepWithTimeout returns KanbanStepWithTimeout

func (KanbanStepWithTimeout) ByID 

func (_d KanbanStepWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.KanbanStepID, opts ...db.KanbanStepSelectConfigOption) (kp1 *db.KanbanStep, err error)

ByID implements repos.KanbanStep

func (KanbanStepWithTimeout) ByProject 

func (_d KanbanStepWithTimeout) ByProject(ctx context.Context, d db.DBTX, projectID db.ProjectID, opts ...db.KanbanStepSelectConfigOption) (ka1 []db.KanbanStep, err error)

ByProject implements repos.KanbanStep

type KanbanStepWithTimeoutConfig 

type KanbanStepWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	ByProjectTimeout time.Duration
}

type KanbanStepWithTracing 

type KanbanStepWithTracing struct {
	repos.KanbanStep
	// contains filtered or unexported fields
}

KanbanStepWithTracing implements repos.KanbanStep interface instrumented with opentracing spans

func NewKanbanStepWithTracing 

func NewKanbanStepWithTracing(base repos.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 db.DBTX, id db.KanbanStepID, opts ...db.KanbanStepSelectConfigOption) (kp1 *db.KanbanStep, err error)

ByID implements repos.KanbanStep

func (KanbanStepWithTracing) ByProject 

func (_d KanbanStepWithTracing) ByProject(ctx context.Context, d db.DBTX, projectID db.ProjectID, opts ...db.KanbanStepSelectConfigOption) (ka1 []db.KanbanStep, err error)

ByProject implements repos.KanbanStep

type NotificationWithPrometheus 

type NotificationWithPrometheus struct {
	// contains filtered or unexported fields
}

NotificationWithPrometheus implements repos.Notification interface with all methods wrapped with Prometheus metrics

func NewNotificationWithPrometheus 

func NewNotificationWithPrometheus(base repos.Notification, instanceName string) NotificationWithPrometheus

NewNotificationWithPrometheus returns an instance of the repos.Notification decorated with prometheus summary metric

func (NotificationWithPrometheus) Create 

func (_d NotificationWithPrometheus) Create(ctx context.Context, d db.DBTX, params *db.NotificationCreateParams) (np1 *db.Notification, err error)

Create implements repos.Notification

func (NotificationWithPrometheus) Delete 

func (_d NotificationWithPrometheus) Delete(ctx context.Context, d db.DBTX, id db.NotificationID) (np1 *db.Notification, err error)

Delete implements repos.Notification

func (NotificationWithPrometheus) LatestUserNotifications 

func (_d NotificationWithPrometheus) LatestUserNotifications(ctx context.Context, d db.DBTX, params *db.GetUserNotificationsParams) (ga1 []db.GetUserNotificationsRow, err error)

LatestUserNotifications implements repos.Notification

type NotificationWithRetry 

type NotificationWithRetry struct {
	repos.Notification
	// contains filtered or unexported fields
}

NotificationWithRetry implements repos.Notification interface instrumented with retries

func NewNotificationWithRetry 

func NewNotificationWithRetry(base repos.Notification, retryCount int, retryInterval time.Duration) NotificationWithRetry

NewNotificationWithRetry returns NotificationWithRetry

func (NotificationWithRetry) Create 

func (_d NotificationWithRetry) Create(ctx context.Context, d db.DBTX, params *db.NotificationCreateParams) (np1 *db.Notification, err error)

Create implements repos.Notification

func (NotificationWithRetry) Delete 

func (_d NotificationWithRetry) Delete(ctx context.Context, d db.DBTX, id db.NotificationID) (np1 *db.Notification, err error)

Delete implements repos.Notification

func (NotificationWithRetry) LatestUserNotifications 

func (_d NotificationWithRetry) LatestUserNotifications(ctx context.Context, d db.DBTX, params *db.GetUserNotificationsParams) (ga1 []db.GetUserNotificationsRow, err error)

LatestUserNotifications implements repos.Notification

type NotificationWithTimeout 

type NotificationWithTimeout struct {
	repos.Notification
	// contains filtered or unexported fields
}

NotificationWithTimeout implements repos.Notification interface instrumented with timeouts

func NewNotificationWithTimeout 

func NewNotificationWithTimeout(base repos.Notification, config NotificationWithTimeoutConfig) NotificationWithTimeout

NewNotificationWithTimeout returns NotificationWithTimeout

func (NotificationWithTimeout) Create 

func (_d NotificationWithTimeout) Create(ctx context.Context, d db.DBTX, params *db.NotificationCreateParams) (np1 *db.Notification, err error)

Create implements repos.Notification

func (NotificationWithTimeout) Delete 

func (_d NotificationWithTimeout) Delete(ctx context.Context, d db.DBTX, id db.NotificationID) (np1 *db.Notification, err error)

Delete implements repos.Notification

func (NotificationWithTimeout) LatestUserNotifications 

func (_d NotificationWithTimeout) LatestUserNotifications(ctx context.Context, d db.DBTX, params *db.GetUserNotificationsParams) (ga1 []db.GetUserNotificationsRow, err error)

LatestUserNotifications implements repos.Notification

type NotificationWithTimeoutConfig 

type NotificationWithTimeoutConfig struct {
	CreateTimeout time.Duration

	DeleteTimeout time.Duration

	LatestUserNotificationsTimeout time.Duration
}

type NotificationWithTracing 

type NotificationWithTracing struct {
	repos.Notification
	// contains filtered or unexported fields
}

NotificationWithTracing implements repos.Notification interface instrumented with opentracing spans

func NewNotificationWithTracing 

func NewNotificationWithTracing(base repos.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 db.DBTX, params *db.NotificationCreateParams) (np1 *db.Notification, err error)

Create implements repos.Notification

func (NotificationWithTracing) Delete 

func (_d NotificationWithTracing) Delete(ctx context.Context, d db.DBTX, id db.NotificationID) (np1 *db.Notification, err error)

Delete implements repos.Notification

func (NotificationWithTracing) LatestUserNotifications 

func (_d NotificationWithTracing) LatestUserNotifications(ctx context.Context, d db.DBTX, params *db.GetUserNotificationsParams) (ga1 []db.GetUserNotificationsRow, err error)

LatestUserNotifications implements repos.Notification

type ProjectWithPrometheus 

type ProjectWithPrometheus struct {
	// contains filtered or unexported fields
}

ProjectWithPrometheus implements repos.Project interface with all methods wrapped with Prometheus metrics

func NewProjectWithPrometheus 

func NewProjectWithPrometheus(base repos.Project, instanceName string) ProjectWithPrometheus

NewProjectWithPrometheus returns an instance of the repos.Project decorated with prometheus summary metric

func (ProjectWithPrometheus) ByID 

func (_d ProjectWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.ProjectID, opts ...db.ProjectSelectConfigOption) (pp1 *db.Project, err error)

ByID implements repos.Project

func (ProjectWithPrometheus) ByName 

func (_d ProjectWithPrometheus) ByName(ctx context.Context, d db.DBTX, name models.Project, opts ...db.ProjectSelectConfigOption) (pp1 *db.Project, err error)

ByName implements repos.Project

type ProjectWithRetry 

type ProjectWithRetry struct {
	repos.Project
	// contains filtered or unexported fields
}

ProjectWithRetry implements repos.Project interface instrumented with retries

func NewProjectWithRetry 

func NewProjectWithRetry(base repos.Project, retryCount int, retryInterval time.Duration) ProjectWithRetry

NewProjectWithRetry returns ProjectWithRetry

func (ProjectWithRetry) ByID 

func (_d ProjectWithRetry) ByID(ctx context.Context, d db.DBTX, id db.ProjectID, opts ...db.ProjectSelectConfigOption) (pp1 *db.Project, err error)

ByID implements repos.Project

func (ProjectWithRetry) ByName 

func (_d ProjectWithRetry) ByName(ctx context.Context, d db.DBTX, name models.Project, opts ...db.ProjectSelectConfigOption) (pp1 *db.Project, err error)

ByName implements repos.Project

type ProjectWithTimeout 

type ProjectWithTimeout struct {
	repos.Project
	// contains filtered or unexported fields
}

ProjectWithTimeout implements repos.Project interface instrumented with timeouts

func NewProjectWithTimeout 

func NewProjectWithTimeout(base repos.Project, config ProjectWithTimeoutConfig) ProjectWithTimeout

NewProjectWithTimeout returns ProjectWithTimeout

func (ProjectWithTimeout) ByID 

func (_d ProjectWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.ProjectID, opts ...db.ProjectSelectConfigOption) (pp1 *db.Project, err error)

ByID implements repos.Project

func (ProjectWithTimeout) ByName 

func (_d ProjectWithTimeout) ByName(ctx context.Context, d db.DBTX, name models.Project, opts ...db.ProjectSelectConfigOption) (pp1 *db.Project, err error)

ByName implements repos.Project

type ProjectWithTimeoutConfig 

type ProjectWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	ByNameTimeout time.Duration
}

type ProjectWithTracing 

type ProjectWithTracing struct {
	repos.Project
	// contains filtered or unexported fields
}

ProjectWithTracing implements repos.Project interface instrumented with opentracing spans

func NewProjectWithTracing 

func NewProjectWithTracing(base repos.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 db.DBTX, id db.ProjectID, opts ...db.ProjectSelectConfigOption) (pp1 *db.Project, err error)

ByID implements repos.Project

func (ProjectWithTracing) ByName 

func (_d ProjectWithTracing) ByName(ctx context.Context, d db.DBTX, name models.Project, opts ...db.ProjectSelectConfigOption) (pp1 *db.Project, err error)

ByName implements repos.Project

type TeamWithPrometheus 

type TeamWithPrometheus struct {
	// contains filtered or unexported fields
}

TeamWithPrometheus implements repos.Team interface with all methods wrapped with Prometheus metrics

func NewTeamWithPrometheus 

func NewTeamWithPrometheus(base repos.Team, instanceName string) TeamWithPrometheus

NewTeamWithPrometheus returns an instance of the repos.Team decorated with prometheus summary metric

func (TeamWithPrometheus) ByID 

func (_d TeamWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.TeamID, opts ...db.TeamSelectConfigOption) (tp1 *db.Team, err error)

ByID implements repos.Team

func (TeamWithPrometheus) ByName 

func (_d TeamWithPrometheus) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.TeamSelectConfigOption) (tp1 *db.Team, err error)

ByName implements repos.Team

func (TeamWithPrometheus) Create 

func (_d TeamWithPrometheus) Create(ctx context.Context, d db.DBTX, params *db.TeamCreateParams) (tp1 *db.Team, err error)

Create implements repos.Team

func (TeamWithPrometheus) Delete 

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

Delete implements repos.Team

func (TeamWithPrometheus) Update 

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

Update implements repos.Team

type TeamWithRetry 

type TeamWithRetry struct {
	repos.Team
	// contains filtered or unexported fields
}

TeamWithRetry implements repos.Team interface instrumented with retries

func NewTeamWithRetry 

func NewTeamWithRetry(base repos.Team, retryCount int, retryInterval time.Duration) TeamWithRetry

NewTeamWithRetry returns TeamWithRetry

func (TeamWithRetry) ByID 

func (_d TeamWithRetry) ByID(ctx context.Context, d db.DBTX, id db.TeamID, opts ...db.TeamSelectConfigOption) (tp1 *db.Team, err error)

ByID implements repos.Team

func (TeamWithRetry) ByName 

func (_d TeamWithRetry) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.TeamSelectConfigOption) (tp1 *db.Team, err error)

ByName implements repos.Team

func (TeamWithRetry) Create 

func (_d TeamWithRetry) Create(ctx context.Context, d db.DBTX, params *db.TeamCreateParams) (tp1 *db.Team, err error)

Create implements repos.Team

func (TeamWithRetry) Delete 

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

Delete implements repos.Team

func (TeamWithRetry) Update 

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

Update implements repos.Team

type TeamWithTimeout 

type TeamWithTimeout struct {
	repos.Team
	// contains filtered or unexported fields
}

TeamWithTimeout implements repos.Team interface instrumented with timeouts

func NewTeamWithTimeout 

func NewTeamWithTimeout(base repos.Team, config TeamWithTimeoutConfig) TeamWithTimeout

NewTeamWithTimeout returns TeamWithTimeout

func (TeamWithTimeout) ByID 

func (_d TeamWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.TeamID, opts ...db.TeamSelectConfigOption) (tp1 *db.Team, err error)

ByID implements repos.Team

func (TeamWithTimeout) ByName 

func (_d TeamWithTimeout) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.TeamSelectConfigOption) (tp1 *db.Team, err error)

ByName implements repos.Team

func (TeamWithTimeout) Create 

func (_d TeamWithTimeout) Create(ctx context.Context, d db.DBTX, params *db.TeamCreateParams) (tp1 *db.Team, err error)

Create implements repos.Team

func (TeamWithTimeout) Delete 

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

Delete implements repos.Team

func (TeamWithTimeout) Update 

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

Update implements repos.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 {
	repos.Team
	// contains filtered or unexported fields
}

TeamWithTracing implements repos.Team interface instrumented with opentracing spans

func NewTeamWithTracing 

func NewTeamWithTracing(base repos.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 db.DBTX, id db.TeamID, opts ...db.TeamSelectConfigOption) (tp1 *db.Team, err error)

ByID implements repos.Team

func (TeamWithTracing) ByName 

func (_d TeamWithTracing) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.TeamSelectConfigOption) (tp1 *db.Team, err error)

ByName implements repos.Team

func (TeamWithTracing) Create 

func (_d TeamWithTracing) Create(ctx context.Context, d db.DBTX, params *db.TeamCreateParams) (tp1 *db.Team, err error)

Create implements repos.Team

func (TeamWithTracing) Delete 

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

Delete implements repos.Team

func (TeamWithTracing) Update 

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

Update implements repos.Team

type TimeEntryWithPrometheus 

type TimeEntryWithPrometheus struct {
	// contains filtered or unexported fields
}

TimeEntryWithPrometheus implements repos.TimeEntry interface with all methods wrapped with Prometheus metrics

func NewTimeEntryWithPrometheus 

func NewTimeEntryWithPrometheus(base repos.TimeEntry, instanceName string) TimeEntryWithPrometheus

NewTimeEntryWithPrometheus returns an instance of the repos.TimeEntry decorated with prometheus summary metric

func (TimeEntryWithPrometheus) ByID 

func (_d TimeEntryWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.TimeEntryID, opts ...db.TimeEntrySelectConfigOption) (tp1 *db.TimeEntry, err error)

ByID implements repos.TimeEntry

func (TimeEntryWithPrometheus) Create 

func (_d TimeEntryWithPrometheus) Create(ctx context.Context, d db.DBTX, params *db.TimeEntryCreateParams) (tp1 *db.TimeEntry, err error)

Create implements repos.TimeEntry

func (TimeEntryWithPrometheus) Delete 

func (_d TimeEntryWithPrometheus) Delete(ctx context.Context, d db.DBTX, id db.TimeEntryID) (tp1 *db.TimeEntry, err error)

Delete implements repos.TimeEntry

func (TimeEntryWithPrometheus) Update 

func (_d TimeEntryWithPrometheus) Update(ctx context.Context, d db.DBTX, id db.TimeEntryID, params *db.TimeEntryUpdateParams) (tp1 *db.TimeEntry, err error)

Update implements repos.TimeEntry

type TimeEntryWithRetry 

type TimeEntryWithRetry struct {
	repos.TimeEntry
	// contains filtered or unexported fields
}

TimeEntryWithRetry implements repos.TimeEntry interface instrumented with retries

func NewTimeEntryWithRetry 

func NewTimeEntryWithRetry(base repos.TimeEntry, retryCount int, retryInterval time.Duration) TimeEntryWithRetry

NewTimeEntryWithRetry returns TimeEntryWithRetry

func (TimeEntryWithRetry) ByID 

func (_d TimeEntryWithRetry) ByID(ctx context.Context, d db.DBTX, id db.TimeEntryID, opts ...db.TimeEntrySelectConfigOption) (tp1 *db.TimeEntry, err error)

ByID implements repos.TimeEntry

func (TimeEntryWithRetry) Create 

func (_d TimeEntryWithRetry) Create(ctx context.Context, d db.DBTX, params *db.TimeEntryCreateParams) (tp1 *db.TimeEntry, err error)

Create implements repos.TimeEntry

func (TimeEntryWithRetry) Delete 

func (_d TimeEntryWithRetry) Delete(ctx context.Context, d db.DBTX, id db.TimeEntryID) (tp1 *db.TimeEntry, err error)

Delete implements repos.TimeEntry

func (TimeEntryWithRetry) Update 

func (_d TimeEntryWithRetry) Update(ctx context.Context, d db.DBTX, id db.TimeEntryID, params *db.TimeEntryUpdateParams) (tp1 *db.TimeEntry, err error)

Update implements repos.TimeEntry

type TimeEntryWithTimeout 

type TimeEntryWithTimeout struct {
	repos.TimeEntry
	// contains filtered or unexported fields
}

TimeEntryWithTimeout implements repos.TimeEntry interface instrumented with timeouts

func NewTimeEntryWithTimeout 

func NewTimeEntryWithTimeout(base repos.TimeEntry, config TimeEntryWithTimeoutConfig) TimeEntryWithTimeout

NewTimeEntryWithTimeout returns TimeEntryWithTimeout

func (TimeEntryWithTimeout) ByID 

func (_d TimeEntryWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.TimeEntryID, opts ...db.TimeEntrySelectConfigOption) (tp1 *db.TimeEntry, err error)

ByID implements repos.TimeEntry

func (TimeEntryWithTimeout) Create 

func (_d TimeEntryWithTimeout) Create(ctx context.Context, d db.DBTX, params *db.TimeEntryCreateParams) (tp1 *db.TimeEntry, err error)

Create implements repos.TimeEntry

func (TimeEntryWithTimeout) Delete 

func (_d TimeEntryWithTimeout) Delete(ctx context.Context, d db.DBTX, id db.TimeEntryID) (tp1 *db.TimeEntry, err error)

Delete implements repos.TimeEntry

func (TimeEntryWithTimeout) Update 

func (_d TimeEntryWithTimeout) Update(ctx context.Context, d db.DBTX, id db.TimeEntryID, params *db.TimeEntryUpdateParams) (tp1 *db.TimeEntry, err error)

Update implements repos.TimeEntry

type TimeEntryWithTimeoutConfig 

type TimeEntryWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	CreateTimeout time.Duration

	DeleteTimeout time.Duration

	UpdateTimeout time.Duration
}

type TimeEntryWithTracing 

type TimeEntryWithTracing struct {
	repos.TimeEntry
	// contains filtered or unexported fields
}

TimeEntryWithTracing implements repos.TimeEntry interface instrumented with opentracing spans

func NewTimeEntryWithTracing 

func NewTimeEntryWithTracing(base repos.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 db.DBTX, id db.TimeEntryID, opts ...db.TimeEntrySelectConfigOption) (tp1 *db.TimeEntry, err error)

ByID implements repos.TimeEntry

func (TimeEntryWithTracing) Create 

func (_d TimeEntryWithTracing) Create(ctx context.Context, d db.DBTX, params *db.TimeEntryCreateParams) (tp1 *db.TimeEntry, err error)

Create implements repos.TimeEntry

func (TimeEntryWithTracing) Delete 

func (_d TimeEntryWithTracing) Delete(ctx context.Context, d db.DBTX, id db.TimeEntryID) (tp1 *db.TimeEntry, err error)

Delete implements repos.TimeEntry

func (TimeEntryWithTracing) Update 

func (_d TimeEntryWithTracing) Update(ctx context.Context, d db.DBTX, id db.TimeEntryID, params *db.TimeEntryUpdateParams) (tp1 *db.TimeEntry, err error)

Update implements repos.TimeEntry

type UserWithPrometheus 

type UserWithPrometheus struct {
	// contains filtered or unexported fields
}

UserWithPrometheus implements repos.User interface with all methods wrapped with Prometheus metrics

func NewUserWithPrometheus 

func NewUserWithPrometheus(base repos.User, instanceName string) UserWithPrometheus

NewUserWithPrometheus returns an instance of the repos.User decorated with prometheus summary metric

func (UserWithPrometheus) ByAPIKey 

func (_d UserWithPrometheus) ByAPIKey(ctx context.Context, d db.DBTX, apiKey string) (up1 *db.User, err error)

ByAPIKey implements repos.User

func (UserWithPrometheus) ByEmail 

func (_d UserWithPrometheus) ByEmail(ctx context.Context, d db.DBTX, email string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByEmail implements repos.User

func (UserWithPrometheus) ByExternalID 

func (_d UserWithPrometheus) ByExternalID(ctx context.Context, d db.DBTX, extID string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByExternalID implements repos.User

func (UserWithPrometheus) ByID 

func (_d UserWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.UserID, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByID implements repos.User

func (UserWithPrometheus) ByProject 

func (_d UserWithPrometheus) ByProject(ctx context.Context, d db.DBTX, projectID db.ProjectID) (ua1 []db.User, err error)

ByProject implements repos.User

func (UserWithPrometheus) ByTeam 

func (_d UserWithPrometheus) ByTeam(ctx context.Context, d db.DBTX, teamID db.TeamID) (ua1 []db.User, err error)

ByTeam implements repos.User

func (UserWithPrometheus) ByUsername 

func (_d UserWithPrometheus) ByUsername(ctx context.Context, d db.DBTX, username string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByUsername implements repos.User

func (UserWithPrometheus) Create 

func (_d UserWithPrometheus) Create(ctx context.Context, d db.DBTX, params *db.UserCreateParams) (up1 *db.User, err error)

Create implements repos.User

func (UserWithPrometheus) CreateAPIKey 

func (_d UserWithPrometheus) CreateAPIKey(ctx context.Context, d db.DBTX, user *db.User) (up1 *db.UserAPIKey, err error)

CreateAPIKey implements repos.User

func (UserWithPrometheus) Delete 

func (_d UserWithPrometheus) Delete(ctx context.Context, d db.DBTX, id db.UserID) (up1 *db.User, err error)

Delete implements repos.User

func (UserWithPrometheus) DeleteAPIKey 

func (_d UserWithPrometheus) DeleteAPIKey(ctx context.Context, d db.DBTX, apiKey string) (up1 *db.UserAPIKey, err error)

DeleteAPIKey implements repos.User

func (UserWithPrometheus) Update 

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

Update implements repos.User

type UserWithRetry 

type UserWithRetry struct {
	repos.User
	// contains filtered or unexported fields
}

UserWithRetry implements repos.User interface instrumented with retries

func NewUserWithRetry 

func NewUserWithRetry(base repos.User, retryCount int, retryInterval time.Duration) UserWithRetry

NewUserWithRetry returns UserWithRetry

func (UserWithRetry) ByAPIKey 

func (_d UserWithRetry) ByAPIKey(ctx context.Context, d db.DBTX, apiKey string) (up1 *db.User, err error)

ByAPIKey implements repos.User

func (UserWithRetry) ByEmail 

func (_d UserWithRetry) ByEmail(ctx context.Context, d db.DBTX, email string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByEmail implements repos.User

func (UserWithRetry) ByExternalID 

func (_d UserWithRetry) ByExternalID(ctx context.Context, d db.DBTX, extID string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByExternalID implements repos.User

func (UserWithRetry) ByID 

func (_d UserWithRetry) ByID(ctx context.Context, d db.DBTX, id db.UserID, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByID implements repos.User

func (UserWithRetry) ByProject 

func (_d UserWithRetry) ByProject(ctx context.Context, d db.DBTX, projectID db.ProjectID) (ua1 []db.User, err error)

ByProject implements repos.User

func (UserWithRetry) ByTeam 

func (_d UserWithRetry) ByTeam(ctx context.Context, d db.DBTX, teamID db.TeamID) (ua1 []db.User, err error)

ByTeam implements repos.User

func (UserWithRetry) ByUsername 

func (_d UserWithRetry) ByUsername(ctx context.Context, d db.DBTX, username string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByUsername implements repos.User

func (UserWithRetry) Create 

func (_d UserWithRetry) Create(ctx context.Context, d db.DBTX, params *db.UserCreateParams) (up1 *db.User, err error)

Create implements repos.User

func (UserWithRetry) CreateAPIKey 

func (_d UserWithRetry) CreateAPIKey(ctx context.Context, d db.DBTX, user *db.User) (up1 *db.UserAPIKey, err error)

CreateAPIKey implements repos.User

func (UserWithRetry) Delete 

func (_d UserWithRetry) Delete(ctx context.Context, d db.DBTX, id db.UserID) (up1 *db.User, err error)

Delete implements repos.User

func (UserWithRetry) DeleteAPIKey 

func (_d UserWithRetry) DeleteAPIKey(ctx context.Context, d db.DBTX, apiKey string) (up1 *db.UserAPIKey, err error)

DeleteAPIKey implements repos.User

func (UserWithRetry) Update 

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

Update implements repos.User

type UserWithTimeout 

type UserWithTimeout struct {
	repos.User
	// contains filtered or unexported fields
}

UserWithTimeout implements repos.User interface instrumented with timeouts

func NewUserWithTimeout 

func NewUserWithTimeout(base repos.User, config UserWithTimeoutConfig) UserWithTimeout

NewUserWithTimeout returns UserWithTimeout

func (UserWithTimeout) ByAPIKey 

func (_d UserWithTimeout) ByAPIKey(ctx context.Context, d db.DBTX, apiKey string) (up1 *db.User, err error)

ByAPIKey implements repos.User

func (UserWithTimeout) ByEmail 

func (_d UserWithTimeout) ByEmail(ctx context.Context, d db.DBTX, email string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByEmail implements repos.User

func (UserWithTimeout) ByExternalID 

func (_d UserWithTimeout) ByExternalID(ctx context.Context, d db.DBTX, extID string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByExternalID implements repos.User

func (UserWithTimeout) ByID 

func (_d UserWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.UserID, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByID implements repos.User

func (UserWithTimeout) ByProject 

func (_d UserWithTimeout) ByProject(ctx context.Context, d db.DBTX, projectID db.ProjectID) (ua1 []db.User, err error)

ByProject implements repos.User

func (UserWithTimeout) ByTeam 

func (_d UserWithTimeout) ByTeam(ctx context.Context, d db.DBTX, teamID db.TeamID) (ua1 []db.User, err error)

ByTeam implements repos.User

func (UserWithTimeout) ByUsername 

func (_d UserWithTimeout) ByUsername(ctx context.Context, d db.DBTX, username string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByUsername implements repos.User

func (UserWithTimeout) Create 

func (_d UserWithTimeout) Create(ctx context.Context, d db.DBTX, params *db.UserCreateParams) (up1 *db.User, err error)

Create implements repos.User

func (UserWithTimeout) CreateAPIKey 

func (_d UserWithTimeout) CreateAPIKey(ctx context.Context, d db.DBTX, user *db.User) (up1 *db.UserAPIKey, err error)

CreateAPIKey implements repos.User

func (UserWithTimeout) Delete 

func (_d UserWithTimeout) Delete(ctx context.Context, d db.DBTX, id db.UserID) (up1 *db.User, err error)

Delete implements repos.User

func (UserWithTimeout) DeleteAPIKey 

func (_d UserWithTimeout) DeleteAPIKey(ctx context.Context, d db.DBTX, apiKey string) (up1 *db.UserAPIKey, err error)

DeleteAPIKey implements repos.User

func (UserWithTimeout) Update 

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

Update implements repos.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

	UpdateTimeout time.Duration
}

type UserWithTracing 

type UserWithTracing struct {
	repos.User
	// contains filtered or unexported fields
}

UserWithTracing implements repos.User interface instrumented with opentracing spans

func NewUserWithTracing 

func NewUserWithTracing(base repos.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 db.DBTX, apiKey string) (up1 *db.User, err error)

ByAPIKey implements repos.User

func (UserWithTracing) ByEmail 

func (_d UserWithTracing) ByEmail(ctx context.Context, d db.DBTX, email string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByEmail implements repos.User

func (UserWithTracing) ByExternalID 

func (_d UserWithTracing) ByExternalID(ctx context.Context, d db.DBTX, extID string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByExternalID implements repos.User

func (UserWithTracing) ByID 

func (_d UserWithTracing) ByID(ctx context.Context, d db.DBTX, id db.UserID, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByID implements repos.User

func (UserWithTracing) ByProject 

func (_d UserWithTracing) ByProject(ctx context.Context, d db.DBTX, projectID db.ProjectID) (ua1 []db.User, err error)

ByProject implements repos.User

func (UserWithTracing) ByTeam 

func (_d UserWithTracing) ByTeam(ctx context.Context, d db.DBTX, teamID db.TeamID) (ua1 []db.User, err error)

ByTeam implements repos.User

func (UserWithTracing) ByUsername 

func (_d UserWithTracing) ByUsername(ctx context.Context, d db.DBTX, username string, opts ...db.UserSelectConfigOption) (up1 *db.User, err error)

ByUsername implements repos.User

func (UserWithTracing) Create 

func (_d UserWithTracing) Create(ctx context.Context, d db.DBTX, params *db.UserCreateParams) (up1 *db.User, err error)

Create implements repos.User

func (UserWithTracing) CreateAPIKey 

func (_d UserWithTracing) CreateAPIKey(ctx context.Context, d db.DBTX, user *db.User) (up1 *db.UserAPIKey, err error)

CreateAPIKey implements repos.User

func (UserWithTracing) Delete 

func (_d UserWithTracing) Delete(ctx context.Context, d db.DBTX, id db.UserID) (up1 *db.User, err error)

Delete implements repos.User

func (UserWithTracing) DeleteAPIKey 

func (_d UserWithTracing) DeleteAPIKey(ctx context.Context, d db.DBTX, apiKey string) (up1 *db.UserAPIKey, err error)

DeleteAPIKey implements repos.User

func (UserWithTracing) Update 

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

Update implements repos.User

type WorkItemCommentWithPrometheus 

type WorkItemCommentWithPrometheus struct {
	// contains filtered or unexported fields
}

WorkItemCommentWithPrometheus implements repos.WorkItemComment interface with all methods wrapped with Prometheus metrics

func NewWorkItemCommentWithPrometheus 

func NewWorkItemCommentWithPrometheus(base repos.WorkItemComment, instanceName string) WorkItemCommentWithPrometheus

NewWorkItemCommentWithPrometheus returns an instance of the repos.WorkItemComment decorated with prometheus summary metric

func (WorkItemCommentWithPrometheus) ByID 

func (_d WorkItemCommentWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.WorkItemCommentID, opts ...db.WorkItemCommentSelectConfigOption) (wp1 *db.WorkItemComment, err error)

ByID implements repos.WorkItemComment

func (WorkItemCommentWithPrometheus) Create 

func (_d WorkItemCommentWithPrometheus) Create(ctx context.Context, d db.DBTX, params *db.WorkItemCommentCreateParams) (wp1 *db.WorkItemComment, err error)

Create implements repos.WorkItemComment

func (WorkItemCommentWithPrometheus) Delete 

func (_d WorkItemCommentWithPrometheus) Delete(ctx context.Context, d db.DBTX, id db.WorkItemCommentID) (wp1 *db.WorkItemComment, err error)

Delete implements repos.WorkItemComment

func (WorkItemCommentWithPrometheus) Update 

func (_d WorkItemCommentWithPrometheus) Update(ctx context.Context, d db.DBTX, id db.WorkItemCommentID, params *db.WorkItemCommentUpdateParams) (wp1 *db.WorkItemComment, err error)

Update implements repos.WorkItemComment

type WorkItemCommentWithRetry 

type WorkItemCommentWithRetry struct {
	repos.WorkItemComment
	// contains filtered or unexported fields
}

WorkItemCommentWithRetry implements repos.WorkItemComment interface instrumented with retries

func NewWorkItemCommentWithRetry 

func NewWorkItemCommentWithRetry(base repos.WorkItemComment, retryCount int, retryInterval time.Duration) WorkItemCommentWithRetry

NewWorkItemCommentWithRetry returns WorkItemCommentWithRetry

func (WorkItemCommentWithRetry) ByID 

func (_d WorkItemCommentWithRetry) ByID(ctx context.Context, d db.DBTX, id db.WorkItemCommentID, opts ...db.WorkItemCommentSelectConfigOption) (wp1 *db.WorkItemComment, err error)

ByID implements repos.WorkItemComment

func (WorkItemCommentWithRetry) Create 

func (_d WorkItemCommentWithRetry) Create(ctx context.Context, d db.DBTX, params *db.WorkItemCommentCreateParams) (wp1 *db.WorkItemComment, err error)

Create implements repos.WorkItemComment

func (WorkItemCommentWithRetry) Delete 

func (_d WorkItemCommentWithRetry) Delete(ctx context.Context, d db.DBTX, id db.WorkItemCommentID) (wp1 *db.WorkItemComment, err error)

Delete implements repos.WorkItemComment

func (WorkItemCommentWithRetry) Update 

func (_d WorkItemCommentWithRetry) Update(ctx context.Context, d db.DBTX, id db.WorkItemCommentID, params *db.WorkItemCommentUpdateParams) (wp1 *db.WorkItemComment, err error)

Update implements repos.WorkItemComment

type WorkItemCommentWithTimeout 

type WorkItemCommentWithTimeout struct {
	repos.WorkItemComment
	// contains filtered or unexported fields
}

WorkItemCommentWithTimeout implements repos.WorkItemComment interface instrumented with timeouts

func NewWorkItemCommentWithTimeout 

func NewWorkItemCommentWithTimeout(base repos.WorkItemComment, config WorkItemCommentWithTimeoutConfig) WorkItemCommentWithTimeout

NewWorkItemCommentWithTimeout returns WorkItemCommentWithTimeout

func (WorkItemCommentWithTimeout) ByID 

func (_d WorkItemCommentWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.WorkItemCommentID, opts ...db.WorkItemCommentSelectConfigOption) (wp1 *db.WorkItemComment, err error)

ByID implements repos.WorkItemComment

func (WorkItemCommentWithTimeout) Create 

func (_d WorkItemCommentWithTimeout) Create(ctx context.Context, d db.DBTX, params *db.WorkItemCommentCreateParams) (wp1 *db.WorkItemComment, err error)

Create implements repos.WorkItemComment

func (WorkItemCommentWithTimeout) Delete 

func (_d WorkItemCommentWithTimeout) Delete(ctx context.Context, d db.DBTX, id db.WorkItemCommentID) (wp1 *db.WorkItemComment, err error)

Delete implements repos.WorkItemComment

func (WorkItemCommentWithTimeout) Update 

func (_d WorkItemCommentWithTimeout) Update(ctx context.Context, d db.DBTX, id db.WorkItemCommentID, params *db.WorkItemCommentUpdateParams) (wp1 *db.WorkItemComment, err error)

Update implements repos.WorkItemComment

type WorkItemCommentWithTimeoutConfig 

type WorkItemCommentWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	CreateTimeout time.Duration

	DeleteTimeout time.Duration

	UpdateTimeout time.Duration
}

type WorkItemCommentWithTracing 

type WorkItemCommentWithTracing struct {
	repos.WorkItemComment
	// contains filtered or unexported fields
}

WorkItemCommentWithTracing implements repos.WorkItemComment interface instrumented with opentracing spans

func NewWorkItemCommentWithTracing 

func NewWorkItemCommentWithTracing(base repos.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 db.DBTX, id db.WorkItemCommentID, opts ...db.WorkItemCommentSelectConfigOption) (wp1 *db.WorkItemComment, err error)

ByID implements repos.WorkItemComment

func (WorkItemCommentWithTracing) Create 

func (_d WorkItemCommentWithTracing) Create(ctx context.Context, d db.DBTX, params *db.WorkItemCommentCreateParams) (wp1 *db.WorkItemComment, err error)

Create implements repos.WorkItemComment

func (WorkItemCommentWithTracing) Delete 

func (_d WorkItemCommentWithTracing) Delete(ctx context.Context, d db.DBTX, id db.WorkItemCommentID) (wp1 *db.WorkItemComment, err error)

Delete implements repos.WorkItemComment

func (WorkItemCommentWithTracing) Update 

func (_d WorkItemCommentWithTracing) Update(ctx context.Context, d db.DBTX, id db.WorkItemCommentID, params *db.WorkItemCommentUpdateParams) (wp1 *db.WorkItemComment, err error)

Update implements repos.WorkItemComment

type WorkItemTagWithPrometheus 

type WorkItemTagWithPrometheus struct {
	// contains filtered or unexported fields
}

WorkItemTagWithPrometheus implements repos.WorkItemTag interface with all methods wrapped with Prometheus metrics

func NewWorkItemTagWithPrometheus 

func NewWorkItemTagWithPrometheus(base repos.WorkItemTag, instanceName string) WorkItemTagWithPrometheus

NewWorkItemTagWithPrometheus returns an instance of the repos.WorkItemTag decorated with prometheus summary metric

func (WorkItemTagWithPrometheus) ByID 

func (_d WorkItemTagWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.WorkItemTagID, opts ...db.WorkItemTagSelectConfigOption) (wp1 *db.WorkItemTag, err error)

ByID implements repos.WorkItemTag

func (WorkItemTagWithPrometheus) ByName 

func (_d WorkItemTagWithPrometheus) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.WorkItemTagSelectConfigOption) (wp1 *db.WorkItemTag, err error)

ByName implements repos.WorkItemTag

func (WorkItemTagWithPrometheus) Create 

func (_d WorkItemTagWithPrometheus) Create(ctx context.Context, d db.DBTX, params *db.WorkItemTagCreateParams) (wp1 *db.WorkItemTag, err error)

Create implements repos.WorkItemTag

func (WorkItemTagWithPrometheus) Delete 

func (_d WorkItemTagWithPrometheus) Delete(ctx context.Context, d db.DBTX, id db.WorkItemTagID) (wp1 *db.WorkItemTag, err error)

Delete implements repos.WorkItemTag

func (WorkItemTagWithPrometheus) Update 

func (_d WorkItemTagWithPrometheus) Update(ctx context.Context, d db.DBTX, id db.WorkItemTagID, params *db.WorkItemTagUpdateParams) (wp1 *db.WorkItemTag, err error)

Update implements repos.WorkItemTag

type WorkItemTagWithRetry 

type WorkItemTagWithRetry struct {
	repos.WorkItemTag
	// contains filtered or unexported fields
}

WorkItemTagWithRetry implements repos.WorkItemTag interface instrumented with retries

func NewWorkItemTagWithRetry 

func NewWorkItemTagWithRetry(base repos.WorkItemTag, retryCount int, retryInterval time.Duration) WorkItemTagWithRetry

NewWorkItemTagWithRetry returns WorkItemTagWithRetry

func (WorkItemTagWithRetry) ByID 

func (_d WorkItemTagWithRetry) ByID(ctx context.Context, d db.DBTX, id db.WorkItemTagID, opts ...db.WorkItemTagSelectConfigOption) (wp1 *db.WorkItemTag, err error)

ByID implements repos.WorkItemTag

func (WorkItemTagWithRetry) ByName 

func (_d WorkItemTagWithRetry) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.WorkItemTagSelectConfigOption) (wp1 *db.WorkItemTag, err error)

ByName implements repos.WorkItemTag

func (WorkItemTagWithRetry) Create 

func (_d WorkItemTagWithRetry) Create(ctx context.Context, d db.DBTX, params *db.WorkItemTagCreateParams) (wp1 *db.WorkItemTag, err error)

Create implements repos.WorkItemTag

func (WorkItemTagWithRetry) Delete 

func (_d WorkItemTagWithRetry) Delete(ctx context.Context, d db.DBTX, id db.WorkItemTagID) (wp1 *db.WorkItemTag, err error)

Delete implements repos.WorkItemTag

func (WorkItemTagWithRetry) Update 

func (_d WorkItemTagWithRetry) Update(ctx context.Context, d db.DBTX, id db.WorkItemTagID, params *db.WorkItemTagUpdateParams) (wp1 *db.WorkItemTag, err error)

Update implements repos.WorkItemTag

type WorkItemTagWithTimeout 

type WorkItemTagWithTimeout struct {
	repos.WorkItemTag
	// contains filtered or unexported fields
}

WorkItemTagWithTimeout implements repos.WorkItemTag interface instrumented with timeouts

func NewWorkItemTagWithTimeout 

func NewWorkItemTagWithTimeout(base repos.WorkItemTag, config WorkItemTagWithTimeoutConfig) WorkItemTagWithTimeout

NewWorkItemTagWithTimeout returns WorkItemTagWithTimeout

func (WorkItemTagWithTimeout) ByID 

func (_d WorkItemTagWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.WorkItemTagID, opts ...db.WorkItemTagSelectConfigOption) (wp1 *db.WorkItemTag, err error)

ByID implements repos.WorkItemTag

func (WorkItemTagWithTimeout) ByName 

func (_d WorkItemTagWithTimeout) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.WorkItemTagSelectConfigOption) (wp1 *db.WorkItemTag, err error)

ByName implements repos.WorkItemTag

func (WorkItemTagWithTimeout) Create 

func (_d WorkItemTagWithTimeout) Create(ctx context.Context, d db.DBTX, params *db.WorkItemTagCreateParams) (wp1 *db.WorkItemTag, err error)

Create implements repos.WorkItemTag

func (WorkItemTagWithTimeout) Delete 

func (_d WorkItemTagWithTimeout) Delete(ctx context.Context, d db.DBTX, id db.WorkItemTagID) (wp1 *db.WorkItemTag, err error)

Delete implements repos.WorkItemTag

func (WorkItemTagWithTimeout) Update 

func (_d WorkItemTagWithTimeout) Update(ctx context.Context, d db.DBTX, id db.WorkItemTagID, params *db.WorkItemTagUpdateParams) (wp1 *db.WorkItemTag, err error)

Update implements repos.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 {
	repos.WorkItemTag
	// contains filtered or unexported fields
}

WorkItemTagWithTracing implements repos.WorkItemTag interface instrumented with opentracing spans

func NewWorkItemTagWithTracing 

func NewWorkItemTagWithTracing(base repos.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 db.DBTX, id db.WorkItemTagID, opts ...db.WorkItemTagSelectConfigOption) (wp1 *db.WorkItemTag, err error)

ByID implements repos.WorkItemTag

func (WorkItemTagWithTracing) ByName 

func (_d WorkItemTagWithTracing) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.WorkItemTagSelectConfigOption) (wp1 *db.WorkItemTag, err error)

ByName implements repos.WorkItemTag

func (WorkItemTagWithTracing) Create 

func (_d WorkItemTagWithTracing) Create(ctx context.Context, d db.DBTX, params *db.WorkItemTagCreateParams) (wp1 *db.WorkItemTag, err error)

Create implements repos.WorkItemTag

func (WorkItemTagWithTracing) Delete 

func (_d WorkItemTagWithTracing) Delete(ctx context.Context, d db.DBTX, id db.WorkItemTagID) (wp1 *db.WorkItemTag, err error)

Delete implements repos.WorkItemTag

func (WorkItemTagWithTracing) Update 

func (_d WorkItemTagWithTracing) Update(ctx context.Context, d db.DBTX, id db.WorkItemTagID, params *db.WorkItemTagUpdateParams) (wp1 *db.WorkItemTag, err error)

Update implements repos.WorkItemTag

type WorkItemTypeWithPrometheus 

type WorkItemTypeWithPrometheus struct {
	// contains filtered or unexported fields
}

WorkItemTypeWithPrometheus implements repos.WorkItemType interface with all methods wrapped with Prometheus metrics

func NewWorkItemTypeWithPrometheus 

func NewWorkItemTypeWithPrometheus(base repos.WorkItemType, instanceName string) WorkItemTypeWithPrometheus

NewWorkItemTypeWithPrometheus returns an instance of the repos.WorkItemType decorated with prometheus summary metric

func (WorkItemTypeWithPrometheus) ByID 

func (_d WorkItemTypeWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.WorkItemTypeID, opts ...db.WorkItemTypeSelectConfigOption) (wp1 *db.WorkItemType, err error)

ByID implements repos.WorkItemType

func (WorkItemTypeWithPrometheus) ByName 

func (_d WorkItemTypeWithPrometheus) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.WorkItemTypeSelectConfigOption) (wp1 *db.WorkItemType, err error)

ByName implements repos.WorkItemType

type WorkItemTypeWithRetry 

type WorkItemTypeWithRetry struct {
	repos.WorkItemType
	// contains filtered or unexported fields
}

WorkItemTypeWithRetry implements repos.WorkItemType interface instrumented with retries

func NewWorkItemTypeWithRetry 

func NewWorkItemTypeWithRetry(base repos.WorkItemType, retryCount int, retryInterval time.Duration) WorkItemTypeWithRetry

NewWorkItemTypeWithRetry returns WorkItemTypeWithRetry

func (WorkItemTypeWithRetry) ByID 

func (_d WorkItemTypeWithRetry) ByID(ctx context.Context, d db.DBTX, id db.WorkItemTypeID, opts ...db.WorkItemTypeSelectConfigOption) (wp1 *db.WorkItemType, err error)

ByID implements repos.WorkItemType

func (WorkItemTypeWithRetry) ByName 

func (_d WorkItemTypeWithRetry) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.WorkItemTypeSelectConfigOption) (wp1 *db.WorkItemType, err error)

ByName implements repos.WorkItemType

type WorkItemTypeWithTimeout 

type WorkItemTypeWithTimeout struct {
	repos.WorkItemType
	// contains filtered or unexported fields
}

WorkItemTypeWithTimeout implements repos.WorkItemType interface instrumented with timeouts

func NewWorkItemTypeWithTimeout 

func NewWorkItemTypeWithTimeout(base repos.WorkItemType, config WorkItemTypeWithTimeoutConfig) WorkItemTypeWithTimeout

NewWorkItemTypeWithTimeout returns WorkItemTypeWithTimeout

func (WorkItemTypeWithTimeout) ByID 

func (_d WorkItemTypeWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.WorkItemTypeID, opts ...db.WorkItemTypeSelectConfigOption) (wp1 *db.WorkItemType, err error)

ByID implements repos.WorkItemType

func (WorkItemTypeWithTimeout) ByName 

func (_d WorkItemTypeWithTimeout) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.WorkItemTypeSelectConfigOption) (wp1 *db.WorkItemType, err error)

ByName implements repos.WorkItemType

type WorkItemTypeWithTimeoutConfig 

type WorkItemTypeWithTimeoutConfig struct {
	ByIDTimeout time.Duration

	ByNameTimeout time.Duration
}

type WorkItemTypeWithTracing 

type WorkItemTypeWithTracing struct {
	repos.WorkItemType
	// contains filtered or unexported fields
}

WorkItemTypeWithTracing implements repos.WorkItemType interface instrumented with opentracing spans

func NewWorkItemTypeWithTracing 

func NewWorkItemTypeWithTracing(base repos.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 db.DBTX, id db.WorkItemTypeID, opts ...db.WorkItemTypeSelectConfigOption) (wp1 *db.WorkItemType, err error)

ByID implements repos.WorkItemType

func (WorkItemTypeWithTracing) ByName 

func (_d WorkItemTypeWithTracing) ByName(ctx context.Context, d db.DBTX, name string, projectID db.ProjectID, opts ...db.WorkItemTypeSelectConfigOption) (wp1 *db.WorkItemType, err error)

ByName implements repos.WorkItemType

type WorkItemWithPrometheus 

type WorkItemWithPrometheus struct {
	// contains filtered or unexported fields
}

WorkItemWithPrometheus implements repos.WorkItem interface with all methods wrapped with Prometheus metrics

func NewWorkItemWithPrometheus 

func NewWorkItemWithPrometheus(base repos.WorkItem, instanceName string) WorkItemWithPrometheus

NewWorkItemWithPrometheus returns an instance of the repos.WorkItem decorated with prometheus summary metric

func (WorkItemWithPrometheus) AssignTag 

func (_d WorkItemWithPrometheus) AssignTag(ctx context.Context, d db.DBTX, params *db.WorkItemWorkItemTagCreateParams) (err error)

AssignTag implements repos.WorkItem

func (WorkItemWithPrometheus) AssignUser 

func (_d WorkItemWithPrometheus) AssignUser(ctx context.Context, d db.DBTX, params *db.WorkItemAssignedUserCreateParams) (err error)

AssignUser implements repos.WorkItem

func (WorkItemWithPrometheus) ByID 

func (_d WorkItemWithPrometheus) ByID(ctx context.Context, d db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.WorkItem

func (WorkItemWithPrometheus) Delete 

func (_d WorkItemWithPrometheus) Delete(ctx context.Context, d db.DBTX, id db.WorkItemID) (wp1 *db.WorkItem, err error)

Delete implements repos.WorkItem

func (WorkItemWithPrometheus) RemoveAssignedUser 

func (_d WorkItemWithPrometheus) RemoveAssignedUser(ctx context.Context, d db.DBTX, memberID db.UserID, workItemID db.WorkItemID) (err error)

RemoveAssignedUser implements repos.WorkItem

func (WorkItemWithPrometheus) RemoveTag 

func (_d WorkItemWithPrometheus) RemoveTag(ctx context.Context, d db.DBTX, tagID db.WorkItemTagID, workItemID db.WorkItemID) (err error)

RemoveTag implements repos.WorkItem

func (WorkItemWithPrometheus) Restore 

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

Restore implements repos.WorkItem

type WorkItemWithRetry 

type WorkItemWithRetry struct {
	repos.WorkItem
	// contains filtered or unexported fields
}

WorkItemWithRetry implements repos.WorkItem interface instrumented with retries

func NewWorkItemWithRetry 

func NewWorkItemWithRetry(base repos.WorkItem, retryCount int, retryInterval time.Duration) WorkItemWithRetry

NewWorkItemWithRetry returns WorkItemWithRetry

func (WorkItemWithRetry) AssignTag 

func (_d WorkItemWithRetry) AssignTag(ctx context.Context, d db.DBTX, params *db.WorkItemWorkItemTagCreateParams) (err error)

AssignTag implements repos.WorkItem

func (WorkItemWithRetry) AssignUser 

func (_d WorkItemWithRetry) AssignUser(ctx context.Context, d db.DBTX, params *db.WorkItemAssignedUserCreateParams) (err error)

AssignUser implements repos.WorkItem

func (WorkItemWithRetry) ByID 

func (_d WorkItemWithRetry) ByID(ctx context.Context, d db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.WorkItem

func (WorkItemWithRetry) Delete 

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

Delete implements repos.WorkItem

func (WorkItemWithRetry) RemoveAssignedUser 

func (_d WorkItemWithRetry) RemoveAssignedUser(ctx context.Context, d db.DBTX, memberID db.UserID, workItemID db.WorkItemID) (err error)

RemoveAssignedUser implements repos.WorkItem

func (WorkItemWithRetry) RemoveTag 

func (_d WorkItemWithRetry) RemoveTag(ctx context.Context, d db.DBTX, tagID db.WorkItemTagID, workItemID db.WorkItemID) (err error)

RemoveTag implements repos.WorkItem

func (WorkItemWithRetry) Restore 

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

Restore implements repos.WorkItem

type WorkItemWithTimeout 

type WorkItemWithTimeout struct {
	repos.WorkItem
	// contains filtered or unexported fields
}

WorkItemWithTimeout implements repos.WorkItem interface instrumented with timeouts

func NewWorkItemWithTimeout 

func NewWorkItemWithTimeout(base repos.WorkItem, config WorkItemWithTimeoutConfig) WorkItemWithTimeout

NewWorkItemWithTimeout returns WorkItemWithTimeout

func (WorkItemWithTimeout) AssignTag 

func (_d WorkItemWithTimeout) AssignTag(ctx context.Context, d db.DBTX, params *db.WorkItemWorkItemTagCreateParams) (err error)

AssignTag implements repos.WorkItem

func (WorkItemWithTimeout) AssignUser 

func (_d WorkItemWithTimeout) AssignUser(ctx context.Context, d db.DBTX, params *db.WorkItemAssignedUserCreateParams) (err error)

AssignUser implements repos.WorkItem

func (WorkItemWithTimeout) ByID 

func (_d WorkItemWithTimeout) ByID(ctx context.Context, d db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.WorkItem

func (WorkItemWithTimeout) Delete 

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

Delete implements repos.WorkItem

func (WorkItemWithTimeout) RemoveAssignedUser 

func (_d WorkItemWithTimeout) RemoveAssignedUser(ctx context.Context, d db.DBTX, memberID db.UserID, workItemID db.WorkItemID) (err error)

RemoveAssignedUser implements repos.WorkItem

func (WorkItemWithTimeout) RemoveTag 

func (_d WorkItemWithTimeout) RemoveTag(ctx context.Context, d db.DBTX, tagID db.WorkItemTagID, workItemID db.WorkItemID) (err error)

RemoveTag implements repos.WorkItem

func (WorkItemWithTimeout) Restore 

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

Restore implements repos.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 {
	repos.WorkItem
	// contains filtered or unexported fields
}

WorkItemWithTracing implements repos.WorkItem interface instrumented with opentracing spans

func NewWorkItemWithTracing 

func NewWorkItemWithTracing(base repos.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 db.DBTX, params *db.WorkItemWorkItemTagCreateParams) (err error)

AssignTag implements repos.WorkItem

func (WorkItemWithTracing) AssignUser 

func (_d WorkItemWithTracing) AssignUser(ctx context.Context, d db.DBTX, params *db.WorkItemAssignedUserCreateParams) (err error)

AssignUser implements repos.WorkItem

func (WorkItemWithTracing) ByID 

func (_d WorkItemWithTracing) ByID(ctx context.Context, d db.DBTX, id db.WorkItemID, opts ...db.WorkItemSelectConfigOption) (wp1 *db.WorkItem, err error)

ByID implements repos.WorkItem

func (WorkItemWithTracing) Delete 

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

Delete implements repos.WorkItem

func (WorkItemWithTracing) RemoveAssignedUser 

func (_d WorkItemWithTracing) RemoveAssignedUser(ctx context.Context, d db.DBTX, memberID db.UserID, workItemID db.WorkItemID) (err error)

RemoveAssignedUser implements repos.WorkItem

func (WorkItemWithTracing) RemoveTag 

func (_d WorkItemWithTracing) RemoveTag(ctx context.Context, d db.DBTX, tagID db.WorkItemTagID, workItemID db.WorkItemID) (err error)

RemoveTag implements repos.WorkItem

func (WorkItemWithTracing) Restore 

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

Restore implements repos.WorkItem

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.