aria2

Documentation

Index

• Variables
• type Aria2Cmd
  • func NewCmd(path string, args []string) *Aria2Cmd
  • func (c *Aria2Cmd) Close() error
• type ClientLockGuard
  • func (g *ClientLockGuard) Close()
  • func (g *ClientLockGuard) Get() rpc.Client
  • func (g *ClientLockGuard) IsUnlocked() bool
  • func (g *ClientLockGuard) Unlock()
• type RpcGuard
  • func NewClient(opts RpcOptions) (*RpcGuard, error)
  • func (r *RpcGuard) Close() error
  • func (r *RpcGuard) GetClient() (*ClientLockGuard, error)
  • func (r *RpcGuard) IsClosed() bool
• type RpcOptions
• type Unlocker

Variables

var (
	ERR_RPC_CLOSED      = errors.New("rpc closed")
	ERR_CLIENT_UNLOCKED = errors.New("client unlocked")
)

Types

type Aria2Cmd

type Aria2Cmd struct {
	*exec.Cmd
}

func NewCmd

func NewCmd(path string, args []string) *Aria2Cmd

func (*Aria2Cmd) Close

func (c *Aria2Cmd) Close() error

type ClientLockGuard

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

func (*ClientLockGuard) Close

func (g *ClientLockGuard) Close()

alias of `Unlock()`

func (*ClientLockGuard) Get

func (g *ClientLockGuard) Get() rpc.Client

func (*ClientLockGuard) IsUnlocked

func (g *ClientLockGuard) IsUnlocked() bool

func (*ClientLockGuard) Unlock

func (g *ClientLockGuard) Unlock()

type RpcGuard

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

func NewClient

func NewClient(opts RpcOptions) (*RpcGuard, error)

func (*RpcGuard) Close

func (r *RpcGuard) Close() error

func (*RpcGuard) GetClient

func (r *RpcGuard) GetClient() (*ClientLockGuard, error)

func (*RpcGuard) IsClosed

func (r *RpcGuard) IsClosed() bool

type RpcOptions

type RpcOptions struct {
	Host      string
	Port      uint
	Secret    string
	Transport string
	Timeout   string
	Notifier  rpc.Notifier
}

type Unlocker

type Unlocker func()