framework

package module
v0.1.38 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2024 License: LGPL-2.1 Imports: 34 Imported by: 0

README

framework

Golaxy分布式服务开发框架，基于Actor线程模型（Actor Model）与分布式实体（Distributed Entities）架构，可以快速开发服务器应用。

本框架特点如下：

...

本包提供以下插件：

  • 消息队列与事件驱动架构（MQ and Broker），基于NATS。
  • 服务发现（Service Discovery），基于Etcd或Redis。
  • 分布式锁（Distributed Sync），基于Etcd或Redis。
  • GTP协议（Golaxy Transfer Protocol），适用于长连接、实时通信的工作场景，需要工作在可靠网络协议（TCP/KCP）之上，支持链路加密、链路鉴权、断线续连等特性。
  • GTP协议网关和客户端（GTP Gate and Client）。
  • GAP协议（Golaxy Application Protocol），适用于开发应用层通信消息，需要工作在GTP协议或MQ之上，支持消息判重，解决了幂等性问题。
  • 分布式服务支持（Distributed Service）。
  • 分布式实体支持（Distributed Entities）。
  • RPC支持（Remote Procedure Call）。
  • 日志（Logger）。

Install

go get -u git.golaxy.org/framework

Documentation

Overview

Package framework Golaxy分布式服务开发框架。

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type App 

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

App 应用

func NewApp 

func NewApp() *App

NewApp 创建应用

func (*App) GetStartupConf 

func (app *App) GetStartupConf() *viper.Viper

GetStartupConf 获取启动参数配置

func (*App) InitCB 

func (app *App) InitCB(cb generic.DelegateAction1[*App]) *App

InitCB 初始化回调

func (*App) Run 

func (app *App) Run()

Run 运行

func (*App) Setup 

func (app *App) Setup(name string, generic any) *App

Setup 安装服务泛化类型

func (*App) StartingCB 

func (app *App) StartingCB(cb generic.DelegateAction1[*App]) *App

StartingCB 启动回调

func (*App) TerminateCB added in v0.1.33 

func (app *App) TerminateCB(cb generic.DelegateAction1[*App]) *App

TerminateCB 终止回调

type IRuntimeInstance added in v0.1.37 

type IRuntimeInstance interface {
	Instance() runtime.Context
}

IRuntimeInstance 运行时实例化接口

type IServiceInstance added in v0.1.37 

type IServiceInstance interface {
	Instance() service.Context
}

IServiceInstance 服务实例化接口

type InstallRuntimeDistEntities 

type InstallRuntimeDistEntities interface {
	InstallDistEntities(ctx runtime.Context)
}

type InstallRuntimeLogger 

type InstallRuntimeLogger interface {
	InstallLogger(ctx runtime.Context)
}

type InstallServiceBroker 

type InstallServiceBroker interface {
	InstallBroker(ctx service.Context)
}

type InstallServiceConfig 

type InstallServiceConfig interface {
	InstallConfig(ctx service.Context)
}

type InstallServiceDistEntityQuerier 

type InstallServiceDistEntityQuerier interface {
	InstallDistEntityQuerier(ctx service.Context)
}

type InstallServiceDistService 

type InstallServiceDistService interface {
	InstallDistService(ctx service.Context)
}

type InstallServiceDistSync 

type InstallServiceDistSync interface {
	InstallDistSync(ctx service.Context)
}

type InstallServiceLogger 

type InstallServiceLogger interface {
	InstallLogger(ctx service.Context)
}

type InstallServiceRPC 

type InstallServiceRPC interface {
	InstallRPC(ctx service.Context)
}

type InstallServiceRegistry 

type InstallServiceRegistry interface {
	InstallRegistry(ctx service.Context)
}

type LifecycleRuntimeBirth 

type LifecycleRuntimeBirth interface {
	Birth(ctx runtime.Context)
}

type LifecycleRuntimeFrameLoopBegin 

type LifecycleRuntimeFrameLoopBegin interface {
	FrameLoopBegin(ctx runtime.Context)
}

type LifecycleRuntimeFrameLoopEnd 

type LifecycleRuntimeFrameLoopEnd interface {
	FrameLoopEnd(ctx runtime.Context)
}

type LifecycleRuntimeFrameUpdateBegin 

type LifecycleRuntimeFrameUpdateBegin interface {
	FrameUpdateBegin(ctx runtime.Context)
}

type LifecycleRuntimeFrameUpdateEnd 

type LifecycleRuntimeFrameUpdateEnd interface {
	FrameUpdateEnd(ctx runtime.Context)
}

type LifecycleRuntimeInit 

type LifecycleRuntimeInit interface {
	Init(ctx runtime.Context)
}

type LifecycleRuntimeRunCallBegin 

type LifecycleRuntimeRunCallBegin interface {
	RunCallBegin(ctx runtime.Context)
}

type LifecycleRuntimeRunCallEnd 

type LifecycleRuntimeRunCallEnd interface {
	RunCallEnd(ctx runtime.Context)
}

type LifecycleRuntimeRunGCBegin 

type LifecycleRuntimeRunGCBegin interface {
	RunGCBegin(ctx runtime.Context)
}

type LifecycleRuntimeRunGCEnd 

type LifecycleRuntimeRunGCEnd interface {
	RunGCEnd(ctx runtime.Context)
}

type LifecycleRuntimeStarted 

type LifecycleRuntimeStarted interface {
	Started(ctx runtime.Context)
}

type LifecycleRuntimeStarting 

type LifecycleRuntimeStarting interface {
	Starting(ctx runtime.Context)
}

type LifecycleRuntimeTerminated 

type LifecycleRuntimeTerminated interface {
	Terminated(ctx runtime.Context)
}

type LifecycleRuntimeTerminating 

type LifecycleRuntimeTerminating interface {
	Terminating(ctx runtime.Context)
}

type LifecycleServiceBirth 

type LifecycleServiceBirth interface {
	Birth(ctx service.Context)
}

type LifecycleServiceInit 

type LifecycleServiceInit interface {
	Init(ctx service.Context)
}

type LifecycleServiceStarted 

type LifecycleServiceStarted interface {
	Started(ctx service.Context)
}

type LifecycleServiceStarting 

type LifecycleServiceStarting interface {
	Starting(ctx service.Context)
}

type LifecycleServiceTerminated 

type LifecycleServiceTerminated interface {
	Terminated(ctx service.Context)
}

type LifecycleServiceTerminating 

type LifecycleServiceTerminating interface {
	Terminating(ctx service.Context)
}

type RuntimeCreator 

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

RuntimeCreator 运行时构建器

func CreateRuntime 

func CreateRuntime(ctx service.Context) RuntimeCreator

CreateRuntime 创建运行时

func (RuntimeCreator) AutoRun 

func (c RuntimeCreator) AutoRun(auto bool) RuntimeCreator

AutoRun 自动开始运行

func (RuntimeCreator) FPS added in v0.1.27 

func (c RuntimeCreator) FPS(fps float32) RuntimeCreator

FPS 帧率

func (RuntimeCreator) Name 

func (c RuntimeCreator) Name(name string) RuntimeCreator

Name 名称

func (RuntimeCreator) PanicHandling added in v0.1.27 

func (c RuntimeCreator) PanicHandling(autoRecover bool, reportError chan error) RuntimeCreator

PanicHandling panic时的处理方式

func (RuntimeCreator) ProcessQueueCapacity 

func (c RuntimeCreator) ProcessQueueCapacity(cap int) RuntimeCreator

ProcessQueueCapacity 任务处理流水线大小

func (RuntimeCreator) Setup 

func (c RuntimeCreator) Setup(generic any) RuntimeCreator

Setup 安装运行时泛化类型

func (RuntimeCreator) Spawn 

func (c RuntimeCreator) Spawn() core.Runtime

Spawn 创建运行时

type RuntimeGeneric added in v0.1.37 

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

RuntimeGeneric 运行时泛化类型

func (*RuntimeGeneric) GetMemKVs added in v0.1.37 

func (r *RuntimeGeneric) GetMemKVs() *sync.Map

GetMemKVs 获取服务内存KV数据库

func (*RuntimeGeneric) GetServiceCtx added in v0.1.37 

func (r *RuntimeGeneric) GetServiceCtx() service.Context

GetServiceCtx 获取服务上下文

func (*RuntimeGeneric) GetStartupConf added in v0.1.37 

func (r *RuntimeGeneric) GetStartupConf() *viper.Viper

GetStartupConf 获取启动参数配置

type ServiceGeneric added in v0.1.37 

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

ServiceGeneric 服务泛化类型

func (*ServiceGeneric) GetName added in v0.1.37 

func (s *ServiceGeneric) GetName() string

GetName 获取服务名称

func (*ServiceGeneric) GetStartupConf added in v0.1.37 

func (s *ServiceGeneric) GetStartupConf() *viper.Viper

GetStartupConf 获取启动参数配置

Source Files

View all Source files

Directories

Path Synopsis
net
gap
Package gap Golaxy应用层协议（golaxy application protocol），适用于开发应用层通信消息，需要工作在GTP协议或MQ之上，支持消息判重，解决了幂等性问题。
 Package gap Golaxy应用层协议（golaxy application protocol），适用于开发应用层通信消息，需要工作在GTP协议或MQ之上，支持消息判重，解决了幂等性问题。
gap/codec
gap/variant
gtp
Package gtp Golaxy传输层协议（golaxy transfer protocol），适用于长连接、实时通信的工作场景，需要工作在可靠网络协议（tcp/kcp/websocket）之上，支持链路加密、链路鉴权、断线续连等特性。
 Package gtp Golaxy传输层协议（golaxy transfer protocol），适用于长连接、实时通信的工作场景，需要工作在可靠网络协议（tcp/kcp/websocket）之上，支持链路加密、链路鉴权、断线续连等特性。
gtp/codec
gtp/method
gtp/transport
netpath
plugins
broker
broker/nats_broker
conf
dent
dentq
+k8s:deepcopy-gen=package
 +k8s:deepcopy-gen=package
discovery
+k8s:deepcopy-gen=package
 +k8s:deepcopy-gen=package
discovery/cache_discovery
discovery/etcd_discovery
discovery/redis_discovery
dserv
dsync
dsync/etcd_dsync
dsync/redis_dsync
gate
gate/cli
log
log/console_log
log/zap_log
router
rpc
rpc/callpath
rpc/processor
rpc/rpcli
rpc/rpcutil
util
binaryutil
concurrent

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.