Documentation
¶
Index ¶
- func InferAttachmentKind(mimeType string) string
- type Attachment
- 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 ¶
func InferAttachmentKind ¶ added in v0.2.7
Types ¶
type Attachment ¶ added in v0.2.7
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.