package serf

import "basic.com/valib/serf.git/serf"

func QueryMsg2Master(topic string, payload []byte) error {
	params := &serf.QueryParam{
		FilterNodes: nil,
		FilterTags:  map[string]string{"role": "master"},
		RequestAck:  false,
		RelayFactor: 0,
		Timeout:     10,
	}

	_, err := agent.Query(topic, payload, params)

	return err
}