system

Documentation

Index

• Constants
• Variables
• func AsyExec(cmd string) <-chan CmdResult
• func CmdStart(cmd *exec.Cmd, conf *Config, env ...string) (*exec.Cmd, error)
• func CreateTmpShellFile(pattern, content string) (tmpFile string, err error)
• func GetPublicIP() (net.IP, error)
• func GetPublicIPWithUrl(url string) (net.IP, error)
• func GetResolveIP() (net.IP, error)
• func GetResolveIPV2() (net.IP, error)
• func IPIsSelf(ip string) string
• func Info() string
• func IsLanIP(IP net.IP) bool
• func IsPublicIP(IP net.IP) bool
• func PublicIPValid() bool
• func Quit()
• func Run()
• func SelfExternalIP(lan bool) string
• func ShellStart(args []string, config Config, env ...string) (*exec.Cmd, error)
• func StripArgs(args []string, arg string) []string
• type Chan
  • func Exit() *Chan
  • func (c *Chan) Done() <-chan os.Signal
• type CmdResult
  • func CmdRun(cmd string, timeout time.Duration) CmdResult
  • func ShellRun(cmd string) CmdResult
  • func SyncExec(cmd string, timeout time.Duration) CmdResult
  • func (r CmdResult) Error() string
  • func (r CmdResult) Result() string
• type Config
• type CpuInfo
  • func Cpu() CpuInfo
• type DiskPath
  • func Disk() DiskPath
• type Event
  • func NewEvent() *Event
  • func (e *Event) Done() <-chan struct{}
  • func (e *Event) Fire() bool
  • func (e *Event) HasFired() bool
• type IPType
  • func GetIPType(IP net.IP) IPType
• type MemInfo
  • func Mem() MemInfo

Constants

const (
	IptUnk  = IPType(0)
	IptPub  = IPType(1)
	IptPriA = IPType(2)
	IptPriB = IPType(3)
	IptPriC = IPType(4)
)

const GB = 1024 * 1024 * 1024

const (
	KLocalHost = "127.0.0.1"
)

Variables

var (
	ResolveIp = net.IP{}
	PublicIp  = net.IP{}
)

Functions

func AsyExec

func AsyExec(cmd string) <-chan CmdResult

AsyExec 异步执行,返回chan

func CmdStart

func CmdStart(cmd *exec.Cmd, conf *Config, env ...string) (*exec.Cmd, error)

func CreateTmpShellFile

func CreateTmpShellFile(pattern, content string) (tmpFile string, err error)

CreateTmpShellFile 创建临时的 shell 脚本文件 content 创建的脚本内容

func GetPublicIP

func GetPublicIP() (net.IP, error)

func GetPublicIPWithUrl

func GetPublicIPWithUrl(url string) (net.IP, error)

func GetResolveIP

func GetResolveIP() (net.IP, error)

func GetResolveIPV2

func GetResolveIPV2() (net.IP, error)

func IPIsSelf

func IPIsSelf(ip string) string

IPIsSelf 是否是自己

func Info

func Info() string

func IsLanIP

func IsLanIP(IP net.IP) bool

IsLanIP 是否局域网 192.168.x.x

func IsPublicIP

func IsPublicIP(IP net.IP) bool

func PublicIPValid

func PublicIPValid() bool

func Quit

func Quit()

func Run

func Run()

func SelfExternalIP

func SelfExternalIP(lan bool) string

SelfExternalIP 自己外部IP，可能是局域网IP，公网IP lan 局域网优先

func ShellStart

func ShellStart(args []string, config Config, env ...string) (*exec.Cmd, error)

func StripArgs

func StripArgs(args []string, arg string) []string

Types

type Chan

type Chan struct {
	S chan os.Signal
}

func Exit

func Exit() *Chan

func (*Chan) Done

func (c *Chan) Done() <-chan os.Signal

type CmdResult

type CmdResult struct {
	Command   string
	Err       error
	StartTime time.Time
	EndTime   time.Time
	// contains filtered or unexported fields
}

func CmdRun

func CmdRun(cmd string, timeout time.Duration) CmdResult

CmdRun 超时同步执行, 等待结果返回 Deprecated: this function simply calls SyncExec.

func ShellRun

func ShellRun(cmd string) CmdResult

ShellRun 阻塞式同步执行

func SyncExec

func SyncExec(cmd string, timeout time.Duration) CmdResult

SyncExec 超时同步执行 timeout = 0, default 30 seconds

func (CmdResult) Error

func (r CmdResult) Error() string

func (CmdResult) Result

func (r CmdResult) Result() string

type Config

type Config struct {
	Stdin     io.Reader
	Stdout    io.Writer
	Stderr    io.Writer
	EnableStd bool `json:"enableStd" yaml:"enableStd" xml:"enableStd"`
	EnableEnv bool `json:"enableEnv" yaml:"enableEnv" xml:"enableEnv"`
}

type CpuInfo

type CpuInfo struct {
	User   float64 `json:"user"`
	System float64 `json:"system"`
	Idle   float64 `json:"idle"`
	Nice   float64 `json:"nice"`
}

func Cpu

func Cpu() CpuInfo

type DiskPath

type DiskPath struct {
	Path        string  `json:"path,omitempty"`
	Total       uint64  `json:"total"`
	Free        uint64  `json:"free"`
	Used        uint64  `json:"used"`
	UsedPercent float64 `json:"usedPercent"`
}

func Disk

func Disk() DiskPath

type Event

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

Event represents a one-time event that may occur in the future.

func NewEvent

func NewEvent() *Event

NewEvent returns a new, ready-to-use Event.

func (*Event) Done

func (e *Event) Done() <-chan struct{}

Done returns a channel that will be closed when Fire is called.

func (*Event) Fire

func (e *Event) Fire() bool

Fire causes e to complete. It is safe to call multiple times, and concurrently. It returns true iff this call to Fire caused the signaling channel returned by Done to close.

func (*Event) HasFired

func (e *Event) HasFired() bool

HasFired returns true if Fire has been called.

type IPType

type IPType int8

func GetIPType

func GetIPType(IP net.IP) IPType

type MemInfo

type MemInfo struct {
	// Total amount of RAM on this system
	Total uint64 `json:"total"`

	// RAM available for programs to allocate
	//
	// This value is computed from the kernel specific values.
	Available uint64 `json:"available"`

	// RAM used by programs
	//
	// This value is computed from the kernel specific values.
	Used uint64 `json:"used"`

	// Percentage of RAM used by programs
	//
	// This value is computed from the kernel specific values.
	UsedPercent float64 `json:"usedPercent"`
}

func Mem

func Mem() MemInfo