eventbus

Documentation

Overview

Provide simplistic application-wide message bus.

Index

• func Call[M any, R any](address string, msg *M) (*R, error)
• func CallWithContext[M any, R any](address string, msg *M, ctx context.Context) (*R, error)
• func Consume[M any](address string, handler func(*M, CallContext)) func()
• func Publish[M any](address string, msg *M)
• type CallContext

Functions

func Call

func Call[M any, R any](address string, msg *M) (*R, error)

Call sends a message to the address specified as an argument, and waits for the response.

func CallWithContext

func CallWithContext[M any, R any](address string, msg *M, ctx context.Context) (*R, error)

CallWithContext sends a message to the address specified as an argument, and waits for the response.

func Consume

func Consume[M any](address string, handler func(*M, CallContext)) func()

Consume registers a consumer for messages sent to the address specified as an argument. Handler is called for each published message inside its own panic-safe goroutine.

func Publish

func Publish[M any](address string, msg *M)

Publish sends a message to the address specified as an argument.

Types

type CallContext

type CallContext interface {
	// Reply sends a reply back to caller.
	Reply(reply any)
}

CallContext is a context passed to an event bus handler. It allows consumers to send replies.