retry_handler_sqs

Documentation

Index

• type Callback
  • func NewCallback() *Callback
  • func (c *Callback) Consume(_ context.Context, m interface{}, attributes map[string]string) (bool, error)
  • func (c *Callback) GetModel(map[string]string) interface{}
• type DataModel
  • func (m *DataModel) EmptyMessage() proto.Message
  • func (m *DataModel) FromMessage(message proto.Message) error
  • func (m *DataModel) ToMessage() (proto.Message, error)

Types

type Callback

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

func NewCallback

func NewCallback() *Callback

func (*Callback) Consume

func (c *Callback) Consume(_ context.Context, m interface{}, attributes map[string]string) (bool, error)

func (*Callback) GetModel

func (c *Callback) GetModel(map[string]string) interface{}

type DataModel

type DataModel struct {
	Id int64
}

func (*DataModel) EmptyMessage

func (m *DataModel) EmptyMessage() proto.Message

func (*DataModel) FromMessage

func (m *DataModel) FromMessage(message proto.Message) error

func (*DataModel) ToMessage

func (m *DataModel) ToMessage() (proto.Message, error)