(t Transport)
| 27 | ) |
| 28 | |
| 29 | func newConnectorLastSyncFunc(t Transport) ConnectorLastSync { |
| 30 | return func(body io.Reader, connector_id string, o ...func(*ConnectorLastSyncRequest)) (*Response, error) { |
| 31 | var r = ConnectorLastSyncRequest{Body: body, ConnectorID: connector_id} |
| 32 | for _, f := range o { |
| 33 | f(&r) |
| 34 | } |
| 35 | |
| 36 | if transport, ok := t.(Instrumented); ok { |
| 37 | r.Instrument = transport.InstrumentationEnabled() |
| 38 | } |
| 39 | |
| 40 | return r.Do(r.ctx, t) |
| 41 | } |
| 42 | } |
| 43 | |
| 44 | // ----- API Definition ------------------------------------------------------- |
| 45 |
no test coverage detected