shad-go/pubsub
2022-03-15 23:49:56 +03:00
..
my_pubsub.go go fix old build tags. 2022-03-15 23:49:56 +03:00
pubsub.go go fix old build tags. 2022-03-15 23:49:56 +03:00
pubsub_example_test.go Add pubsub task 2020-03-26 17:42:29 +00:00
pubsub_test.go Fix linter 2020-04-02 22:25:04 +03:00
README.md Update README 2021-04-01 18:05:31 +03:00

pubsub

В этой задаче нужно написать простую шину событий работающую по принципу pub/sub.

В файле pubsub.go заданы интерфейсы PubSub/Subscription с подробным описанием всех методов.

Требования к системе:

  • На один топик может подписываться (и отписываться) множество подписчиков.
  • FIFO для сообщений, вы не должны терять их порядок.
  • Один медленный подписчик не должен тормозить остальных.
  • Метод Close должен уважать переданный контекст, так если он отменен - выходим сразу, бегущие хендлеры оставляем бежать.
  • Если будут использоваться горутины - они не должны течь :)

Нужно написать реализацию и конструктор (см. my_pubsub.go):

func NewPubSub() PubSub