client

Documentation

Index

• type ApiError
  • func (a ApiError) Error() string
• type Client
  • func New(log *zap.Logger, option ...Option) *Client
  • func (c *Client) CancelWorkflowInstance(ctx context.Context, instanceID string) error
  • func (c *Client) CompleteManualTask(ctx context.Context, trackingID string, newVars model.Vars) error
  • func (c *Client) CompleteServiceTask(ctx context.Context, trackingID string, newVars model.Vars) error
  • func (c *Client) CompleteUserTask(ctx context.Context, owner string, trackingID string, newVars model.Vars) error
  • func (c *Client) Dial(natsURL string) error
  • func (c *Client) GetUserTask(ctx context.Context, owner string, trackingID string) (*model.WorkflowState, 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(messageName string, sender senderFn)
  • func (c *Client) RegisterServiceTask(taskName string, fn serviceFn)
  • func (c *Client) RegisterWorkflowInstanceComplete(fn chan *model.WorkflowInstanceComplete)
  • func (c *Client) SendMessage(ctx context.Context, workflowInstanceID string, name string, key any, ...) error
• type Command
  • func (c *Command) SendMessage(ctx context.Context, name string, key any, vars model.Vars) error
• type EphemeralStorage
• type Option

Types

type ApiError

type ApiError struct {
	Code    int
	Message string
}

ApiError returns a GRPC error code and an error message

func (ApiError) Error

func (a ApiError) Error() string

type Client

type Client struct {
	SvcTasks map[string]serviceFn

	MsgSender map[string]senderFn
	// contains filtered or unexported fields
}

func New

func New(log *zap.Logger, option ...Option) *Client

func (*Client) CancelWorkflowInstance

func (c *Client) CancelWorkflowInstance(ctx context.Context, instanceID string) error

func (*Client) CompleteManualTask

func (c *Client) CompleteManualTask(ctx context.Context, trackingID string, newVars model.Vars) error

func (*Client) CompleteServiceTask

func (c *Client) CompleteServiceTask(ctx context.Context, trackingID string, newVars model.Vars) error

func (*Client) CompleteUserTask

func (c *Client) CompleteUserTask(ctx context.Context, owner string, trackingID string, newVars model.Vars) error

func (*Client) Dial

func (c *Client) Dial(natsURL string) error

func (*Client) GetUserTask

func (c *Client) GetUserTask(ctx context.Context, owner string, trackingID string) (*model.WorkflowState, error)

func (*Client) GetWorkflowInstanceStatus

func (c *Client) GetWorkflowInstanceStatus(ctx context.Context, id string) ([]*model.WorkflowState, error)

func (*Client) LaunchWorkflow

func (c *Client) LaunchWorkflow(ctx context.Context, workflowName string, mvars model.Vars) (string, error)

func (*Client) ListUserTaskIDs

func (c *Client) ListUserTaskIDs(ctx context.Context, owner string) (*model.UserTasks, error)

func (*Client) ListWorkflowInstance

func (c *Client) ListWorkflowInstance(ctx context.Context, name string) ([]*model.ListWorkflowInstanceResult, error)

func (*Client) ListWorkflows

func (c *Client) ListWorkflows(ctx context.Context) ([]*model.ListWorkflowResult, error)

func (*Client) Listen

func (c *Client) Listen(ctx context.Context) error

func (*Client) LoadBPMNWorkflowFromBytes

func (c *Client) LoadBPMNWorkflowFromBytes(ctx context.Context, name string, b []byte) (string, error)

func (*Client) RegisterMessageSender

func (c *Client) RegisterMessageSender(messageName string, sender senderFn)

func (*Client) RegisterServiceTask

func (c *Client) RegisterServiceTask(taskName string, fn serviceFn)

func (*Client) RegisterWorkflowInstanceComplete

func (c *Client) RegisterWorkflowInstanceComplete(fn chan *model.WorkflowInstanceComplete)

func (*Client) SendMessage

func (c *Client) SendMessage(ctx context.Context, workflowInstanceID string, name string, key any, mvars model.Vars) error

type Command

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

func (*Command) SendMessage

func (c *Command) SendMessage(ctx context.Context, name string, key any, vars model.Vars) error

type EphemeralStorage

type EphemeralStorage struct {
	Option
}

type Option

type Option interface {
	// contains filtered or unexported methods
}