| | |
| | | package deliver |
| | | |
| | | import "errors" |
| | | |
| | | // Deliver define a interface how to use mangos |
| | | type Deliver interface { |
| | | |
| | |
| | | if m > ModeStart && m < ModeNNG { |
| | | return nngServer(m, url, args...) |
| | | } else if m == Shm { |
| | | return shmServer(m, url, args...) |
| | | s, _ := shmServer(m, url, args...) |
| | | return s |
| | | } |
| | | return nil |
| | | } |
| | |
| | | if m > ModeStart && m < ModeNNG { |
| | | return nngClient(m, url, args...) |
| | | } else if m == Shm { |
| | | return shmClient(m, url, args...) |
| | | s, _ := shmClient(m, url, args...) |
| | | return s |
| | | } |
| | | |
| | | return nil |
| | | } |
| | | |
| | | // NewServerWithError create listener args presentive for parameter with protocal, e.g. sub topic |
| | | func NewServerWithError(m Mode, url string, args ...interface{}) (Deliver, error) { |
| | | |
| | | if m > ModeStart && m < ModeNNG { |
| | | return nngServer(m, url, args...), nil |
| | | } else if m == Shm { |
| | | return shmServer(m, url, args...) |
| | | } |
| | | return nil, errors.New("please choose a suitable deliver.mode") |
| | | } |
| | | |
| | | // NewClientWithError create dialer args presentive for parameter with protocal, e.g. sub topic |
| | | func NewClientWithError(m Mode, url string, args ...interface{}) (Deliver, error) { |
| | | |
| | | if m > ModeStart && m < ModeNNG { |
| | | return nngClient(m, url, args...), nil |
| | | } else if m == Shm { |
| | | return shmClient(m, url, args...) |
| | | } |
| | | |
| | | return nil, errors.New("please choose a suitable deliver.mode") |
| | | } |