| | |
|---|
| | | QueryEventGetDB = "GetDatabase" |
|---|
| | | QueryEventUpdateDBData = "UpdateDBData" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | // Agent warps the serf agent |
|---|
| | | type Agent struct { |
|---|
| | | *agent.Agent |
|---|
| | |
|---|
| | | //var res []*Rows |
|---|
| | | //json.Unmarshal(bytesReturn, &res) |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | default: |
|---|
| | | fmt.Printf("Unknown event type: %s\n", ev.EventType().String()) |
|---|
| | |
|---|
| | | time.Sleep(time.Second) |
|---|
| | | fmt.Println("Stats:",agent.Agent.Serf().Stats()) |
|---|
| | | fmt.Println("EncryptionEnabled:",agent.Agent.Serf().EncryptionEnabled()) |
|---|
| | | fmt.Printf("create agent sucess!!") |
|---|
| | | fmt.Println("create agent sucess!!") |
|---|
| | | |
|---|
| | | return agent, nil |
|---|
| | | } |
|---|
| | |
|---|
| | | |
|---|
| | | return nodes |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
