basethird

Documentation

Index

• type Caller
• type HttpInterceptor
• type HttpThird
  • func (a *HttpThird) AddInterceptor(hi HttpInterceptor)
  • func (a *HttpThird) Delete(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)
  • func (a *HttpThird) DisableDefaultInterceptor()
  • func (a *HttpThird) Get(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)
  • func (a *HttpThird) Head(api string, opts ...*grequests.RequestOptions) (*Response, error)
  • func (a *HttpThird) InitConfig(configSection string) error
  • func (a *HttpThird) Options(api string, opts ...*grequests.RequestOptions) (*Response, error)
  • func (a *HttpThird) Patch(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)
  • func (a *HttpThird) Post(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)
  • func (a *HttpThird) Put(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)
  • func (a *HttpThird) SetBaseAuth(username, password string)
  • func (a *HttpThird) SetHeader(headers map[string]string)
  • func (a *HttpThird) SetLogInfoFlag(on bool)
  • func (a *HttpThird) SetMaxConnsPerHost(num int)
  • func (a *HttpThird) SetMaxIdleConnsPerHost(num int)
  • func (a *HttpThird) SetMaxLoggedRespSizeKb(size int64)
  • func (a *HttpThird) SetTLSClientConfig(cfg *tls.Config)
  • func (a *HttpThird) SetTLSInsecure()
• type PostFile
  • func (p PostFile) Value(name string) (f grequests.FileUpload, e error)
• type Response
  • func ErrResponse(err error) *Response
  • func (r *Response) JSON(v interface{}) error
  • func (r *Response) String() (string, error)
  • func (r *Response) ToJSON(v interface{}) error
• type RpcThird
  • func (a *RpcThird) AddStreamClientInterceptor(sci grpc.StreamClientInterceptor)
  • func (a *RpcThird) AddUnaryClientInterceptor(uci grpc.UnaryClientInterceptor)
  • func (a *RpcThird) DisableDefaultStreamInterceptor()
  • func (a *RpcThird) DisableDefaultUnaryInterceptor()
  • func (a *RpcThird) GetConn() (*grpc.ClientConn, error)
  • func (a *RpcThird) GetCtx() (context.Context, context.CancelFunc)
  • func (a *RpcThird) InitConfig(configSection string) error
  • func (a *RpcThird) SetLogInfoFlag(on bool)
• type StreamClientInterceptor
• type UnaryClientInterceptor

Types

type Caller

type Caller func(method, uri string, ro *grequests.RequestOptions) (resp *Response, err error)

type HttpInterceptor

type HttpInterceptor func(method, uri string, ro *grequests.RequestOptions, call Caller) (*Response, error)

type HttpThird

type HttpThird struct {
	Address          string
	Hostname         string
	ConnectTimeout   int
	ReadWriteTimeout int
	SslOn            bool
	CertFile         string
	// contains filtered or unexported fields
}

封装 http 接口的基础类

func (*HttpThird) AddInterceptor

func (a *HttpThird) AddInterceptor(hi HttpInterceptor)

func (*HttpThird) Delete

func (a *HttpThird) Delete(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)

func (*HttpThird) DisableDefaultInterceptor

func (a *HttpThird) DisableDefaultInterceptor()

func (*HttpThird) Get

func (a *HttpThird) Get(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)

func (*HttpThird) Head

func (a *HttpThird) Head(api string, opts ...*grequests.RequestOptions) (*Response, error)

func (*HttpThird) InitConfig

func (a *HttpThird) InitConfig(configSection string) error

func (*HttpThird) Options

func (a *HttpThird) Options(api string, opts ...*grequests.RequestOptions) (*Response, error)

func (*HttpThird) Patch

func (a *HttpThird) Patch(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)

func (*HttpThird) Post

func (a *HttpThird) Post(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)

func (*HttpThird) Put

func (a *HttpThird) Put(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)

func (*HttpThird) SetBaseAuth

func (a *HttpThird) SetBaseAuth(username, password string)

func (*HttpThird) SetHeader

func (a *HttpThird) SetHeader(headers map[string]string)

func (*HttpThird) SetLogInfoFlag

func (a *HttpThird) SetLogInfoFlag(on bool)

设置是否要关闭 info 日志

func (*HttpThird) SetMaxConnsPerHost

func (a *HttpThird) SetMaxConnsPerHost(num int)

func (*HttpThird) SetMaxIdleConnsPerHost

func (a *HttpThird) SetMaxIdleConnsPerHost(num int)

func (*HttpThird) SetMaxLoggedRespSizeKb

func (a *HttpThird) SetMaxLoggedRespSizeKb(size int64)

func (*HttpThird) SetTLSClientConfig

func (a *HttpThird) SetTLSClientConfig(cfg *tls.Config)

func (*HttpThird) SetTLSInsecure

func (a *HttpThird) SetTLSInsecure()

type PostFile

type PostFile string

func (PostFile) Value

func (p PostFile) Value(name string) (f grequests.FileUpload, e error)

type Response

type Response struct {
	*grequests.Response
}

func ErrResponse

func ErrResponse(err error) *Response

func (*Response) JSON

func (r *Response) JSON(v interface{}) error

func (*Response) String

func (r *Response) String() (string, error)

func (*Response) ToJSON

func (r *Response) ToJSON(v interface{}) error

rewrite ToJSON then you can use ToJSON many times

type RpcThird

type RpcThird struct {
	sync.Mutex
	Address          string
	Timeout          int
	MaxRecvMsgsizeMb int
	MaxSendMsgsizeMb int
	SslOn            bool
	CertFile         string
	Hostname         string
	// contains filtered or unexported fields
}

封装 rpc 的基础类

func (*RpcThird) AddStreamClientInterceptor

func (a *RpcThird) AddStreamClientInterceptor(sci grpc.StreamClientInterceptor)

func (*RpcThird) AddUnaryClientInterceptor

func (a *RpcThird) AddUnaryClientInterceptor(uci grpc.UnaryClientInterceptor)

func (*RpcThird) DisableDefaultStreamInterceptor

func (a *RpcThird) DisableDefaultStreamInterceptor()

func (*RpcThird) DisableDefaultUnaryInterceptor

func (a *RpcThird) DisableDefaultUnaryInterceptor()

func (*RpcThird) GetConn

func (a *RpcThird) GetConn() (*grpc.ClientConn, error)

func (*RpcThird) GetCtx

func (a *RpcThird) GetCtx() (context.Context, context.CancelFunc)

func (*RpcThird) InitConfig

func (a *RpcThird) InitConfig(configSection string) error

func (*RpcThird) SetLogInfoFlag

func (a *RpcThird) SetLogInfoFlag(on bool)

设置是否要关闭 info 日志

type StreamClientInterceptor

type StreamClientInterceptor func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, opts ...grpc.CallOption) error

type UnaryClientInterceptor

type UnaryClientInterceptor func(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, opts ...grpc.CallOption) error