diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-18 17:26:42 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2021-08-18 17:26:42 +0300 |
| commit | 324407b3e2d779143be65872993c4d091abb1d38 (patch) | |
| tree | e6f0bd64241ab2d4dc05809128c8e8d7d74cbcc4 /common/pubsub/interface.go | |
| parent | a5435be8ab58bd23f1c2d3afd4484dd1d86b6002 (diff) | |
| parent | eb70b89cb2f23ccd44b91bbcac7438a05a40c801 (diff) | |
#764: feat(stat): `job` plugin drivers statistic
#764: feat(stat): `job` plugin drivers statistic
Diffstat (limited to 'common/pubsub/interface.go')
| -rw-r--r-- | common/pubsub/interface.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/common/pubsub/interface.go b/common/pubsub/interface.go index 06252d70..5b69d577 100644 --- a/common/pubsub/interface.go +++ b/common/pubsub/interface.go @@ -1,5 +1,7 @@ package pubsub +import "context" + /* This interface is in BETA. It might be changed. */ @@ -45,7 +47,7 @@ type Publisher interface { // Reader interface should return next message type Reader interface { - Next() (*Message, error) + Next(ctx context.Context) (*Message, error) } // Constructor is a special pub-sub interface made to return a constructed PubSub type |