tbus

package

v0.2.2 Latest Latest Go to latest Published: Sep 14, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type TopicBinding struct {
	Topic string
}

TopicBinding routes an internal memory event to an action.

func Topic(topic string) TopicBinding

Topic binds an action to an in-process pub/sub topic.

func (b TopicBinding) String() string

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

Transport bridges the internal Nexss Bus to the Action execution engine.

func New(eventBus *bus.Bus[any]) *Transport

New creates a new internal bus transport.

func (t *Transport) CanHandle(b action.Binding) bool

func (t *Transport) Do(ctx context.Context, _ any) (any, error)

Do implements the Transport interface. It just blocks since the bus is in-memory.

func (t *Transport) Mount(actions []action.AnyAction)

Mount scans actions for tbus.Topic bindings and subscribes them to the internal bus.

func (t *Transport) Publish(ctx context.Context, topic string, payload any) error

Publish is a convenience wrapper to emit events to the internal bus.

func (t *Transport) String() string