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, send callback.SendMessage, receive callback.ReceiveMessage, ...) *Receive
  • func (r *Receive) Cancel(cancel context.CancelFunc)
  • func (r *Receive) Do(ctx context.Context, url *string) (*sqs.ReceiveMessageOutput, error)
  • func (r *Receive) Exited() bool
• type Send
  • func NewSend(send callback.SendMessage, url callback.Url) *Send

Types

type Client

type Client struct {
	*Provider

	Region string
	Wait   time.Duration
	Queues map[string]*string
	Http   *http.Client
	Logger log.Logger
	Exit   bool
	Cancel context.CancelFunc
}

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 time.Duration
	Number     int32
	Names      []types.QueueAttributeName
	Attributes []string

	Send          callback.SendMessage
	Url           callback.Url
	GetAttributes callback.GetAttributes
	// contains filtered or unexported fields
}

func NewReceive

func NewReceive(
	client *Client,
	send callback.SendMessage, receive callback.ReceiveMessage,
	url callback.Url, attributes callback.GetAttributes,
) *Receive

func (*Receive) Cancel

func (r *Receive) Cancel(cancel context.CancelFunc)

func (*Receive) Do

func (r *Receive) Do(ctx context.Context, url *string) (*sqs.ReceiveMessageOutput, error)

func (*Receive) Exited

func (r *Receive) Exited() bool

type Send

type Send struct {
	*internal.Base
	*Provider

	Data       any
	Delay      time.Duration
	Runtime    *time.Time
	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