processor

Documentation

Index

• func NewAcknowledgmentError(err error) error
• func NewCreateCommandError(err error) error
• type AcknowledgmentError
  • func (e AcknowledgmentError) Error() string
• type CreateCommandError
  • func (e CreateCommandError) Error() string
• type Processor
  • func New(b command.Builder, a acknowledger.Acknowledger, l logr.Logger) Processor

Functions

func NewAcknowledgmentError

func NewAcknowledgmentError(err error) error

NewAcknowledgmentError creates a new AcknowledgmentError from the given error.

func NewCreateCommandError

func NewCreateCommandError(err error) error

NewCreateCommandError creates a new CreateCommandError from the given error.

Types

type AcknowledgmentError

type AcknowledgmentError struct {
	// contains filtered or unexported fields
}

AcknowledgmentError defines an error indicating that acknowledgment of a message failed.

func (AcknowledgmentError) Error

func (e AcknowledgmentError) Error() string

Error is part of the error builtin.

type CreateCommandError

type CreateCommandError struct {
	// contains filtered or unexported fields
}

CreateCommandError defines an error indicating that the creation of a command failed.

func (CreateCommandError) Error

func (e CreateCommandError) Error() string

Error is part of the error builtin.

type Processor

type Processor interface {
	Process(delivery.Delivery) error
}

Processor describes the interface used by the consumer to process messages.

func New

func New(b command.Builder, a acknowledger.Acknowledger, l logr.Logger) Processor

New creates a new processor instance.