example

Documentation

Index

• type Consumer
  • func (c *Consumer) CreatePost(ctx context.Context, m gosqs.Message) error
  • func (c *Consumer) RegisterHandlers(adapters ...gosqs.Adapter)
  • func (c *Consumer) Test(ctx context.Context, m gosqs.Message) error
• type Post
  • func (p Post) ModelName() string
• type ServiceHandler
  • func (h *ServiceHandler) Test(w http.ResponseWriter, r *http.Request)

Types

type Consumer

type Consumer struct {
	gosqs.Consumer
}

Consumer a wrapper for the gosqs consumer

func (*Consumer) CreatePost

func (c *Consumer) CreatePost(ctx context.Context, m gosqs.Message) error

CreatePost an example of what an event listener looks like

func (*Consumer) RegisterHandlers

func (c *Consumer) RegisterHandlers(adapters ...gosqs.Adapter)

RegisterHandlers listens to the specific event types from the queue

func (*Consumer) Test

func (c *Consumer) Test(ctx context.Context, m gosqs.Message) error

Test example event handler

type Post

type Post struct {
	ID     string `json:"id"`
	UserID string `json:"userId"`
	Body   string `json:"body"`
}

Post defines a message post

func (Post) ModelName

func (p Post) ModelName() string

ModelName satisfies the gosqs interface and allows messages to be sent out

this will look like Dispatcher(ctx).Create(&post{}) will send the message post_created

type ServiceHandler

type ServiceHandler struct{}

ServiceHandler example http handler

func (*ServiceHandler) Test

func (h *ServiceHandler) Test(w http.ResponseWriter, r *http.Request)

Test a showcase of various ways to send messages