service

Documentation

Index

• type FlowEditorService
  • func NewFlowEditorService(flowStore store.FlowStore) *FlowEditorService
  • func (s *FlowEditorService) CreateFlow(ctx context.Context, req *types.CreateFlowRequest) (*types.CreateFlowResponse, error)
  • func (s *FlowEditorService) UpdateFlow(ctx context.Context, req *types.CreateFlowRequest) (*types.CreateFlowResponse, error)
• type FlowQueryService
  • func NewFlowQueryService(flowStore store.FlowStore) *FlowQueryService
  • func (f *FlowQueryService) GetFlowByID(ctx context.Context, req *types.GetFlowByIDRequest) (*types.FlowResponse, error)
  • func (f *FlowQueryService) GetFlowByParam(ctx context.Context, req *types.GetFlowByParamRequest) (*types.FlowResponse, error)

Types

type FlowEditorService

type FlowEditorService struct {
	Store store.FlowStore
}

func NewFlowEditorService

func NewFlowEditorService(flowStore store.FlowStore) *FlowEditorService

func (*FlowEditorService) CreateFlow

func (s *FlowEditorService) CreateFlow(ctx context.Context, req *types.CreateFlowRequest) (*types.CreateFlowResponse, error)

func (*FlowEditorService) UpdateFlow

func (s *FlowEditorService) UpdateFlow(ctx context.Context, req *types.CreateFlowRequest) (*types.CreateFlowResponse, error)

type FlowQueryService

type FlowQueryService struct {
	Store store.FlowStore
}

func NewFlowQueryService

func NewFlowQueryService(flowStore store.FlowStore) *FlowQueryService

func (*FlowQueryService) GetFlowByID

func (f *FlowQueryService) GetFlowByID(ctx context.Context, req *types.GetFlowByIDRequest) (*types.FlowResponse, error)

func (*FlowQueryService) GetFlowByParam

func (f *FlowQueryService) GetFlowByParam(ctx context.Context, req *types.GetFlowByParamRequest) (*types.FlowResponse, error)