blob: 2ebc375597aef67b7605073b852ce53f68cb58e4 [file] [log] [blame]
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* See the License for the specific language governing permissions and
* limitations under the License.
package registry
import (
import (
func init() {
// ////////////////////////////////////////
// service event
// ////////////////////////////////////////
// ServiceEvent includes create, update, delete event
type ServiceEvent struct {
Action remoting.EventType
Service *common.URL
// store the key for Service.Key()
key string
// If the url is updated, such as Merged.
updated bool
// String return the description of event
func (e *ServiceEvent) String() string {
return fmt.Sprintf("ServiceEvent{Action{%s}, Path{%s}, Key{%s}}", e.Action, e.Service, e.key)
// Update() update the url with the merged URL. Work with Updated() can reduce the process of some merging URL.
func (e *ServiceEvent) Update(url *common.URL) {
e.Service = url
e.updated = true
// Updated() check if the url is updated.
// If the serviceEvent is updated, then it don't need merge url again.
func (e *ServiceEvent) Updated() bool {
return e.updated
// Key() generate the key for service.Key(). It is cached once.
func (e *ServiceEvent) Key() string {
if len(e.key) > 0 {
return e.key
e.key = e.Service.Key()
return e.key
// ServiceInstancesChangedEvent represents service instances make some changing
type ServiceInstancesChangedEvent struct {
ServiceName string
Instances []ServiceInstance
// String return the description of the event
func (s *ServiceInstancesChangedEvent) String() string {
return fmt.Sprintf("ServiceInstancesChangedEvent[source=%s]", s.ServiceName)
// NewServiceInstancesChangedEvent will create the ServiceInstanceChangedEvent instance
func NewServiceInstancesChangedEvent(serviceName string, instances []ServiceInstance) *ServiceInstancesChangedEvent {
return &ServiceInstancesChangedEvent{
BaseEvent: observer.BaseEvent{
Source: serviceName,
Timestamp: time.Now(),
ServiceName: serviceName,
Instances: instances,