engine

package
v0.0.1-alpha Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 30, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Wrapper

func Wrapper(smpl SimpleEngine) core.Engine

Wrapper 将给定的简单引擎实例包装成完整的引擎实例

Types

type EngineAccessor

type EngineAccessor interface {
	// Global 获取全局唯一对象
	Global() core.Global
	// RootConfig 根配置
	RootConfig() core.ConfigMap
	// ErrorManager 异常管理器
	ErrorManager() core.ErrorManager
	// Components 组件集合
	Components() map[core.CID]core.Component
	// Schedulers 调度器集合
	Schedulers() map[core.CID]core.Scheduler
	// ContentScheduler (当前使用的)内容调度器
	ContentScheduler() core.ContentScheduler
	// TransformScheduler (当前使用的)转换调度器
	TransformScheduler() core.TransformScheduler
	// HandleScheduler (当前使用的)处理调度器
	HandleScheduler() core.HandleScheduler
	// PushScheduler (当前使用的)推送调度器
	PushScheduler() core.PushScheduler
	// Receivers 接收器集合
	Receivers() map[core.CID]core.Receiver
	// Pollers 轮询器集合
	Pollers() map[core.CID]core.Poller
	// Transformers 转换器集合
	Transformers() map[core.CID]core.Transformer
	// Handlers 处理器集合
	Handlers() map[core.CID]core.Handler
	// Senders 发送器集合
	Senders() map[core.CID]core.Sender
	// Pushers 推送器集合
	Pushers() map[core.CID]core.Pusher
}

EngineAccessor 引擎访问器

type SimpleEngine

type SimpleEngine interface {
	// Init 引擎初始化函数
	Init(EngineAccessor) error
	// Prepare 准备
	Prepare() error
	// Run 运行
	Run() error
	// Stop 暂停
	Stop() error
	// Destroy 销毁
	Destroy() error
}

SimpleEngine 简单的引擎 通过实现该接口来快速构建一个引擎 具体的状态变更、异常处理、并发等功能全部托管给上层引擎代理实现

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL