diff --git a/sdk/common/common.go b/sdk/common/common.go index 40d57d7058ee1bda059e887803426ff1b16e0ba7..9670b2e152dbdb40957ed2bf9994904d92b02619 100644 --- a/sdk/common/common.go +++ b/sdk/common/common.go @@ -15,3 +15,5 @@ type CommonResult struct { func (r *CommonResult) ParseData(d interface{}) error { return json.Unmarshal(r.Data, d) } + +type EventCallback func(e *EventMessage) diff --git a/sdk/plugin/client/client.go b/sdk/plugin/client/client.go index b6d6ef20a3f31048ec238d2254bc54872ae9dc1f..6bf95ba6eb5cbd1432736e62cacb56c99563cbb8 100644 --- a/sdk/plugin/client/client.go +++ b/sdk/plugin/client/client.go @@ -24,7 +24,7 @@ type Client struct { // 用于event消息处理 EventChan chan *common.EventMessage - EventCallbackMap map[int]EventCallback + EventCallbackMap map[int]common.EventCallback // 用于异步command及script执行结果处理机 asyncCmdResultChan chan *common.AsyncCmdResult @@ -51,7 +51,7 @@ func DefaultClient(desc *PluginInfo) *Client { PluginInfo: desc, EventChan: make(chan *common.EventMessage, 20), - EventCallbackMap: make(map[int]EventCallback), + EventCallbackMap: make(map[int]common.EventCallback), asyncCmdResultChan: make(chan *common.AsyncCmdResult, 20), cmdProcessorCallbackMap: make(map[string]CallbackHandler),