v1

Documentation

Index

• func ParseGrpcOperator(ctx context.Context) string
• type DiscoverServer
  • func NewDiscoverServer(options ...Option) *DiscoverServer
  • func (g *DiscoverServer) DeregisterInstance(ctx context.Context, in *api.Instance) (*api.Response, error)
  • func (g *DiscoverServer) Discover(server api.PolarisGRPC_DiscoverServer) error
  • func (g *DiscoverServer) Heartbeat(ctx context.Context, in *api.Instance) (*api.Response, error)
  • func (g *DiscoverServer) RegisterInstance(ctx context.Context, in *api.Instance) (*api.Response, error)
  • func (g *DiscoverServer) ReportClient(ctx context.Context, in *api.Client) (*api.Response, error)
• type Option
  • 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

Functions

func ParseGrpcOperator

func ParseGrpcOperator(ctx context.Context) string

ParseGrpcOperator 构造请求源

Types

type DiscoverServer

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

func NewDiscoverServer

func NewDiscoverServer(options ...Option) *DiscoverServer

func (*DiscoverServer) DeregisterInstance

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

DeregisterInstance 反注册服务实例

func (*DiscoverServer) Discover

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

Discover 统一发现接口

func (*DiscoverServer) Heartbeat

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

Heartbeat 上报心跳

func (*DiscoverServer) RegisterInstance

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

RegisterInstance 注册服务实例

func (*DiscoverServer) ReportClient

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

ReportClient 客户端上报

type Option

type Option func(s *DiscoverServer)

func WithAllowAccess

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

func WithEnterRateLimit

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

func WithHealthCheckerServer

func WithHealthCheckerServer(svr *healthcheck.Server) Option

func WithNamingServer

func WithNamingServer(svr service.DiscoverServer) Option