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