services

package

v0.1.73 Latest Latest Go to latest Published: Jun 29, 2022 License: MIT Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CompleteJobProcessorFunc func(ctx context.Context, jobId string, vars []byte) error

type EventProcessorFunc func(ctx context.Context, workflowInstanceId, elementId, traversalId string, vars []byte, traverseOnly bool) error

type MessageCompleteProcessorFunc func(ctx context.Context, state *model.WorkflowState) error

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

func NewNatsService(log *zap.Logger, conn common.NatsConn, storageType nats.StorageType, concurrency int) (*NatsService, error)

func (s *NatsService) AwaitMsg(ctx context.Context, state *model.WorkflowState) error

func (s *NatsService) Conn() common.NatsConn

func (s *NatsService) CreateJob(ctx context.Context, job *model.WorkflowState) (string, error)

func (s *NatsService) CreateWorkflowInstance(ctx context.Context, wfInstance *model.WorkflowInstance) (*model.WorkflowInstance, error)

func (s *NatsService) DestroyWorkflowInstance(ctx context.Context, workflowInstanceId string) error

func (s *NatsService) GetJob(ctx context.Context, id string) (*model.WorkflowState, error)

func (s *NatsService) GetLatestVersion(ctx context.Context, workflowName string) (string, error)

GetLatestVersion queries the workflow versions table for the latest entry

func (s *NatsService) GetWorkflow(ctx context.Context, workflowId string) (*model.Workflow, error)

func (s *NatsService) GetWorkflowInstance(ctx context.Context, workflowInstanceId string) (*model.WorkflowInstance, error)

func (s *NatsService) GetWorkflowInstanceStatus(ctx context.Context, id string) (*model.WorkflowInstanceStatus, error)

func (s *NatsService) ListWorkflowInstance(ctx context.Context, workflowName string) (chan *model.ListWorkflowInstanceResult, chan error)

func (s *NatsService) ListWorkflows(ctx context.Context) (chan *model.ListWorkflowResult, chan error)

func (s *NatsService) PublishMessage(ctx context.Context, workflowInstanceID string, name string, key string, vars []byte) error

func (s *NatsService) PublishWorkflowState(ctx context.Context, stateName string, state *model.WorkflowState) error

func (s *NatsService) SetCompleteJobProcessor(processor CompleteJobProcessorFunc)

func (s *NatsService) SetEventProcessor(processor EventProcessorFunc)

func (s *NatsService) SetMessageCompleteProcessor(processor MessageCompleteProcessorFunc)

func (s *NatsService) Shutdown()

func (s *NatsService) StartProcessing(ctx context.Context) error

func (s *NatsService) StoreWorkflow(ctx context.Context, wf *model.Workflow) (string, error)