sqs

Documentation

Index

• Constants
• type Bucket
• type Config
  • func ParseConfig(confData []byte) (*Config, error)
• type Message
• type Object
• type Queue
  • func New(l *slog.Logger, c *Config, flowName string) (*Queue, error)
  • func (internalSqs *Queue) Enqueue(msg *domain.MessageContext) error
  • func (internalSqs *Queue) Name() string
  • func (internalSqs *Queue) Type() string

Constants

const TYPE string = "sqs"

Types

type Bucket

type Bucket struct {
	Name   string `json:"name"`
	Region string `json:"region"`
}

type Config

type Config struct {
	URL       string `yaml:"url"`
	Region    string `yaml:"region"`
	Endpoint  string `yaml:"endpoint"`
	AccessKey string `yaml:"access_key"`
	SecretKey string `yaml:"secret_key"`
}

func ParseConfig

func ParseConfig(confData []byte) (*Config, error)

type Message

type Message struct {
	SchemaVersion string `json:"schema_version"`
	FlowName      string `json:"flow_name"`
	Bucket        Bucket `json:"bucket"`
	Object        Object `json:"object"`
}

type Object

type Object struct {
	Path            string `json:"path"`
	FullURL         string `json:"full_url"`
	SizeInBytes     int    `json:"size_in_bytes"`
	CompressionType string `json:"compression_algorithm,omitempty"`
}

type Queue

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

func New

func New(l *slog.Logger, c *Config, flowName string) (*Queue, error)

func (*Queue) Enqueue

func (internalSqs *Queue) Enqueue(msg *domain.MessageContext) error

func (*Queue) Name

func (internalSqs *Queue) Name() string

func (*Queue) Type

func (internalSqs *Queue) Type() string