services

Documentation

Index

• type CompleteJobProcessorFunc
• type EventProcessorFunc
• type MessageCompleteProcessorFunc
• type NatsService
  • func NewNatsService(log *zap.Logger, conn common.NatsConn, storageType nats.StorageType, ...) (*NatsService, error)
  • func (s *NatsService) AwaitMsg(ctx context.Context, state *model.WorkflowState) error
  • func (s *NatsService) CloseUserTask(ctx context.Context, trackingID string) 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, state model.CancellationState, ...) error
  • func (s *NatsService) GetJob(_ context.Context, trackingID string) (*model.WorkflowState, error)
  • func (s *NatsService) GetLatestVersion(_ context.Context, workflowName string) (string, error)
  • func (s *NatsService) GetUserTaskIDs(ctx context.Context, owner string) (*model.UserTasks, error)
  • func (s *NatsService) GetWorkflow(_ context.Context, workflowId string) (*model.Workflow, error)
  • func (s *NatsService) GetWorkflowInstance(_ context.Context, workflowInstanceId string) (*model.WorkflowInstance, error)
  • func (s *NatsService) GetWorkflowInstanceStatus(_ context.Context, id string) (*model.WorkflowInstanceStatus, error)
  • func (s *NatsService) ListWorkflowInstance(_ context.Context, workflowName string) (chan *model.ListWorkflowInstanceResult, chan error)
  • func (s *NatsService) ListWorkflows(_ context.Context) (chan *model.ListWorkflowResult, chan error)
  • func (s *NatsService) OpenUserTask(ctx context.Context, owner string, id string) error
  • func (s *NatsService) OwnerId(name string) (string, error)
  • func (s *NatsService) OwnerName(id string) (string, error)
  • func (s *NatsService) PublishMessage(_ context.Context, workflowInstanceID string, name string, key string, ...) error
  • func (s *NatsService) PublishWorkflowState(ctx context.Context, stateName string, state *model.WorkflowState, embargo int) 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)
  • func (s *NatsService) WorkflowStats() *model.WorkflowStats

Types

type CompleteJobProcessorFunc

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

type EventProcessorFunc

type EventProcessorFunc func(ctx context.Context, traversal *model.WorkflowState, traverseOnly bool) error

type MessageCompleteProcessorFunc

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

type NatsService

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

func NewNatsService

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

func (*NatsService) AwaitMsg

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

func (*NatsService) CloseUserTask

func (s *NatsService) CloseUserTask(ctx context.Context, trackingID string) error

func (*NatsService) Conn

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

func (*NatsService) CreateJob

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

func (*NatsService) CreateWorkflowInstance

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

func (*NatsService) DestroyWorkflowInstance

func (s *NatsService) DestroyWorkflowInstance(ctx context.Context, workflowInstanceId string, state model.CancellationState, wfError *model.Error) error

func (*NatsService) GetJob

func (s *NatsService) GetJob(_ context.Context, trackingID string) (*model.WorkflowState, error)

func (*NatsService) GetLatestVersion

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

GetLatestVersion queries the workflow versions table for the latest entry

func (*NatsService) GetUserTaskIDs

func (s *NatsService) GetUserTaskIDs(ctx context.Context, owner string) (*model.UserTasks, error)

func (*NatsService) GetWorkflow

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

func (*NatsService) GetWorkflowInstance

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

func (*NatsService) GetWorkflowInstanceStatus

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

func (*NatsService) ListWorkflowInstance

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

func (*NatsService) ListWorkflows

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

func (*NatsService) OpenUserTask

func (s *NatsService) OpenUserTask(ctx context.Context, owner string, id string) error

func (*NatsService) OwnerId

func (s *NatsService) OwnerId(name string) (string, error)

func (*NatsService) OwnerName

func (s *NatsService) OwnerName(id string) (string, error)

func (*NatsService) PublishMessage

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

func (*NatsService) PublishWorkflowState

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

func (*NatsService) SetCompleteJobProcessor

func (s *NatsService) SetCompleteJobProcessor(processor CompleteJobProcessorFunc)

func (*NatsService) SetEventProcessor

func (s *NatsService) SetEventProcessor(processor EventProcessorFunc)

func (*NatsService) SetMessageCompleteProcessor

func (s *NatsService) SetMessageCompleteProcessor(processor MessageCompleteProcessorFunc)

func (*NatsService) Shutdown

func (s *NatsService) Shutdown()

func (*NatsService) StartProcessing

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

func (*NatsService) StoreWorkflow

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

func (*NatsService) WorkflowStats

func (s *NatsService) WorkflowStats() *model.WorkflowStats