(f *FSSReconcileServer, addr string)
| 342 | } |
| 343 | |
| 344 | func StartGRPCServer(f *FSSReconcileServer, addr string) (*grpc.Server, error) { |
| 345 | lis, err := net.Listen("tcp", addr) |
| 346 | if err != nil { |
| 347 | return nil, err |
| 348 | } |
| 349 | s := grpc.NewServer() |
| 350 | proto.RegisterFSReconcileServer(s, f) |
| 351 | proto.RegisterFunctionServer(s, NewFunctionServerImpl(f)) |
| 352 | go func() { |
| 353 | if err := s.Serve(lis); err != nil { |
| 354 | slog.Error("failed to serve", slog.Any("error", err)) |
| 355 | } |
| 356 | }() |
| 357 | return s, nil |
| 358 | } |