Versions in this module Expand all Collapse all v0 v0.1.0 Sep 15, 2023 Changes in this version + func HandleActionWrapper(ctx context.Context, conn db.Conn, thread *db.Thread, isAsyncAction bool, ...) error + type ArgoClient struct + func NewArgoClient(ctx context.Context, ac *config.ArgoConf, wfs []*config.Workflow) (*ArgoClient, error) + func (ac *ArgoClient) HandleAction(ctx context.Context, conn db.Conn, thread *db.Thread) error + func (ac *ArgoClient) SubmitWorkflow(ctx context.Context, wfId string, wfUuid uuid.UUID, priority int) error + type ArgoWorkflow struct + func ArgoWorkflowFromWorkflow(wf *config.Workflow) (*ArgoWorkflow, error) + func (awf *ArgoWorkflow) SubmitWorkflow(ctx context.Context, ac *ArgoClient, wfUuid uuid.UUID, priority int) error + type Handler struct + func (h *Handler) GetName() string + func (h *Handler) Notify() + func (h *Handler) NotifyNow() + func (h *Handler) Run(ctx context.Context, conn db.Conn) error + func (h *Handler) Start(ctx context.Context, dbConf *db.ConnectConfig) error + type HandlerClient interface + HandleAction func(ctx context.Context, conn db.Conn, thread *db.Thread) error + type PgConductor struct + DbConfig *db.ConnectConfig + InstanceName string + S3 *s3.SwoopS3 + SwoopConfig *config.SwoopConfig + func (c *PgConductor) AddFlags(fs *pflag.FlagSet) + func (c *PgConductor) NewHandlerFromConfig(ctx context.Context, conf *config.Handler) (*Handler, error) + func (c *PgConductor) Run(ctx context.Context, cancel context.CancelFunc) error + func (c *PgConductor) SignalHandler(signalChan <-chan os.Signal, ctx context.Context, cancel context.CancelFunc)