Documentation ¶
Index ¶
- func NewClient(bindaddr string) *serv.CeleryClient
- func NewSTLClient(bindaddr string, certFile string) *serv.CeleryClient
- func NewTaskResquest() *task.Request
- type GCeleryServer
- func (this *GCeleryServer) InitCelery()
- func (this *GCeleryServer) NewCronWorker() *serv.Cron
- func (this *GCeleryServer) NewSyncWroker() *serv.SyncWorker
- func (this *GCeleryServer) RegisterCeleryWorker(fs ...func(*task.Request) (error, *task.Response))
- func (this *GCeleryServer) RegisterCron(cronWorker *serv.Cron)
- func (this *GCeleryServer) RegisterSync(SyncWorker *serv.SyncWorker)
- func (this *GCeleryServer) RegisterTransport()
- func (this *GCeleryServer) StartCelery()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSTLClient ¶
func NewSTLClient(bindaddr string, certFile string) *serv.CeleryClient
STL Client
Types ¶
type GCeleryServer ¶
func NewTlsCelery ¶
func NewTlsCelery(address string, cretFile string, key string) *GCeleryServer
New TLS Server
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 (*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
Click to show internal directories.
Click to hide internal directories.