| 41 | } |
| 42 | |
| 43 | func (m *mockRegistrationHandler) RegisterPlugin(context.Context, *connect.Request[pluginsv1.RegisterPluginRequest]) (*connect.Response[pluginsv1.RegisterPluginResponse], error) { |
| 44 | m.registerRequests++ |
| 45 | return connect.NewResponse(pluginsv1.RegisterPluginResponse_builder{ |
| 46 | EngineName: proto.String("mock"), |
| 47 | EngineVersion: proto.String("v1.0.0"), |
| 48 | RequestTimeout: durationpb.New(10 * time.Second), |
| 49 | }.Build()), nil |
| 50 | } |
| 51 | |
| 52 | func Test_setup(t *testing.T) { |
| 53 | t.Run("plugin shuts down its IPC when runtime calls shutdown", func(t *testing.T) { |