96 lines
2.1 KiB
Go
96 lines
2.1 KiB
Go
package http
|
|
|
|
import (
|
|
"net"
|
|
"net/http"
|
|
|
|
"github.com/unistack-org/micro/v3/client"
|
|
)
|
|
|
|
var (
|
|
// DefaultPoolMaxStreams maximum streams on a connectioin
|
|
// (20)
|
|
DefaultPoolMaxStreams = 20
|
|
|
|
// DefaultPoolMaxIdle maximum idle conns of a pool
|
|
// (50)
|
|
DefaultPoolMaxIdle = 50
|
|
|
|
// DefaultMaxRecvMsgSize maximum message that client can receive
|
|
// (4 MB).
|
|
DefaultMaxRecvMsgSize = 1024 * 1024 * 4
|
|
|
|
// DefaultMaxSendMsgSize maximum message that client can send
|
|
// (4 MB).
|
|
DefaultMaxSendMsgSize = 1024 * 1024 * 4
|
|
)
|
|
|
|
type poolMaxStreams struct{}
|
|
type poolMaxIdle struct{}
|
|
type codecsKey struct{}
|
|
type tlsAuth struct{}
|
|
type maxRecvMsgSizeKey struct{}
|
|
type maxSendMsgSizeKey struct{}
|
|
|
|
// PoolMaxStreams maximum streams on a connectioin
|
|
func PoolMaxStreams(n int) client.Option {
|
|
return client.SetOption(poolMaxStreams{}, n)
|
|
}
|
|
|
|
// PoolMaxIdle maximum idle conns of a pool
|
|
func PoolMaxIdle(d int) client.Option {
|
|
return client.SetOption(poolMaxIdle{}, d)
|
|
}
|
|
|
|
// MaxRecvMsgSize set the maximum size of message that client can receive.
|
|
func MaxRecvMsgSize(s int) client.Option {
|
|
return client.SetOption(maxRecvMsgSizeKey{}, s)
|
|
}
|
|
|
|
// MaxSendMsgSize set the maximum size of message that client can send.
|
|
func MaxSendMsgSize(s int) client.Option {
|
|
return client.SetOption(maxSendMsgSizeKey{}, s)
|
|
}
|
|
|
|
type httpClientKey struct{}
|
|
|
|
func HTTPClient(c *http.Client) client.Option {
|
|
return client.SetOption(httpClientKey{}, c)
|
|
}
|
|
|
|
type httpDialerKey struct{}
|
|
|
|
func HTTPDialer(d *net.Dialer) client.Option {
|
|
return client.SetOption(httpDialerKey{}, d)
|
|
}
|
|
|
|
type methodKey struct{}
|
|
|
|
func Method(m string) client.CallOption {
|
|
return client.SetCallOption(methodKey{}, m)
|
|
}
|
|
|
|
type pathKey struct{}
|
|
|
|
func Path(p string) client.CallOption {
|
|
return client.SetCallOption(pathKey{}, p)
|
|
}
|
|
|
|
type bodyKey struct{}
|
|
|
|
func Body(b string) client.CallOption {
|
|
return client.SetCallOption(bodyKey{}, b)
|
|
}
|
|
|
|
type errorMapKey struct{}
|
|
|
|
func ErrorMap(m map[string]interface{}) client.CallOption {
|
|
return client.SetCallOption(errorMapKey{}, m)
|
|
}
|
|
|
|
type structTagsKey struct{}
|
|
|
|
func StructTags(tags []string) client.CallOption {
|
|
return client.SetCallOption(structTagsKey{}, tags)
|
|
}
|