Golang controller.Event类代码示例

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

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

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

示例1: AddInstanceListener

func (da *DemoApp) AddInstanceListener(event controller.Event) {
	if event.Type() != controller.AddInstanceEventType {
		panic("")
	}

	e := event.(*controller.AddInstanceEvent)
	for _, r := range da.Controller.Routers {
		instance := e.Instance

		port, ok := ServicePortMap[instance.Service]
		if !ok {
			log.Println("Unknown port for service:", instance.Service)
			continue
		}
		// TODO: debugging, delete it
		if r.Id() == "rr" {
			port = ":8081"
		}

		err := r.AddService(instance.Service, port, rIdPolicyMap[r.Id()])
		if err != nil {
			log.Println(err)
		}

		err = r.AddServiceInstance(instance.Service, instance)
		if err != nil {
			log.Println(err)
		}
	}
}

开发者ID:hongchaodeng，项目名称:raccoon，代码行数:30，代码来源:demoapp.go

示例2: FailureInstanceListener

func (da *DemoApp) FailureInstanceListener(event controller.Event) {
	if event.Type() != controller.FailureInstanceEventType {
		panic("")
	}

	e := event.(*controller.FailureInstanceEvent)

	log.Printf("Failure Instance: '%v', '%v'\n", e.Reporter, e.Instance)

	list := da.failureRecord[e.Instance.Name]
	for _, reporter := range list {
		if reporter == e.Reporter {
			log.Println(reporter, "has reported failure of", e.Instance.Name, "before")
			return
		}
	}

	list = append(list, e.Reporter)
	da.failureRecord[e.Instance.Name] = list

	if len(list) == len(da.Controller.Routers) {
		for _, r := range da.Controller.Routers {
			instance := e.Instance

			err := r.RemoveServiceInstance(instance.Service, instance)
			if err != nil {
				log.Println(err)
			}
		}
	}
}

开发者ID:hongchaodeng，项目名称:raccoon，代码行数:31，代码来源:demoapp.go

示例3: AddInstanceListener

// AddInstanceListener makes the Load Balancer know of the newly added service instance.
// It adds the service instances to the routers it knew.
// TODO: It assumes the new instance is newly created: which means no other router had it before.
func (lb *LoadBalancer) AddInstanceListener(event controller.Event) {
	if event.Type() != controller.AddInstanceEventType {
		panic("")
	}

	e := event.(*controller.AddInstanceEvent)
	for _, r := range lb.Controller.Routers {
		instance := e.Instance

		port, ok := ServicePortMap[instance.Service]
		if !ok {
			log.Println("Unknown port for service:", instance.Service)
			continue
		}

		err := r.AddService(instance.Service, port, router.NewRoundRobinPolicy())
		if err != nil {
			log.Println(err)
		}

		err = r.AddServiceInstance(instance.Service, instance)
		if err != nil {
			log.Println(err)
		}
	}
}

开发者ID:hongchaodeng，项目名称:raccoon，代码行数:29，代码来源:load_balancer.go

示例4: AddRouterListener

// AddRouterListener makes the Load Balancer know of the newly added router.
// It adds known service instances to the router and set service policy as round robin.
// TODO: It assumes the new router is newly created: which means it has no services.
func (lb *LoadBalancer) AddRouterListener(event controller.Event) {
	if event.Type() != controller.AddRouterEventType {
		panic("")
	}

	e := event.(*controller.AddRouterEvent)

	r := lb.Controller.Routers[e.Id]

	for service, instances := range lb.Controller.ServiceInstances {
		port, ok := ServicePortMap[service]
		if !ok {
			log.Println("Unknown port for service:", service)
			continue
		}
		err := r.AddService(service, port, router.NewRoundRobinPolicy())
		if err != nil {
			log.Println(err)
		}

		for _, instance := range instances {
			err := r.AddServiceInstance(service, instance)
			if err != nil {
				log.Println(err)
			}
		}
	}
}

开发者ID:hongchaodeng，项目名称:raccoon，代码行数:31，代码来源:load_balancer.go

示例5: FailureInstanceListener

func (lb *LoadBalancer) FailureInstanceListener(event controller.Event) {
	if event.Type() != controller.FailureInstanceEventType {
		panic("")
	}

	e := event.(*controller.FailureInstanceEvent)

	log.Printf("Failure Instance: '%v', '%v'", e.Reporter, e.Instance)
}

开发者ID:hongchaodeng，项目名称:raccoon，代码行数:9，代码来源:load_balancer.go

示例6: RmInstanceListener

func (da *DemoApp) RmInstanceListener(event controller.Event) {
	if event.Type() != controller.RmInstanceEventType {
		panic("")
	}

	e := event.(*controller.RmInstanceEvent)

	for _, r := range da.Controller.Routers {
		instance := e.Instance

		err := r.RemoveServiceInstance(instance.Service, instance)
		if err != nil {
			log.Println(err)
		}
	}
}

开发者ID:hongchaodeng，项目名称:raccoon，代码行数:16，代码来源:demoapp.go

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