async

package

v0.5.1 Latest Latest Go to latest Published: Aug 16, 2018 License: Apache-2.0 Imports: 7 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.

func DetermineDecoder(contentType string) (encoding.DecodeRawFunc, error)

DetermineDecoder determines the decoder based on the content type.

type Component struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Component implementation of a async component.

func New(p ProcessorFunc, cns Consumer) (*Component, error)

New returns a new async component.

func (c *Component) Run(ctx context.Context) error

Run starts the consumer processing loop messages.

func (c *Component) Shutdown(ctx context.Context) error

Shutdown gracefully the component by closing the consumer.

type Consumer interface {
	Consume(context.Context) (<-chan Message, <-chan error, error)
	Close() error
}

Consumer interface which every specific consumer has to implement.

type Message interface {
	Context() context.Context
	Decode(v interface{}) error
	Ack() error
	Nack() error
}

Message interface for defining messages that are handled by the async component.

type ProcessorFunc func(Message) error

ProcessorFunc definition of a async processor.

Path	Synopsis
amqp
kafka