service

Documentation

Index

• type Service
  • func New(cfg *types.Config, logger *slog.Logger) (*Service, error)
  • func (svc *Service) GetResult(flowName string, sessID string) (map[string]*flow.ExecResult, error)
  • func (svc *Service) NewFlow(flowName string) (*flow.Flow, error)
  • func (svc *Service) RegisterFlows(mux *asynq.ServeMux, flows ...*flow.Flow) error
  • func (svc *Service) RegisterFlowsWithDefinitor(mux *asynq.ServeMux, flows map[string]flow.Definitor) error
  • func (svc *Service) Submit(flowName string, body []byte) (string, error)

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

func New

func New(cfg *types.Config, logger *slog.Logger) (*Service, error)

func (*Service) GetResult

func (svc *Service) GetResult(flowName string, sessID string) (map[string]*flow.ExecResult, error)

func (*Service) NewFlow

func (svc *Service) NewFlow(flowName string) (*flow.Flow, error)

func (*Service) RegisterFlows

func (svc *Service) RegisterFlows(mux *asynq.ServeMux, flows ...*flow.Flow) error

func (*Service) RegisterFlowsWithDefinitor

func (svc *Service) RegisterFlowsWithDefinitor(mux *asynq.ServeMux, flows map[string]flow.Definitor) error

func (*Service) Submit

func (svc *Service) Submit(flowName string, body []byte) (string, error)

submit a flow task