aria2

Documentation

Index

• Variables
• func GetLoadBalancer() balancer.Balancer
• func Init(isReload bool, pool cluster.Pool, mqClient mq.MQ)
• func TestRPCConnection(server, secret string, timeout int) (rpc.VersionInfo, error)

Variables

var Instance common.Aria2 = &common.DummyAria2{}

Instance 默认使用的Aria2处理实例

var LB balancer.Balancer

LB 获取 Aria2 节点的负载均衡器

var Lock sync.RWMutex

Lock Instance的读写锁

Functions

func GetLoadBalancer

func GetLoadBalancer() balancer.Balancer

GetLoadBalancer 返回供Aria2使用的负载均衡器

func Init

func Init(isReload bool, pool cluster.Pool, mqClient mq.MQ)

Init 初始化

func TestRPCConnection

func TestRPCConnection(server, secret string, timeout int) (rpc.VersionInfo, error)

TestRPCConnection 发送测试用的 RPC 请求，测试服务连通性