Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Compressor ¶
type Compressor struct {
// contains filtered or unexported fields
}
Compressor is used for compressing gRPC traffic using the snappy library. It implements the grpc.Compressor interface.
func NewCompressor ¶
func NewCompressor() *Compressor
NewCompressor creates a new Compressor instance.
func (*Compressor) Do ¶
func (c *Compressor) Do(writer io.Writer, data []byte) error
Do implements the grpc.Compressor interface, it compresses the data into the specified writer.
func (*Compressor) Type ¶
func (c *Compressor) Type() string
Type implements the grpc.Compressor interface, it returns the algorithm name used by the compressor.
type Decompressor ¶
type Decompressor struct {
// contains filtered or unexported fields
}
Decompressor is used for decompress gRPC traffic using the snappy library.
func NewDecompressor ¶
func NewDecompressor() *Decompressor
NewDecompressor creates a new decompressor instance. It implements the grpc.Decompressor interface.
func (*Decompressor) Do ¶
func (d *Decompressor) Do(reader io.Reader) ([]byte, error)
Do implements the grpc.Decompressor interface, it read the data from the reader and decompress it into the return []byte.
func (*Decompressor) Type ¶
func (d *Decompressor) Type() string
Type implements the grpc.Decompressor interface. It returns the compression algorithm used by the Decompressor.
Source Files
Directories