driverbridge

func NewObserverSink ¶ added in v0.3.0

func NewObserverSink(observers ...queue.Observer) queue.Observer

NewObserverSink creates the shared observer instance that a driver must pass to its producer, worker, and root configuration.

func NewQueue ¶ added in v0.3.0

func NewQueue(cfg queue.Config, observer queue.Observer, descriptor runtimehook.Descriptor, opts ...queue.Option) (*queue.Queue, error)

NewQueue preserves declared driver capabilities across ordinary backend adaptation. Unlike the compatibility constructor, it never infers a workflow mode. The caller owns the supplied backend until construction succeeds and must clean up its owned resources on error; the bridge never closes borrowed resources.

func NewQueueFromDriver ¶

func NewQueueFromDriver(
	cfg queue.Config,
	observer queue.Observer,
	backend any,
	workerFactory func(workers int) (any, error),
	opts ...queue.Option,
) (*queue.Queue, error)

NewQueueFromDriver builds a high-level *queue.Queue from a driver backend.

The helper keeps driver modules off the public low-level constructor path while the runtime seam is being moved behind internal APIs.