rpcclient

package

v0.1.1 Latest Latest Go to latest Published: May 18, 2025 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func InitBuilder()

type Client struct {
	// grpc.ClientConn
	CliConn *grpc.ClientConn
	// contains filtered or unexported fields
}

func NewClient(opts ...ClientOptions) (*Client, error)

func (c *Client) Close(ctx context.Context) error

func (c *Client) Endpoint() string

type ClientOptions func(c *clientOptions)

ClientOptions defines the method to customize a clientOptions.

func WithBalancerName(name string) ClientOptions

func WithCounterVecOpts(opts *metric.CounterVecOpts) ClientOptions

func WithDiscovery(discovery registry.Discovery) ClientOptions

func WithEnableMetrics(enableMetrics bool) ClientOptions

func WithEnableTracing(enableTracing bool) ClientOptions

func WithEndpoint(endpoint string) ClientOptions

func WithHistogramVecOpts(opts *metric.HistogramVecOpts) ClientOptions

func WithInsecure(insecure bool) ClientOptions

func WithOptions(opts ...grpc.DialOption) ClientOptions

func WithStreamInterceptors(interceptors ...grpc.StreamClientInterceptor) ClientOptions

func WithTimeout(timeout time.Duration) ClientOptions

func WithUnaryInterceptors(interceptors ...grpc.UnaryClientInterceptor) ClientOptions

type RPCClientMethod interface {
	Endpoint() string
	Close(context.Context) error
}

RPCClientMethod interface 定义了 RPC 客户端的基本方法

type Trailer metadata.MD

Trailer is a grpc trailder MD.

func (t Trailer) Get(k string) string

Get get a grpc trailer value.