mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-15 10:57:42 +00:00
Code Activity

zstd removed speedbestcompression opt

Browse source
This commit is contained in:
postmannen 2022-01-03 13:00:23 +01:00
parent f6e667dd82
commit c4aa08711a
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
process.go
View file

@ -362,7 +362,6 @@ func (p process) messageSubscriberHandler(natsConn *nats.Conn, thisNode string,
// fmt.Printf(" * DEBUG: ok = %v, map = %v, len of val = %v\n", ok, msg.Header, len(val)) // fmt.Printf(" * DEBUG: ok = %v, map = %v, len of val = %v\n", ok, msg.Header, len(val))
switch val[0] { switch val[0] {
case "z": case "z":
fmt.Println(" ******** READING ZSTD ************")
zr, err := zstd.NewReader(nil) zr, err := zstd.NewReader(nil)
if err != nil { if err != nil {
log.Printf("error: zstd NewReader failed: %v\n", err) log.Printf("error: zstd NewReader failed: %v\n", err)
@ -380,7 +379,6 @@ func (p process) messageSubscriberHandler(natsConn *nats.Conn, thisNode string,
zr.Close() zr.Close()
case "g": case "g":
fmt.Println(" ******** READING GZIP ************")
r := bytes.NewReader(msgData) r := bytes.NewReader(msgData)
gr, err := gzip.NewReader(r) gr, err := gzip.NewReader(r)
if err != nil { if err != nil {
@ -575,7 +573,8 @@ func (p process) publishMessages(natsConn *nats.Conn) {
// encoder for all messages. // encoder for all messages.
switch p.configuration.Compression { switch p.configuration.Compression {
case "z": // zstd case "z": // zstd
enc, err := zstd.NewWriter(nil, zstd.WithEncoderLevel(zstd.SpeedBestCompression)) // enc, err := zstd.NewWriter(nil, zstd.WithEncoderLevel(zstd.SpeedBestCompression))
enc, err := zstd.NewWriter(nil)
if err != nil { if err != nil {
log.Printf("error: zstd new encoder failed: %v\n", err) log.Printf("error: zstd new encoder failed: %v\n", err)
os.Exit(1) os.Exit(1)
@ -658,6 +657,8 @@ func (p process) publishMessages(natsConn *nats.Conn) {
natsMsgPayloadCompressed = zEnc.EncodeAll(natsMsgPayloadSerialized, nil) natsMsgPayloadCompressed = zEnc.EncodeAll(natsMsgPayloadSerialized, nil)
natsMsgHeader["cmp"] = []string{p.configuration.Compression} natsMsgHeader["cmp"] = []string{p.configuration.Compression}
zEnc.Reset(nil)
case "g": // gzip case "g": // gzip
var buf bytes.Buffer var buf bytes.Buffer
gzipW := gzip.NewWriter(&buf) gzipW := gzip.NewWriter(&buf)