Visit Directly
Kitex can opt for direct access without service discovery when the downstream address is clear.
Specify RPC Host and Port
You can use callopt.WithHostPort
to specify host and port, supports two parameters:
- Normal IP address, in the form of
host:port
, supportIPv6
- Sock file address, communicating with UDS (Unix Domain Socket)
import "github.com/cloudwego/kitex/client/callopt"
...
resp, err := cli.Echo(context.Background(), req, callopt.WithHostPort("127.0.0.1:8888"))
if err != nil {
log.Fatal(err)
}
Specify RPC URL
You can use callopt.WithURL
to specify a URL, which will be resolved by default DNS resolver to get host and port. It’s functionally equal to callopt.WithHostPort
.
import "github.com/cloudwego/kitex/client/callopt"
...
url := callopt.WithURL("http://myserverdomain.com:8888")
resp, err := cli.Echo(context.Background(), req, url)
if err != nil {
log.Fatal(err)
}
Customized DNS resolver
You can also use your own DNS resolver
resolver interface(pkg/http):
type Resolver interface {
Resolve(string) (string, error)
}
The only parameter is URL,return value should be “host:port”.
You can use client.WithHTTPResolver
to specify DNS resolver.
import "github.com/cloudwego/kitex/client/callopt"
...
dr := client.WithHTTPResolver(myResolver)
cli, err := echo.NewClient("echo", dr)
if err != nil {
log.Fatal(err)
}
Last modified
April 18, 2023
: docs(wip): request context handler (36ea2d4)