messaging

Documentation

Index

• type Consumer
• type Producer

Types

type Consumer

type Consumer interface {
	Consume(consumeFn func(msg *types.ConsumeMsg) error, opts types.ConsumeOpts) error
	Stop(ctx context.Context) error
}

type Producer

type Producer interface {
	Produce(ctx context.Context, msg types.ProduceMsg) error
	ProduceAsync(ctx context.Context, msg types.ProduceMsg) error

	Stop(ctx context.Context) error
}