messaging

Documentation

Index

• func Consume(req http.Request, cb Callback) (int, error)
• type Callback
• type Consumer
• type Message
• type Publisher

Functions

func Consume

func Consume(req http.Request, cb Callback) (int, error)

Consume the request, call callback and return http code (pushing mode)

Types

type Callback

type Callback func(ctx context.Context, m *Message) error

Callback is a function that processes a Message.

type Consumer

type Consumer interface {
	// Pull the next message, call callback and return
	// If callback returns a temporary error, the message must be rescheduled, increasing its trycount
	Pull(ctx context.Context, cb Callback) error
}

Consumer is an interface to consume messages

type Message

type Message struct {
	ID          string
	Data        []byte
	Attributes  map[string]string
	PublishTime time.Time
	TryCount    int
}

type Publisher

type Publisher interface {
	Publish(ctx context.Context, data ...[]byte) error
}

Publisher is an interface to publish messages