From e04b187702acb0c9908237a35b3a9857e2167b3f Mon Sep 17 00:00:00 2001 From: tobi <31960611+tsmethurst@users.noreply.github.com> Date: Mon, 4 Oct 2021 15:24:19 +0200 Subject: Refactor/tidy (#261) * tidy up streaming * cut down code duplication * test get followers/following * test streaming processor * fix some test models * add TimeMustParse * fix uri / url typo * make trace logging less verbose * make logging more consistent * disable quote on logging * remove context.Background * remove many extraneous mastodon references * regenerate swagger * don't log query on no rows result * log latency first for easier reading --- internal/stream/stream.go | 12 ++++++++++++ 1 file changed, 12 insertions(+) (limited to 'internal/stream') diff --git a/internal/stream/stream.go b/internal/stream/stream.go index 9d1d27d72..011b7dbe1 100644 --- a/internal/stream/stream.go +++ b/internal/stream/stream.go @@ -2,6 +2,18 @@ package stream import "sync" +// EventType models a type of stream event. +type EventType string + +const ( + // EventTypeNotification -- a user should be shown a notification + EventTypeNotification EventType = "notification" + // EventTypeUpdate -- a user should be shown an update in their timeline + EventTypeUpdate EventType = "update" + // EventTypeDelete -- something should be deleted from a user + EventTypeDelete EventType = "delete" +) + // StreamsForAccount is a wrapper for the multiple streams that one account can have running at the same time. // TODO: put a limit on this type StreamsForAccount struct { -- cgit v1.3