聊聊dubbo-go的broadcastCluster

type broadcastCluster struct{}

const broadcast = "broadcast"

func init() {
    extension.SetCluster(broadcast, NewBroadcastCluster)
}

// NewBroadcastCluster ...
func NewBroadcastCluster() cluster.Cluster {
    return &broadcastCluster{}
}

func (cluster *broadcastCluster) Join(directory cluster.Directory) protocol.Invoker {
    return newBroadcastClusterInvoker(directory)
}

type broadcastClusterInvoker struct {
    baseClusterInvoker
}

func newBroadcastClusterInvoker(directory cluster.Directory) protocol.Invoker {
    return &broadcastClusterInvoker{
        baseClusterInvoker: newBaseClusterInvoker(directory),
    }
}

func (invoker *broadcastClusterInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result {
    invokers := invoker.directory.List(invocation)
    err := invoker.checkInvokers(invokers, invocation)
    if err != nil {
        return &protocol.RPCResult{Err: err}
    }
    err = invoker.checkWhetherDestroyed()
    if err != nil {
        return &protocol.RPCResult{Err: err}
    }

    var result protocol.Result
    for _, ivk := range invokers {
        result = ivk.Invoke(ctx, invocation)
        if result.Error() != nil {
            logger.Warnf("broadcast invoker invoke err: %v when use invoker: %vn", result.Error(), ivk)
            err = result.Error()
        }
    }
    if err != nil {
        return &protocol.RPCResult{Err: err}
    }
    return result
}