mirror of
https://github.com/weaveworks/scope.git
synced 2026-07-28 09:41:57 +00:00
0d917b2d8b
* New encoding format:
* Msgpack reports between probe<->app (smaller representation, faster to
encode/decode).
* Still use JSON between app<->UI (try to avoid making javascript deal with
mspack).
The app still suports publishing reports in both gob and JSON, not braking
backwards compatibility.
* Use compile-time generated marshallers/unmarshallers for higher performance. In
order to be able to skip code-generation for certain types, I included
https://github.com/2opremio/go-1/tree/master/codec/codecgen instead of
upstream until https://github.com/ugorji/go/pull/139 is merged.
* Encode/decode intermediate types using github.com/ugorji/go/codec.Selfer
for higher performance and reducing garbage collection (no temporary buffers).
35 lines
867 B
Go
35 lines
867 B
Go
package appclient
|
|
|
|
import (
|
|
"bytes"
|
|
"compress/gzip"
|
|
"github.com/ugorji/go/codec"
|
|
|
|
"github.com/weaveworks/scope/report"
|
|
)
|
|
|
|
// A ReportPublisher uses a buffer pool to serialise reports, which it
|
|
// then passes to a publisher
|
|
type ReportPublisher struct {
|
|
publisher Publisher
|
|
}
|
|
|
|
// NewReportPublisher creates a new report publisher
|
|
func NewReportPublisher(publisher Publisher) *ReportPublisher {
|
|
return &ReportPublisher{
|
|
publisher: publisher,
|
|
}
|
|
}
|
|
|
|
// Publish serialises and compresses a report, then passes it to a publisher
|
|
func (p *ReportPublisher) Publish(r report.Report) error {
|
|
buf := &bytes.Buffer{}
|
|
gzwriter := gzip.NewWriter(buf)
|
|
if err := codec.NewEncoder(gzwriter, &codec.MsgpackHandle{}).Encode(r); err != nil {
|
|
return err
|
|
}
|
|
gzwriter.Close() // otherwise the content won't get flushed to the output stream
|
|
|
|
return p.publisher.Publish(buf)
|
|
}
|