Versions in this module Expand all Collapse all v2 v2.9.1 Dec 25, 2023 Changes in this version + func Report(reporters []metrics.Reporter, period time.Duration) + type RPCJob interface + GetArgReply func(route string) (arg, reply proto.Message, err error) + RPC func(ctx context.Context, serverID, routeStr string, reply, arg proto.Message) error + ServerDiscovery func(route string, rpcMetadata map[string]interface{}) (serverID string, err error) + type Worker struct + func NewWorker(config config.WorkerConfig, opts config.EnqueueOpts) (*Worker, error) + func (w *Worker) EnqueueRPC(routeStr string, metadata map[string]interface{}, reply, arg proto.Message) (jid string, err error) + func (w *Worker) EnqueueRPCWithOptions(routeStr string, metadata map[string]interface{}, reply, arg proto.Message, ...) (jid string, err error) + func (w *Worker) RegisterRPCJob(rpcJob RPCJob) error + func (w *Worker) SetLogger(logger interfaces.Logger) + func (w *Worker) Start() + func (w *Worker) Started() bool Other modules containing this package github.com/pandazxx/pitaya
Go to main page