gcelery

package module
v0.0.0-...-caf5360 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

README

github.com/et-zone/gcelery

What about Gcelery

Gcelery, 功能和python的celery框架类似的异步任务框架，功能可参考celery。

  • 主要功能
    • 自定义worker路径，用于gcelery执行异步程序
    • client 集成到项目中
    • 支持tls 模式
    • 支持定时任务
    • 支持异步任务（用于持续执行相关业务）
    • 支持task任务，可以获取返回数据，（可以异步获取响应，需要自己起Goroutine）

性能（8核16G 3.2GHz 服务器）

极限测试
  • Server支持10万级 op/s

install

`go get -u github.com/et-zone/gcelery`

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewClient 

func NewClient(bindaddr string) *serv.CeleryClient

Client

func NewSTLClient 

func NewSTLClient(bindaddr string, certFile string) *serv.CeleryClient

STL Client

func NewTaskResquest 

func NewTaskResquest() *task.Request

Request

Types

type GCeleryServer 

type GCeleryServer struct {
	Server *grpc.Server
	// contains filtered or unexported fields
}

func NewCelery 

func NewCelery(address string) *GCeleryServer

New Server

func NewTlsCelery 

func NewTlsCelery(address string, cretFile string, key string) *GCeleryServer

New TLS Server

func (*GCeleryServer) InitCelery 

func (this *GCeleryServer) InitCelery()

Gcelery Task Wroker init

func (*GCeleryServer) NewCronWorker 

func (this *GCeleryServer) NewCronWorker() *serv.Cron

Cron Wroker

func (*GCeleryServer) NewSyncWroker 

func (this *GCeleryServer) NewSyncWroker() *serv.SyncWorker

Sync Long wroker

func (*GCeleryServer) RegisterCeleryWorker 

func (this *GCeleryServer) RegisterCeleryWorker(fs ...func(*task.Request) (error, *task.Response))

func (*GCeleryServer) RegisterCron 

func (this *GCeleryServer) RegisterCron(cronWorker *serv.Cron)

Register Cron Wroker to Server

func (*GCeleryServer) RegisterSync 

func (this *GCeleryServer) RegisterSync(SyncWorker *serv.SyncWorker)

Register Sync Long Wroker to Server

func (*GCeleryServer) RegisterTransport 

func (this *GCeleryServer) RegisterTransport()

Register Protobuf

func (*GCeleryServer) StartCelery 

func (this *GCeleryServer) StartCelery()

Start Server GCelery

Source Files

View all Source files

Directories

Path Synopsis
protos
base
cron
transform

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.