events

Documentation

Index

• Variables
• func Init()
• type ActorPublisher
  • func NewActorPublisher(publisher *actor.PID, evtHub ...*eventhub.EventHub) *ActorPublisher
  • func (this *ActorPublisher) Publish(topic string, msg interface{})
  • func (this *ActorPublisher) PublishEvent(evt *eventhub.Event)
• type ActorSubscriber
  • func NewActorSubscriber(subscriber *actor.PID, evtHub ...*eventhub.EventHub) *ActorSubscriber
  • func (this *ActorSubscriber) Subscribe(topic string)
  • func (this *ActorSubscriber) Unsubscribe(topic string)

Variables

var DefEvtHub *eventhub.EventHub

var DefPublisherPID *actor.PID

Functions

func Init

func Init()

Types

type ActorPublisher

type ActorPublisher struct {
	EvtHub    *eventhub.EventHub
	Publisher *actor.PID
}

var DefActorPublisher *ActorPublisher

func NewActorPublisher

func NewActorPublisher(publisher *actor.PID, evtHub ...*eventhub.EventHub) *ActorPublisher

func (*ActorPublisher) Publish

func (this *ActorPublisher) Publish(topic string, msg interface{})

func (*ActorPublisher) PublishEvent

func (this *ActorPublisher) PublishEvent(evt *eventhub.Event)

type ActorSubscriber

type ActorSubscriber struct {
	EvtHub     *eventhub.EventHub
	Subscriber *actor.PID
}

func NewActorSubscriber

func NewActorSubscriber(subscriber *actor.PID, evtHub ...*eventhub.EventHub) *ActorSubscriber

func (*ActorSubscriber) Subscribe

func (this *ActorSubscriber) Subscribe(topic string)

func (*ActorSubscriber) Unsubscribe

func (this *ActorSubscriber) Unsubscribe(topic string)