reader

package

v0.0.16 Latest Latest Go to latest Published: Apr 8, 2021 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

View Source

var Module = fx.Provide(
	NewReader,
)

Module provides all of the dependencies required by the reader module

func Run(reader Reader)

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

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(
	queue pubsub.Subscriber,
	logger *zap.Logger,
	shutdowner fx.Shutdowner,
) Reader

NewReader is the constructor of the reader type

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