Documentation
¶
Index ¶
Constants ¶
View Source
const SQSCarrierPrefix = "sqs-carrier-"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SNSCarrierPropagator ¶
type SNSCarrierPropagator struct {
// contains filtered or unexported fields
}
func SNSCarrier ¶
func SNSCarrier(pubInput *sns.PublishInput) *SNSCarrierPropagator
func (*SNSCarrierPropagator) ForeachKey ¶
func (p *SNSCarrierPropagator) ForeachKey(handler func(key, val string) error) error
func (*SNSCarrierPropagator) Set ¶
func (p *SNSCarrierPropagator) Set(key, val string)
type SQSCarrierPropagator ¶
type SQSCarrierPropagator struct {
// contains filtered or unexported fields
}
func SQSCarrier ¶
func SQSCarrier(msg *sqs.Message) *SQSCarrierPropagator
func (*SQSCarrierPropagator) ForeachKey ¶
func (p *SQSCarrierPropagator) ForeachKey(handler func(key, val string) error) error
func (*SQSCarrierPropagator) Set ¶
func (p *SQSCarrierPropagator) Set(key, val string)
Source Files
Click to show internal directories.
Click to hide internal directories.