events

Dec 3, 2025

Changes in this version

type ActionPublisher

+ func (p *ActionPublisher) PublishLinkOpened(ctx context.Context, tenantID, sessionID, workflowID, recipientID string, ...) error

Dec 2, 2025

Changes in this version

type ActionPublisher

+ func (p *ActionPublisher) PublishDelivered(ctx context.Context, tenantID, sessionID, workflowID, recipientID string, ...) error

+ func (p *ActionPublisher) PublishSent(ctx context.Context, tenantID, sessionID, workflowID, recipientID string, ...) error

Dec 2, 2025

Changes in this version

type ActionExecutionPayload

+ NodeID string

+ NodeName string

Dec 2, 2025

Changes in this version

type WorkflowEventPayload

+ NodeID string

+ NodeName string

Dec 1, 2025

Changes in this version

type ActionExecutionPayload

+ ActionType ActionChannel

+ ExecutionStatus string

+ OriginalLink string

+ TrackingLink string

type WorkflowEventPayload

+ ActionLabel string

Dec 1, 2025

Changes in this version

type EventType

+ const EventTypeCompleted

+ const EventTypeStarted

type Publisher

+ func (p *Publisher) PublishWorkflowExited(ctx context.Context, tenantID, workflowID, workflowName, sessionID string, ...) error

type WorkflowEventPayload

+ ExecutionStatus string

Dec 1, 2025

Changes in this version

+ type ActionChannel string

+ const ActionChannelEmail

+ const ActionChannelLINE

+ const ActionChannelSMS

+ const ActionChannelSlack

+ type ActionExecutionPayload struct

+ ActionID string

+ ActionKey string

+ ActionLabel string

+ Channel ActionChannel

+ DeliveryStatus DeliveryStatus

+ ErrorMessage string

+ EventTime time.Time

+ HasTrackingLink bool

+ MessageContent string

+ ProviderResponse map[string]interface{}

+ RecipientID string

+ SessionID string

+ Status string

+ TenantID string

+ Timestamp time.Time

+ WorkflowID string

+ func (p *ActionExecutionPayload) ToJSON() ([]byte, error)

+ type ActionPublisher struct

+ func NewActionPublisher(brokers []string) *ActionPublisher

+ func NewActionPublisherWithAuth(config PublisherConfig) *ActionPublisher

+ func (p *ActionPublisher) Close() error

+ func (p *ActionPublisher) Publish(ctx context.Context, payload *ActionExecutionPayload) error

+ func (p *ActionPublisher) PublishFailed(ctx context.Context, tenantID, sessionID, workflowID, recipientID string, ...) error

+ func (p *ActionPublisher) PublishSuccess(ctx context.Context, tenantID, sessionID, workflowID, recipientID string, ...) error

Dec 1, 2025

Changes in this version

type WorkflowNotificationPayload

+ TenantID string

Dec 1, 2025

Changes in this version

+ func GetWorkflowActionsTopic() string

+ func GetWorkflowExecutionsTopic() string

+ func GetWorkflowNodesTopic() string

Nov 25, 2025

Changes in this version

type WorkflowNotificationPayload

+ SessionID string

type WorkflowRecipientPayload

+ SessionID string

Nov 25, 2025

Changes in this version

+ func GetWorkflowNotificationsTopic() string

+ func GetWorkflowRecipientsTopic() string

+ type DeliveryStatus string

+ const DeliveryStatusBounced

+ const DeliveryStatusDelivered

+ const DeliveryStatusFailed

+ const DeliveryStatusSent

+ type NotificationChannel string

+ const NotificationChannelEmail

+ const NotificationChannelLINE

+ const NotificationChannelSMS

+ const NotificationChannelSlack

+ type NotificationPublisher struct

+ func NewNotificationPublisher(brokers []string) *NotificationPublisher

+ func NewNotificationPublisherWithAuth(config PublisherConfig) *NotificationPublisher

+ func (p *NotificationPublisher) Close() error

+ func (p *NotificationPublisher) Publish(ctx context.Context, payload *WorkflowNotificationPayload) error

+ func (p *NotificationPublisher) PublishFailed(ctx context.Context, executionID, workflowID, recipientID string, ...) error

+ func (p *NotificationPublisher) PublishSuccess(ctx context.Context, executionID, workflowID, recipientID string, ...) error

+ type RecipientEventType string

+ const RecipientEventTypeCompleted

+ const RecipientEventTypeExited

+ const RecipientEventTypeStarted

+ type RecipientPublisher struct

+ func NewRecipientPublisher(brokers []string) *RecipientPublisher

+ func NewRecipientPublisherWithAuth(config PublisherConfig) *RecipientPublisher

+ func (p *RecipientPublisher) Close() error

+ func (p *RecipientPublisher) Publish(ctx context.Context, payload *WorkflowRecipientPayload) error

+ func (p *RecipientPublisher) PublishCompleted(ctx context.Context, tenantID, workflowID string, ...) error

+ func (p *RecipientPublisher) PublishExited(ctx context.Context, tenantID, workflowID string, ...) error

+ func (p *RecipientPublisher) PublishStarted(ctx context.Context, tenantID, workflowID, workflowName string, ...) error

+ type WorkflowNotificationPayload struct

+ ActionID string

+ ActionKey string

+ ActionLabel string

+ Channel NotificationChannel

+ DeliveryStatus DeliveryStatus

+ ErrorMessage string

+ EventTime time.Time

+ ExecutionID string

+ HasTrackingLink bool

+ MessageContent string

+ ProviderResponse map[string]interface{}

+ RecipientID string

+ Status string

+ Timestamp time.Time

+ WorkflowID string

+ func (p *WorkflowNotificationPayload) ToJSON() ([]byte, error)

+ type WorkflowRecipientPayload struct

+ EventTime time.Time

+ EventType RecipientEventType

+ ExecutionID string

+ ExitReason string

+ RecipientID string

+ RecipientType string

+ TenantID string

+ Timestamp time.Time

+ WorkflowID string

+ WorkflowName string

+ func (p *WorkflowRecipientPayload) ToJSON() ([]byte, error)

Nov 25, 2025

Changes in this version

type Publisher

+ func NewPublisherWithAuth(config PublisherConfig) *Publisher

+ type PublisherConfig struct

+ Brokers []string

+ Password string

+ Username string

Nov 25, 2025

Changes in this version

+ const ActionIDContactEnrollmentTrigger

+ const ActionIDEmail

+ const ActionIDLine

+ const ActionIDLog

+ const ActionIDOrderEnrollmentTrigger

+ const ActionIDPointEnrollmentTrigger

+ const ActionIDQuery

+ const ActionIDSMS

+ const ActionIDSlack

+ const ActionIDTag

+ const ActionIDWait

+ const ActionIDWebhook

+ const RecipientTypeContacts

+ const RecipientTypeOrders

+ func GetWorkflowEventsTopic() string

+ type EventType string

+ const EventTypeEntered

+ const EventTypeExited

+ const EventTypeWorkflowCompleted

+ const EventTypeWorkflowFailed

+ const EventTypeWorkflowStarted

+ type Publisher struct

+ func NewPublisher(brokers []string) *Publisher

+ func (p *Publisher) Close() error

+ func (p *Publisher) Publish(ctx context.Context, event *WorkflowEventPayload) error

+ func (p *Publisher) PublishEntered(ctx context.Context, ...) error

+ func (p *Publisher) PublishExited(ctx context.Context, ...) error

+ func (p *Publisher) PublishExitedFailed(ctx context.Context, ...) error

+ func (p *Publisher) PublishExitedSuccess(ctx context.Context, ...) error

+ func (p *Publisher) PublishWorkflowCompleted(ctx context.Context, tenantID, workflowID, workflowName, sessionID string, ...) error

+ func (p *Publisher) PublishWorkflowFailed(ctx context.Context, tenantID, workflowID, workflowName, sessionID string, ...) error

+ func (p *Publisher) PublishWorkflowStarted(ctx context.Context, tenantID, workflowID, workflowName, sessionID string, ...) error

+ type RecipientType string

+ type WorkflowEventPayload struct

+ ActionID string

+ ActionKey string

+ ErrorMessage string

+ EventTime time.Time

+ EventType EventType

+ Payload map[string]interface{}

+ RecipientID string

+ RecipientType RecipientType

+ SessionID string

+ Status string

+ TaskID string

+ TenantID string

+ Timestamp time.Time

+ WorkflowID string

+ WorkflowName string

+ func (p *WorkflowEventPayload) ToJSON() ([]byte, error)