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)
• type Event
  • func NewEvent() *Event
  • func (e *Event) Notify(eventtype EventType, value interface{}) (err error)
  • func (e *Event) NotifyAll() (errs []error)
  • func (e *Event) NotifySubscriber(eventfunc EventFunc, value interface{})
  • func (e *Event) Subscribe(eventtype EventType, eventfunc EventFunc) Subscriber
  • func (e *Event) UnSubscribe(eventtype EventType, subscriber Subscriber) (err error)
• type EventFunc
• type EventType
• type Subscriber

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)

type Event

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

func NewEvent

func NewEvent() *Event

func (*Event) Notify

func (e *Event) Notify(eventtype EventType, value interface{}) (err error)

Notify subscribers that Subscribe specified event

func (*Event) NotifyAll

func (e *Event) NotifyAll() (errs []error)

Notify all event subscribers

func (*Event) NotifySubscriber

func (e *Event) NotifySubscriber(eventfunc EventFunc, value interface{})

func (*Event) Subscribe

func (e *Event) Subscribe(eventtype EventType, eventfunc EventFunc) Subscriber

adds a new subscriber to Event.

func (*Event) UnSubscribe

func (e *Event) UnSubscribe(eventtype EventType, subscriber Subscriber) (err error)

UnSubscribe removes the specified subscriber

type EventFunc

type EventFunc func(v interface{})

type EventType

type EventType int16

const (
	EventSaveBlock               EventType = 0
	EventReplyTx                 EventType = 1
	EventBlockPersistCompleted   EventType = 2
	EventNewInventory            EventType = 3
	EventNodeDisconnect          EventType = 4
	EventSmartCode               EventType = 5
	EventNodeConsensusDisconnect EventType = 6
)

type Subscriber

type Subscriber chan interface{}