mirror of
https://github.com/foomo/gotsrpc.git
synced 2025-10-16 12:35:35 +00:00
feat: add http in constructor (if required)
This commit is contained in:
parent
c18c777692
commit
aeba882310
@ -26,6 +26,14 @@ func NewClient() Client {
|
||||
return &bufferedClient{client: defaultHttpFactory(), handle: getHandleForEncoding(EncodingMsgpack)}
|
||||
}
|
||||
|
||||
func NewClientWithHttpClient(client *http.Client) Client {
|
||||
if client != nil {
|
||||
return &bufferedClient{client: client, handle: getHandleForEncoding(EncodingMsgpack)}
|
||||
} else {
|
||||
return &bufferedClient{client: defaultHttpFactory(), handle: getHandleForEncoding(EncodingMsgpack)}
|
||||
}
|
||||
}
|
||||
|
||||
func newRequest(url string, contentType string, reader io.Reader) (r *http.Request, err error) {
|
||||
request, errRequest := http.NewRequest("POST", url, reader)
|
||||
if errRequest != nil {
|
||||
|
||||
9
go.go
9
go.go
@ -436,12 +436,17 @@ func renderTSRPCServiceClients(services ServiceList, fullPackageName string, pac
|
||||
}
|
||||
|
||||
func New` + interfaceName + `(url string, endpoint string) ` + interfaceName + ` {
|
||||
return New` + interfaceName + `WithClient(url, "` + service.Endpoint + `", nil)
|
||||
}
|
||||
|
||||
func New` + interfaceName + `WithClient(url string, endpoint string, client *http.Client) ` + interfaceName + ` {
|
||||
return &` + clientName + `{
|
||||
URL: url,
|
||||
EndPoint: endpoint,
|
||||
Client: gotsrpc.NewClient(),
|
||||
Client: gotsrpc.NewClientWithHttpClient(client),
|
||||
}
|
||||
}`)
|
||||
}`)
|
||||
|
||||
//Render Methods
|
||||
|
||||
g.l(`
|
||||
|
||||
Loading…
Reference in New Issue
Block a user