| | |
| | | "nanomsg.org/go-mangos/transport/all" |
| | | ) |
| | | |
| | | // type deliver |
| | | type td int |
| | | |
| | | const ( |
| | | agent = td(iota) |
| | | coactee |
| | | ) |
| | | |
| | | // NNG mangos wrap |
| | | type NNG struct { |
| | | sock mangos.Socket |
| | | server bool |
| | | mode Mode |
| | | url string |
| | | sock mangos.Socket |
| | | typ td |
| | | mode Mode |
| | | url string |
| | | |
| | | arguments []interface{} |
| | | } |
| | |
| | | rmExistedIpcName(url) |
| | | |
| | | return &NNG{ |
| | | server: true, |
| | | typ: agent, |
| | | mode: m, |
| | | url: url, |
| | | arguments: args, |
| | |
| | | func nngClient(m Mode, url string, args ...interface{}) *NNG { |
| | | |
| | | return &NNG{ |
| | | server: false, |
| | | typ: coactee, |
| | | mode: m, |
| | | url: url, |
| | | arguments: args, |