Return an event object suitable for the named transport :param IOLoop io_loop: Pass in an io_loop if you want asynchronous operation for obtaining events. Eg use of set_event_handler() API. Otherwise, operation
(
node,
sock_dir=None,
opts=None,
listen=True,
io_loop=None,
keep_loop=False,
raise_errors=False,
)
| 130 | |
| 131 | |
| 132 | def get_event( |
| 133 | node, |
| 134 | sock_dir=None, |
| 135 | opts=None, |
| 136 | listen=True, |
| 137 | io_loop=None, |
| 138 | keep_loop=False, |
| 139 | raise_errors=False, |
| 140 | ): |
| 141 | """ |
| 142 | Return an event object suitable for the named transport |
| 143 | |
| 144 | :param IOLoop io_loop: Pass in an io_loop if you want asynchronous |
| 145 | operation for obtaining events. Eg use of |
| 146 | set_event_handler() API. Otherwise, operation |
| 147 | will be synchronous. |
| 148 | """ |
| 149 | sock_dir = sock_dir or opts["sock_dir"] |
| 150 | # TODO: AIO core is separate from transport |
| 151 | if node == "master": |
| 152 | return MasterEvent( |
| 153 | sock_dir, |
| 154 | opts, |
| 155 | listen=listen, |
| 156 | io_loop=io_loop, |
| 157 | keep_loop=keep_loop, |
| 158 | raise_errors=raise_errors, |
| 159 | ) |
| 160 | return SaltEvent( |
| 161 | node, |
| 162 | sock_dir, |
| 163 | opts, |
| 164 | listen=listen, |
| 165 | io_loop=io_loop, |
| 166 | keep_loop=keep_loop, |
| 167 | raise_errors=raise_errors, |
| 168 | ) |
| 169 | |
| 170 | |
| 171 | def get_master_event(opts, sock_dir, listen=True, io_loop=None, raise_errors=False): |
no test coverage detected