handler

Documentation

Index

• type FetchReq
• type FetchRes
• type Handler
  • func NewHandler(mq broker.Broker) *Handler
  • func (h *Handler) Fetch(ctx echo.Context) error
  • func (h *Handler) Publish(ctx echo.Context) error
  • func (h *Handler) PublishAsync(ctx echo.Context) error
  • func (h *Handler) Subscribe(ctx echo.Context) error
• type PublishReq
• type SubscribeReq
• type SubscribeRes

Types

type FetchReq

type FetchReq struct {
	Subject string `json:"subject"`
	ID      string `json:"id"`
}

FetchReq represents fetch request body.

type FetchRes

type FetchRes struct {
	Subject string   `json:"subject"`
	ID      string   `json:"id"`
	Data    []string `json:"data"`
}

FetchRes represents fetch response body.

type Handler

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

Handler represents broker handler.

func NewHandler

func NewHandler(mq broker.Broker) *Handler

NewHandler creates new Handler.

func (*Handler) Fetch

func (h *Handler) Fetch(ctx echo.Context) error

func (*Handler) Publish

func (h *Handler) Publish(ctx echo.Context) error

func (*Handler) PublishAsync

func (h *Handler) PublishAsync(ctx echo.Context) error

func (*Handler) Subscribe

func (h *Handler) Subscribe(ctx echo.Context) error

type PublishReq

type PublishReq struct {
	Subject string `json:"subject"`
	Data    string `json:"data"`
}

PublishReq represents publish request body.

type SubscribeReq

type SubscribeReq struct {
	Subject string `json:"subject"`
}

SubscribeReq represents subscribe request body.

type SubscribeRes

type SubscribeRes struct {
	Subject string `json:"subject"`
	ID      string `json:"id"`
}

SubscribeRes represents subscribe response body.