grpc

package

v0.2.3 Latest Latest Go to latest Published: Apr 7, 2026 License: MIT Imports: 13 Imported by: 0

Details

View Source

const Type = "grpc"

This section is empty.

func BuildClientConfigIndex(dataCfg *conf.Data) (map[string]*conf.Data_Client_Endpoint, error)

BuildClientConfigIndex 预构建 gRPC 客户端配置索引，避免热路径重复遍历配置列表。

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

Connection gRPC 连接封装，实现 runtime.Connection。 conn 在构造后不可变，无需互斥锁保护。

func NewConnection(conn *gogrpc.ClientConn) *Connection

func (g *Connection) Close() error

Close 关闭底层 gRPC 连接并释放所有资源。

func (g *Connection) IsHealthy() bool

func (g *Connection) Value() any

type Plugin struct{}

func (p *Plugin) Build(_ context.Context, in runtime.ClientBuildInput) (runtime.ClientFactory, error)

func (p *Plugin) Type() string