| 171 | } |
| 172 | |
| 173 | type grpcTransport struct { |
| 174 | cc *grpc.ClientConn |
| 175 | |
| 176 | // cleanup is the function to be invoked for releasing the references to |
| 177 | // the gRPC transport each time Close() is called. |
| 178 | cleanup func() |
| 179 | } |
| 180 | |
| 181 | // NewStream creates a new gRPC stream to the server for the specified method. |
| 182 | func (g *grpcTransport) NewStream(ctx context.Context, method string) (clients.Stream, error) { |
nothing calls this directly
no outgoing calls
no test coverage detected