async

Documentation

Index

• func DetermineDecoder(contentType string) (encoding.DecodeRawFunc, error)
• type Component
  • func New(p ProcessorFunc, cns Consumer) (*Component, error)
  • func (c *Component) Run(ctx context.Context) error
  • func (c *Component) Shutdown(ctx context.Context) error
• type Consumer
• type Message
• type ProcessorFunc

Functions

func DetermineDecoder

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

DetermineDecoder determines the decoder based on the content type.

Types

type Component

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

Component implementation of a async component.

func New

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

New returns a new async component.

func (*Component) Run

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

Run starts the consumer processing loop messages.

func (*Component) Shutdown

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

Shutdown gracefully the component by closing the consumer.

type 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

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

type ProcessorFunc func(context.Context, Message) error

ProcessorFunc definition of a async processor.