tmsg

package

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

Details

Package tmsg routes canonical messages to Kernel actions.

This section is empty.

This section is empty.

This section is empty.

type TopicBinding struct {
	Topic string
	// contains filtered or unexported fields
}

TopicBinding routes a Kernel action from the canonical message envelope.

func Topic(topic string) TopicBinding

func (b TopicBinding) String() string

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

Transport routes envelopes to Topic-bound actions.

func New(router *message.Router) *Transport

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

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

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

func (t *Transport) Publish(ctx context.Context, env *message.Envelope) error

func (t *Transport) Router() *message.Router

func (t *Transport) String() string