bus

package

v0.2.0 Latest Latest Go to latest Published: May 15, 2026 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

func NewChannelBus(bufSize int) (*ChannelProducer, *ChannelConsumer)

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

ChannelConsumer is an in-process Consumer backed by a Go channel.

func (c *ChannelConsumer) Close() error

func (c *ChannelConsumer) Listen(ctx context.Context, handler func(ctx context.Context, data []byte) error) error

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

ChannelProducer is an in-process Producer backed by a Go channel.

func (p *ChannelProducer) Close() error

func (p *ChannelProducer) Publish(_ context.Context, data []byte) error

type Consumer interface {
	Listen(ctx context.Context, handler func(ctx context.Context, data []byte) error) error
	Close() error
}

Consumer receives messages from a topic/stream.

type Producer interface {
	Publish(ctx context.Context, data []byte) error
	Close() error
}

Producer publishes messages to a topic/stream.