destawssqs

Documentation

Index

• func ParseQueueURL(queueURL string) (baseURL string, region string, err error)
• type AWSSQSDestination
  • func New(loader metadata.MetadataLoader, ...) (*AWSSQSDestination, error)
  • func (d *AWSSQSDestination) ComputeTarget(destination *models.Destination) destregistry.DestinationTarget
  • func (p *AWSSQSDestination) CreatePublisher(ctx context.Context, destination *models.Destination) (destregistry.Publisher, error)
  • func (d *AWSSQSDestination) Validate(ctx context.Context, destination *models.Destination) error
• type AWSSQSDestinationConfig
• type AWSSQSDestinationCredentials
• type AWSSQSPublisher
  • func (p *AWSSQSPublisher) Close() error
  • func (p *AWSSQSPublisher) Format(ctx context.Context, event *models.Event) (*sqs.SendMessageInput, error)
  • func (p *AWSSQSPublisher) Publish(ctx context.Context, event *models.Event) (*destregistry.Delivery, error)

Functions

func ParseQueueURL

func ParseQueueURL(queueURL string) (baseURL string, region string, err error)

ParseQueueURL extracts the full URL into baseURL & region

Types

type AWSSQSDestination

type AWSSQSDestination struct {
	*destregistry.BaseProvider
}

func New

func New(loader metadata.MetadataLoader, basePublisherOpts []destregistry.BasePublisherOption) (*AWSSQSDestination, error)

func (*AWSSQSDestination) ComputeTarget

func (d *AWSSQSDestination) ComputeTarget(destination *models.Destination) destregistry.DestinationTarget

func (*AWSSQSDestination) CreatePublisher

func (p *AWSSQSDestination) CreatePublisher(ctx context.Context, destination *models.Destination) (destregistry.Publisher, error)

func (*AWSSQSDestination) Validate

func (d *AWSSQSDestination) Validate(ctx context.Context, destination *models.Destination) error

type AWSSQSDestinationConfig

type AWSSQSDestinationConfig struct {
	Endpoint string
	QueueURL string
}

type AWSSQSDestinationCredentials

type AWSSQSDestinationCredentials struct {
	Key     string
	Secret  string
	Session string // optional
}

type AWSSQSPublisher

type AWSSQSPublisher struct {
	*destregistry.BasePublisher
	// contains filtered or unexported fields
}

func (*AWSSQSPublisher) Close

func (p *AWSSQSPublisher) Close() error

func (*AWSSQSPublisher) Format

func (p *AWSSQSPublisher) Format(ctx context.Context, event *models.Event) (*sqs.SendMessageInput, error)

func (*AWSSQSPublisher) Publish

func (p *AWSSQSPublisher) Publish(ctx context.Context, event *models.Event) (*destregistry.Delivery, error)