Golang utils.HostClient类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中github.com/flynn/flynn/controller/utils.HostClient类的典型用法代码示例。如果您正苦于以下问题：Golang HostClient类的具体用法？Golang HostClient怎么用？Golang HostClient使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了HostClient类的5个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: addHost

func (c *FakeCluster) addHost(h utils.HostClient) {
	c.hosts[h.ID()] = h

	for ch := range c.hostChannels {
		ch <- createDiscoverdEvent(h.ID(), discoverd.EventKindUp)
	}
}

开发者ID:imjorge，项目名称:flynn，代码行数:7，代码来源:fake_cluster.go

示例2: NewHost

func NewHost(h utils.HostClient) *Host {
	return &Host{
		ID:      h.ID(),
		client:  h,
		healthy: true,
		stop:    make(chan struct{}),
		done:    make(chan struct{}),
	}
}

开发者ID:rikur，项目名称:flynn，代码行数:9，代码来源:host.go

示例3: NewHost

func NewHost(h utils.HostClient, l log15.Logger) *Host {
	return &Host{
		ID:      h.ID(),
		Tags:    h.Tags(),
		client:  h,
		healthy: true,
		stop:    make(chan struct{}),
		done:    make(chan struct{}),
		logger:  l,
	}
}

开发者ID:eldarion-gondor，项目名称:cli，代码行数:11，代码来源:host.go

示例4: followHost

func (s *Scheduler) followHost(h utils.HostClient) error {
	if _, ok := s.hosts[h.ID()]; ok {
		return nil
	}

	host := NewHost(h)
	jobs, err := host.StreamEventsTo(s.jobEvents)
	if err != nil {
		return err
	}
	s.hosts[host.ID] = host

	for _, job := range jobs {
		s.handleActiveJob(&job)
	}

	s.triggerSyncFormations()

	return nil
}

开发者ID:solotzg，项目名称:flynn，代码行数:20，代码来源:scheduler.go

示例5: followHost

func (s *Scheduler) followHost(h utils.HostClient) {
	if _, ok := s.hostStreams[h.ID()]; ok {
		return
	}

	log := logger.New("fn", "followHost", "host.id", h.ID())
	log.Info("streaming job events")
	events := make(chan *host.Event)
	stream, err := h.StreamEvents("all", events)
	if err != nil {
		log.Error("error streaming job events", "err", err)
		return
	}
	s.hostStreams[h.ID()] = stream

	log.Info("getting active jobs")
	jobs, err := h.ListJobs()
	if err != nil {
		log.Error("error getting active jobs", "err", err)
		return
	}
	log.Info(fmt.Sprintf("got %d active job(s) for host %s", len(jobs), h.ID()))

	for _, job := range jobs {
		s.handleActiveJob(&job)
	}

	s.triggerSyncFormations()

	go func() {
		for e := range events {
			s.jobEvents <- e
		}
		// TODO: reconnect this stream unless unfollowHost was called gh#1921
		log.Error("job event stream closed unexpectedly")
	}()
}

开发者ID:joshteng，项目名称:flynn，代码行数:37，代码来源:scheduler.go

注：本文中的github.com/flynn/flynn/controller/utils.HostClient类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。