core

Documentation

Overview

*

• @Author: kwens *
• @Date: 2023-06-05 15:55:17
• @Description:

Index

• type Core
  • func (eb *Core) CheckWatch() bool
  • func (eb *Core) Exec(pubInfo *val.PubInfo)
  • func (eb *Core) ExecSuper(pubInfo *val.PubInfo)
  • func (eb *Core) Stop()
  • func (eb *Core) Watch()
• type EventCore

Types

type Core

type Core struct {
	OpenRemote bool // [预设]是否开启支持远程事件服务，后续可以支持远程事件服务，比如nsq、nats等

	EventFunc  sync.Map // 订阅事件方法
	SuperSub   sync.Map // 超级订阅者执行事件
	GlobalSub  sync.Map // 全局订阅者执行事件
	ErrHandler errors.ErrHandler

	Queue  chan *val.PubInfo
	Cancel chan struct{}
	// contains filtered or unexported fields
}

func (*Core) CheckWatch

func (eb *Core) CheckWatch() bool

func (*Core) Exec

func (eb *Core) Exec(pubInfo *val.PubInfo)

ExecPub 发布执行动作

func (*Core) ExecSuper

func (eb *Core) ExecSuper(pubInfo *val.PubInfo)

func (*Core) Stop

func (eb *Core) Stop()

func (*Core) Watch

func (eb *Core) Watch()

type EventCore

type EventCore interface {
	Watch()
	CheckWatch() bool
	Exec(pubInfo *val.PubInfo)
}