dispatcher

Documentation

Index

• func DispatchAPIKeyCreate(h hash.Hash, k key.APIKeyType) error
• func DispatchAPIKeyDelete(h hash.Hash, k key.APIKeyType) error
• func DispatchAuthKeyCreate(h hash.Hash, k key.AuthKeyType) error
• func DispatchAuthKeyDelete(h hash.Hash, k key.AuthKeyType) error
• func DispatchLocalDelivery(h hash.Hash, header *message.Header, msgID string) error
• func DispatchRemoteDelivery(h hash.Hash, header *message.Header, msgID string) error
• func DispatchWebhookCreate(h hash.Hash, wh webhook.Type) error
• func DispatchWebhookDelete(h hash.Hash, wh webhook.Type) error
• func DispatchWebhookUpdate(h hash.Hash, wh webhook.Type) error
• func InitDispatcher(c int)
• func Work(w webhook.Type, payload interface{})

Functions

func DispatchAPIKeyCreate

func DispatchAPIKeyCreate(h hash.Hash, k key.APIKeyType) error

DispatchAPIKeyCreate dispatches event

func DispatchAPIKeyDelete

func DispatchAPIKeyDelete(h hash.Hash, k key.APIKeyType) error

DispatchAPIKeyDelete dispatches event

func DispatchAuthKeyCreate

func DispatchAuthKeyCreate(h hash.Hash, k key.AuthKeyType) error

DispatchAuthKeyCreate dispatches event

func DispatchAuthKeyDelete

func DispatchAuthKeyDelete(h hash.Hash, k key.AuthKeyType) error

DispatchAuthKeyDelete dispatches event

func DispatchLocalDelivery

func DispatchLocalDelivery(h hash.Hash, header *message.Header, msgID string) error

DispatchLocalDelivery dispatches event

func DispatchRemoteDelivery

func DispatchRemoteDelivery(h hash.Hash, header *message.Header, msgID string) error

DispatchRemoteDelivery dispatches event

func DispatchWebhookCreate

func DispatchWebhookCreate(h hash.Hash, wh webhook.Type) error

DispatchWebhookCreate dispatches event

func DispatchWebhookDelete

func DispatchWebhookDelete(h hash.Hash, wh webhook.Type) error

DispatchWebhookDelete dispatches event

func DispatchWebhookUpdate

func DispatchWebhookUpdate(h hash.Hash, wh webhook.Type) error

DispatchWebhookUpdate dispatches event

func InitDispatcher

func InitDispatcher(c int)

InitDispatcher initializes the dispatcher system with the given number of workers

func Work

func Work(w webhook.Type, payload interface{})

Work is the main function that will get dispatched as a job. It will do the actual work of sending data