本文整理汇总了Golang中github.com/golang/glog.Infoln函数的典型用法代码示例。如果您正苦于以下问题:Golang Infoln函数的具体用法?Golang Infoln怎么用?Golang Infoln使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Infoln函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: switchCase
func switchCase() {
var arg = flag.String("foo", "", "...")
var bar int
flag.Lookup("logtostderr").Value.Set("true")
flag.Parse()
switch *arg {
case "":
case "+1":
bar = bar + 1
case "+2":
bar = bar + 2
default:
bar = bar + 3
}
switch bar {
case 0:
glog.Infoln("foo is nil, do nothing")
case 1:
glog.Infoln("foo is +1")
case 2:
glog.Infoln("foo is +2")
case 3:
glog.Infoln("foo is other case")
}
}
开发者ID:zykzhang,项目名称:practice,代码行数:26,代码来源:main.go
示例2: main
func main() {
flag.Parse()
glog.Infoln("START. Use 'botbot -help' for command line options.")
storage := common.NewPostgresStorage()
defer storage.Close()
queue := common.NewRedisQueue()
botbot := NewBotBot(storage, queue)
// Listen for incoming commands
go botbot.listen(LISTEN_QUEUE_PREFIX)
// Start the main loop
go botbot.mainLoop()
// Start and http server to serve the stats from expvar
log.Fatal(http.ListenAndServe(":3030", nil))
// Trap stop signal (Ctrl-C, kill) to exit
kill := make(chan os.Signal)
signal.Notify(kill, syscall.SIGINT, syscall.SIGKILL, syscall.SIGTERM)
// Wait for stop signal
for {
<-kill
glog.Infoln("Graceful shutdown")
botbot.shutdown()
break
}
glog.Infoln("Bye")
}
开发者ID:barkinet,项目名称:botbot-bot,代码行数:34,代码来源:main.go
示例3: useGet
func useGet(query string) {
uri := googleAPI + "?q=" + url.QueryEscape(query)
glog.Infoln("uri: ", uri)
resp, err := http.Get(uri)
glog.Infoln("err: ", err)
glog.Infof("resp: %#v", resp)
}
开发者ID:zykzhang,项目名称:practice,代码行数:7,代码来源:main.go
示例4: init
func init() {
if client, err := db.Client(); err != nil {
glog.Errorln(err)
} else {
defer db.Release(client)
{
if len(config.Cfg.Metrics.AddScript) > 0 {
if addSha, err = client.Cmd("SCRIPT", "LOAD", config.Cfg.Metrics.AddScript).Str(); err != nil {
glog.Errorln(err)
} else {
glog.Infoln("ADD SHA", addSha)
}
}
if len(config.Cfg.Metrics.GetScript) > 0 {
if getSha, err = client.Cmd("SCRIPT", "LOAD", config.Cfg.Metrics.GetScript).Str(); err != nil {
glog.Errorln(err)
} else {
glog.Infoln("GET SHA", getSha)
}
}
if len(config.Cfg.Metrics.TtlScript) > 0 {
if ttlSha, err = client.Cmd("SCRIPT", "LOAD", config.Cfg.Metrics.TtlScript).Str(); err != nil {
glog.Errorln(err)
} else {
glog.Infoln("TTL SHA", ttlSha)
}
}
}
}
}
开发者ID:EyckWigo,项目名称:yag,代码行数:32,代码来源:metrics.go
示例5: Dispatch
// Main loop for dispatching SyncQueue
// TODO exit
func Dispatch() {
var err error
for {
select {
case si := <-SyncQueue:
if si.FullSync {
syncAlbum(si)
} else if si, err = NewSyncItemPhoto(si.Filename); err != nil {
glog.Errorln(err)
} else {
syncAlbum(si)
}
case ai := <-AlbumQueue:
switch {
case ai.MetaUpdate:
glog.Infoln("Updating Album meta")
if err = updateMeta(ai.AlbumId); err != nil {
glog.Errorln(err)
} else {
glog.Infof("Metainfo was updated for albumId", ai.AlbumId)
}
case ai.StatusUpdate:
glog.Infoln("Reloading albums")
if err = updateAlbums(); err != nil {
glog.Errorln(err)
} else {
glog.Infoln("Albums were reloaded")
}
}
}
}
}
开发者ID:sergeyfast,项目名称:eazyphotod,代码行数:34,代码来源:sync.go
示例6: DelConn
// Implementing Pool interface
func (p *PGPool) DelConn(ws *websocket.Conn) error {
for i := range p.conns {
// Find connection
if p.conns[i] == ws {
// Remove connection
p.conns = append(p.conns[:i], p.conns[i+1:]...)
if glog.V(INFOLOG_LEVEL_ABOUT_CONNS) {
glog.Infoln("Connection was found and removed")
}
// Stop all child goroutines if empty pool
if p.IsEmpty() {
if glog.V(INFOLOG_LEVEL_ABOUT_POOLS) {
glog.Infoln("Pool is empty")
}
if p.cancel != nil {
p.cancel()
if glog.V(INFOLOG_LEVEL_ABOUT_POOLS) {
glog.Infoln("Pool goroutines was canceled")
}
} else {
glog.Errorln("CancelFunc is nil")
}
}
return nil
}
}
return errors.New("Cannot delete connection: " +
"connection was not found in pool")
}
开发者ID:ivan1993spb,项目名称:clever-snake,代码行数:35,代码来源:pool_factory.go
示例7: resourcesOffered
func (driver *MesosSchedulerDriver) resourcesOffered(from *upid.UPID, pbMsg proto.Message) {
log.V(2).Infoln("Handling resource offers.")
msg := pbMsg.(*mesos.ResourceOffersMessage)
if driver.status == mesos.Status_DRIVER_ABORTED {
log.Infoln("Ignoring ResourceOffersMessage, the driver is aborted!")
return
}
if !driver.connected {
log.Infoln("Ignoring ResourceOffersMessage, the driver is not connected!")
return
}
pidStrings := msg.GetPids()
if len(pidStrings) != len(msg.Offers) {
log.Errorln("Ignoring offers, Offer count does not match Slave PID count.")
return
}
for i, offer := range msg.Offers {
if pid, err := upid.Parse(pidStrings[i]); err == nil {
driver.cache.putOffer(offer, pid)
log.V(2).Infof("Cached offer %s from SlavePID %s", offer.Id.GetValue(), pid)
} else {
log.Warningf("Failed to parse offer PID '%v': %v", pid, err)
}
}
driver.withScheduler(func(s Scheduler) { s.ResourceOffers(driver, msg.Offers) })
}
开发者ID:basho-labs,项目名称:mesos-go,代码行数:31,代码来源:scheduler.go
示例8: StartCluster
// StartCluster starts a k8s cluster on the specified Host.
func StartCluster(h sshAble, ip string, config MachineConfig) error {
commands := []string{stopCommand, GetStartCommand(ip)}
if config.DeployRegistry {
commands = append(commands, `
cd /var/lib/minishift;
sudo /usr/local/bin/openshift admin registry --service-account=registry --config=openshift.local.config/master/admin.kubeconfig;
sudo /usr/local/bin/openshift cli patch service docker-registry -p '{"spec": {"type": "NodePort"}}' --config=openshift.local.config/master/admin.kubeconfig
`)
}
if config.DeployRouter {
commands = append(commands, `
cd /var/lib/minishift;
sudo /usr/local/bin/openshift admin policy add-scc-to-user hostnetwork -z router --config=openshift.local.config/master/admin.kubeconfig;
sudo /usr/local/bin/openshift admin router --service-account=router --config=openshift.local.config/master/admin.kubeconfig
`)
}
for _, cmd := range commands {
glog.Infoln(cmd)
output, err := h.RunSSHCommand(cmd)
glog.Infoln(output)
if err != nil {
return err
}
}
return nil
}
开发者ID:rawlingsj,项目名称:gofabric8,代码行数:28,代码来源:cluster.go
示例9: StatusUpdate
func (sched *ExampleScheduler) StatusUpdate(driver sched.SchedulerDriver, status *mesos.TaskStatus) {
log.Infoln("Status update: task", status.TaskId.GetValue(), " is in state ", status.State.Enum().String())
for _, task := range sched.tasks {
if task.name == status.TaskId.GetValue() &&
(status.GetState() == mesos.TaskState_TASK_FINISHED ||
status.GetState() == mesos.TaskState_TASK_LOST ||
status.GetState() == mesos.TaskState_TASK_KILLED ||
status.GetState() == mesos.TaskState_TASK_FAILED ||
status.GetState() == mesos.TaskState_TASK_ERROR) {
// No matter what the outcome was, move to finished state so that we can unreserve resources
task.state = FinishedState
}
}
if status.GetState() == mesos.TaskState_TASK_LOST ||
status.GetState() == mesos.TaskState_TASK_KILLED ||
status.GetState() == mesos.TaskState_TASK_FAILED ||
status.GetState() == mesos.TaskState_TASK_ERROR {
log.Infoln(
"Task", status.TaskId.GetValue(),
"is in unexpected state", status.State.String(),
"with message", status.GetMessage(),
". Unreserving resources",
)
}
}
开发者ID:cebufooddroid,项目名称:mesos-go,代码行数:27,代码来源:main.go
示例10: syncRuntime
// go run main.go -logtostderr
func syncRuntime() {
var wg sync.WaitGroup
var urls = []string{
"http://www.baidu.com/",
"http://dict.youdao.com/w/currency/#keyfrom=dict2.top",
"https://docs.mongodb.com/manual/mongo/",
"http://www.runoob.com/mongodb/mongodb-q,uery.html",
"http://studygolang.com/articles/2059",
}
glog.Infoln("fetching url..")
for _, url := range urls {
// Increment the WaitGroup counter.
wg.Add(1)
// Launch a goroutine to fetch the URL.
go func(url string) {
glog.Infoln("fetch url: ", url)
// Decrement the counter when the goroutine completes.
defer wg.Done()
// Fetch the URL.
r, _ := http.Get(url)
glog.Infoln("status: %s, code: %d, url is %s", r.Status, r.StatusCode, url)
}(url)
}
// Wait for all HTTP fetches to complete.
wg.Wait()
}
开发者ID:zykzhang,项目名称:practice,代码行数:27,代码来源:main.go
示例11: OpenNewTask
func (ecwrap *EngineContainerWrap) OpenNewTask(job string) (string, error) {
name := ecwrap.engineId + "_" + job
ecwrap.jobc = JobContext{
containerName: name,
dirname: path.Join(*jobsdir, name),
}
glog.Infoln("new task ", ecwrap.engineId, ecwrap.jobc.containerName, ecwrap.jobc.dirname)
// build container mount
if err := os.MkdirAll(ecwrap.jobc.dirname, 0700); err != nil {
glog.Infoln("could not create dir worker for engine", ecwrap.engineId, ecwrap.jobc.containerName, ecwrap.jobc.dirname)
return "", errors.New("error creating work dir")
}
docker_create_tokens := append(
append([]string{"create", "-v", name + ":" + ecwrap.MountPoint, "-u", strconv.Itoa(ecwrap.User), "--name", ecwrap.jobc.containerName}, ecwrap.RunFlags...),
[]string{ecwrap.Image, "/bin/bash", "-c", ecwrap.Cmd}...)
docker_create_cmd := exec.Command("docker", docker_create_tokens...)
docker_create_cmd.Stdout = os.Stdout
docker_create_cmd.Stderr = os.Stderr
glog.Infoln("volume create Command", docker_create_cmd.Args)
err := docker_create_cmd.Run()
if err != nil {
return "", err
}
glog.Infoln("create dir worker for engine", ecwrap.engineId, ecwrap.jobc.dirname)
return path.Join(ecwrap.jobc.dirname, ecwrap.InputFileName), nil
}
开发者ID:ibm-security-innovation,项目名称:menagerie,代码行数:28,代码来源:engine_container_wrap.go
示例12: Query
func Query(ctx context.Context, req *http.Request) (int, []byte, error) {
m := metric{}
defer func(m *metric) {
metricc <- *m
}(&m)
if glog.V(10) {
dump, _ := httputil.DumpRequest(req, true)
glog.Infoln(string(dump))
}
start := time.Now()
resp, err := ctxhttp.Do(ctx, nil, req)
m.latency = time.Since(start).Nanoseconds()
if err != nil {
return 0, nil, err
}
if glog.V(10) {
dump, _ := httputil.DumpResponse(resp, true)
glog.Infoln(string(dump))
}
defer resp.Body.Close()
body, err := ioutil.ReadAll(resp.Body)
if err != nil {
return 0, nil, err
}
m.bytes = len(body)
m.success = true
return resp.StatusCode, body, nil
}
开发者ID:Kaign,项目名称:newharv,代码行数:33,代码来源:web.go
示例13: Trigger
func (this *client) Trigger(t Trigger) (<-chan interface{}, chan<- int, error) {
stop := make(chan int)
events := make(chan interface{}, 8)
var cStop chan<- int
var cStopped <-chan error
var err error
switch t := t.(type) {
case Create:
cStop, cStopped, err = this.Watch(t.Path.String(),
func(e Event) {
if e.Type == EventNodeCreated {
events <- e
}
})
if err != nil {
return nil, nil, err
}
case Change:
cStop, cStopped, err = this.Watch(t.Path.String(),
func(e Event) {
if e.Type == EventNodeDataChanged {
events <- e
}
})
if err != nil {
return nil, nil, err
}
case Delete:
cStop, cStopped, err = this.Watch(t.Path.String(),
func(e Event) {
if e.Type == EventNodeDeleted {
events <- e
}
})
if err != nil {
return nil, nil, err
}
case Members:
// TODO - Implement the matching criteria using min/max/delta, etc.
cStop, cStopped, err = this.WatchChildren(t.Path.String(),
func(e Event) {
if e.Type == EventNodeChildrenChanged {
events <- e
}
})
if err != nil {
return nil, nil, err
}
}
go func() {
// Stop the watch
c := <-stop
cStop <- c
glog.Infoln("Waiting for user callbacks to finish")
<-cStopped
glog.Infoln("Stopped.")
}()
return events, stop, nil
}
开发者ID:conductant,项目名称:gohm,代码行数:60,代码来源:registry.go
示例14: restart
// Restart a chatbot
func (nm *NetworkManager) restart(botId int) {
glog.Infoln("Restarting bot ", botId)
var config *common.BotConfig
// Find configuration for this bot
botConfigs := nm.storage.BotConfig()
for _, botConf := range botConfigs {
if botConf.Id == botId {
config = botConf
break
}
}
if config == nil {
glog.Infoln("Could not find configuration for bot ", botId, ". Bot will not run.")
delete(nm.chatbots, botId)
return
}
nm.Lock()
nm.chatbots[botId] = nm.Connect(config)
nm.Unlock()
}
开发者ID:barkinet,项目名称:botbot-bot,代码行数:27,代码来源:network.go
示例15: setup
func setup() {
flag.Parse()
numCPU := runtime.NumCPU()
glog.Infoln("NumCPU", numCPU)
if envMaxProcs := os.Getenv("GOMAXPROCS"); envMaxProcs == "" {
if numCPU > 1 {
// Consuming N-1 appears to greatly reduce per-request latency in loaded systems.
runtime.GOMAXPROCS(numCPU - 1)
}
}
glog.Infoln("GOMAXPROCS", runtime.GOMAXPROCS(0))
var d db.DB
switch *useDB {
case "cassandra":
d = cassandradb.New()
default:
glog.Fatalln("Unknown DB:", *useDB)
}
if err := d.Init(); err != nil {
glog.Fatalln("An error occured Initializing the DB: ", err)
}
handlers.InitializeAndRegister(d)
}
开发者ID:meteorfox,项目名称:tsviewdb,代码行数:25,代码来源:main.go
示例16: StatusUpdate
func (sched *Scheduler) StatusUpdate(driver sched.SchedulerDriver, status *mesos.TaskStatus) {
log.Infoln("Status update: task", status.TaskId.GetValue(), " is in state ", status.State.Enum().String())
if status.GetState() == mesos.TaskState_TASK_FINISHED {
sched.tasksFinished++
log.Infoln("%v of %v tasks finished.", sched.tasksFinished, sched.totalTasks)
}
//TODO if a job is finished, failed, error, lost, killed
// figure out how this impacts dependent jobs and update job graph
/*
//never shut down framework!
if sched.tasksFinished >= sched.totalTasks {
log.Infoln("Total tasks completed, stopping framework.")
driver.Stop(false)
}
*/
/*
if status.GetState() == mesos.TaskState_TASK_LOST ||
status.GetState() == mesos.TaskState_TASK_KILLED ||
status.GetState() == mesos.TaskState_TASK_FAILED {
log.Infoln(
"Aborting because task", status.TaskId.GetValue(),
"is in unexpected state", status.State.String(),
"with message", status.GetMessage(),
)
driver.Abort()
}
*/
}
开发者ID:byxorna,项目名称:moroccron,代码行数:32,代码来源:scheduler.go
示例17: main
func main() {
httpAddr := flag.String("http", "127.0.0.1:5000", "address and port to listen on")
httpDocroot := flag.String("root", "www", "HTTP document root for static web files")
dataPath := flag.String("data", "/usr/local/var/lib/shadowcaster", "data directory (for indexes and such)")
flag.Parse()
Config = config{
IndexPath: *dataPath,
HTTPAddr: *httpAddr,
HTTPDocumentRoot: *httpDocroot}
// Run consistency checks on the indexes.
glog.Infoln("Running consistency checks on the indexes")
if err := CheckIndexes(*dataPath); err != nil {
glog.Fatalln(err)
}
glog.Infoln("Consistency checks passed")
// Set up the HTTP handling.
http.HandleFunc("/movies/", HandleMovies)
http.HandleFunc("/movies/setdir", HandleSetMovieDir)
http.HandleFunc("/movies/status", HandleMovieStatus)
http.HandleFunc("/tv/", HandleTV)
http.HandleFunc("/music/", HandleMusic)
http.HandleFunc("/pictures/", HandlePictures)
http.HandleFunc("/settings/", HandleSettings)
http.Handle("/", http.FileServer(http.Dir(*httpDocroot)))
glog.Infof("Listening on %v", *httpAddr)
if err := http.ListenAndServe(*httpAddr, nil); err != nil {
glog.Fatalln(err)
}
glog.Infof("ShadowCaster offline")
}
开发者ID:nesv,项目名称:go-shadowcaster,代码行数:33,代码来源:main.go
示例18: HandleStatusMessage
func (self *manager) HandleStatusMessage(statusMessage *mesosproto.StatusUpdateMessage) {
glog.Infof("Status Update %v\n", statusMessage)
status := statusMessage.GetUpdate().GetStatus()
switch {
case *status.State == mesosproto.TaskState_TASK_RUNNING:
task, _ := taskRegistry.Fetch(status.GetTaskId().GetValue())
task.Running = true
task.SlaveID = status.GetSlaveId().GetValue()
managerInterface.UpdateTaskWithDockerInfo(task, status.GetData())
case *status.State == mesosproto.TaskState_TASK_FAILED:
taskRegistry.Delete(status.GetTaskId().GetValue())
glog.Infoln("Task Failed: ", status.GetTaskId().GetValue())
case *status.State == mesosproto.TaskState_TASK_LOST:
switch {
case strings.Contains(status.GetMessage(), "Task has duplicate ID"):
// ignore
case strings.Contains(status.GetMessage(), "is no longer valid"):
task, _ := taskRegistry.Fetch(status.GetTaskId().GetValue())
task.RequestSent = false
default:
taskRegistry.Delete(status.GetTaskId().GetValue())
}
glog.Infoln("Task Lost: ", status.GetTaskId().GetValue())
case *status.State == mesosproto.TaskState_TASK_FINISHED:
taskRegistry.Delete(status.GetTaskId().GetValue())
glog.Infoln("Task Finished: ", status.GetTaskId().GetValue())
case *status.State == mesosproto.TaskState_TASK_KILLED:
taskRegistry.Delete(status.GetTaskId().GetValue())
glog.Infoln("Task Killed: ", status.GetTaskId().GetValue())
}
self.acknowledgeStatusUpdate(statusMessage)
}
开发者ID:lsheiba,项目名称:charmander-scheduler,代码行数:34,代码来源:manager.go
示例19: main
func main() {
flag.Parse()
buildInfo := version.BuildInfo()
flag.Usage = func() {
fmt.Fprintf(os.Stderr, "%s\n", buildInfo.Notice())
fmt.Fprintf(os.Stderr, "flags:\n")
flag.PrintDefaults()
}
glog.Infoln(buildInfo.Notice())
buildInfo.HandleFlag()
// Two server cores running on different ports. Note that quitquitquit will
// only shutdown the server requested but no the other one. Kernel signals
// will shutdown both.
stopped1 := startServer(*port)
stopped2 := startServer(*port + 1)
for range []int{1, 2} {
select {
case <-stopped1:
case <-stopped2:
}
}
glog.Infoln("Bye")
}
开发者ID:conductant,项目名称:gohm,代码行数:28,代码来源:server.go
示例20: frameworkReregistered
func (driver *MesosSchedulerDriver) frameworkReregistered(from *upid.UPID, pbMsg proto.Message) {
log.V(1).Infoln("Handling Scheduler re-registered event.")
msg := pbMsg.(*mesos.FrameworkReregisteredMessage)
if driver.status == mesos.Status_DRIVER_ABORTED {
log.Infoln("Ignoring FrameworkReregisteredMessage from master, driver is aborted!")
return
}
if driver.connected {
log.Infoln("Ignoring FrameworkReregisteredMessage from master,driver is already connected!")
return
}
if !driver.masterPid.Equal(from) {
log.Warningf("ignoring framework re-registered message because it was sent from '%v' instead of leading master '%v'", from, driver.masterPid)
return
}
// TODO(vv) detect if message was from leading-master (sched.cpp)
log.Infof("Framework re-registered with ID [%s] ", msg.GetFrameworkId().GetValue())
driver.connected = true
driver.failover = false
driver.connection = uuid.NewUUID()
driver.withScheduler(func(s Scheduler) { s.Reregistered(driver, msg.GetMasterInfo()) })
}
开发者ID:basho-labs,项目名称:mesos-go,代码行数:26,代码来源:scheduler.go
注:本文中的github.com/golang/glog.Infoln函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论