client

package

v0.0.5 Latest Latest Go to latest Published: Dec 15, 2024 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/tuannh982/simple-workflow-go

Links

Open Source Insights

Documentation ¶

Index ¶

func AwaitWorkflowResult[T any, R any](ctx context.Context, backend backend.Backend, workflow types.Workflow[T, R], ...) (*R, error, error)
func GetWorkflowResult[T any, R any](ctx context.Context, backend backend.Backend, workflow types.Workflow[T, R], ...) (*dto.WorkflowExecutionResult, error)
func ScheduleWorkflow[T any, R any](ctx context.Context, backend backend.Backend, workflow types.Workflow[T, R], ...) error
func ScheduleWorkflowUnsafe(ctx context.Context, backend backend.Backend, workflowName string, input any, ...) error
func SignalWorkflow(ctx context.Context, backend backend.Backend, workflowID string, ...) error
type WorkflowScheduleOptions

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AwaitWorkflowResult ¶

func AwaitWorkflowResult[T any, R any](
	ctx context.Context,
	backend backend.Backend,
	workflow types.Workflow[T, R],
	workflowID string,
) (*R, error, error)

func GetWorkflowResult ¶

func GetWorkflowResult[T any, R any](
	ctx context.Context,
	backend backend.Backend,
	workflow types.Workflow[T, R],
	workflowID string,
) (*dto.WorkflowExecutionResult, error)

func ScheduleWorkflow ¶

func ScheduleWorkflow[T any, R any](
	ctx context.Context,
	backend backend.Backend,
	workflow types.Workflow[T, R],
	input *T,
	options WorkflowScheduleOptions,
) error

func ScheduleWorkflowUnsafe ¶ added in v0.0.5

func ScheduleWorkflowUnsafe(
	ctx context.Context,
	backend backend.Backend,
	workflowName string,
	input any,
	options WorkflowScheduleOptions,
) error

func SignalWorkflow ¶

func SignalWorkflow(
	ctx context.Context,
	backend backend.Backend,
	workflowID string,
	eventName string,
	eventInput []byte,
) error

Types ¶

type WorkflowScheduleOptions ¶

type WorkflowScheduleOptions struct {
	WorkflowID               string
	Version                  string
	ScheduleToStartTimestamp *int64
}

Source Files ¶

View all Source files

client.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL