param

Documentation

Index

• type Client
  • func NewClient() *Client
• type Handle
  • func NewHandle() *Handle
• type Receive
  • func NewReceive(client *Client, receive callback.ReceiveMessage, url callback.Url) *Receive
  • func (r *Receive) WaitTimeSeconds() int32
• type Send
  • func NewSend(send callback.SendMessage, url callback.Url) *Send

Types

type Client

type Client struct {
	Region   string
	Provider aws.CredentialsProvider
	Wait     time.Duration
	Queues   map[string]*string
}

func NewClient

func NewClient() *Client

type Handle

type Handle struct {
	*internal.Base

	Times    int
	Interval time.Duration

	Decoder    transcoder.Decoder
	Visibility callback.ChangeMessageVisibility
	Delete     callback.DeleteMessage
}

func NewHandle

func NewHandle() *Handle

type Receive

type Receive struct {
	*internal.Base

	Wait       time.Duration
	Visibility int32
	Number     int32
	Names      []types.QueueAttributeName
	Attributes []string

	Receive callback.ReceiveMessage
	Url     callback.Url
	// contains filtered or unexported fields
}

func NewReceive

func NewReceive(client *Client, receive callback.ReceiveMessage, url callback.Url) *Receive

func (*Receive) WaitTimeSeconds

func (r *Receive) WaitTimeSeconds() int32

type Send

type Send struct {
	*internal.Base

	Delay      time.Duration
	Attributes map[string]types.MessageAttributeValue
	Systems    map[string]types.MessageSystemAttributeValue

	Encoder transcoder.Encoder
	Send    callback.SendMessage
	Url     callback.Url
}

func NewSend

func NewSend(send callback.SendMessage, url callback.Url) *Send