(ctx context.Context, req *proto.PutStateRequest)
| 311 | } |
| 312 | |
| 313 | func (f *FunctionServerImpl) PutState(ctx context.Context, req *proto.PutStateRequest) (*proto.Response, error) { |
| 314 | runtime, err := f.getFunctionRuntime(ctx) |
| 315 | if err != nil { |
| 316 | return nil, err |
| 317 | } |
| 318 | runtime.log.Debug("put state") |
| 319 | err = runtime.instance.FunctionContext().PutState(req.Key, req.Value) |
| 320 | if err != nil { |
| 321 | return nil, err |
| 322 | } |
| 323 | return &proto.Response{ |
| 324 | Status: proto.Response_OK, |
| 325 | }, nil |
| 326 | } |
| 327 | |
| 328 | func (f *FunctionServerImpl) GetState(ctx context.Context, req *proto.GetStateRequest) (*proto.GetStateResponse, |
| 329 | error) { |
nothing calls this directly
no test coverage detected