wesher/cluster/delegate.go

package cluster

import (
	"github.com/costela/wesher/common"
	"github.com/hashicorp/memberlist"
	"github.com/sirupsen/logrus"
)

// DelegateNode implements the memberlist delegation interface
type delegateNode struct {
	*common.Node
}

// NotifyConflict implements the memberlist.Delegate interface
func (n *delegateNode) NotifyConflict(node, other *memberlist.Node) {
	logrus.Errorf("node name conflict detected: %s", other.Name)
}

// NodeMeta implements the memberlist.Delegate interface
// Metadata is provided by the local node settings, encoding is handled
// by the node implementation directly
func (n *delegateNode) NodeMeta(limit int) []byte {
	encoded, err := n.EncodeMeta(limit)
	if err != nil {
		logrus.Errorf("failed to encode local node: %s", err)
		return nil
	}
	return encoded
}

// NotifyMsg implements the memberlist.Delegate interface
func (n *delegateNode) NotifyMsg([]byte) {}

// GetBroadcasts implements the memberlist.Delegate interface
func (n *delegateNode) GetBroadcasts(overhead, limit int) [][]byte { return nil }

// LocalState implements the memberlist.Delegate interface
func (n *delegateNode) LocalState(join bool) []byte { return nil }

// MergeRemoteState implements the memberlist.Delegate interface
func (n *delegateNode) MergeRemoteState(buf []byte, join bool) {}