v1

package

v1.18.1 Latest Latest Go to latest Published: May 23, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 3 more Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

func ParseGrpcOperator(ctx context.Context) string

ParseGrpcOperator 构造请求源

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

func NewDiscoverServer(options ...Option) *DiscoverServer

func (g *DiscoverServer) BatchDelHeartbeat(ctx context.Context,
	req *apiservice.DelHeartbeatsRequest) (*apiservice.DelHeartbeatsResponse, error)

BatchDelHeartbeat 批量删除心跳记录

func (g *DiscoverServer) BatchGetHeartbeat(ctx context.Context,
	req *apiservice.GetHeartbeatsRequest) (*apiservice.GetHeartbeatsResponse, error)

BatchGetHeartbeat 批量获取心跳记录

func (g *DiscoverServer) BatchHeartbeat(svr apiservice.PolarisHeartbeatGRPC_BatchHeartbeatServer) error

BatchHeartbeat 批量上报心跳

func (g *DiscoverServer) DeregisterInstance(
	ctx context.Context, in *apiservice.Instance) (*apiservice.Response, error)

DeregisterInstance 反注册服务实例

func (g *DiscoverServer) Discover(server apiservice.PolarisGRPC_DiscoverServer) error

Discover 统一发现接口

func (g *DiscoverServer) GetServiceContract(ctx context.Context, req *apiservice.ServiceContract) (*apiservice.Response, error)

查询服务契约

func (g *DiscoverServer) Heartbeat(ctx context.Context, in *apiservice.Instance) (*apiservice.Response, error)

Heartbeat 上报心跳

func (g *DiscoverServer) RegisterInstance(ctx context.Context, in *apiservice.Instance) (*apiservice.Response, error)

RegisterInstance 注册服务实例

func (g *DiscoverServer) ReportClient(ctx context.Context, in *apiservice.Client) (*apiservice.Response, error)

ReportClient 客户端上报

func (g *DiscoverServer) ReportServiceContract(ctx context.Context, in *apiservice.ServiceContract) (*apiservice.Response, error)

type Option func(s *DiscoverServer)

func WithAllowAccess(f func(method string) bool) Option

func WithEnterRateLimit(f func(ip string, method string) uint32) Option

func WithHealthCheckerServer(svr *healthcheck.Server) Option

func WithNamingServer(svr service.DiscoverServer) Option