rpcx

type Client interface {
	Next() (*grpc.ClientConn, bool)
}

type ClientOption func(options *ClientOptions)

type ClientOptions struct {
	Timeout     time.Duration
	DialOptions []grpc.DialOption
}

type DirectClient struct {
	// contains filtered or unexported fields
}

type RegisterFn func(*grpc.Server)

type RpcServer struct {
	// contains filtered or unexported fields
}

type Server interface {
	AddOptions(options ...grpc.ServerOption)
	AddStreamInterceptors(interceptors ...grpc.StreamServerInterceptor)
	AddUnaryInterceptors(interceptors ...grpc.UnaryServerInterceptor)
	Start(register RegisterFn) error
}