Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

client

package

Go to main page

Versions in this module

v1

v1.4.1

Jun 28, 2018

v1.4.0

Jun 25, 2018

v1.3.0

Jun 4, 2018

v1.2.2

May 4, 2018

v1.2.1

Apr 11, 2018

v1.2.0

Apr 11, 2018

Changes in this version

+ const CommandsQueue

+ const LevelJson

+ const ResultDefaultTimeout

+ const ResultNoTimeout

+ const StateDuplicateID

+ const StateError

+ const StateKilled

+ const StateSuccess

+ const StateTimeout

+ const StateUnknownCmd

+ var NotFound = fmt.Errorf("not found")

+ func NewPool(address, password string) *redis.Pool

+ type A map[string]interface

+ type AggregatorManager interface

+ Query func() (interface{}, error)

+ func Aggregator(cl Client) AggregatorManager

+ type AggregatorMgr struct

+ func (b *AggregatorMgr) Query() (interface{}, error)

+ type BlockDevice struct

+ Alignment string

+ Children []BlockDevice

+ DiscAln string

+ DiscGran string

+ DiscMax string

+ DiscZero string

+ Fstype string

+ Group string

+ Hctl string

+ Hotplug string

+ Kname string

+ Label string

+ LogSec string

+ MajMin string

+ MinIo string

+ Mode string

+ Model string

+ Mountpoint string

+ Name string

+ OptIo string

+ Owner string

+ Partflags string

+ Partlabel string

+ Parttype string

+ Partuuid string

+ PhySec string

+ Pkname string

+ Ra string

+ Rand string

+ Rev string

+ Rm string

+ Ro string

+ Rota string

+ RqSize string

+ Sched string

+ Serial string

+ Size string

+ State string

+ Subsystems string

+ Tran string

+ Type string

+ UUID string

+ Vendor string

+ Wsame string

+ Wwn string

+ type BtrfsFS struct

+ Devices []btrfsDevice

+ Label string

+ TotalDevices int

+ UUID string

+ Used int64

+ type BtrfsManager interface

+ List func() ([]BtrfsFS, error)

+ func Btrfs(cl Client) BtrfsManager

+ type CPUStats struct

+ GuestNice float64

+ Idle float64

+ IoWait float64

+ Irq float64

+ Nice float64

+ SoftIrq float64

+ Steal float64

+ Stolen float64

+ System float64

+ User float64

+ type Client interface

+ Exists func(job JobId) bool

+ Raw func(command string, args A, opts ...Option) (JobId, error)

+ Result func(job JobId, timeout ...int) (*Result, error)

+ ResultNonBlock func(job JobId) (*Result, error)

+ func NewClient(address, password string) Client

+ func NewClientWithPool(pool *redis.Pool) Client

+ type Command struct

+ Arguments A

+ Command string

+ ID string

+ LogLevels []int

+ MaxRestart int

+ MaxTime int

+ Queue string

+ RecurringPeriod int

+ StatsInterval int

+ Tags Tags

+ type ContainerCreateAguments struct

+ HostNetwork bool

+ Hostname string

+ Mount map[string]string

+ Nics []Nic

+ Port map[int]int

+ Root string

+ Storage string

+ Tags []string

+ type ContainerInfo struct

+ Arguments ContainerCreateAguments

+ Pid int

+ Root string

+ type ContainerManager interface

+ Client func(id int) Client

+ List func() (map[int16]ContainerResult, error)

+ func Container(cl Client) ContainerManager

+ type ContainerResult struct

+ CPU int

+ Container ContainerInfo

+ RSS int

+ Swap int

+ type CoreManager interface

+ Bash func(bash string, stdin string, opt ...Option) (JobId, error)

+ Job func(job JobId) (*Job, error)

+ Jobs func() ([]Job, error)

+ KillAllJobs func() error

+ KillJob func(job JobId, signal syscall.Signal) error

+ KillProcess func(pid ProcessId, signal syscall.Signal) error

+ Ping func() error

+ Process func(pid ProcessId) (*Process, error)

+ ProcessAlive func(pid ProcessId) (bool, error)

+ Processes func() ([]Process, error)

+ State func() (*JobStats, error)

+ System func(cmd string, env map[string]string, cwd string, stdin string, opt ...Option) (JobId, error)

+ SystemArgs func(cmd string, args []string, env map[string]string, cwd string, stdin string, ...) (JobId, error)

+ func Core(client Client) CoreManager

+ type DiskManager interface

+ List func() (Disks, error)

+ func Disk(cl Client) DiskManager

+ type DiskStats struct

+ RdBytes uint64

+ RdTimes uint64

+ WrBytes uint64

+ WrTimes uint64

+ type Disks struct

+ BlockDevices []BlockDevice

+ type File string

+ type FilesystemManager interface

+ Download func(p string, writer io.Writer) error

+ Exists func(p string) (bool, error)

+ Remove func(p string) error

+ Upload func(reader io.Reader, p string) error

+ func Filesystem(client Client) FilesystemManager

+ type InfoManager interface

+ CPU func() ([]cpu.InfoStat, error)

+ Disk func() ([]disk.PartitionStat, error)

+ Mem func() (mem.VirtualMemoryStat, error)

+ Nic func() ([]net.InterfaceStat, error)

+ OS func() (host.InfoStat, error)

+ func Info(cl Client) InfoManager

+ type Job struct

+ CPU float64

+ Command Command

+ RSS int64

+ StartTime int64

+ Swap int64

+ VMS int64

+ type JobId string

+ type JobStats struct

+ CPU float64

+ Debug string

+ RSS uint64

+ Swap uint64

+ VMS uint64

+ type KvmManager interface

+ InfoPs func(uuid string) (VMInfo, error)

+ List func() ([]VM, error)

+ func Kvm(cl Client) KvmManager

+ type Network struct

+ RxBytes uint64

+ RxPkts uint64

+ TxBytes uint64

+ TxPkts uint64

+ type NetworkConfig struct

+ CIDR string

+ DNS []string

+ Dhcp bool

+ Gateway string

+ type Nic struct

+ Config NetworkConfig

+ HWAddress string

+ ID string

+ Type string

+ type Option interface

+ func ID(id string) Option

+ func MaxRestart(restart int) Option

+ func MaxTime(timeout int) Option

+ func Queue(queue string) Option

+ func RecurringPeriod(period int) Option

+ type Process struct

+ Command string

+ Cpu CPUStats

+ Createtime uint64

+ PID ProcessId

+ PPID ProcessId

+ RSS uint64

+ Swap uint64

+ VMS uint64

+ type ProcessId uint64

+ type Result struct

+ Code uint32

+ Command string

+ Container uint64

+ Critical string

+ Data string

+ ID string

+ Level int

+ StartTime int64

+ State State

+ Streams Streams

+ Tags string

+ Time int64

+ func (r *Result) Json(v interface{}) error

+ type State string

+ type Streams []string

+ func (s Streams) Stderr() string

+ func (s Streams) Stdout() string

+ func (s Streams) String() string

+ type Tags []string

+ type VCpu struct

+ State float64

+ Time float64

+ type VM struct

+ ID uint64

+ Name string

+ State string

+ UUID string

+ type VMInfo struct

+ Block map[string]DiskStats

+ Network map[string]Network

+ Vcpu map[string]VCpu

+ type ZerotierItem struct

+ AllowDefault bool

+ AllowGlobal bool

+ AllowManaged bool

+ AssignedAddresses []string

+ Bridge bool

+ BroadcastEnabled bool

+ DHCP bool

+ ID string

+ Mac string

+ Mtu uint64

+ Name string

+ NetConfRevision uint64

+ Nwid string

+ PortDeviceName string

+ PortError uint8

+ Status string

+ Type string

+ type ZerotierManager interface

+ List func() ([]ZerotierItem, error)

+ func Zerotier(cl Client) ZerotierManager

+ type ZerotierRoute struct

+ Flags uint64

+ Metric uint64

+ Target string

+ Via string

v1.1.0-alpha-7

Aug 17, 2017

v1.1.0-alpha-5

Jul 17, 2017

v1.1.0-alpha-4

Jun 21, 2017

v1.1.0-alpha-3

Jun 8, 2017