eventhub

Documentation

Index

• Constants
• Variables
• type Event
• type EventHub
  • func (this *EventHub) Publish(event *Event)
  • func (this *EventHub) RemovePID(pid actor.PID)
  • func (this *EventHub) Subscribe(topic string, subscriber *actor.PID)
  • func (this *EventHub) Unsubscribe(topic string, subscriber *actor.PID)
• type PublishPolicy
• type RoundRobinState

Constants

const (
	PublishPolicyAll = iota
	PublishPolicyRoundRobin
	PublishPolicyRandom
)

Variables

var GlobalEventHub = &EventHub{Subscribers: cmap.New(), RoundRobinState: RoundRobinState{make(map[string]int)}}

Types

type Event

type Event struct {
	Publisher *actor.PID
	Topic     string
	Message   interface{}
	Policy    PublishPolicy
}

type EventHub

type EventHub struct {
	//sync.RWMutex
	Subscribers cmap.ConcurrentMap
	RoundRobinState
}

func (*EventHub) Publish

func (this *EventHub) Publish(event *Event)

func (*EventHub) RemovePID

func (this *EventHub) RemovePID(pid actor.PID)

func (*EventHub) Subscribe

func (this *EventHub) Subscribe(topic string, subscriber *actor.PID)

func (*EventHub) Unsubscribe

func (this *EventHub) Unsubscribe(topic string, subscriber *actor.PID)

type PublishPolicy

type PublishPolicy int

type RoundRobinState

type RoundRobinState struct {
	// contains filtered or unexported fields
}