awssqs

Documentation

Index

• Constants
• func Dynamic(opts *cli.Options) error
• func NewService(opts *cli.Options) (*sqs.SQS, string, error)
• func Read(opts *cli.Options, md *desc.MessageDescriptor) error
• func Relay(opts *cli.Options, relayCh chan interface{}, shutdownCtx context.Context) (relay.IRelayBackend, error)
• func Write(opts *cli.Options, md *desc.MessageDescriptor) error
• type AWSSQS
  • func (a *AWSSQS) Read() error
  • func (a *AWSSQS) Write(value []byte) error
• type Relayer
  • func (r *Relayer) Relay() error

Constants

const (
	ErrInvalidWriteDelaySeconds = "--delay-seconds must be between 0 and 900"
	ErrUnableToSend             = "unable to complete message send"
	ErrMissingMessageGroupID    = "--message-group-id must be specified when writing to a FIFO queue"
)

const (
	RetryDuration = time.Duration(10) * time.Second
)

const (
	RetryReadInterval = 5 * time.Second
)

Functions

func Dynamic

func Dynamic(opts *cli.Options) error

Dynamic starts up a new GRPC client connected to the dProxy service and receives a stream of outbound replay messages which are then written to the message bus.

func NewService

func NewService(opts *cli.Options) (*sqs.SQS, string, error)

func Read

func Read(opts *cli.Options, md *desc.MessageDescriptor) error

Read is the entry point function for performing read operations in AWS SQS.

This is where we verify that the provided arguments and flag combination makes sense/are valid; this is also where we will perform our initial conn.

func Relay

func Relay(opts *cli.Options, relayCh chan interface{}, shutdownCtx context.Context) (relay.IRelayBackend, error)

func Write

func Write(opts *cli.Options, md *desc.MessageDescriptor) error

Write is the entry point function for performing write operations in AWSSQS.

This is where we verify that the passed args and flags combo makes sense, attempt to establish a connection, parse protobuf before finally attempting to perform the write.

Types

type AWSSQS

type AWSSQS struct {
	Options  *cli.Options
	Service  types.ISQSAPI
	QueueURL string
	MsgDesc  *desc.MessageDescriptor
	Log      *logrus.Entry
	Printer  printer.IPrinter
}

func (*AWSSQS) Read

func (a *AWSSQS) Read() error

func (*AWSSQS) Write

func (a *AWSSQS) Write(value []byte) error

type Relayer

type Relayer struct {
	Options     *cli.Options
	Service     *sqs.SQS
	QueueURL    string
	RelayCh     chan interface{}
	ShutdownCtx context.Context
	// contains filtered or unexported fields
}

func (*Relayer) Relay

func (r *Relayer) Relay() error