builder

Documentation

Index

• type Base
  • 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 Handle
  • func NewHandle(client *param.Client, send callback.SendMessage, ...) *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 Provider
  • func NewProvider() *Provider
  • func (p *Provider) Credentials(credentials aws.CredentialsProvider) (provider *Provider)
• type Receive
  • func NewReceive(client *param.Client, send callback.SendMessage, ...) *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(visibility time.Duration) (receive *Receive)
  • func (r *Receive) Wait(wait time.Duration) (receive *Receive)
• type Send
  • 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) Data(data any) (send *Send)
  • func (s *Send) Delay(delay time.Duration) (send *Send)
  • func (s *Send) Encoder(encoder transcoder.Encoder) (send *Send)
  • func (s *Send) Fix(set time.Time) (send *Send)
  • func (s *Send) Label(label string) (send *Send)
  • func (s *Send) System(key string, value types.MessageSystemAttributeValue) (send *Send)
• type Url
  • func NewUrl(url callback.Url) *Url
  • func (u *Url) Build() *worker.Url

Types

type Base

type Base struct {
	*Provider
	// contains filtered or unexported fields
}

func NewBase

func NewBase() *Base

func (*Base) Label

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

func (*Base) Queue

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

func (*Base) Url

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

type Handle

type Handle struct {
	*Receive
	// contains filtered or unexported fields
}

func NewHandle

func NewHandle(
	client *param.Client,
	send callback.SendMessage, receive callback.ReceiveMessage,
	url callback.Url, visibility callback.ChangeMessageVisibility,
	delete callback.DeleteMessage, attributes callback.GetAttributes,
) *Handle

func (*Handle) Build

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

func (*Handle) Decoder

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

func (*Handle) Interval

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

func (*Handle) Times

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

type Provider

type Provider struct {
	// contains filtered or unexported fields
}

func NewProvider

func NewProvider() *Provider

func (*Provider) Credentials

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

type Receive

type Receive struct {
	*Base
	// contains filtered or unexported fields
}

func NewReceive

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

func (*Receive) Attributes

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

func (*Receive) Build

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

func (*Receive) Label

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

func (*Receive) Names

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

func (*Receive) Number

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

func (*Receive) Visibility

func (r *Receive) Visibility(visibility time.Duration) (receive *Receive)

func (*Receive) Wait

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

type Send

type Send struct {
	*Base
	// contains filtered or unexported fields
}

func NewSend

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

func (*Send) Attribute

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

func (*Send) Build

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

func (*Send) Data

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

func (*Send) Delay

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

func (*Send) Encoder

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

func (*Send) Fix

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

func (*Send) Label

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

func (*Send) System

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

type Url

type Url struct {
	*Base
	// contains filtered or unexported fields
}

func NewUrl

func NewUrl(url callback.Url) *Url

func (*Url) Build

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