Compare commits

...

6 Commits

Author SHA1 Message Date
lzf
e2781cde50 Merge branch 'main' of ssh://git.makemake.in:5566/kzkzzzz/mycommon 2026-03-20 09:55:00 +08:00
lzf
fecb52d12c update 2026-03-20 09:54:17 +08:00
kzkzzzz
e95976a4db update 2026-02-27 00:37:04 +08:00
kzkzzzz
e496e76ee7 update 2026-02-27 00:36:14 +08:00
kzkzzzz
9560131870 update 2026-02-27 00:29:16 +08:00
kzkzzzz
9b20ffc450 update 2026-02-27 00:26:14 +08:00
3 changed files with 17 additions and 7 deletions

View File

@@ -14,6 +14,7 @@ const (
HeaderOrigin = "Origin" HeaderOrigin = "Origin"
HeaderReferer = "Referer" HeaderReferer = "Referer"
HeaderAcceptLanguage = "Accept-Language" HeaderAcceptLanguage = "Accept-Language"
HeaderAcceptEncoding = "Accept-Encoding"
ContentTypeJSON = "application/json; charset=utf-8" ContentTypeJSON = "application/json; charset=utf-8"
) )

View File

@@ -25,18 +25,18 @@ var (
func init() { func init() {
defaultClient = New() defaultClient = New()
defaultNoRedirectClient = New(WithNoRedirect()) defaultNoRedirectClient = New(WithNoRedirect(), WithNoCheckStatus(true))
} }
func ReInitDefault(timeout time.Duration) { func ReInitDefault(timeout time.Duration) {
defaultClient = New(WithTimout(timeout)) defaultClient = New(WithTimout(timeout))
defaultNoRedirectClient = New(WithNoRedirect(), WithTimout(timeout)) defaultNoRedirectClient = New(WithNoRedirect(), WithNoCheckStatus(true), WithTimout(timeout))
} }
func ReInitDefaultOpt(opts ...ConfigOpt) { func ReInitDefaultOpt(opts ...ConfigOpt) {
defaultClient = New(opts...) defaultClient = New(opts...)
defaultNoRedirectClient = New(slices.Concat([]ConfigOpt{WithNoRedirect()}, opts)...) defaultNoRedirectClient = New(slices.Concat([]ConfigOpt{WithNoRedirect(), WithNoCheckStatus(true)}, opts)...)
} }
@@ -221,6 +221,15 @@ func (r *Request) SetCookieMap(cookiesMap map[string]*http.Cookie) *Request {
return r return r
} }
func (r *Request) SetHtmlHeaders() *Request {
r.SetHeaders(map[string]string{
HeaderAccept: AcceptHtml,
HeaderAcceptLanguage: AcceptCNLanguage,
HeaderAcceptEncoding: AcceptEncodingIdentity,
})
return r
}
func (r *Request) SetHeaders(headers map[string]string) *Request { func (r *Request) SetHeaders(headers map[string]string) *Request {
for k, v := range headers { for k, v := range headers {
r.SetHeader(k, v) r.SetHeader(k, v)

View File

@@ -2,12 +2,12 @@ package consul
import ( import (
"fmt" "fmt"
"sort"
"time"
"github.com/hashicorp/consul/api" "github.com/hashicorp/consul/api"
"github.com/pkg/errors" "github.com/pkg/errors"
"google.golang.org/grpc/resolver" "google.golang.org/grpc/resolver"
"sort"
"strings"
"time"
) )
const schemeName = "consul" const schemeName = "consul"
@@ -116,7 +116,7 @@ func (c *consulResolver) watchService() {
if err != nil { if err != nil {
defaultLog.Errorf("%s update service state err: %s", err, c.tgt.String()) defaultLog.Errorf("%s update service state err: %s", err, c.tgt.String())
} else { } else {
defaultLog.Infof("%s update service num:%d (%s)", c.tgt.String(), len(addrs), strings.Join(addrs, ", ")) //defaultLog.Infof("%s update service num:%d (%s)", c.tgt.String(), len(addrs), strings.Join(addrs, ", "))
} }