Versions in this module Expand all Collapse all v0 v0.2.0 May 15, 2026 Changes in this version + func NewChannelBus(bufSize int) (*ChannelProducer, *ChannelConsumer) + type ChannelConsumer struct + func (c *ChannelConsumer) Close() error + func (c *ChannelConsumer) Listen(ctx context.Context, handler func(ctx context.Context, data []byte) error) error + type ChannelProducer struct + func (p *ChannelProducer) Close() error + func (p *ChannelProducer) Publish(_ context.Context, data []byte) error + type Consumer interface + Close func() error + Listen func(ctx context.Context, handler func(ctx context.Context, data []byte) error) error + type Producer interface + Close func() error + Publish func(ctx context.Context, data []byte) error
Go to main page