nexssflow

package

v0.7.0 Latest Latest Go to latest Published: Oct 17, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Package nexssflow exposes the in-process task queue to Nexss Flow.

This section is empty.

This section is empty.

func Bundle(_ map[string]string) compiler.Bundle

Bundle returns the Flow bundle for task queue producers and workers.

func Library() action.Library

Library creates a Flow action library backed by a fresh in-memory queue.

func LibraryWithConfig(cfg corequeue.Config) action.Library

LibraryWithConfig creates a Flow library with the supplied queue settings.

func LibraryWithQueue(q *corequeue.Queue) action.Library

LibraryWithQueue uses the provided queue so producers and listeners share it.

type EnqueueRequest struct {
	Type     string `json:"type"`
	Payload  any    `json:"payload"`
	Priority string `json:"priority,omitempty"`
}

EnqueueRequest is the input accepted by taskqueue.enqueue.

type TaskBinding struct {
	Type string
}

TaskBinding marks an action as a handler for a named queue task type.

func Task(taskType string) TaskBinding

Task binds an action to a task type.