pubsub

package
v0.0.0-...-237b7d6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 19, 2023 License: MIT Imports: 2 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Directories

Path Synopsis
kafka @author LanguageY++2013 2023/5/11 09:33 @company soulgame
kafka @author LanguageY++2013 2023/5/11 09:33 @company soulgame
logging @author LanguageY++2013 2023/5/11 17:17 @company soulgame
logging @author LanguageY++2013 2023/5/11 17:17 @company soulgame
entities @author LanguageY++2013 2023/5/18 23:16 @company soulgame
entities @author LanguageY++2013 2023/5/18 23:16 @company soulgame
redis @author LanguageY++2013 2023/5/16 17:00 @company soulgame
redis @author LanguageY++2013 2023/5/16 17:00 @company soulgame

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL