bus

Documentation

Index

• func NewChannelBus(bufSize int) (*ChannelProducer, *ChannelConsumer)
• type ChannelConsumer
  • func (c *ChannelConsumer) Close() error
  • func (c *ChannelConsumer) Listen(ctx context.Context, handler func(ctx context.Context, data []byte) error) error
• type ChannelProducer
  • func (p *ChannelProducer) Close() error
  • func (p *ChannelProducer) Publish(_ context.Context, data []byte) error
• type Consumer
• type Producer

Functions

func NewChannelBus

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

Types

type ChannelConsumer

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

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

func (*ChannelConsumer) Close

func (c *ChannelConsumer) Close() error

func (*ChannelConsumer) Listen

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

type ChannelProducer

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

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

func (*ChannelProducer) Close

func (p *ChannelProducer) Close() error

func (*ChannelProducer) Publish

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

type Consumer

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

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

Producer publishes messages to a topic/stream.