aws

Documentation

Index

• Constants
• type SNSCarrierPropagator
  • func SNSCarrier(pubInput *sns.PublishInput) *SNSCarrierPropagator
  • func (p *SNSCarrierPropagator) ForeachKey(handler func(key, val string) error) error
  • func (p *SNSCarrierPropagator) Set(key, val string)
• type SQSCarrierPropagator
  • func SQSCarrier(msg *sqs.Message) *SQSCarrierPropagator
  • func (p *SQSCarrierPropagator) ForeachKey(handler func(key, val string) error) error
  • func (p *SQSCarrierPropagator) Set(key, val string)

Constants

const SQSCarrierPrefix = "sqs-carrier-"

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)