reader

Documentation

Index

• Variables
• func Run(reader Reader)
• type Reader
  • func NewReader(queue pubsub.Subscriber, logger *zap.Logger, shutdowner fx.Shutdowner) Reader
  • func (r Reader) Run()

Variables

var Module = fx.Provide(
	NewReader,
)

Module provides all of the dependencies required by the reader module

Functions

func Run

func Run(reader Reader)

Run is a function to be used in invoke to start the server running.

Types

type Reader

type Reader struct {
	Queue      pubsub.Subscriber
	Logger     *zap.Logger
	Shutdowner fx.Shutdowner
}

Reader reads from an SQS Queue and logs out the messages

func NewReader

func NewReader(
	queue pubsub.Subscriber,
	logger *zap.Logger,
	shutdowner fx.Shutdowner,
) Reader

NewReader is the constructor of the reader type

func (Reader) Run

func (r Reader) Run()

Run starts the reader reading messages and logs them out, it will shutdown the server if the queue doesn't return any more messages