(rt *kayak.Runtime)
| 155 | } |
| 156 | |
| 157 | func newFakeService(rt *kayak.Runtime) (fs *fakeService) { |
| 158 | fs = &fakeService{ |
| 159 | rt: rt, |
| 160 | s: rpc.NewServer(), |
| 161 | } |
| 162 | |
| 163 | fs.s.RegisterName("Test", fs) |
| 164 | |
| 165 | return |
| 166 | } |
| 167 | |
| 168 | func (s *fakeService) Apply(req *kt.ApplyRequest, resp *interface{}) (err error) { |
| 169 | // add some delay for timeout test |
no test coverage detected