include hostport/name to leader callback

cmd/demo/main.go

@@ -78,6 +78,9 @@ func main() {
 
 	op := hedge.New(client, ":8080", *spindleTable, *lockName, *logTable,
 		hedge.WithGroupSyncInterval(time.Second*5),
+		hedge.WithLeaderCallback(nil, func(d interface{}, m []byte) {
+			log.Println("callback:", string(m))
+		}),
 		hedge.WithLeaderHandler(
 			nil, // since this is nil, 'data' should be 'op'
 			func(data interface{}, msg []byte) ([]byte, error) {

hedge.go

@@ -363,7 +363,12 @@ func (op *Op) Run(ctx context.Context, done ...chan error) error {
 		fmt.Sprintf("hedge/spindle/lockname/%v", op.lockName),
 		spindle.WithDuration(op.lockTimeout),
 		spindle.WithId(op.hostPort),
-		spindle.WithLeaderCallback(op.cbLeaderData, op.cbLeader),
+		spindle.WithLeaderCallback(op.cbLeaderData, func(data interface{}, msg []byte) {
+			if op.cbLeader != nil {
+				m := fmt.Sprintf("%v %v", string(msg), op.Name())
+				op.cbLeader(data, []byte(m))
+			}
+		}),
 		spindle.WithLogger(op.logger),
 	)