events

package

v2.0.2 Latest Latest Go to latest Published: Apr 1, 2026 License: MIT Imports: 7 Imported by: 0

Details

View Source

const AsyncJobName = "framework.events.publish"

This section is empty.

func DeliverAsync(ctx context.Context, bus *Bus, payload []byte) error

DeliverAsync decodes the async bridge envelope and republishes the event into the local bus.

func PublishAsync(ctx context.Context, bus *Bus, jobs core.Jobs, event any) error

func Subscribe[T any](b *Bus, handler func(ctx context.Context, event T) error)

type AsyncEnvelope struct {
	Type  string          `json:"type"`
	Event json.RawMessage `json:"event"`
}

type Bus struct {
	// contains filtered or unexported fields
}

func NewBus() *Bus

func (b *Bus) Publish(ctx context.Context, event any) error

type HandlerFunc func(ctx context.Context, event any) error

Path	Synopsis
types