| 49 | } |
| 50 | |
| 51 | type invoker struct { |
| 52 | conn *grpc.ClientConn |
| 53 | fwd portforwarder.PortForwarder |
| 54 | listener net.Listener |
| 55 | jupyterClient jupyter.JupyterServerHostClient |
| 56 | codespaceClient codespace.CodespaceHostClient |
| 57 | sshClient ssh.SshServerHostClient |
| 58 | cancelPF context.CancelFunc |
| 59 | keepAliveOverride bool |
| 60 | } |
| 61 | |
| 62 | // Connects to the internal RPC server and returns a new invoker for it |
| 63 | func CreateInvoker(ctx context.Context, fwd portforwarder.PortForwarder) (Invoker, error) { |
nothing calls this directly
no outgoing calls
no test coverage detected