Documentation
¶
Index ¶
- type Bus
- func (b *Bus) ConsumeInbound(ctx context.Context) (InboundMessage, error)
- func (b *Bus) ConsumeOutbound(ctx context.Context) (OutboundMessage, error)
- func (b *Bus) PublishInbound(ctx context.Context, msg InboundMessage) error
- func (b *Bus) PublishOutbound(ctx context.Context, msg OutboundMessage) error
- type Delivery
- type InboundMessage
- type OutboundMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Bus ¶
type Bus struct {
// contains filtered or unexported fields
}
func (*Bus) ConsumeInbound ¶
func (b *Bus) ConsumeInbound(ctx context.Context) (InboundMessage, error)
func (*Bus) ConsumeOutbound ¶
func (b *Bus) ConsumeOutbound(ctx context.Context) (OutboundMessage, error)
func (*Bus) PublishInbound ¶
func (b *Bus) PublishInbound(ctx context.Context, msg InboundMessage) error
func (*Bus) PublishOutbound ¶
func (b *Bus) PublishOutbound(ctx context.Context, msg OutboundMessage) error
type InboundMessage ¶
Click to show internal directories.
Click to hide internal directories.