sync

package

v0.0.0-...-ef83a17 Latest Latest Go to latest Published: Aug 11, 2020 License: Apache-2.0 Imports: 2 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.

This section is empty.

This section is empty.

type Queue struct {
	Name string
	// contains filtered or unexported fields
}

Queue provides a task queue

func New(name string) (*Queue, error)

New returns a new Queue

func (q *Queue) Handle(h nsq.Handler) *Queue

Handle adds a nmodifier handler

func (q Queue) Pipe(q2 Queue) (Queue, error)

Pipe connects two queues

func (q *Queue) Push(b []byte) error

Push pushes a new message to the inTopic. Useful for piping in data while running

func (q *Queue) PushFunc(h nsq.Handler) error

PushFunc runs a handler function to

func (q *Queue) Run() error

Run registers all handlers with source