param

package
v0.1.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 9, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.0.2

type Provider struct {
	Credentials aws.CredentialsProvider
}

func NewProvider added in v0.0.2

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 added in v0.0.8

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

func (*Receive) Do added in v0.0.4

func (*Receive) Exited added in v0.0.7

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL