builder

Jan 9, 2024

Changes in this version

+ type Client struct

+ func NewBuilder() *Client

+ func (c *Client) Build() *core.Client

+ func (c *Client) Credential() *Credential

+ func (c *Client) Http(http *http.Client) (client *Client)

+ func (c *Client) Logger(logger log.Logger) (client *Client)

+ func (c *Client) Queue(label string, name string) (client *Client)

+ func (c *Client) Region(region string) (client *Client)

+ func (c *Client) Wait(wait time.Duration) (client *Client)

+ type Credential struct

+ func NewCredential(client *Client, param *param.Client) *Credential

+ func (c *Credential) Build() (client *Client)

+ func (c *Credential) Default(access string, secret string) (cdl *Credential)

+ func (c *Credential) Http(method http.Method, url string) (cdl *Credential)

Sep 30, 2023

Changes in this version

type Send

+ func (s *Send) Fix(set time.Time) (send *Send)

Sep 7, 2023

Changes in this version

type Send

+ func (s *Send) Data(data any) (send *Send)

Jul 27, 2023

Changes in this version

+ type Base struct

+ func NewBase() *Base

+ func (b *Base) Label(label string) (base *Base)

+ func (b *Base) Queue(queue string) (base *Base)

+ func (b *Base) Url(url string) (base *Base)

+ type Provider struct

+ func NewProvider() *Provider

+ func (p *Provider) Credentials(credentials aws.CredentialsProvider) (provider *Provider)

+ type Url struct

+ func NewUrl(url callback.Url) *Url

+ func (u *Url) Build() *worker.Url

Jul 27, 2023

Changes in this version

+ type Handle struct

+ func NewHandle(client *param.Client, receive callback.ReceiveMessage, url callback.Url, ...) *Handle

+ func (h *Handle) Build() *worker.Handle

+ func (h *Handle) Decoder(decoder transcoder.Decoder) (handle *Handle)

+ func (h *Handle) Interval(duration time.Duration) (handle *Handle)

+ func (h *Handle) Times(max int) (handle *Handle)

+ type Receive struct

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

+ func (r *Receive) Attributes(names ...string) (receive *Receive)

+ func (r *Receive) Build() *worker.Receive

+ func (r *Receive) Label(label string) (receive *Receive)

+ func (r *Receive) Names(names ...types.QueueAttributeName) (receive *Receive)

+ func (r *Receive) Number(number int32) (receive *Receive)

+ func (r *Receive) Visibility(timeout time.Duration) (receive *Receive)

+ func (r *Receive) Wait(wait time.Duration) (receive *Receive)

+ type Send struct

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

+ func (s *Send) Attribute(key string, value types.MessageAttributeValue) (send *Send)

+ func (s *Send) Build() *worker.Send

+ func (s *Send) Delay(delay time.Duration) (send *Send)

+ func (s *Send) Encoder(encoder transcoder.Encoder) (send *Send)

+ func (s *Send) Label(label string) (send *Send)

+ func (s *Send) System(key string, value types.MessageSystemAttributeValue) (send *Send)