unistack-org/micro-server-http
4
0
Fork 2
Code Issues 4 Pull Requests Packages Projects Releases 112 Wiki Activity

change set md

Browse Source
This commit is contained in:
Gorbunov Kirill Andreevich 2024-03-18 16:46:54 +03:00
parent 3e79e73eaa
commit 83fc7c54ca
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
handler/meter/meter.go
View File

@ -45,6 +45,7 @@ type Options struct {
Meter meter.Meter
Name string
MeterOptions []options.Option
Gzip bool
}
func Meter(m meter.Meter) Option {
@ -59,6 +60,12 @@ func Name(name string) Option {
}
}
func Gzip(g bool) Option {
return func(o *Options) {
o.Gzip = g
}
}
func MeterOptions(opts ...options.Option) Option {
return func(o *Options) {
o.MeterOptions = append(o.MeterOptions, opts...)
@ -66,7 +73,7 @@ func MeterOptions(opts ...options.Option) Option {
}
func NewOptions(opts ...Option) Options {
options := Options{Meter: meter.DefaultMeter}
options := Options{Meter: meter.DefaultMeter, Gzip: true}
for _, o := range opts {
o(&options)
}
@ -90,8 +97,9 @@ func (h *Handler) Metrics(ctx context.Context, req *codecpb.Frame, rsp *codecpb.
w := io.Writer(buf)
if md, ok := metadata.FromOutgoingContext(ctx); gzipAccepted(md) && ok {
md.Set(contentEncodingHeader, "gzip")
if md, ok := metadata.FromIncomingContext(ctx); gzipAccepted(md) && ok && h.opts.Gzip {
omd, _ := metadata.FromOutgoingContext(ctx)
omd.Set(contentEncodingHeader, "gzip")
gz := gzipPool.Get().(*gzip.Writer)
defer gzipPool.Put(gz)