eventbridge

Documentation

Index

• func New(sys swarm.System, id string, opts ...Config) (swarm.Queue, error)
• type Config
  • func PolicyIO(policy backoff.Seq) Config
  • func PolicyTimeToFlight(t time.Duration) Config
• type Queue

Functions

func New

func New(sys swarm.System, id string, opts ...Config) (swarm.Queue, error)

New ...

Types

type Config

type Config func(*Queue)

Config ...

func PolicyIO

func PolicyIO(policy backoff.Seq) Config

PolicyIO configures retry of queue I/O

sqs.New(sys, "q", sqs.PolicyIO(backoff.Exp(...)) )

func PolicyTimeToFlight

func PolicyTimeToFlight(t time.Duration) Config

PolicyTimeToFlight configures ack timeout

type Queue

type Queue struct {
	*queue.Queue

	Bus   eventbridgeiface.EventBridgeAPI
	Start func(interface{})
	// contains filtered or unexported fields
}

Queue ...