pubsub

Documentation

Overview

pubsub @author LanguageY++2013 2023/5/11 09:26 @company soulgame

pubsub @author LanguageY++2013 2023/5/16 17:11 @company soulgame

match_api @author LanguageY++2013 2023/5/10 23:20 @company soulgame

Index

• type EventHandlers
  • func (s *EventHandlers) Receive(ev *open.MatchEvent) error
  • func (s *EventHandlers) RegisterEventHandler(evType open.MatchEventType, handler eventHandler)
• type MultiPublisher
  • func NewMultiPublisher(multi ...Publisher) MultiPublisher
  • func (mp *MultiPublisher) Add(p Publisher)
  • func (mp MultiPublisher) Name() string
  • func (mp MultiPublisher) Send(topic string, ev *open.MatchEvent) (errSend error)
• type Publisher
• type Subscriber

Types

type EventHandlers

type EventHandlers map[open.MatchEventType]eventHandler

func (*EventHandlers) Receive

func (s *EventHandlers) Receive(ev *open.MatchEvent) error

func (*EventHandlers) RegisterEventHandler

func (s *EventHandlers) RegisterEventHandler(evType open.MatchEventType, handler eventHandler)

type MultiPublisher

type MultiPublisher []Publisher

func NewMultiPublisher

func NewMultiPublisher(multi ...Publisher) MultiPublisher

func (*MultiPublisher) Add

func (mp *MultiPublisher) Add(p Publisher)

func (MultiPublisher) Name

func (mp MultiPublisher) Name() string

func (MultiPublisher) Send

func (mp MultiPublisher) Send(topic string, ev *open.MatchEvent) (errSend error)

type Publisher

type Publisher interface {
	Name() string
	Send(topic string, ev *open.MatchEvent) error
}

type Subscriber

type Subscriber interface {
	Name() string
	Receive(ev *open.MatchEvent) error
}