MCPcopy Create free account
hub / github.com/actiontech/dtle / Encode

Function Encode

driver/common/common.go:102–109  ·  view source on GitHub ↗
(v GencodeType)

Source from the content-addressed store, hash-verified

100 return buf.Bytes(), nil
101}
102func Encode(v GencodeType) ([]byte, error) {
103 bs, err := v.Marshal(nil)
104 if err != nil {
105 return nil, err
106 }
107
108 return Compress(bs)
109}
110
111func Decode(data []byte, out GencodeType) (err error) {
112 r, err := compress.NewReader(bytes.NewReader(data))

Callers 4

StreamEventsMethod · 0.92
sendFullCompleteMethod · 0.92
StreamEventsMethod · 0.92
sendFullCompleteMethod · 0.92

Calls 2

CompressFunction · 0.85
MarshalMethod · 0.65

Tested by

no test coverage detected