queue

package

v0.2.0 Latest Latest Go to latest Published: Jun 28, 2026 License: MIT Imports: 0 Imported by: 0

Details

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

Repository

github.com/tupicapp/go-modules

Links

Open Source Insights

Documentation ¶

Overview ¶

Package queue defines the shared task-queue vocabulary: the Task contract, the default channel, and the channel→subject mapping. The Queue interface itself is consumer-defined and lives in each service. The outbox-backed implementation lives in adapter/outbox_queue.

Index ¶

Constants
func Subject(channel, name string) string
type Task

Constants ¶

View Source

const DefaultChannel = "default"

DefaultChannel is the channel used by Enqueue. Callers that do not care about channels and prioritization never name a channel; the transport layer routes them here.

Variables ¶

This section is empty.

Functions ¶

func Subject ¶

func Subject(channel, name string) string

Subject composes the wire message queue subject for a task on a channel: queues.<channel>.<name>.

Types ¶

type Task ¶

type Task interface {
	Name() string
	Version() string
}

Task is the constraint for queueable point-to-point work units. A task names itself logically (e.g. "log-created-asset") and declares its schema version. The transport channel is an infrastructure concern composed at enqueue time and not tied to task itself.

Source Files ¶

View all Source files

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