Documentation ¶
Index ¶
- Constants
- func NewConn(target string, opt ...grpc.DialOption) (*grpc.ClientConn, error)
- func WithDialLogFlag(flag int8) grpc.DialOption
- func WithLogFlag(flag int8) grpc.CallOption
- type Client
- func (c *Client) Dial(ctx context.Context, target string, opts ...grpc.DialOption) (conn *grpc.ClientConn, err error)
- func (c *Client) DialTLS(ctx context.Context, target string, file string, name string, ...) (conn *grpc.ClientConn, err error)
- func (c *Client) SetConfig(conf *ClientConfig) (err error)
- func (c *Client) Use(handlers ...grpc.UnaryClientInterceptor) *Client
- func (c *Client) UseOpt(opts ...grpc.DialOption) *Client
- type ClientConfig
- type Server
- func (s *Server) GetValidate() *validator.Validate
- func (s *Server) RegisterValidation(key string, fn validator.Func) error
- func (s *Server) Run(addr string) error
- func (s *Server) RunUnix(file string) error
- func (s *Server) Serve(lis net.Listener) error
- func (s *Server) Server() *grpc.Server
- func (s *Server) SetConfig(conf *ServerConfig) (err error)
- func (s *Server) Shutdown(ctx context.Context) (err error)
- func (s *Server) Start() (*Server, error)
- func (s *Server) StartWithAddr() (*Server, net.Addr, error)
- func (s *Server) Use(handlers ...grpc.UnaryServerInterceptor) *Server
- type ServerConfig
- type TimeoutCallOption
Examples ¶
Constants ¶
const ( // disable all log. LogFlagDisable = 1 << iota // disable print args on log. LogFlagDisableArgs // disable info level log. LogFlagDisableInfo )
Warden Log Flag
Variables ¶
This section is empty.
Functions ¶
func NewConn ¶
func NewConn(target string, opt ...grpc.DialOption) (*grpc.ClientConn, error)
NewConn will create a grpc conn by default config.
func WithDialLogFlag ¶
func WithDialLogFlag(flag int8) grpc.DialOption
WithDialLogFlag set client level log behaviour.
func WithLogFlag ¶
func WithLogFlag(flag int8) grpc.CallOption
WithLogFlag disable client access log.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is the framework's client side instance, it contains the ctx, opt and interceptors. Create an instance of Client, by using NewClient().
Example ¶
package main import ( "context" "fmt" "time" "github.com/everxyz/kratos/pkg/log" "github.com/everxyz/kratos/pkg/net/netutil/breaker" "github.com/everxyz/kratos/pkg/net/rpc/warden" pb "github.com/everxyz/kratos/pkg/net/rpc/warden/internal/proto/testproto" xtime "github.com/everxyz/kratos/pkg/time" "google.golang.org/grpc" ) func main() { client := warden.NewClient(&warden.ClientConfig{ Dial: xtime.Duration(time.Second * 10), Timeout: xtime.Duration(time.Second * 10), Breaker: &breaker.Config{ Window: xtime.Duration(3 * time.Second), Bucket: 10, K: 1.5, Request: 20, }, }) // apply client interceptor middleware client.Use(func(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) (ret error) { newctx, cancel := context.WithTimeout(ctx, time.Second*5) defer cancel() ret = invoker(newctx, method, req, reply, cc, opts...) return }) conn, err := client.Dial(context.Background(), "127.0.0.1:8080") if err != nil { log.Error("did not connect: %v", err) return } defer conn.Close() c := pb.NewGreeterClient(conn) name := "2233" rp, err := c.SayHello(context.Background(), &pb.HelloRequest{Name: name, Age: 18}) if err != nil { log.Error("could not greet: %v", err) return } fmt.Println("rp", *rp) }
Output:
func DefaultClient ¶
func DefaultClient() *Client
DefaultClient returns a new default Client instance with a default client interceptor and default dialoption. opt can be used to add grpc dial options.
func NewClient ¶
func NewClient(conf *ClientConfig, opt ...grpc.DialOption) *Client
NewClient returns a new blank Client instance with a default client interceptor. opt can be used to add grpc dial options.
func (*Client) Dial ¶
func (c *Client) Dial(ctx context.Context, target string, opts ...grpc.DialOption) (conn *grpc.ClientConn, err error)
Dial creates a client connection to the given target. Target format is scheme://authority/endpoint?query_arg=value example: discovery://default/account.account.service?cluster=shfy01&cluster=shfy02
func (*Client) DialTLS ¶
func (c *Client) DialTLS(ctx context.Context, target string, file string, name string, opts ...grpc.DialOption) (conn *grpc.ClientConn, err error)
DialTLS creates a client connection over tls transport to the given target.
func (*Client) SetConfig ¶
func (c *Client) SetConfig(conf *ClientConfig) (err error)
SetConfig hot reloads client config
type ClientConfig ¶
type ClientConfig struct { Dial xtime.Duration Timeout xtime.Duration Breaker *breaker.Config Method map[string]*ClientConfig Clusters []string Zone string Subset int NonBlock bool KeepAliveInterval xtime.Duration KeepAliveTimeout xtime.Duration KeepAliveWithoutStream bool }
ClientConfig is rpc client conf.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server is the framework's server side instance, it contains the GrpcServer, interceptor and interceptors. Create an instance of Server, by using NewServer().
Example ¶
package main import ( "context" "io" "time" "github.com/everxyz/kratos/pkg/net/rpc/warden" pb "github.com/everxyz/kratos/pkg/net/rpc/warden/internal/proto/testproto" xtime "github.com/everxyz/kratos/pkg/time" "google.golang.org/grpc" ) type helloServer struct { } func (s *helloServer) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) { return &pb.HelloReply{Message: "Hello " + in.Name, Success: true}, nil } func (s *helloServer) StreamHello(ss pb.Greeter_StreamHelloServer) error { for i := 0; i < 3; i++ { in, err := ss.Recv() if err == io.EOF { return nil } if err != nil { return err } ret := &pb.HelloReply{Message: "Hello " + in.Name, Success: true} err = ss.Send(ret) if err != nil { return err } } return nil } func main() { s := warden.NewServer(&warden.ServerConfig{Timeout: xtime.Duration(time.Second), Addr: ":8080"}) // apply server interceptor middleware s.Use(func(ctx context.Context, req interface{}, args *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) { newctx, cancel := context.WithTimeout(ctx, time.Second*10) defer cancel() resp, err := handler(newctx, req) return resp, err }) pb.RegisterGreeterServer(s.Server(), &helloServer{}) s.Start() }
Output:
func NewServer ¶
func NewServer(conf *ServerConfig, opt ...grpc.ServerOption) (s *Server)
NewServer returns a new blank Server instance with a default server interceptor.
func (*Server) GetValidate ¶
func (s *Server) GetValidate() *validator.Validate
GetValidate return the default validate
func (*Server) RegisterValidation ¶
RegisterValidation adds a validation Func to a Validate's map of validators denoted by the key NOTE: if the key already exists, the previous validation function will be replaced. NOTE: this method is not thread-safe it is intended that these all be registered prior to any validation
func (*Server) Run ¶
Run create a tcp listener and start goroutine for serving each incoming request. Run will return a non-nil error unless Stop or GracefulStop is called.
func (*Server) RunUnix ¶
RunUnix create a unix listener and start goroutine for serving each incoming request. RunUnix will return a non-nil error unless Stop or GracefulStop is called.
func (*Server) Serve ¶
Serve accepts incoming connections on the listener lis, creating a new ServerTransport and service goroutine for each. Serve will return a non-nil error unless Stop or GracefulStop is called.
func (*Server) SetConfig ¶
func (s *Server) SetConfig(conf *ServerConfig) (err error)
SetConfig hot reloads server config
func (*Server) Shutdown ¶
Shutdown stops the server gracefully. It stops the server from accepting new connections and RPCs and blocks until all the pending RPCs are finished or the context deadline is reached.
func (*Server) Start ¶
Start create a new goroutine run server with configured listen addr will panic if any error happened return server itself
func (*Server) StartWithAddr ¶
StartWithAddr create a new goroutine run server with configured listen addr will panic if any error happened return server itself and the actually listened address (if configured listen port is zero, the os will allocate an unused port)
type ServerConfig ¶
type ServerConfig struct { // Network is grpc listen network,default value is tcp Network string `dsn:"network"` // Addr is grpc listen addr,default value is 0.0.0.0:9000 Addr string `dsn:"address"` // Timeout is context timeout for per rpc call. Timeout xtime.Duration `dsn:"query.timeout"` // IdleTimeout is a duration for the amount of time after which an idle connection would be closed by sending a GoAway. // Idleness duration is defined since the most recent time the number of outstanding RPCs became zero or the connection establishment. IdleTimeout xtime.Duration `dsn:"query.idleTimeout"` // MaxLifeTime is a duration for the maximum amount of time a connection may exist before it will be closed by sending a GoAway. // A random jitter of +/-10% will be added to MaxConnectionAge to spread out connection storms. MaxLifeTime xtime.Duration `dsn:"query.maxLife"` // ForceCloseWait is an additive period after MaxLifeTime after which the connection will be forcibly closed. ForceCloseWait xtime.Duration `dsn:"query.closeWait"` // KeepAliveInterval is after a duration of this time if the server doesn't see any activity it pings the client to see if the transport is still alive. KeepAliveInterval xtime.Duration `dsn:"query.keepaliveInterval"` // KeepAliveTimeout is After having pinged for keepalive check, the server waits for a duration of Timeout and if no activity is seen even after that // the connection is closed. KeepAliveTimeout xtime.Duration `dsn:"query.keepaliveTimeout"` // LogFlag to control log behaviour. e.g. LogFlag: warden.LogFlagDisableLog. // Disable: 1 DisableArgs: 2 DisableInfo: 4 LogFlag int8 `dsn:"query.logFlag"` }
ServerConfig is rpc server conf.
type TimeoutCallOption ¶
type TimeoutCallOption struct { *grpc.EmptyCallOption Timeout time.Duration }
TimeoutCallOption timeout option.
func WithTimeoutCallOption ¶
func WithTimeoutCallOption(timeout time.Duration) *TimeoutCallOption
WithTimeoutCallOption can override the timeout in ctx and the timeout in the configuration file
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
balancer
|
|
internal
|
|
benchmark/bench/proto
Package grpc is a generated protocol buffer package.
|
Package grpc is a generated protocol buffer package. |
proto/testproto
Package testproto is a generated protocol buffer package.
|
Package testproto is a generated protocol buffer package. |