job

package

v0.0.0-...-58d095e Latest Latest Go to latest Published: May 14, 2020 License: MIT Imports: 6 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

View Source

const LogJobName = "log"

LogJobName is LogJob's unique identifier.

This section is empty.

func Do(ctx context.Context, message events.SQSMessage) (context.Context, error)

Do parses the SQS message and invokes Job.Do.

type Job interface {
	Do(context.Context) (context.Context, error)
}

Job is the interfce implemented by jobs.

func NewLogJob() Job

NewLogJob returns a LogJob.

type LogJob struct{}

LogJob is a job that simply prints a log message.

func (j LogJob) Do(ctx context.Context) (context.Context, error)

Do implements Job.Do by printing a log message.

type Message struct {
	Job string `json:"job"`
}

Message models a job message sent to the queue.

func NewMessage(job string) Message

NewMessage returns an initialized Message.

func (m Message) String() string

String implementes Stringer by marshaling the message to JSON.

type NewJob = func() Job

NewJob is a function definition for functions that return initialized Jobs.