Method SetHeader

pkg/ratelimit/grpc_test.go:47–54

(md metadata.MD)

}

func (ss *serverStream) SetHeader(md metadata.MD) error {
	a := assertions.New(ss.t)
	a.So(md.Get("x-rate-limit-limit"), should.NotBeEmpty)
	a.So(md.Get("x-rate-limit-available"), should.NotBeEmpty)
	a.So(md.Get("x-rate-limit-reset"), should.NotBeEmpty)
	a.So(md.Get("x-rate-limit-retry"), should.NotBeEmpty)
	return nil
}

func grpcClusterContext() context.Context {
	return metadata.NewIncomingContext(test.Context(), metadata.Pairs(