README
¶
Queue Config Extension
Vendor-agnostic interface for providing queue configurations.
Interfaces
Store
Provides queue configurations by name.
type Store interface {
Get(ctx context.Context, name string) (entity.QueueConfig, error)
List(ctx context.Context) ([]entity.QueueConfig, error)
}
Entities
Queue configuration entity lives in entity/queue_config.go:
- QueueConfig — identifies a single submit queue (just its name); the registry of valid queue names. Behavioral/VCS config lives in the extension factory implementations, not here.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNotFound = errors.New("queue config not found")
ErrNotFound is returned when the requested queue configuration does not exist.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store interface {
// Get returns the configuration for a named queue.
// Returns ErrNotFound if no configuration exists for the given name.
Get(ctx context.Context, name string) (entity.QueueConfig, error)
// List returns all configured queues.
List(ctx context.Context) ([]entity.QueueConfig, error)
}
Store loads and provides queue configurations. Implementations may read from YAML files, databases, remote services, etc.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.