MCPcopy Index your code
hub / github.com/FunctionStream/function-stream / GetStateStore

Method GetStateStore

fs/manager.go:60–60  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

58 ProduceEvent(name string, event contube.Record) error
59 ConsumeEvent(name string) (contube.Record, error)
60 GetStateStore() api.StateStore
61 Close() error
62}
63

Callers 2

TestFMWithGRPCRuntimeFunction · 0.95
makeStateServiceMethod · 0.65

Implementers 2

testFunctionManagerImplserver/function_store_test.go
functionManagerImplfs/manager.go

Calls

no outgoing calls

Tested by 1

TestFMWithGRPCRuntimeFunction · 0.76