shad-go

History

Arseny Balobanov 28564b4257 go fix old build tags.		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