responder

Documentation

Index

• type ProcessFunc
• type RequiredAttributeMissing
  • func (r *RequiredAttributeMissing) Error() string
• type Responder
  • func NewResponder(sqsClient sqsClient, processFunc ProcessFunc) Responder
  • func (r *Responder) ProcessAndReply(ctx context.Context, message types.Message) error

Types

type ProcessFunc

type ProcessFunc func(message string) (string, error)

type RequiredAttributeMissing

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

func (*RequiredAttributeMissing) Error

func (r *RequiredAttributeMissing) Error() string

type Responder

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

func NewResponder

func NewResponder(sqsClient sqsClient, processFunc ProcessFunc) Responder

func (*Responder) ProcessAndReply

func (r *Responder) ProcessAndReply(ctx context.Context, message types.Message) error