param

Documentation

Index

• type Client
  • func NewClient() *Client
• type Handle
  • func NewHandle(visibility callback.ChangeMessageVisibility, delete callback.DeleteMessage) *Handle
• type Provider
  • func NewProvider() (provider *Provider)
• 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 {
	*Provider
	simaqian.Logger

	Region string
	Wait   time.Duration
	Queues map[string]*string
}

func NewClient

func NewClient() *Client

type Handle

type Handle struct {
	*internal.Base
	*Provider

	Times    int
	Interval time.Duration

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

func NewHandle

func NewHandle(visibility callback.ChangeMessageVisibility, delete callback.DeleteMessage) *Handle

type Provider

type Provider struct {
	Credentials aws.CredentialsProvider
}

func NewProvider

func NewProvider() (provider *Provider)

type Receive

type Receive struct {
	*internal.Base
	*Provider

	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
	*Provider

	Data       any
	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