cmd

Documentation

Index

• func Execute()
• func LoadConfig(file string, conf *Config) error
• func NewSQSClient(ctx context.Context) (*sqs.Client, error)
• func PrintConfig(conf *Config)
• func Sleep(dur time.Duration)
• func SourceMessages(ctx context.Context, n int) chan internal.Message
• type Config
• type Consumer
  • func NewConsumer(ctx context.Context, queueURL string) *Consumer
  • func (c *Consumer) Consume(ctx context.Context) ([]*internal.QueueMessage[internal.Message], error)
  • func (c *Consumer) DeleteMessage(ctx context.Context, receiptHandles []string) error
• type ConsumerWorker
  • func NewConsumerWorker(ctx context.Context, configFile string) (*ConsumerWorker, error)
  • func (w *ConsumerWorker) ApplyConfig()
  • func (w *ConsumerWorker) Convert(msg awss.QueueMessage[string]) Message
  • func (w *ConsumerWorker) DeleteMessage(msgs []Message) []Message
  • func (w *ConsumerWorker) Do(msg Message) (ret Message)
  • func (w *ConsumerWorker) LoadConfig(configFile string) error
  • func (w *ConsumerWorker) Start() error
• type Logger
  • func NewLogger(filename string, options *slog.HandlerOptions) (*Logger, error)
  • func (l *Logger) Close()
  • func (l *Logger) Error(msg string, args ...any)
  • func (l *Logger) Info(msg string, args ...any)
  • func (l *Logger) Reload() error
• type Message
• type Producer
  • func NewProducer(ctx context.Context, limiter *rate.Limiter, queueURL string) *Producer
  • func (p *Producer) Produce(ctx context.Context, message []*internal.Message) error
• type Reloadable
  • func NewReloadable[T any](value *T, sig ...os.Signal) *Reloadable[T]
  • func (r *Reloadable[T]) Watch(ctx context.Context, do func(T) T)

Functions

func Execute

func Execute()

Execute adds all child commands to the root command and sets flags appropriately. This is called by main.main(). It only needs to happen once to the rootCmd.

func LoadConfig

func LoadConfig(file string, conf *Config) error

func NewSQSClient

func NewSQSClient(ctx context.Context) (*sqs.Client, error)

func PrintConfig

func PrintConfig(conf *Config)

func Sleep

func Sleep(dur time.Duration)

func SourceMessages

func SourceMessages(ctx context.Context, n int) chan internal.Message

Types

type Config

type Config struct {
	HomeDir     string `yaml:"home_dir"`
	Concurrency int    `yaml:"concurrency"`
}

type Consumer

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

func NewConsumer

func NewConsumer(ctx context.Context, queueURL string) *Consumer

func (*Consumer) Consume

func (c *Consumer) Consume(ctx context.Context) ([]*internal.QueueMessage[internal.Message], error)

func (*Consumer) DeleteMessage

func (c *Consumer) DeleteMessage(ctx context.Context, receiptHandles []string) error

type ConsumerWorker

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

func NewConsumerWorker

func NewConsumerWorker(ctx context.Context, configFile string) (*ConsumerWorker, error)

func (*ConsumerWorker) ApplyConfig

func (w *ConsumerWorker) ApplyConfig()

func (*ConsumerWorker) Convert

func (w *ConsumerWorker) Convert(msg awss.QueueMessage[string]) Message

func (*ConsumerWorker) DeleteMessage

func (w *ConsumerWorker) DeleteMessage(msgs []Message) []Message

func (*ConsumerWorker) Do

func (w *ConsumerWorker) Do(msg Message) (ret Message)

func (*ConsumerWorker) LoadConfig

func (w *ConsumerWorker) LoadConfig(configFile string) error

func (*ConsumerWorker) Start

func (w *ConsumerWorker) Start() error

type Logger

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

func NewLogger

func NewLogger(filename string, options *slog.HandlerOptions) (*Logger, error)

func (*Logger) Close

func (l *Logger) Close()

func (*Logger) Error

func (l *Logger) Error(msg string, args ...any)

func (*Logger) Info

func (l *Logger) Info(msg string, args ...any)

func (*Logger) Reload

func (l *Logger) Reload() error

type Message

type Message awss.QueueMessage[internal.Message]

type Producer

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

func NewProducer

func NewProducer(ctx context.Context, limiter *rate.Limiter, queueURL string) *Producer

func (*Producer) Produce

func (p *Producer) Produce(ctx context.Context, message []*internal.Message) error

type Reloadable

type Reloadable[T any] struct {
	Value *T
	// contains filtered or unexported fields
}

func NewReloadable

func NewReloadable[T any](value *T, sig ...os.Signal) *Reloadable[T]

func (*Reloadable[T]) Watch

func (r *Reloadable[T]) Watch(ctx context.Context, do func(T) T)