| 提交 | 用户 | age | ||
| 9d4b12 | 1 | package deliver |
| Z | 2 | |
| 3 | // Deliver define a interface how to use mangos | |
| 4 | type Deliver interface { | |
| 5 | ||
| 6 | // Send send data | |
| 7 | Send([]byte) error | |
| 8 | ||
| 9 | // Recv recv data | |
| 10 | Recv() ([]byte, error) | |
| aaae99 | 11 | |
| Z | 12 | // Close close Deliver |
| 13 | Close() | |
| 9d4b12 | 14 | } |
| Z | 15 | |
| 16 | // NewProducer create producer args presentive for parameter with protocal, e.g. sub topic | |
| 17 | func NewProducer(m Mode, url string, args ...interface{}) Deliver { | |
| 18 | ||
| 19 | if m > ModeStart && m < ModeNNG { | |
| aaae99 | 20 | return nngProducer(m, url, args...) |
| 9d4b12 | 21 | } |
| Z | 22 | return nil |
| 23 | } | |
| 24 | ||
| 25 | // NewConsumer create consumer args presentive for parameter with protocal, e.g. sub topic | |
| 26 | func NewConsumer(m Mode, url string, args ...interface{}) Deliver { | |
| 27 | ||
| 28 | if m > ModeStart && m < ModeNNG { | |
| aaae99 | 29 | return nngConsumer(m, url, args...) |
| 9d4b12 | 30 | } |
| Z | 31 | |
| 32 | return nil | |
| 33 | } | |
