Skip to content

Commit

Permalink
add comment for public method
Browse files Browse the repository at this point in the history
  • Loading branch information
cityiron committed Jul 29, 2020
1 parent 4a1625a commit 08c3674
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 0 deletions.
2 changes: 2 additions & 0 deletions cluster/cluster_impl/zone_aware_cluster.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,10 +36,12 @@ func NewZoneAwareCluster() cluster.Cluster {
return &zoneAwareCluster{}
}

// Join returns a zoneAwareClusterInvoker instance
func (cluster *zoneAwareCluster) Join(directory cluster.Directory) protocol.Invoker {
return newZoneAwareClusterInvoker(directory)
}

// Get cluster name
func GetZoneAwareName() string {
return zoneAware
}
1 change: 1 addition & 0 deletions cluster/cluster_impl/zone_aware_cluster_invoker.go
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@ func newZoneAwareClusterInvoker(directory cluster.Directory) protocol.Invoker {
}
}

// nolint
func (invoker *zoneAwareClusterInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result {
invokers := invoker.directory.List(invocation)

Expand Down

0 comments on commit 08c3674

Please sign in to comment.