sqs

package
v0.0.29 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 17, 2022 License: MIT Imports: 16 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

Functions

func QueueIdToName

func QueueIdToName(id *rpc.QueueId) *string

func QueueUrlToQueueId

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

func SkipUrl added in v0.0.25

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 (*Backend) CreateQueue

func (*Backend) DeleteQueue

func (*Backend) GetMessages

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 (*Backend) ListQueues

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

func (*Backend) ModifyAckDeadline

func (*Backend) ModifyQueue

func (*Backend) PublishMessages

func (*Backend) PurgeQueue

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL