| | |
|---|
| | | return |
|---|
| | | } |
|---|
| | | bytesReturn, err := json.Marshal(datas) |
|---|
| | | fmt.Println("results: ", bytesReturn) |
|---|
| | | fmt.Println("results.len: ", len(bytesReturn)) |
|---|
| | | if query, ok := event.(*serf.Query); ok { |
|---|
| | | if err := query.Respond(bytesReturn); err != nil { |
|---|
| | | fmt.Printf("err: %s\n", err) |
|---|
| | |
|---|
| | | } |
|---|
| | | fmt.Println("Query.resp.err:",err,"resp:",resp) |
|---|
| | | |
|---|
| | | //go func() { |
|---|
| | | // respCh := resp.ResponseCh() |
|---|
| | | // for { |
|---|
| | | // select { |
|---|
| | | // case r := <-respCh: |
|---|
| | | // fmt.Println("x length is: ", len(r.Payload)) |
|---|
| | | // // // byte to file. |
|---|
| | | // var dumpSqls []string |
|---|
| | | // err := json.Unmarshal(r.Payload, &dumpSqls) |
|---|
| | | // if err ==nil { |
|---|
| | | // if flag,_ := ExecuteSqlByGorm(dumpSqls);flag{ |
|---|
| | | // fmt.Println("data dump success") |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // return |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | //}() |
|---|
| | | go func() { |
|---|
| | | respCh := resp.ResponseCh() |
|---|
| | | for { |
|---|
| | | select { |
|---|
| | | case r := <-respCh: |
|---|
| | | fmt.Println("x length is: ", len(r.Payload)) |
|---|
| | | // // byte to file. |
|---|
| | | var dumpSqls []string |
|---|
| | | err := json.Unmarshal(r.Payload, &dumpSqls) |
|---|
| | | if err ==nil { |
|---|
| | | fmt.Println("dumpSql:",dumpSqls) |
|---|
| | | //if flag,_ := ExecuteSqlByGorm(dumpSqls);flag{ |
|---|
| | | // fmt.Println("data dump success") |
|---|
| | | //} |
|---|
| | | } |
|---|
| | | return |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }() |
|---|
| | | return err |
|---|
| | | |
|---|
| | | //r, err = c.Query([]string{query}, false, false) |
|---|
