diff options
Diffstat (limited to 'app/cluster_handlers.go')
| -rw-r--r-- | app/cluster_handlers.go | 50 |
1 files changed, 25 insertions, 25 deletions
diff --git a/app/cluster_handlers.go b/app/cluster_handlers.go index 892bf00d3..f8bd8fe0e 100644 --- a/app/cluster_handlers.go +++ b/app/cluster_handlers.go @@ -10,17 +10,17 @@ import ( "github.com/mattermost/platform/model" ) -func RegisterAllClusterMessageHandlers() { +func (a *App) RegisterAllClusterMessageHandlers() { einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_PUBLISH, ClusterPublishHandler) einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_UPDATE_STATUS, ClusterUpdateStatusHandler) - einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_ALL_CACHES, ClusterInvalidateAllCachesHandler) - einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_WEBHOOK, ClusterInvalidateCacheForWebhookHandler) - einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_POSTS, ClusterInvalidateCacheForChannelPostsHandler) - einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_MEMBERS_NOTIFY_PROPS, ClusterInvalidateCacheForChannelMembersNotifyPropHandler) - einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_MEMBERS, ClusterInvalidateCacheForChannelMembersHandler) - einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_BY_NAME, ClusterInvalidateCacheForChannelByNameHandler) - einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL, ClusterInvalidateCacheForChannelHandler) - einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_USER, ClusterInvalidateCacheForUserHandler) + einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_ALL_CACHES, a.ClusterInvalidateAllCachesHandler) + einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_WEBHOOK, a.ClusterInvalidateCacheForWebhookHandler) + einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_POSTS, a.ClusterInvalidateCacheForChannelPostsHandler) + einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_MEMBERS_NOTIFY_PROPS, a.ClusterInvalidateCacheForChannelMembersNotifyPropHandler) + einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_MEMBERS, a.ClusterInvalidateCacheForChannelMembersHandler) + einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_BY_NAME, a.ClusterInvalidateCacheForChannelByNameHandler) + einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL, a.ClusterInvalidateCacheForChannelHandler) + einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_USER, a.ClusterInvalidateCacheForUserHandler) einterfaces.GetClusterInterface().RegisterClusterMessageHandler(model.CLUSTER_EVENT_CLEAR_SESSION_CACHE_FOR_USER, ClusterClearSessionCacheForUserHandler) } @@ -35,36 +35,36 @@ func ClusterUpdateStatusHandler(msg *model.ClusterMessage) { AddStatusCacheSkipClusterSend(status) } -func ClusterInvalidateAllCachesHandler(msg *model.ClusterMessage) { - InvalidateAllCachesSkipSend() +func (a *App) ClusterInvalidateAllCachesHandler(msg *model.ClusterMessage) { + a.InvalidateAllCachesSkipSend() } -func ClusterInvalidateCacheForWebhookHandler(msg *model.ClusterMessage) { - InvalidateCacheForWebhookSkipClusterSend(msg.Data) +func (a *App) ClusterInvalidateCacheForWebhookHandler(msg *model.ClusterMessage) { + a.InvalidateCacheForWebhookSkipClusterSend(msg.Data) } -func ClusterInvalidateCacheForChannelPostsHandler(msg *model.ClusterMessage) { - InvalidateCacheForChannelPostsSkipClusterSend(msg.Data) +func (a *App) ClusterInvalidateCacheForChannelPostsHandler(msg *model.ClusterMessage) { + a.InvalidateCacheForChannelPostsSkipClusterSend(msg.Data) } -func ClusterInvalidateCacheForChannelMembersNotifyPropHandler(msg *model.ClusterMessage) { - InvalidateCacheForChannelMembersNotifyPropsSkipClusterSend(msg.Data) +func (a *App) ClusterInvalidateCacheForChannelMembersNotifyPropHandler(msg *model.ClusterMessage) { + a.InvalidateCacheForChannelMembersNotifyPropsSkipClusterSend(msg.Data) } -func ClusterInvalidateCacheForChannelMembersHandler(msg *model.ClusterMessage) { - InvalidateCacheForChannelMembersSkipClusterSend(msg.Data) +func (a *App) ClusterInvalidateCacheForChannelMembersHandler(msg *model.ClusterMessage) { + a.InvalidateCacheForChannelMembersSkipClusterSend(msg.Data) } -func ClusterInvalidateCacheForChannelByNameHandler(msg *model.ClusterMessage) { - InvalidateCacheForChannelByNameSkipClusterSend(msg.Props["id"], msg.Props["name"]) +func (a *App) ClusterInvalidateCacheForChannelByNameHandler(msg *model.ClusterMessage) { + a.InvalidateCacheForChannelByNameSkipClusterSend(msg.Props["id"], msg.Props["name"]) } -func ClusterInvalidateCacheForChannelHandler(msg *model.ClusterMessage) { - InvalidateCacheForChannelSkipClusterSend(msg.Data) +func (a *App) ClusterInvalidateCacheForChannelHandler(msg *model.ClusterMessage) { + a.InvalidateCacheForChannelSkipClusterSend(msg.Data) } -func ClusterInvalidateCacheForUserHandler(msg *model.ClusterMessage) { - InvalidateCacheForUserSkipClusterSend(msg.Data) +func (a *App) ClusterInvalidateCacheForUserHandler(msg *model.ClusterMessage) { + a.InvalidateCacheForUserSkipClusterSend(msg.Data) } func ClusterClearSessionCacheForUserHandler(msg *model.ClusterMessage) { |