Versions in this module Expand all Collapse all v0 v0.2.0 Sep 4, 2026 Changes in this version + var ErrValidation = errors.New("flowapi: validation failed") + type API struct + func NewAPI(svc *Service, mw *auth.Middleware) *API + func (a *API) Mount(mux *http.ServeMux) + type CreateFlowRequest struct + AutoRestart bool + Config json.RawMessage + Name string + Pipeline string + type FlowView struct + AutoRestart bool + Config json.RawMessage + CreatedAt time.Time + ErrorMessage *string + FailedBlock *string + Name string + Pipeline string + Realm string + RuntimeID string + StartedAt *time.Time + Status string + StoppedAt *time.Time + UpdatedAt time.Time + type PipelineView struct + CreatedAt time.Time + Definition json.RawMessage + Name string + ReferencingFlows []string + UpdatedAt time.Time + type Service struct + func NewService(st *store.Store, mgr *flow.Manager, reg *flow.Registry, bus *stream.Bus, ...) *Service + func (s *Service) CreateAndStartFlow(ctx context.Context, realm string, req CreateFlowRequest) (*FlowView, error) + func (s *Service) CreatePipeline(ctx context.Context, realm, name string, definition []byte) (*PipelineView, error) + func (s *Service) CreateUserBlock(ctx context.Context, realm, name, blockType string, ...) (*UserBlockView, error) + func (s *Service) DeleteFlow(ctx context.Context, realm, name string) error + func (s *Service) DeletePipeline(ctx context.Context, realm, name string) error + func (s *Service) DeleteUserBlock(ctx context.Context, realm, name string) error + func (s *Service) GetBlock(_, blockType string) (*blocks.Info, error) + func (s *Service) GetFlow(ctx context.Context, realm, name string) (*FlowView, error) + func (s *Service) GetPipeline(ctx context.Context, realm, name string) (*PipelineView, error) + func (s *Service) GetUserBlock(ctx context.Context, realm, name string) (*UserBlockView, error) + func (s *Service) HasBuiltInBlock(blockType string) bool + func (s *Service) ListBlocks(_ string) []blocks.Info + func (s *Service) ListFlows(ctx context.Context, realm string) ([]FlowView, error) + func (s *Service) ListPipelines(ctx context.Context, realm string) ([]string, error) + func (s *Service) ListUserBlocks(ctx context.Context, realm string) ([]UserBlockView, error) + func (s *Service) Manager() *flow.Manager + func (s *Service) MarkRunningFlowsStopped(ctx context.Context) + func (s *Service) RehydrateAutoRestart(ctx context.Context) error + func (s *Service) ReloadFlow(ctx context.Context, realm, name string) (*FlowView, error) + func (s *Service) RestartFlowInstance(ctx context.Context, realm string, realmID int16, name string) (*FlowView, error) + func (s *Service) UpdateFlowConfig(ctx context.Context, realm, name string, config json.RawMessage) (*FlowView, error) + func (s *Service) UpdatePipeline(ctx context.Context, realm, name string, definition []byte) (*PipelineView, error) + func (s *Service) UpdateUserBlock(ctx context.Context, realm, name, blockType string, ...) (*UserBlockView, error) + type UserBlockView struct + BlockType string + ConfigSchema json.RawMessage + CreatedAt time.Time + Name string + Source json.RawMessage + UpdatedAt time.Time
Go to main page