awssqs

Documentation

Index

• Constants
• Variables
• type AWSSQS
  • func New(connOpts *opts.ConnectionOptions) (*AWSSQS, error)
  • func (a *AWSSQS) Close(_ context.Context) error
  • func (a *AWSSQS) DisplayError(msg *records.ErrorRecord) error
  • func (a *AWSSQS) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error
  • func (a *AWSSQS) Dynamic(ctx context.Context, opts *opts.DynamicOptions, dynamicSvc dynamic.IDynamic) error
  • func (a *AWSSQS) Name() string
  • func (a *AWSSQS) Read(ctx context.Context, readOpts *opts.ReadOptions, ...) error
  • func (a *AWSSQS) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, ...) error
  • func (a *AWSSQS) Test(_ context.Context) error
  • func (a *AWSSQS) Write(_ context.Context, writeOpts *opts.WriteOptions, ...) error

Constants

const BackendName = "aws-sqs"

Variables

var (
	ErrMissingQueue              = errors.New("SQS Queue name cannot be empty")
	ErrInvalidMaxNumMessages     = errors.New("max number of messages must be between 1 and 10")
	ErrInvalidWaitTime           = errors.New("wait time seconds must be between 0 and 20")
	ErrMissingAwsSecretAccessKey = errors.New("AWS Secret Access Key cannot be empty")
	ErrMissingRegion             = errors.New("AWS Region cannot be empty")
)

Types

type AWSSQS

type AWSSQS struct {
	// contains filtered or unexported fields
}

func New

func New(connOpts *opts.ConnectionOptions) (*AWSSQS, error)

func (*AWSSQS) Close

func (a *AWSSQS) Close(_ context.Context) error

func (*AWSSQS) DisplayError

func (a *AWSSQS) DisplayError(msg *records.ErrorRecord) error

DisplayError will parse an Error record and print (pretty) output to STDOUT

func (*AWSSQS) DisplayMessage

func (a *AWSSQS) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error

DisplayMessage will parse a Read record and print (pretty) output to STDOUT

func (*AWSSQS) Dynamic

func (a *AWSSQS) Dynamic(ctx context.Context, opts *opts.DynamicOptions, dynamicSvc dynamic.IDynamic) error

func (*AWSSQS) Name

func (a *AWSSQS) Name() string

func (*AWSSQS) Read

func (a *AWSSQS) Read(ctx context.Context, readOpts *opts.ReadOptions, resultsChan chan *records.ReadRecord, errorChan chan *records.ErrorRecord) error

func (*AWSSQS) Relay

func (a *AWSSQS) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, errorCh chan *records.ErrorRecord) error

func (*AWSSQS) Test

func (a *AWSSQS) Test(_ context.Context) error

func (*AWSSQS) Write

func (a *AWSSQS) Write(_ context.Context, writeOpts *opts.WriteOptions, errorCh chan *records.ErrorRecord, messages ...*records.WriteRecord) error