node

Documentation

Index

• Constants
• type AutomationNotification
  • func NewAutomationNotification(taskSvc task.Service, userSvc user.Service, ...) (*AutomationNotification, error)
  • func (n *AutomationNotification) IsNotification(ctx context.Context, wf workflow.Workflow, instanceId int, nodeId string) (bool, map[string]interface{}, error)
  • func (n *AutomationNotification) Send(ctx context.Context, nOrder order.Order, params notification.NotifyParams) (bool, error)
• type MyNotifications
• type UserNotification
  • func NewUserNotification(engineSvc engineSvc.Service, templateSvc templateSvc.Service, ...) (*UserNotification, error)
  • func (n *UserNotification) IsNotification(ctx context.Context, wf workflow.Workflow, instanceId int, nodeId string) (bool, map[string]interface{}, error)
  • func (n *UserNotification) Send(ctx context.Context, nOrder order.Order, params notification.NotifyParams) (bool, error)

Constants

const (
	// ProcessEndSend 流程结束后发送
	ProcessEndSend = 1
	// ProcessNowSend 当前节点通过直接发送
	ProcessNowSend = 2
)

Types

type AutomationNotification

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

func NewAutomationNotification

func NewAutomationNotification(taskSvc task.Service, userSvc user.Service, integrations []method.NotifyIntegration) (*AutomationNotification, error)

func (*AutomationNotification) IsNotification

func (n *AutomationNotification) IsNotification(ctx context.Context, wf workflow.Workflow, instanceId int,
	nodeId string) (bool, map[string]interface{}, error)

func (*AutomationNotification) Send

func (n *AutomationNotification) Send(ctx context.Context, nOrder order.Order,
	params notification.NotifyParams) (bool, error)

type MyNotifications

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

type UserNotification

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

func NewUserNotification

func NewUserNotification(engineSvc engineSvc.Service, templateSvc templateSvc.Service, orderSvc order.Service,
	userSvc user.Service, taskSvc task.Service, integrations []method.NotifyIntegration) (*UserNotification, error)

func (*UserNotification) IsNotification

func (n *UserNotification) IsNotification(ctx context.Context, wf workflow.Workflow, instanceId int,
	nodeId string) (bool, map[string]interface{}, error)

func (*UserNotification) Send

func (n *UserNotification) Send(ctx context.Context, nOrder order.Order, params notification.NotifyParams) (bool, error)