handler

Documentation

Index

• func AddHandleTask(rc redis.Conn, contactID flows.ContactID, task *queue.Task) error
• func NewExpirationEvent(orgID models.OrgID, contactID flows.ContactID, sessionID models.SessionID, ...) *queue.Task
• func NewTimeoutEvent(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 NewExpirationEvent

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

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

func NewTimeoutEvent

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

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