jobq

package
v1.17.0 Latest Latest
Warning

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

Go to latest
Published: Nov 6, 2025 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Inspect added in v1.14.0

type Inspect struct {
	Server    string `required:"true"`
	Identity  string `required:"true"`
	Placement int    `required:"true"`
	StreamID  string `arg:""`
}

func (*Inspect) Run added in v1.14.0

func (s *Inspect) Run() error

type Jobq

type Jobq struct {
	Stat    Stat    `cmd:"" help:"Show job queue statistics."`
	Peek    Peek    `cmd:"" help:"Peek into the job queue, showing the next jobs without removing them."`
	Trim    Trim    `cmd:"" help:"Trim the job queue, removing jobs up to a specified placement constraint."`
	Inspect Inspect `cmd:"" help:"Inspect jobs in the job queue, showing detailed information about each job."`
}

type Peek added in v1.9.0

type Peek struct {
	Server        string `required:"true"`
	Identity      string `required:"true"`
	WithHistogram bool
	Placement     *int
	Number        int `help:"number of jobs to peek" alias:"n" default:"10"`
}

func (*Peek) Run added in v1.9.0

func (s *Peek) Run() error

type Stat

type Stat struct {
	Server        string `required:"true"`
	Identity      string `required:"true"`
	WithHistogram bool   `help:"Include raw histogram data in the output (all records)."`
	Histogram     string `help:"Include histogram data in the output (healthy,retrievable,oop)."`
	Placement     *int
	Retry         bool
}

func (*Stat) Run

func (s *Stat) Run() error

type Trim added in v1.14.0

type Trim struct {
	Server    string `required:"true"`
	Identity  string `required:"true"`
	Placement *int   `required:"true"`
}

func (*Trim) Run added in v1.14.0

func (s *Trim) Run() error

Jump to

Keyboard shortcuts

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