client

package

v0.2.2 Latest Latest Go to latest Published: Mar 27, 2026 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(
	NewDefaultClient,
)

ProviderSet 是客户端的依赖注入提供者集合。

func GetValue[T any](ctx context.Context, c Client, in runtime.ClientDialInput) (T, error)

GetValue 按 DialInput 建立连接并提取底层值。

func RegisterPlugins(r *runtime.Registry, plugins ...runtime.ClientPlugin) error

RegisterPlugins 批量注册 client plugin。

type Client interface {
	Dial(ctx context.Context, in runtime.ClientDialInput) (runtime.Connection, error)
}

Client 客户端接口。

func NewClient(
	dataCfg *conf.Data,
	traceCfg *conf.Trace,
	discovery registry.Discovery,
	l logger.Logger,
	opts ...Option,
) (Client, error)

func NewDefaultClient(
	dataCfg *conf.Data,
	traceCfg *conf.Trace,
	discovery registry.Discovery,
	l logger.Logger,
) (Client, error)

NewDefaultClient 使用内建插件和默认配置构建 Client，便于依赖注入场景直接使用。

type Option func(*options)

func WithMiddleware(mw ...middleware.Middleware) Option

WithMiddleware 追加 client 治理中间件。

func WithPlugins(plugins ...runtime.ClientPlugin) Option

WithPlugins 追加外部 client plugins。

func WithRegistry(r *runtime.Registry) Option

WithRegistry 注入已有 runtime registry。

func WithoutBuiltinPlugins() Option

WithoutBuiltinPlugins 关闭内建 client plugins 自动注册。