Documentation
¶
Index ¶
Constants ¶
View Source
const (
Root = "boost.wrapper.publisher"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Driver ¶
type Driver interface {
Publish(context.Context, []*cloudevents.Event) ([]PublishOutput, error)
}
type PublishOutput ¶
type PublishOutput struct {
Event *cloudevents.Event
Error error
}
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
func New ¶
func New(driver Driver, mid ...middleware.AnyErrorMiddleware[[]PublishOutput]) *Publisher
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
driver
|
|
|
contrib/aws/kinesis/v1
Package kinesis is a publisher driver that puts each event in the Kinesis stream named by the event subject.
|
Package kinesis is a publisher driver that puts each event in the Kinesis stream named by the event subject. |
|
contrib/aws/sns/v1
Package sns is a publisher driver that sends each event to the SNS topic whose ARN is the event subject.
|
Package sns is a publisher driver that sends each event to the SNS topic whose ARN is the event subject. |
|
contrib/aws/sqs/v1
Package sqs is a publisher driver that sends each event to the SQS queue named by the event subject.
|
Package sqs is a publisher driver that sends each event to the SQS queue named by the event subject. |
Click to show internal directories.
Click to hide internal directories.