handler

Documentation

Index

• func AddHandleTask(rc redis.Conn, contactID flows.ContactID, task *queue.Task) error
• func NewExpirationTask(orgID models.OrgID, contactID flows.ContactID, sessionID models.SessionID, ...) *queue.Task
• func NewTimeoutTask(orgID models.OrgID, contactID flows.ContactID, sessionID models.SessionID, ...) *queue.Task

Functions

func AddHandleTask

func AddHandleTask(rc redis.Conn, contactID flows.ContactID, task *queue.Task) error

AddHandleTask adds a single task for the passed in contact

func NewExpirationTask

func NewExpirationTask(orgID models.OrgID, contactID flows.ContactID, sessionID models.SessionID, runID models.FlowRunID, time time.Time) *queue.Task

NewExpirationTask creates a new event task for the passed in expiration event

func NewTimeoutTask

func NewTimeoutTask(orgID models.OrgID, contactID flows.ContactID, sessionID models.SessionID, time time.Time) *queue.Task

NewTimeoutTask creates a new event task for the passed in timeout event