event

Documentation

Index

• Variables
• type DataPushReq
• type DataPushRsp
• type DataPushRsps
• type HandleDataPush
  • func (r *HandleDataPush) Output(ctx context.Context) (interface{}, error)
  • func (r *HandleDataPush) Path() string
• type HandleEvent
  • func (r *HandleEvent) Output(ctx context.Context) (interface{}, error)
  • func (r *HandleEvent) Path() string

Variables

var (
	Root  = kit.NewRouter(httptransport.Group("/event"), &middleware.EventReqRateLimit{})
	Root2 = kit.NewRouter(httptransport.Group("/event2"), &middleware.EventReqRateLimit{})
)

TODO: Unify the event interface

Types

type DataPushReq

type DataPushReq []struct {
	DeviceID  string `json:"device_id"`
	EventType string `json:"event_type,omitempty"`
	Payload   string `json:"payload"`
	Timestamp int64  `json:"timestamp,omitempty"`
}

type DataPushRsp

type DataPushRsp struct {
	Index   int             `json:"index"`
	Results []*event.Result `json:"results"`
}

type DataPushRsps

type DataPushRsps []*DataPushRsp

type HandleDataPush

type HandleDataPush struct {
	httpx.MethodPost
	DataPushReq `in:"body"`
	Channel     string `in:"path" name:"channel"`
}

func (*HandleDataPush) Output

func (r *HandleDataPush) Output(ctx context.Context) (interface{}, error)

func (*HandleDataPush) Path

func (r *HandleDataPush) Path() string

type HandleEvent

type HandleEvent struct {
	httpx.MethodPost
	event.EventReq
}

func (*HandleEvent) Output

func (r *HandleEvent) Output(ctx context.Context) (interface{}, error)

func (*HandleEvent) Path

func (r *HandleEvent) Path() string