Versions in this module Expand all Collapse all v1 v1.5.4 Oct 26, 2023 Changes in this version + const DefaultMaxCallRecvMsgSize + const MaxMaxCallRecvMsgSize + type Connector struct + func (g *Connector) CreateConnection(address string, timeout time.Duration, clientInfo *network.ClientInfo) (network.ClosableConn, error) + func (g *Connector) DeRegisterServiceHandler(key *model.ServiceEventKey) error + func (g *Connector) DeregisterInstance(req *model.InstanceDeRegisterRequest) error + func (g *Connector) Destroy() error + func (g *Connector) GetConnectionManager() network.ConnectionManager + func (g *Connector) Heartbeat(req *model.InstanceHeartbeatRequest) error + func (g *Connector) Init(ctx *plugin.InitContext) error + func (g *Connector) IsEnable(cfg config.Configuration) bool + func (g *Connector) Name() string + func (g *Connector) RegisterInstance(req *model.InstanceRegisterRequest, header map[string]string) (*model.InstanceRegisterResponse, error) + func (g *Connector) RegisterServiceHandler(svcEventHandler *serverconnector.ServiceEventHandler) error + func (g *Connector) ReportClient(req *model.ReportClientRequest) (*model.ReportClientResponse, error) + func (g *Connector) Start() error + func (g *Connector) Type() common.Type + func (g *Connector) UpdateServers(key *model.ServiceEventKey) error
Go to main page