summaryrefslogtreecommitdiff
path: root/internal/processing/streaming/streaming.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/processing/streaming/streaming.go')
-rw-r--r--internal/processing/streaming/streaming.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/internal/processing/streaming/streaming.go b/internal/processing/streaming/streaming.go
index de75b8f27..f349a655a 100644
--- a/internal/processing/streaming/streaming.go
+++ b/internal/processing/streaming/streaming.go
@@ -1,6 +1,7 @@
package streaming
import (
+ "context"
"sync"
"github.com/sirupsen/logrus"
@@ -17,9 +18,9 @@ import (
// Processor wraps a bunch of functions for processing streaming.
type Processor interface {
// AuthorizeStreamingRequest returns an oauth2 token info in response to an access token query from the streaming API
- AuthorizeStreamingRequest(accessToken string) (*gtsmodel.Account, error)
+ AuthorizeStreamingRequest(ctx context.Context, accessToken string) (*gtsmodel.Account, error)
// OpenStreamForAccount returns a new Stream for the given account, which will contain a channel for passing messages back to the caller.
- OpenStreamForAccount(account *gtsmodel.Account, streamType string) (*gtsmodel.Stream, gtserror.WithCode)
+ OpenStreamForAccount(ctx context.Context, account *gtsmodel.Account, streamType string) (*gtsmodel.Stream, gtserror.WithCode)
// StreamStatusToAccount streams the given status to any open, appropriate streams belonging to the given account.
StreamStatusToAccount(s *apimodel.Status, account *gtsmodel.Account) error
// StreamNotificationToAccount streams the given notification to any open, appropriate streams belonging to the given account.