queuemetrics

Documentation

Index

• type Bucket
• type Client
• type Params
• type Request
• type Result
  • func New(p Params) Result

Types

type Bucket

type Bucket struct {
	Queue           string
	Status          model.QueueJobStatus
	CreatedAtBucket time.Time
	RanAtBucket     time.Time
	Count           uint
	Latency         *time.Duration
}

type Client

type Client interface {
	Request(context.Context, Request) ([]Bucket, error)
}

type Params

type Params struct {
	fx.In
	Db lazy.Lazy[*gorm.DB]
}

type Request

type Request struct {
	BucketDuration metrics.BucketDuration
	Statuses       []model.QueueJobStatus
	Queues         []string
	StartTime      time.Time
	EndTime        time.Time
}

type Result

type Result struct {
	fx.Out
	Client lazy.Lazy[Client]
}

func New

func New(p Params) Result