store

Documentation

Index

• type Controller
  • func NewController(store broker.TopicMessageStore) *Controller
  • func (c *Controller) Get(ctx echo.Context) error
  • func (c *Controller) Info(ctx echo.Context) error
• type InfoData
• type InfoResponse

Types

type Controller

type Controller struct {
	broker.TopicMessageStore
}

func NewController

func NewController(store broker.TopicMessageStore) *Controller

func (*Controller) Get

func (c *Controller) Get(ctx echo.Context) error

func (*Controller) Info

func (c *Controller) Info(ctx echo.Context) error

type InfoData

type InfoData struct {
	MessageID   string
	Payload     []byte
	PubReceived bool
	FromSession bool
	TimeStamp   int64
	ExpiredTime int64
	Will        bool
}

type InfoResponse

type InfoResponse struct {
	base.Response
	Data InfoData `json:"data"`
}