Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelBus ¶
type ChannelBus struct {
// contains filtered or unexported fields
}
ChannelBus is an in-process pub/sub implementation for runtime events.
func NewChannelBus ¶
func NewChannelBus() *ChannelBus
NewChannelBus constructs an in-process event bus backed by Go channels.
func (*ChannelBus) Close ¶
func (b *ChannelBus) Close() error
Close shuts down the bus and closes all active subscriptions.
type PGNotifyBus ¶
type PGNotifyBus struct {
// contains filtered or unexported fields
}
func NewPGNotifyBus ¶
func NewPGNotifyBus(dsn string, logger *slog.Logger) (*PGNotifyBus, error)
func (*PGNotifyBus) Close ¶
func (b *PGNotifyBus) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.