sqs

package

v0.5.0 Latest Latest Go to latest Published: Sep 8, 2021 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/xmidt-org/ears

Links

Open Source Insights

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
type ReceiverConfig
- func (rc *ReceiverConfig) Validate() error
- func (rc *ReceiverConfig) WithDefaults() ReceiverConfig
type Sender
type SenderConfig
- func (sc *SenderConfig) Validate() error
- func (sc SenderConfig) WithDefaults() SenderConfig

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),
}

View Source

var DefaultSenderConfig = SenderConfig{
	QueueUrl:            "",
	MaxNumberOfMessages: pointer.Int(10),
	SendTimeout:         pointer.Int(1),
	DelaySeconds:        pointer.Int(0),
}

Functions ¶

func NewPlugin ¶

func NewPlugin() (*pkgplugin.Plugin, error)

func NewPluginVersion ¶

func NewPluginVersion(name string, version string, commitID string) (*pkgplugin.Plugin, error)

func NewReceiver ¶

func NewReceiver(tid tenant.Id, plugin string, name string, config interface{}, secrets secret.Vault) (receiver.Receiver, error)

func NewSender ¶

func NewSender(tid tenant.Id, plugin string, name string, config interface{}, secrets secret.Vault) (sender.Sender, error)

Types ¶

type Receiver ¶

type Receiver struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Receiver) Config ¶ added in v0.2.1

func (r *Receiver) Config() interface{}

func (*Receiver) Count ¶

func (r *Receiver) Count() int

func (*Receiver) Name ¶ added in v0.2.1

func (r *Receiver) Name() string

func (*Receiver) Plugin ¶ added in v0.2.1

func (r *Receiver) Plugin() string

func (*Receiver) Receive ¶

func (r *Receiver) Receive(next receiver.NextFn) error

func (*Receiver) StopReceiving ¶

func (r *Receiver) StopReceiving(ctx context.Context) error

func (*Receiver) Tenant ¶ added in v0.3.0

func (r *Receiver) Tenant() tenant.Id

func (*Receiver) Trigger ¶

func (r *Receiver) Trigger(e event.Event)

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"`
}

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 ¶

type Sender struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Sender) Config ¶ added in v0.2.1

func (s *Sender) Config() interface{}

func (*Sender) Count ¶

func (s *Sender) Count() int

func (*Sender) Name ¶ added in v0.2.1

func (s *Sender) Name() string

func (*Sender) Plugin ¶ added in v0.2.1

func (s *Sender) Plugin() string

func (*Sender) Send ¶

func (s *Sender) Send(e event.Event)

func (*Sender) StopSending ¶

func (s *Sender) StopSending(ctx context.Context)

func (*Sender) Tenant ¶ added in v0.3.0

func (s *Sender) Tenant() tenant.Id

func (*Sender) Unwrap ¶

func (s *Sender) Unwrap() sender.Sender

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.

func (*SenderConfig) Validate ¶

func (sc *SenderConfig) Validate() error

Validate

func (SenderConfig) WithDefaults ¶

func (sc SenderConfig) WithDefaults() SenderConfig

WithDefaults

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
main

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