Versions in this module Expand all Collapse all v0 v0.0.1 Sep 26, 2022 Changes in this version + type SVC struct + func New() *SVC + func (s *SVC) AddFlow(ctx context.Context, id nameid.ID, rd io.ReadCloser) error + func (s *SVC) CancelRunningFlow(ctx context.Context, id nameid.ID) error + func (s *SVC) GetAvailableMeta(ctx context.Context, id nameid.ID) (exported.FlowMetaInsight, error) + func (s *SVC) InsightFlow(ctx context.Context, fid nameid.ID) (exported.FlowRunningInsight, error) + func (s *SVC) InspectStdFunction(ctx context.Context, name string) exported.InspectStdFunction + func (s *SVC) ListAvailables(ctx context.Context) []exported.FlowMetaInsight + func (s *SVC) ListStdFunctions(ctx context.Context) []exported.ListStdFunctions + func (s *SVC) LookupID(ctx context.Context, nameorid nameid.NameOrID) (nameid.ID, error) + func (s *SVC) ReadyFlow(ctx context.Context, id nameid.ID, out io.Writer) (exported.FlowRunningInsight, error) + func (s *SVC) StartEventFlow(ctx context.Context, id nameid.ID) chan error + func (s *SVC) StartEventFlowAndWait(ctx context.Context, id nameid.ID) error + func (s *SVC) StartFlow(ctx context.Context, id nameid.ID) chan error + func (s *SVC) StartFlowAndWait(ctx context.Context, id nameid.ID) error + func (s *SVC) StartFlowOrEventFlow(ctx context.Context, id nameid.ID) error + func (s *SVC) ViewLog(ctx context.Context, id nameid.ID, seq int, w io.Writer) error + type Writer interface + JsonWrite func(io.Writer) error