reader

package

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

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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