Documentation
¶
Index ¶
- func WithEphemeralStorage() ephemeralStorage
- type Client
- func (c *Client) CancelWorkflowInstance(ctx context.Context, instanceID string) error
- func (c *Client) CompleteUserTask(ctx context.Context, owner string, trackingID string, newVars model.Vars) error
- func (c *Client) Dial(natsURL string, opts ...nats.Option) error
- func (c *Client) GetServerInstanceStats(ctx context.Context) (*model.WorkflowStats, error)
- func (c *Client) GetUserTask(ctx context.Context, owner string, trackingID string) (*model.GetUserTaskResponse, model.Vars, error)
- func (c *Client) GetWorkflowInstanceStatus(ctx context.Context, id string) ([]*model.WorkflowState, error)
- func (c *Client) LaunchWorkflow(ctx context.Context, workflowName string, mvars model.Vars) (string, error)
- func (c *Client) ListUserTaskIDs(ctx context.Context, owner string) (*model.UserTasks, error)
- func (c *Client) ListWorkflowInstance(ctx context.Context, name string) ([]*model.ListWorkflowInstanceResult, error)
- func (c *Client) ListWorkflows(ctx context.Context) ([]*model.ListWorkflowResult, error)
- func (c *Client) Listen(ctx context.Context) error
- func (c *Client) LoadBPMNWorkflowFromBytes(ctx context.Context, name string, b []byte) (string, error)
- func (c *Client) RegisterMessageSender(ctx context.Context, workflowName string, messageName string, sender SenderFn) error
- func (c *Client) RegisterServiceTask(ctx context.Context, taskName string, fn ServiceFn) error
- func (c *Client) RegisterWorkflowInstanceComplete(fn chan *model.WorkflowInstanceComplete)
- func (c *Client) SendMessage(ctx context.Context, workflowInstanceID string, name string, key any, ...) error
- type JobClient
- type MessageClient
- type Option
- type SenderFn
- type ServiceFn
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithEphemeralStorage ¶ added in v0.1.175
func WithEphemeralStorage() ephemeralStorage
Types ¶
type Client ¶
type Client struct {
SvcTasks map[string]ServiceFn
MsgSender map[string]SenderFn
// contains filtered or unexported fields
}
func (*Client) CancelWorkflowInstance ¶
func (*Client) CompleteUserTask ¶
func (*Client) GetServerInstanceStats ¶ added in v0.1.134
func (*Client) GetUserTask ¶ added in v0.1.88
func (*Client) GetWorkflowInstanceStatus ¶
func (*Client) LaunchWorkflow ¶
func (*Client) ListUserTaskIDs ¶ added in v0.1.86
func (*Client) ListWorkflowInstance ¶
func (*Client) ListWorkflows ¶
func (*Client) LoadBPMNWorkflowFromBytes ¶
func (*Client) RegisterMessageSender ¶
func (*Client) RegisterServiceTask ¶
func (*Client) RegisterWorkflowInstanceComplete ¶ added in v0.1.66
func (c *Client) RegisterWorkflowInstanceComplete(fn chan *model.WorkflowInstanceComplete)
type JobClient ¶ added in v1.0.271
type JobClient struct {
// contains filtered or unexported fields
}
type MessageClient ¶ added in v1.0.271
type MessageClient struct {
// contains filtered or unexported fields
}
func (*MessageClient) Log ¶ added in v1.0.271
func (c *MessageClient) Log(ctx context.Context, severity messages.WorkflowLogLevel, code int32, message string, attrs map[string]string) error
func (*MessageClient) SendMessage ¶ added in v1.0.271
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.