(ctx context.Context, req *proto.GetStateRequest)
| 326 | } |
| 327 | |
| 328 | func (f *FunctionServerImpl) GetState(ctx context.Context, req *proto.GetStateRequest) (*proto.GetStateResponse, |
| 329 | error) { |
| 330 | runtime, err := f.getFunctionRuntime(ctx) |
| 331 | if err != nil { |
| 332 | return nil, err |
| 333 | } |
| 334 | runtime.log.Debug("get state") |
| 335 | v, err := runtime.instance.FunctionContext().GetState(req.Key) |
| 336 | if err != nil { |
| 337 | return nil, err |
| 338 | } |
| 339 | return &proto.GetStateResponse{ |
| 340 | Value: v, |
| 341 | }, nil |
| 342 | } |
| 343 | |
| 344 | func StartGRPCServer(f *FSSReconcileServer, addr string) (*grpc.Server, error) { |
| 345 | lis, err := net.Listen("tcp", addr) |
nothing calls this directly
no test coverage detected