async

package

v0.5.1 Latest Latest Go to latest Published: Aug 16, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Details

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