本文整理汇总了Golang中github.com/fatih/color.Yellow函数的典型用法代码示例。如果您正苦于以下问题:Golang Yellow函数的具体用法?Golang Yellow怎么用?Golang Yellow使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Yellow函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: parseGauges
func parseGauges(info string) map[string]int64 {
gauges_with_values := map[string]int64{
"blocked_clients": 0,
"connected_clients": 0,
"instantaneous_ops_per_sec": 0,
"latest_fork_usec": 0,
"mem_fragmentation_ratio": 0,
"migrate_cached_sockets": 0,
"pubsub_channels": 0,
"pubsub_patterns": 0,
"uptime_in_seconds": 0,
"used_memory": 0,
"used_memory_lua": 0,
"used_memory_peak": 0,
"used_memory_rss": 0,
}
color.White("-------------------")
color.White("GAUGES:")
for gauge, _ := range gauges_with_values {
r, _ := regexp.Compile(fmt.Sprint(gauge, ":([0-9]*)"))
matches := r.FindStringSubmatch(info)
if matches == nil {
color.Yellow(fmt.Sprint("WARN: ", gauge, "is not displayed in redis info"))
} else {
value := matches[len(matches)-1]
color.Cyan(fmt.Sprint(gauge, ": ", value))
v, _ := strconv.ParseInt(value, 10, 64)
gauges_with_values[gauge] = v
}
}
return gauges_with_values
}
开发者ID:feelobot,项目名称:stadis,代码行数:32,代码来源:stadis.go
示例2: getClientCredentials
func getClientCredentials(c *cli.Context) []string {
credentials := []string{c.GlobalString("client-id"), c.GlobalString("client-secret")}
if credentials[0] == "" || credentials[1] == "" {
color.Yellow("No client credentials given. Fallback to builtin default...")
color.Yellow("Keep in mind that your document might be visible to other users.")
color.Yellow("Your unique user-id is the only secret to protect your data.\n\n")
superSecretSecret := []byte("V;4nJvuANmoywKNYk.yewNhqwmAQctc3BvByxeozQVpiK")
// Decode HEX default credentials
credentialsBytes, err := hex.DecodeString(defaultClientCredentials)
if err != nil {
color.Red("Error: client-id and client-secret missing and fallback decoding (step 1) failed: %s\n\n", err)
cli.ShowCommandHelp(c, c.Command.FullName())
os.Exit(1)
}
decodedCredentials := strings.Split(string(xorBytes(credentialsBytes, superSecretSecret)), ":")
if len(decodedCredentials) < 2 {
color.Red("Error: client-id and client-secret missing and fallback decoding (step 2) failed: %s\n\n", err)
cli.ShowCommandHelp(c, c.Command.FullName())
os.Exit(1)
}
credentials = decodedCredentials
}
return credentials
}
开发者ID:gini,项目名称:gapicmd,代码行数:30,代码来源:utils.go
示例3: copyfile
func copyfile() {
color.Yellow("开始执行文件发送:")
info, err := os.Lstat(all_ssh.ArgsInfo.File)
if err != nil || info.IsDir() {
color.Blue("检查要发送的文件.")
return
}
for _, v := range all_ssh.ServerList {
go func() {
client := all_ssh.Connection(v)
if client != nil {
all_ssh.CopyFile(client, all_ssh.ArgsInfo.File, all_ssh.ArgsInfo.Dir)
}
}()
}
var num int
var Over chan os.Signal = make(chan os.Signal, 1)
go signal.Notify(Over, os.Interrupt, os.Kill)
go result(&num, Over)
<-Over
color.Yellow("一共有%d条错误.\n", len(all_ssh.ErrorList))
for _, v := range all_ssh.ErrorList {
color.Red(v)
}
color.Red("收到结果:%d条\n", num)
}
开发者ID:czxichen,项目名称:Goprograme,代码行数:26,代码来源:ssh_maste.go
示例4: DisplayInfo
func DisplayInfo() {
color.Yellow("\n\n******* GO WORKER INFORMATION *******\n\n")
infoObj := GetInfoObj()
color.Green("%+v", infoObj)
color.Yellow("\n\n*************************************\n\n")
}
开发者ID:rohanraja,项目名称:jobworker,代码行数:11,代码来源:signals.go
示例5: handleInteractiveMode
func handleInteractiveMode() {
reader := bufio.NewReader(os.Stdin)
for {
red := color.New(color.FgCyan)
red.Printf("%s %s %s => ", time.Now().Format("15:04:05"), *serverFlag, *executorFlag)
line, err := reader.ReadString('\n')
if err != nil {
log.Fatal(color.RedString("ERROR reading string: %s", err.Error()))
}
line = strings.Trim(line, "\r\n")
if strings.EqualFold(line, "exit") {
color.Green("Exit command received. Good bye.")
os.Exit(0)
}
exeAndArgs, err := parsecommand.Parse(line)
if err != nil {
color.Red("Cannot parse line '%s', error: %s", line, err.Error())
continue
}
var exe string
var args []string = []string{}
exe = exeAndArgs[0]
if len(exeAndArgs) > 1 {
args = exeAndArgs[1:]
}
onFeedback := func(fb string) {
fmt.Println(fb)
}
color.Green("Exe '%s' and args '%#v'", exe, args)
color.Yellow("-------------------------------------")
println()
err = execute(false, onFeedback, *serverFlag, *executorFlag, *clientPemFlag, exe, args...)
if err != nil {
color.Red("Execute failed with error: %s", err.Error())
continue
}
println()
color.Yellow("-------------------------------------")
println()
println()
}
}
开发者ID:golang-devops,项目名称:go-psexec,代码行数:49,代码来源:interactive_mode.go
示例6: main
func main() {
if all_ssh.ArgsInfo.IP != "" {
color.Yellow("开始登录:%s\n", all_ssh.ArgsInfo.IP)
var v all_ssh.ConnetctionInfo
for _, v = range all_ssh.ServerList {
if v.IP == all_ssh.ArgsInfo.IP {
break
}
}
v.IP = all_ssh.ArgsInfo.IP
client := all_ssh.Connection(v)
if client == nil {
return
}
err := all_ssh.TtyClient(client)
if err != nil {
println(err.Error())
}
if len(all_ssh.ErrorList) >= 1 {
color.Red(all_ssh.ErrorList[0])
}
return
}
if all_ssh.ArgsInfo.File != "" {
copyfile()
return
}
if all_ssh.ArgsInfo.Cmd != "" {
runcmd()
return
}
color.Blue("使用%s -h查看帮助.\n", os.Args[0])
}
开发者ID:czxichen,项目名称:Goprograme,代码行数:33,代码来源:ssh_maste.go
示例7: Run
func (n *Notifier) Run(message string) {
switch n.Name {
case "slack":
if slack_api == nil {
color.Red("[!] Slack used as a notifier, but not configured with ENV vars.")
return
}
err = slack_api.ChatPostMessage(slack_channel.Id, message, &slack.ChatPostMessageOpt{IconEmoji: ":fire:"})
if err != nil {
color.Red(fmt.Sprintf("[!] Error posting to Slack: %s", err))
}
case "hipchat":
if hipchat_api == nil {
color.Red("[!] HipChat used as a notifier, but not configured with ENV vars.")
return
}
_, err = hipchat_api.Room.Notification(os.Getenv("HIPCHAT_ROOM_ID"), &hipchat.NotificationRequest{Message: "Testing", Color: "red"})
if err != nil {
color.Red(fmt.Sprintf("[!] Error posting to HipChat: %s", err))
}
case n.Name: // default
color.Yellow(fmt.Sprintf("[>] Unknown notifier: %s", n.Name))
}
}
开发者ID:joock,项目名称:influx-alert,代码行数:25,代码来源:notifiers.go
示例8: TestPlugin
func TestPlugin(t *testing.T) {
color.NoColor = false
casses := map[string]testrunnerTestCase{
"simple": {
first: map[string]interface{}{"name": "value"},
second: map[string]interface{}{"name": "value"},
expect: make(map[string]interface{}),
},
"diff": {
first: map[string]interface{}{"name1": "value"},
second: map[string]interface{}{"name": "value"},
expect: map[string]interface{}{"name": "<nil> != value", "name1": "value != <nil>"},
},
}
for name, test := range casses {
if d := diff(test.first, test.second); !reflect.DeepEqual(d, test.expect) {
color.Red("\n\nTest `%s` failed!", name)
color.Yellow("\n\nexpected: %v\n\ngiven: %v\n\n", test.expect, d)
t.Fail()
} else {
color.Green("\n%s: OK\n", name)
}
}
}
开发者ID:kulikov,项目名称:serve,代码行数:27,代码来源:testrunner_test.go
示例9: Warn
// Warn is a convenience method appending a warning message to the logger
func Warn(obj interface{}) {
// Get the line number and calling func sig
_, fn, line, _ := runtime.Caller(1)
msg := fmt.Sprintf("%+v\n%s:%d\n\n", obj, fn, line)
formattedMessage := formattedLogMessage("WARN", msg)
color.Yellow(formattedMessage)
}
开发者ID:meshhq,项目名称:gohttp,代码行数:8,代码来源:meshLog.go
示例10: writeWarning
func writeWarning(format string, a ...interface{}) {
if silent {
return
}
color.Yellow(format, a...)
}
开发者ID:getcarina,项目名称:dvm,代码行数:7,代码来源:util.go
示例11: parseCounters
func parseCounters(info string) map[string]int64 {
counters := map[string]int64{
"evicted_keys": 0,
"expired_keys": 0,
"keyspace_hits": 0,
"keyspace_misses": 0,
"rejected_connections": 0,
"sync_full": 0,
"sync_partial_err": 0,
"sync_partial_ok": 0,
"total_commands_processed": 0,
"total_connections_received": 0,
}
color.White("-------------------")
color.White("COUNTERS:")
for counter, _ := range counters {
r, _ := regexp.Compile(fmt.Sprint(counter, ":([0-9]*)"))
matches := r.FindStringSubmatch(info)
if matches == nil {
color.Yellow(fmt.Sprint("ERROR: ", counter, "is not displayed in redis info"))
} else {
value := matches[len(matches)-1]
color.Cyan(fmt.Sprint(counter, ": ", value))
v, _ := strconv.ParseInt(value, 10, 64)
counters[counter] = v
}
}
return counters
}
开发者ID:feelobot,项目名称:stadis,代码行数:29,代码来源:stadis.go
示例12: Warnf
// Warnf is a convenience method appending a warning message to the logger
func Warnf(msg string, a ...interface{}) {
_, fn, line, _ := runtime.Caller(1)
msg = fmt.Sprintf(msg, a...)
msg = fmt.Sprintf("%+v%s:%d\n\n", msg, fn, line)
formattedMessage := formattedLogMessage("WARN", msg)
color.Yellow(formattedMessage)
}
开发者ID:meshhq,项目名称:gohttp,代码行数:8,代码来源:meshLog.go
示例13: isWatching
func isWatching(channel string, name string) (bool, error) {
chanName := strings.Replace(channel, "#", "", 1)
if k+60 <= time.Now().Unix() {
var err error
url := "http://tmi.twitch.tv/group/user/" + chanName + "/chatters"
response, err := http.Get(url)
if err != nil {
log.Printf("Cannot get URL response: %s\n", err.Error())
return false, err
}
defer response.Body.Close()
dec := json.NewDecoder(response.Body)
if err := dec.Decode(&v); err != nil {
log.Printf("Parse error: %s\n", err.Error())
return false, err
}
k = time.Now().Unix()
color.Yellow("Updating chatters")
}
//fmt.Printf("%q\n", v)
chats := v["chatters"].(map[string]interface{})
views := chats["viewers"].([]interface{})
mods := chats["moderators"].([]interface{})
for _, b := range views {
if b == strings.ToLower(name) {
return true, nil
}
}
for _, b := range mods {
if b == strings.ToLower(name) {
return true, nil
}
}
return false, nil
}
开发者ID:laam4,项目名称:mariomaker-twitch,代码行数:35,代码来源:db.go
示例14: writeLevelDB
func writeLevelDB(channel string, userName string, userMessage string, levelId string) {
chanId := channels[channel]
//Check for duplicate LevelId for this channel
var duplicateLevel string
checkDuplicate := db.QueryRow("SELECT Level FROM Levels WHERE Level=? AND StreamID=?;", levelId, chanId).Scan(&duplicateLevel)
switch {
case checkDuplicate == sql.ErrNoRows:
color.Green("No such level, Adding...\n")
insertLevel, dberr := db.Prepare("INSERT Levels SET StreamID=?,Nick=?,Level=?,Message=?,Added=?;")
if dberr != nil {
log.Fatalf("Cannot prepare insertLevel on %s: %s\n", channel, dberr.Error())
}
defer insertLevel.Close()
timeNow := time.Now().Format(time.RFC3339)
execLevel, dberr := insertLevel.Exec(chanId, userName, levelId, userMessage, timeNow)
if dberr != nil {
log.Fatalf("Cannot exec insertLevel on %s: %s\n", channel, dberr.Error())
}
rowsAff, dberr := execLevel.RowsAffected()
if dberr != nil {
log.Fatalf("No rows changed on %s: %s\n", channel, dberr.Error())
}
lastId, dberr := execLevel.LastInsertId()
if dberr != nil {
log.Fatalf("No last id on %s: %s\n", channel, dberr.Error())
}
color.Green("Added level %s by %s for %d %s. Row|#: %d|%d\n", levelId, userName, chanId, channel, rowsAff, lastId)
case checkDuplicate != nil:
log.Fatalf("Checking duplicate level failed, error: %s\n", checkDuplicate.Error())
default:
color.Yellow("Duplicate level, not adding...\n")
}
}
开发者ID:carriercomm,项目名称:mariomaker-twitch,代码行数:33,代码来源:db.go
示例15: main
func main() {
color.Yellow("Job Worker Client")
jobworker.Run()
}
开发者ID:rohanraja,项目名称:jobworker,代码行数:7,代码来源:main.go
示例16: main
func main() {
argsWithoutProg := os.Args[1:]
if len(argsWithoutProg) == 0 {
fmt.Println("Usage: go run sum.go filter")
return
}
filter := strings.Join(argsWithoutProg, " ")
file, err := os.Open("diff.txt")
check(err)
defer file.Close()
var added, removed uint64
re, err := regexp.Compile(`(.+)\:`)
scanner := bufio.NewScanner(file)
for scanner.Scan() {
line := scanner.Text()
if len(line) > 3 && strings.Contains(line[3:], filter) {
if line[0:3] == "Inc" || line[0:3] == "New" {
res := re.FindStringSubmatch(line[4:])
if len(res) > 0 {
added += SizeInBytes(res[1])
}
} else if line[0:3] == "Dec" || line[0:3] == "Rem" {
res := re.FindStringSubmatch(line[4:])
if len(res) > 0 {
removed += SizeInBytes(res[1])
}
}
}
}
color.Green("Added: " + bytefmt.ByteSize(added))
color.Yellow("Removed: " + bytefmt.ByteSize(removed))
diff := int64(added) - int64(removed)
if diff < 0 {
color.Yellow("= Net total: -" + bytefmt.ByteSize(uint64(-diff)))
} else {
color.Green("= Net total: " + bytefmt.ByteSize(uint64(diff)))
}
}
开发者ID:davidhq,项目名称:snapshots,代码行数:47,代码来源:sum.go
示例17: writeLevelDB
func writeLevelDB(channel string, userName string, userMessage string, levelID string) {
chanID := channels[channel]
//Check for duplicate LevelId for this channel
var duplicateLevel string
var info map[string]string
var exist bool
info = make(map[string]string)
err := try.Do(func(attempt int) (bool, error) {
var err error
info, exist, err = fetchInfo(levelID)
return attempt < 5, err // try 5 times
})
if err != nil {
log.Println("Error: " + err.Error())
} else if exist {
checkDuplicate := db.QueryRow("SELECT Level FROM Levels WHERE Level=? AND StreamID=?;", levelID, chanID).Scan(&duplicateLevel)
switch {
case checkDuplicate == sql.ErrNoRows:
color.Green("No such level, Adding...\n")
insertLevel, dberr := db.Prepare("INSERT Levels SET StreamID=?,Nick=?,Level=?,Message=?,Added=?,Removed=?,Title=?,Difficulty=?,Style=?,Creator=?,Flag=?,Created=?,Tags=?,Image=?,ImageFull=?;")
if dberr != nil {
log.Fatalf("Cannot prepare insertLevel on %s: %s\n", channel, dberr.Error())
}
defer insertLevel.Close()
timeNow := time.Now().Format(time.RFC3339)
execLevel, dberr := insertLevel.Exec(chanID, userName, levelID, userMessage, timeNow, 0, info["title"], info["diff"], info["style"], info["name"], info["flag"], info["created"], info["tags"], info["img"], info["imgfull"])
if dberr != nil {
log.Fatalf("Cannot exec insertLevel on %s: %s\n", channel, dberr.Error())
}
rowsAff, dberr := execLevel.RowsAffected()
if dberr != nil {
log.Fatalf("No rows changed on %s: %s\n", channel, dberr.Error())
}
lastID, dberr := execLevel.LastInsertId()
if dberr != nil {
log.Fatalf("No lastID on %s: %s\n", channel, dberr.Error())
}
color.Green("Added level %s by %s for %d %s. Row|#: %d|%d\n", levelID, userName, chanID, channel, rowsAff, lastID)
case checkDuplicate != nil:
log.Fatalf("Checking duplicate level failed, error: %s\n", checkDuplicate.Error())
default:
color.Yellow("Duplicate level, not adding...\n")
}
} else {
color.Yellow("Level doesn't exist...\n")
}
}
开发者ID:laam4,项目名称:mariomaker-twitch,代码行数:47,代码来源:db.go
示例18: monitorHosts
func monitorHosts(interval int, execute string) {
color.Yellow("Monitoring %d hosts every %d seconds. Will invoke '%s' if any change.", flag.NArg(), interval, execute)
changes := make(chan string)
for _, hostname := range flag.Args() {
go monitor(hostname, interval, changes)
go react(hostname, execute, changes)
}
}
开发者ID:stevenharradine,项目名称:dns-reactor,代码行数:8,代码来源:dns-reactor.go
示例19: check4ForgeUpdate
func check4ForgeUpdate(moduleName string, currentVersion string, latestVersion string) {
Verbosef("found currently deployed Forge module " + moduleName + " in version: " + currentVersion)
Verbosef("found latest Forge module of " + moduleName + " in version: " + latestVersion)
if currentVersion != latestVersion {
color.Yellow("ATTENTION: Forge module: " + moduleName + " latest: " + latestVersion + " currently deployed: " + currentVersion)
needSyncForgeCount++
}
}
开发者ID:xorpaul,项目名称:g10k,代码行数:8,代码来源:forge.go
示例20: setupPagerduty
func setupPagerduty() {
if len(os.Getenv("PAGERDUTY_API_TOKEN")) == 0 ||
len(os.Getenv("PAGERDUTY_SERVICE_KEY")) == 0 {
color.Yellow("[>] Skipping Pagerduty setup, missing PAGERDUTY_API_TOKEN and PAGERDUTY_SERVICE_KEY")
return
}
pagerduty_api_token = os.Getenv("PAGERDUTY_API_TOKEN")
pagerduty_service_key = os.Getenv("PAGERDUTY_SERVICE_KEY")
}
开发者ID:joshrendek,项目名称:influx-alert,代码行数:10,代码来源:notifiers.go
注:本文中的github.com/fatih/color.Yellow函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论