basethird

Documentation

Index

• type HttpThird
  • func (a *HttpThird) Delete(api string, params map[string]interface{}, opts ...*grequests.RequestOptions) (*Response, error)
  • 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) 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) SetTLSClientConfig(cfg *tls.Config)
• type PostFile
  • func (p PostFile) Value(name string) (f grequests.FileUpload, e error)
• type 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) Call(f func(conn *grpc.ClientConn, ctx context.Context) (proto.Message, error), ...) (proto.Message, error)
  • func (a *RpcThird) GetConn() (*grpc.ClientConn, error)
  • func (a *RpcThird) GetCtx() (context.Context, context.CancelFunc)
  • func (a *RpcThird) SetAfterUnaryClientInterceptor(unary UnaryClientInterceptor)
  • func (a *RpcThird) SetBeforeStreamClientInterceptor(stream StreamClientInterceptor)
  • func (a *RpcThird) SetBeforeUnaryClientInterceptor(unary UnaryClientInterceptor)
  • func (a *RpcThird) SetLogInfoFlag(on bool)
• type StreamClientInterceptor
• type UnaryClientInterceptor

Types

type HttpThird

type HttpThird struct {
	Domain           string
	Hostname         string
	ConnectTimeout   int
	ReadWriteTimeout int
	// contains filtered or unexported fields
}

封装 http 接口的基础类

func (*HttpThird) Delete

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

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) 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) SetTLSClientConfig

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

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 (*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) Call

func (a *RpcThird) Call(f func(conn *grpc.ClientConn, ctx context.Context) (proto.Message, error), params interface{}) (proto.Message, error)

func (*RpcThird) GetConn

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

func (*RpcThird) GetCtx

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

func (*RpcThird) SetAfterUnaryClientInterceptor

func (a *RpcThird) SetAfterUnaryClientInterceptor(unary UnaryClientInterceptor)

func (*RpcThird) SetBeforeStreamClientInterceptor

func (a *RpcThird) SetBeforeStreamClientInterceptor(stream StreamClientInterceptor)

func (*RpcThird) SetBeforeUnaryClientInterceptor

func (a *RpcThird) SetBeforeUnaryClientInterceptor(unary UnaryClientInterceptor)

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