1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
| 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
| }
|
|
