Documentation ¶
Index ¶
- Variables
- func NewPlugin() (*pkgplugin.Plugin, error)
- func NewPluginVersion(name string, version string, commitID string) (*pkgplugin.Plugin, error)
- func NewReceiver(tid tenant.Id, plugin string, name string, config interface{}, ...) (receiver.Receiver, error)
- func NewSender(tid tenant.Id, plugin string, name string, config interface{}, ...) (sender.Sender, error)
- type Receiver
- func (r *Receiver) Config() interface{}
- func (r *Receiver) Count() int
- func (r *Receiver) Name() string
- func (r *Receiver) Plugin() string
- func (r *Receiver) Receive(next receiver.NextFn) error
- func (r *Receiver) StopReceiving(ctx context.Context) error
- func (r *Receiver) Tenant() tenant.Id
- func (r *Receiver) Trigger(e event.Event)
- type ReceiverConfig
- type Sender
- type SenderConfig
- type SqsMessageAttributeCarrier
Constants ¶
This section is empty.
Variables ¶
View Source
var ( Name = "sqs" Version = "v0.0.0" CommitID = "" )
View Source
var DefaultReceiverConfig = ReceiverConfig{ QueueUrl: "", MaxNumberOfMessages: pointer.Int(10), VisibilityTimeout: pointer.Int(10), WaitTimeSeconds: pointer.Int(10), AcknowledgeTimeout: pointer.Int(5), NumRetries: pointer.Int(0), ReceiverQueueDepth: pointer.Int(100), ReceiverPoolSize: pointer.Int(1), NeverDelete: pointer.Bool(false), TracePayloadOnNack: pointer.Bool(false), }
View Source
var DefaultSenderConfig = SenderConfig{ QueueUrl: "", MaxNumberOfMessages: pointer.Int(10), SendTimeout: pointer.Int(1), DelaySeconds: pointer.Int(0), }
Functions ¶
func NewPluginVersion ¶
func NewReceiver ¶
Types ¶
type ReceiverConfig ¶
type ReceiverConfig struct { QueueUrl string `json:"queueUrl,omitempty"` MaxNumberOfMessages *int `json:"maxNumberOfMessages,omitempty"` VisibilityTimeout *int `json:"visibilityTimeout,omitempty"` WaitTimeSeconds *int `json:"waitTimeSeconds,omitempty"` AcknowledgeTimeout *int `json:"acknowledgeTimeout,omitempty"` NumRetries *int `json:"numRetries,omitempty"` ReceiverQueueDepth *int `json:"receiverQueueDepth,omitempty"` ReceiverPoolSize *int `json:"receiverPoolSize,omitempty"` NeverDelete *bool `json:"neverDelete,omitempty"` TracePayloadOnNack *bool `json:"tracePayloadOnNack,omitempty"` }
func (*ReceiverConfig) Validate ¶
func (rc *ReceiverConfig) Validate() error
Validate returns an error upon validation failure
func (*ReceiverConfig) WithDefaults ¶
func (rc *ReceiverConfig) WithDefaults() ReceiverConfig
WithDefaults returns a new config object that has all of the unset (nil) values filled in.
type Sender ¶
func (*Sender) StopSending ¶
type SenderConfig ¶
type SenderConfig struct { QueueUrl string `json:"queueUrl,omitempty"` MaxNumberOfMessages *int `json:"maxNumberOfMessages,omitempty"` SendTimeout *int `json:"sendTimeout,omitempty"` DelaySeconds *int `json:"delaySeconds,omitempty"` }
SenderConfig can be passed into NewSender() in order to configure the behavior of the sender.
type SqsMessageAttributeCarrier ¶ added in v0.7.0
type SqsMessageAttributeCarrier struct {
// contains filtered or unexported fields
}
func NewSqsMessageAttributeCarrier ¶ added in v0.7.0
func NewSqsMessageAttributeCarrier(attributes map[string]*sqs.MessageAttributeValue) *SqsMessageAttributeCarrier
func (*SqsMessageAttributeCarrier) Get ¶ added in v0.7.0
func (c *SqsMessageAttributeCarrier) Get(key string) string
func (*SqsMessageAttributeCarrier) Keys ¶ added in v0.7.0
func (c *SqsMessageAttributeCarrier) Keys() []string
func (*SqsMessageAttributeCarrier) Set ¶ added in v0.7.0
func (c *SqsMessageAttributeCarrier) Set(key, val string)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.