usp_sqs_files

package
v0.0.0-...-a979c26 Latest Latest
Warning

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

Go to latest
Published: May 12, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SQSFilesAdapter

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

func NewSQSFilesAdapter

func NewSQSFilesAdapter(conf SQSFilesConfig) (*SQSFilesAdapter, chan struct{}, error)

func (*SQSFilesAdapter) Close

func (a *SQSFilesAdapter) Close() error

type SQSFilesConfig

type SQSFilesConfig struct {
	ClientOptions uspclient.ClientOptions `json:"client_options" yaml:"client_options"`

	// SQS specific
	AccessKey string `json:"access_key" yaml:"access_key"`
	SecretKey string `json:"secret_key,omitempty" yaml:"secret_key,omitempty"`
	QueueURL  string `json:"queue_url" yaml:"queue_url"`
	Region    string `json:"region" yaml:"region"`

	// S3 specific
	ParallelFetch int    `json:"parallel_fetch" yaml:"parallel_fetch"`
	BucketPath    string `json:"bucket_path,omitempty" yaml:"bucket_path,omitempty"`
	FilePath      string `json:"file_path,omitempty" yaml:"file_path,omitempty"`
}

func (*SQSFilesConfig) Validate

func (c *SQSFilesConfig) Validate() error

Jump to

Keyboard shortcuts

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