sqs

Documentation

Index

• Variables
• func QueueIdToName(id *rpc.QueueId) *string
• func QueueUrlToQueueId(url string) (*rpc.QueueId, error)
• func SkipUrl(url string) bool
• type Backend
  • func New(conf *config.Config, mets metrics.QProxyMetrics) (*Backend, error)
  • func (s *Backend) AckMessages(ctx context.Context, in *rpc.AckMessagesRequest) (*rpc.AckMessagesResponse, error)
  • func (s *Backend) CreateQueue(ctx context.Context, in *rpc.CreateQueueRequest) (*rpc.CreateQueueResponse, error)
  • func (s *Backend) DeleteQueue(ctx context.Context, in *rpc.DeleteQueueRequest) (*rpc.DeleteQueueResponse, error)
  • func (s *Backend) GetMessages(ctx context.Context, in *rpc.GetMessagesRequest) (*rpc.GetMessagesResponse, error)
  • func (s *Backend) GetQueue(ctx context.Context, in *rpc.GetQueueRequest) (*rpc.GetQueueResponse, error)
  • func (s *Backend) GetQueueUrl(ctx context.Context, in *rpc.QueueId) (string, error)
  • func (s *Backend) Healthcheck(ctx context.Context, in *rpc.HealthcheckRequest) (*rpc.HealthcheckResponse, error)
  • func (s *Backend) ListQueues(in *rpc.ListQueuesRequest, stream rpc.QProxy_ListQueuesServer) (err error)
  • func (s *Backend) ModifyAckDeadline(ctx context.Context, in *rpc.ModifyAckDeadlineRequest) (*rpc.ModifyAckDeadlineResponse, error)
  • func (s *Backend) ModifyQueue(ctx context.Context, in *rpc.ModifyQueueRequest) (*rpc.ModifyQueueResponse, error)
  • func (s *Backend) PublishMessages(ctx context.Context, in *rpc.PublishMessagesRequest) (*rpc.PublishMessagesResponse, error)
  • func (s *Backend) PurgeQueue(ctx context.Context, in *rpc.PurgeQueueRequest) (*rpc.PurgeQueueResponse, error)

Variables

var SQSErrorCodes = []string{
	sqs.ErrCodeBatchEntryIdsNotDistinct,
	sqs.ErrCodeBatchRequestTooLong,
	sqs.ErrCodeEmptyBatchRequest,
	sqs.ErrCodeInvalidAttributeName,
	sqs.ErrCodeInvalidBatchEntryId,
	sqs.ErrCodeInvalidIdFormat,
	sqs.ErrCodeInvalidMessageContents,
	sqs.ErrCodeMessageNotInflight,
	sqs.ErrCodeOverLimit,
	sqs.ErrCodePurgeQueueInProgress,
	sqs.ErrCodeQueueDeletedRecently,
	sqs.ErrCodeQueueDoesNotExist,
	sqs.ErrCodeQueueNameExists,
	sqs.ErrCodeReceiptHandleIsInvalid,
	sqs.ErrCodeTooManyEntriesInBatchRequest,
	sqs.ErrCodeUnsupportedOperation,
}

Functions

func QueueIdToName

func QueueIdToName(id *rpc.QueueId) *string

func QueueUrlToQueueId

func QueueUrlToQueueId(url string) (*rpc.QueueId, error)

func SkipUrl

func SkipUrl(url string) bool

Types

type Backend

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

func New

func New(conf *config.Config, mets metrics.QProxyMetrics) (*Backend, error)

func (*Backend) AckMessages

func (s *Backend) AckMessages(ctx context.Context, in *rpc.AckMessagesRequest) (*rpc.AckMessagesResponse, error)

func (*Backend) CreateQueue

func (s *Backend) CreateQueue(ctx context.Context, in *rpc.CreateQueueRequest) (*rpc.CreateQueueResponse, error)

func (*Backend) DeleteQueue

func (s *Backend) DeleteQueue(ctx context.Context, in *rpc.DeleteQueueRequest) (*rpc.DeleteQueueResponse, error)

func (*Backend) GetMessages

func (s *Backend) GetMessages(ctx context.Context, in *rpc.GetMessagesRequest) (*rpc.GetMessagesResponse, error)

func (*Backend) GetQueue

func (s *Backend) GetQueue(ctx context.Context, in *rpc.GetQueueRequest) (*rpc.GetQueueResponse, error)

func (*Backend) GetQueueUrl

func (s *Backend) GetQueueUrl(ctx context.Context, in *rpc.QueueId) (string, error)

func (*Backend) Healthcheck

func (s *Backend) Healthcheck(ctx context.Context, in *rpc.HealthcheckRequest) (*rpc.HealthcheckResponse, error)

func (*Backend) ListQueues

func (s *Backend) ListQueues(in *rpc.ListQueuesRequest, stream rpc.QProxy_ListQueuesServer) (err error)

func (*Backend) ModifyAckDeadline

func (s *Backend) ModifyAckDeadline(ctx context.Context, in *rpc.ModifyAckDeadlineRequest) (*rpc.ModifyAckDeadlineResponse, error)

func (*Backend) ModifyQueue

func (s *Backend) ModifyQueue(ctx context.Context, in *rpc.ModifyQueueRequest) (*rpc.ModifyQueueResponse, error)

func (*Backend) PublishMessages

func (s *Backend) PublishMessages(ctx context.Context, in *rpc.PublishMessagesRequest) (*rpc.PublishMessagesResponse, error)

func (*Backend) PurgeQueue

func (s *Backend) PurgeQueue(ctx context.Context, in *rpc.PurgeQueueRequest) (*rpc.PurgeQueueResponse, error)