callback

package

v0.19.976 Latest Latest Go to latest Published: May 29, 2026 License: AGPL-3.0 Imports: 7 Imported by: 0

Details

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

Repository

github.com/nuonco/nuon

Links

Open Source Insights

Documentation ¶

Index ¶

func Send(ctx workflow.Context, l *zap.Logger, ref Ref, result Result)
func SignalName(id string) string
type Ref
- func New(ctx workflow.Context, id string) Ref
type Result
- func Await(ctx workflow.Context, ref Ref) (*Result, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Send ¶

func Send(ctx workflow.Context, l *zap.Logger, ref Ref, result Result)

Send signals the target workflow described by ref with the given result. Best-effort: if the target workflow has already terminated, the error is logged but not propagated.

func SignalName ¶

func SignalName(id string) string

SignalName returns the deterministic signal name for a given id.

Types ¶

type Ref ¶

type Ref struct {
	WorkflowID string `json:"workflow_id,omitempty"`
	SignalName string `json:"signal_name,omitempty"`
	Namespace  string `json:"namespace,omitempty"`
}

Ref describes where to send a Temporal signal when an operation completes. It is stored as a JSONB column on QueueSignal and passed through the enqueue → handler → completion chain.

func New ¶

func New(ctx workflow.Context, id string) Ref

New creates a Ref pointing back to the current workflow with a deterministic signal name derived from id. The caller should register the signal channel before the handler starts to avoid races.

func (Ref) GormDataType ¶

func (Ref) GormDataType() string

GormDataType tells GORM to use the jsonb PostgreSQL type.

func (Ref) IsSet ¶

func (c Ref) IsSet() bool

IsSet returns true if the callback has a target workflow.

func (*Ref) Scan ¶

func (c *Ref) Scan(v interface{}) error

Scan implements database/sql.Scanner for reading JSONB from PostgreSQL.

func (Ref) Value ¶

func (c Ref) Value() (driver.Value, error)

Value implements driver.Valuer for writing JSONB to PostgreSQL.

type Result ¶

type Result struct {
	Status            string `json:"status"`
	StatusDescription string `json:"status_description,omitempty"`
}

Result is the payload sent by the handler on completion.

func Await ¶

func Await(ctx workflow.Context, ref Ref) (*Result, error)

Await waits for a completion signal on the Ref's signal channel. Returns the Result on success, or an error if the signal failed or timed out.

Source Files ¶

View all Source files

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