temporal

Documentation

Index

• type TemporalService
  • func NewTemporalService() TemporalService

Types

type TemporalService

type TemporalService interface {
	Connect(ctx context.Context, params models.ConnectClientParams) error
	ExecuteScheduledWorkflow(ctx context.Context, params models.ExecuteWorkflowWithScheduleParams) (models.ScheduledWorkflowResponse, error)
	ExecuteAsyncWorkflow(ctx context.Context, params models.ExecuteWorkflowParams) (models.WorkflowResponse, error)
	ExecuteSyncWorkflow(ctx context.Context, params models.ExecuteWorkflowParams) (models.WorkflowResponse, error)
	ListWorkflows(ctx context.Context, params models.ListWorkflowsParams) (models.ListWorkflowsResponse, error)
	GetWorkflowDetails(ctx context.Context, params models.GetWorkflowDetailsParams) (models.WorkflowDetailsResponse, error)
	TerminateWorkflow(ctx context.Context, params models.TerminateWorkflowParams) error
	CancelWorkflow(ctx context.Context, params models.CancelWorkflowParams) error
	SignalWorkflow(ctx context.Context, params models.SignalWorkflowParams) error
	QueryWorkflow(ctx context.Context, params models.QueryWorkflowParams) (models.QueryWorkflowResponse, error)
	QuerySchedule(ctx context.Context, params models.QueryScheduleParams) (models.QueryScheduleResponse, error)
	GetNewWorker(ctx context.Context, params models.NewWorkerParams) (worker.Worker, error)
	Close(ctx context.Context)
}

func NewTemporalService

func NewTemporalService() TemporalService