dispatcher

Documentation

Index

• Constants
• Variables
• type CallBackFunc
  • func (f CallBackFunc) DataEvent(e IEvent) error
• type CallBackHandler
• type Data
  • func NewMyData(data map[string]map[string][]byte) *Data
  • func (d *Data) DoEvent(event IEvent)
  • func (d *Data) GET() map[string]map[string][]byte
  • func (d *Data) GetNamespace(namespace string) (map[string][]byte, bool)
• type DataDispatchCenter
  • func (d *DataDispatchCenter) Close() error
  • func (d *DataDispatchCenter) Listener() IListener
  • func (d *DataDispatchCenter) Register(handlerFunc CallBackFunc) (closeChan chan<- int)
  • func (d *DataDispatchCenter) Send(e IEvent)
• type IDispatchCenter
  • func NewDataDispatchCenter() IDispatchCenter
  • func NewEventDispatchCenter() IDispatchCenter
• type IEvent
• type IListener
• type InitEvent
  • func (r InitEvent) All() map[string]map[string][]byte
  • func (r InitEvent) Data() []byte
  • func (r InitEvent) Event() string
  • func (r InitEvent) Key() string
  • func (r InitEvent) Namespace() string

Constants

const EventCall = "__EventCall"

Variables

var (
	ErrorIsClosed = errors.New("closed")
)

Types

type CallBackFunc

type CallBackFunc func(e IEvent) error

func (CallBackFunc) DataEvent

func (f CallBackFunc) DataEvent(e IEvent) error

type CallBackHandler

type CallBackHandler interface {
	DataEvent(e IEvent) error
}

type Data

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

func NewMyData

func NewMyData(data map[string]map[string][]byte) *Data

func (*Data) DoEvent

func (d *Data) DoEvent(event IEvent)

func (*Data) GET

func (d *Data) GET() map[string]map[string][]byte

func (*Data) GetNamespace

func (d *Data) GetNamespace(namespace string) (map[string][]byte, bool)

type DataDispatchCenter

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

DataDispatchCenter 数据广播中心

func (*DataDispatchCenter) Close

func (d *DataDispatchCenter) Close() error

func (*DataDispatchCenter) Listener

func (d *DataDispatchCenter) Listener() IListener

func (*DataDispatchCenter) Register

func (d *DataDispatchCenter) Register(handlerFunc CallBackFunc) (closeChan chan<- int)

func (*DataDispatchCenter) Send

func (d *DataDispatchCenter) Send(e IEvent)

type IDispatchCenter

type IDispatchCenter interface {
	io.Closer
	Register(handler CallBackFunc) (closeChan chan<- int)
	Listener() IListener
	Send(e IEvent)
}

func NewDataDispatchCenter

func NewDataDispatchCenter() IDispatchCenter

func NewEventDispatchCenter

func NewEventDispatchCenter() IDispatchCenter

type IEvent

type IEvent interface {
	Namespace() string
	Event() string
	Key() string
	Data() []byte
	All() map[string]map[string][]byte
}

type IListener

type IListener interface {
	Leave()
	Event() <-chan IEvent
}

type InitEvent

type InitEvent map[string]map[string][]byte

func (InitEvent) All

func (r InitEvent) All() map[string]map[string][]byte

func (InitEvent) Data

func (r InitEvent) Data() []byte

func (InitEvent) Event

func (r InitEvent) Event() string

func (InitEvent) Key

func (r InitEvent) Key() string

func (InitEvent) Namespace

func (r InitEvent) Namespace() string