sqs

Documentation

Index

• Constants
• type Option
  • func WithEncoding(encoding encoding.Encoding) Option
• type Transport
  • func New(queueURL string, opts ...Option) (*Transport, error)
  • func (t *Transport) HasConverter() bool
  • func (t *Transport) HasTracePropagation() bool
  • func (t *Transport) Send(ctx context.Context, event cloudevents.Event) (context.Context, *cloudevents.Event, error)
  • func (t *Transport) SetConverter(c transport.Converter)
  • func (t *Transport) SetReceiver(r transport.Receiver)
  • func (t *Transport) StartReceiver(ctx context.Context) (err error)

Constants

const (
	// TransportName is the name of this transport.
	TransportName = "AWS SNS"
)

Types

type Option

type Option func(*Transport) error

Option is the function signature required to be considered an nats.Option.

func WithEncoding

func WithEncoding(encoding encoding.Encoding) Option

WithEncoding sets the encoding for NATS transport.

type Transport

type Transport struct {
	Encoding encoding.Encoding
	Client   *_sqs.SQS
	QueueURL string

	Receiver transport.Receiver
	// Converter is invoked if the incoming transport receives an undecodable
	// message.
	Converter transport.Converter
	// contains filtered or unexported fields
}

Transport acts as both a http client and a http handler.

func New

func New(queueURL string, opts ...Option) (*Transport, error)

New creates a new NATS transport.

func (*Transport) HasConverter

func (t *Transport) HasConverter() bool

HasConverter implements Transport.HasConverter

func (*Transport) HasTracePropagation

func (t *Transport) HasTracePropagation() bool

HasTracePropagation implements Transport.HasTracePropagation

func (*Transport) Send

func (t *Transport) Send(ctx context.Context, event cloudevents.Event) (context.Context, *cloudevents.Event, error)

Send implements Transport.Send

func (*Transport) SetConverter

func (t *Transport) SetConverter(c transport.Converter)

SetConverter implements Transport.SetConverter

func (*Transport) SetReceiver

func (t *Transport) SetReceiver(r transport.Receiver)

SetReceiver implements Transport.SetReceiver

func (*Transport) StartReceiver

func (t *Transport) StartReceiver(ctx context.Context) (err error)

StartReceiver implements Transport.StartReceiver NOTE: This is a blocking call.