worker

package

v0.17.0 Latest Latest Go to latest Published: Feb 14, 2025 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/AlexGustafsson/cupdate

Links

Open Source Insights

Documentation ¶

Index ¶

type Event
type EventType
type Queue
- func NewQueue[T comparable](burst int, tick time.Duration) *Queue[T]
type Worker
- func New(httpClient *httputil.Client, store *store.Store, ...) *Worker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Event ¶ added in v0.17.0

type Event struct {
	Reference string
	Type      EventType
}

type EventType ¶ added in v0.17.0

type EventType string

const (
	EventTypeUpdated             EventType = "updated"
	EventTypeProcessed           EventType = "processed"
	EventTypeNewVersionAvailable EventType = "newVersionAvailable"
)

type Queue ¶ added in v0.17.0

type Queue[T comparable] struct {
	// contains filtered or unexported fields
}

func NewQueue ¶ added in v0.17.0

func NewQueue[T comparable](burst int, tick time.Duration) *Queue[T]

func (*Queue[T]) AvailableBurst ¶ added in v0.17.0

func (q *Queue[T]) AvailableBurst() int

func (*Queue[T]) Close ¶ added in v0.17.0

func (q *Queue[T]) Close()

func (*Queue[T]) Collect ¶ added in v0.17.0

func (w *Queue[T]) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector.

func (*Queue[T]) Describe ¶ added in v0.17.0

func (w *Queue[T]) Describe(descs chan<- *prometheus.Desc)

Describe implements prometheus.Collector.

func (*Queue[T]) Len ¶ added in v0.17.0

func (q *Queue[T]) Len() int

func (*Queue[T]) Pull ¶ added in v0.17.0

func (q *Queue[T]) Pull() iter.Seq[T]

func (*Queue[T]) Push ¶ added in v0.17.0

func (q *Queue[T]) Push(items ...T)

type Worker ¶

type Worker struct {
	*events.Hub[Event]
	// contains filtered or unexported fields
}

func New ¶

func New(httpClient *httputil.Client, store *store.Store, registryAuth *httputil.AuthMux) *Worker

func (*Worker) Collect ¶

func (w *Worker) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector.

func (*Worker) Describe ¶

func (w *Worker) Describe(descs chan<- *prometheus.Desc)

Describe implements prometheus.Collector.

func (*Worker) ProcessRawImage ¶

func (w *Worker) ProcessRawImage(ctx context.Context, reference oci.Reference) error

Source Files ¶

View all Source files

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