(ctx context.Context, e *proto.Event)
| 299 | } |
| 300 | |
| 301 | func (f *FunctionServerImpl) Output(ctx context.Context, e *proto.Event) (*proto.Response, error) { |
| 302 | runtime, err := f.getFunctionRuntime(ctx) |
| 303 | if err != nil { |
| 304 | return nil, err |
| 305 | } |
| 306 | runtime.log.Debug("received event") |
| 307 | runtime.output <- contube.NewRecordImpl([]byte(e.Payload), func() {}) |
| 308 | return &proto.Response{ |
| 309 | Status: proto.Response_OK, |
| 310 | }, nil |
| 311 | } |
| 312 | |
| 313 | func (f *FunctionServerImpl) PutState(ctx context.Context, req *proto.PutStateRequest) (*proto.Response, error) { |
| 314 | runtime, err := f.getFunctionRuntime(ctx) |
nothing calls this directly
no test coverage detected