util

Documentation

Index

• Variables
• func CheckAndCreateDir(path string) error
• func CmdRunWithTimeout(cmd *exec.Cmd, timeout time.Duration) (bool, error)
• func Deweight(data *[]string)
• func Exec(ctx context.Context, f func() error, wait time.Duration) error
• func FileExists(filename string) (bool, error)
• func GetDirSize(path string) float64
• func GetIDFromKey(key string) string
• func IntermittentExec(ctx context.Context, f func(), t time.Duration)
• func LocalIP() (net.IP, error)
• func NewUUID() string
• func OpenOrCreateFile(filename string) (*os.File, error)
• func ReadHostID(filePath string) (string, error)
• func SendNoBlocking(m []byte, ch chan []byte)
• type SSHClient
  • func NewSSHClient(ip, user, password, cmd string, port int, stdout, stderr io.Writer) *SSHClient
  • func (server *SSHClient) Connection() error

Variables

var StatefulServiceType = "StatefulServiceType"

StatefulServiceType 有状态应用

var StatelessServiceType = "StatelessServiceType"

StatelessServiceType 无状态应用

Functions

func CheckAndCreateDir

func CheckAndCreateDir(path string) error

CheckAndCreateDir check and create dir

func CmdRunWithTimeout

func CmdRunWithTimeout(cmd *exec.Cmd, timeout time.Duration) (bool, error)

CmdRunWithTimeout exec cmd with timeout

func Deweight

func Deweight(data *[]string)

Deweight 去除数组重复

func Exec

func Exec(ctx context.Context, f func() error, wait time.Duration) error

Exec 上下文执行

func FileExists

func FileExists(filename string) (bool, error)

FileExists check file exist

func GetDirSize

func GetDirSize(path string) float64

GetDirSize kb为单位

func GetIDFromKey

func GetIDFromKey(key string) string

GetIDFromKey 从 etcd 的 key 中取 id

func IntermittentExec

func IntermittentExec(ctx context.Context, f func(), t time.Duration)

IntermittentExec 间歇性执行

func LocalIP

func LocalIP() (net.IP, error)

LocalIP 获取本机 ip 获取第一个非 loopback ip

func NewUUID

func NewUUID() string

NewUUID 创建无-的32位uuid

func OpenOrCreateFile

func OpenOrCreateFile(filename string) (*os.File, error)

OpenOrCreateFile open or create file

func ReadHostID

func ReadHostID(filePath string) (string, error)

ReadHostID 读取当前机器ID ID是节点的唯一标识，acp_node将把ID与机器信息的绑定关系维护于etcd中

func SendNoBlocking

func SendNoBlocking(m []byte, ch chan []byte)

SendNoBlocking 无阻塞发送

Types

type SSHClient

type SSHClient struct {
	IP             string
	Port           int
	User           string
	Password       string
	Method         string
	Key            string
	Stdout, Stderr io.Writer
	Cmd            string
}

SSHClient ssh client

func NewSSHClient

func NewSSHClient(ip, user, password, cmd string, port int, stdout, stderr io.Writer) *SSHClient

NewSSHClient new ssh client

func (*SSHClient) Connection

func (server *SSHClient) Connection() error

Connection 执行远程连接