sqs

Documentation

Index

• Variables
• func ConcurrentHandlerCount(n int) broker.SubscribeOption
• func MaxInFlight(n int) broker.Option
• func New(opts ...broker.Option) (broker.Broker, error)
• func QueueName(q string) broker.Option
• func Session(sess *session.Session) broker.Option
• func SubscriptionTimeout(d time.Duration) broker.SubscribeOption

Variables

var (
	DefaultConcurrentHandlerCount = 1
	DefaultSubscriptionTimeout    = int64(5) // second
)

DefaultConcurrentHandlerCount ...

var (
	Config = &sqsConfig{
		done: make(chan struct{}),
	}
)

Config ...

Functions

func ConcurrentHandlerCount

func ConcurrentHandlerCount(n int) broker.SubscribeOption

ConcurrentHandlerCount ...

func MaxInFlight

func MaxInFlight(n int) broker.Option

MaxInFlight ...

func New

func New(opts ...broker.Option) (broker.Broker, error)

New ...

func QueueName

func QueueName(q string) broker.Option

QueueName ...

func Session

func Session(sess *session.Session) broker.Option

Session ...

func SubscriptionTimeout

func SubscriptionTimeout(d time.Duration) broker.SubscribeOption

SubscriptionTimeout ...