Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StreamingWorkflow ¶
func StreamingWorkflow(hatchet v1.HatchetClient) workflow.WorkflowDeclaration[StreamTaskInput, StreamTaskOutput]
Types ¶
type StreamTaskInput ¶
type StreamTaskInput struct{}
type StreamTaskOutput ¶
type StreamTaskOutput struct {
Message string `json:"message"`
}
func StreamTask ¶
func StreamTask(ctx worker.HatchetContext, input StreamTaskInput) (*StreamTaskOutput, error)
Source Files
Click to show internal directories.
Click to hide internal directories.