event

Documentation

Index

• func HandleEvent(ctx context.Context, t string, data []byte) (interface{}, error)
• type EventReq
  • func (r *EventReq) IsDataPush() bool
  • func (r *EventReq) SetDefault()
• type EventRsp
• type Result
  • func OnEvent(ctx context.Context, data []byte) (ret []*Result)

Functions

func HandleEvent

func HandleEvent(ctx context.Context, t string, data []byte) (interface{}, error)

HandleEvent support other module call TODO the full project info is not in context so query and set here. this impl is for support other module, which is temporary. And it will be deprecated when rpc/http is ready

Types

type EventReq

type EventReq struct {
	// Channel message channel named (intact project name)
	Channel string `in:"path"  name:"channel"`
	// EventType used for filter strategies created in w3b before
	EventType string `in:"query" name:"eventType,omitempty"`
	// EventID unique id for tracing event under channel
	EventID string `in:"query" name:"eventID,omitempty"`
	// Timestamp event time when publisher do send
	Timestamp int64 `in:"query" name:"timestamp,omitempty"`
	// Payload event payload (binary only)
	Payload bytes.Buffer `in:"body" mime:"stream"`
}

func (*EventReq) IsDataPush

func (r *EventReq) IsDataPush() bool

func (*EventReq) SetDefault

func (r *EventReq) SetDefault()

type EventRsp

type EventRsp struct {
	// Channel intact project name
	Channel string `json:"channel"`
	// PublisherID publisher(device) unique id in w3b node
	PublisherID types.SFID `json:"publisherID"`
	// PublisherKey publisher(device) mn unique id of this device
	PublisherKey string `json:"publisherKey"`
	// EventID same as EventReq.EventID
	EventID string `json:"eventID"`
	// Timestamp event respond time when event handled done.
	Timestamp int64 `json:"timestamp"`
	// Results result for each wasm invoke, which hits strategies.
	Results []*Result `json:"results"`
	// Error error message from w3b node (api level), different from Result.Error
	Error string `json:"error,omitempty"`
}

type Result

type Result struct {
	// AppletName applet name(unique) under published channel(project)
	AppletName string `json:"appletName"`
	// InstanceID the unique wasm vm  id
	InstanceID types.SFID `json:"instanceID"`
	// Handler invoked wasm entry name
	Handler string `json:"handler"`
	// ReturnValue wasm call returned value
	ReturnValue []byte `json:"returnValue"`
	// ReturnCode wasm call returned code
	ReturnCode int `json:"code"`
	// Error message instance module, presents result for wasm invoking
	Error string `json:"error,omitempty"`
}

func OnEvent

func OnEvent(ctx context.Context, data []byte) (ret []*Result)