grpc

Documentation

Index

• type Client
  • func NewClient(address string) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) DeregisterInstance(instance *api.Instance) error
  • func (c *Client) Discover(drt api.DiscoverRequest_DiscoverRequestType, service *api.Service, ...) error
  • func (c *Client) DiscoverRequest(request *api.DiscoverRequest) (*api.DiscoverResponse, error)
  • func (c *Client) GetConfigFile(ctx context.Context, in *api.ClientConfigFileInfo) (*api.ConfigClientResponse, error)
  • func (c *Client) Heartbeat(instance *api.Instance) error
  • func (c *Client) RegisterInstance(instance *api.Instance) error
  • func (c *Client) ReportClient(client *api.Client) error
  • func (c *Client) WatchConfigFiles(ctx context.Context, in *api.ClientWatchConfigFileRequest) (*api.ConfigClientResponse, error)

Types

type Client

type Client struct {
	Conn         *grpc.ClientConn
	ConfigConn   *grpc.ClientConn
	Worker       api.PolarisGRPCClient
	ConfigWorker api.PolarisConfigGRPCClient
}

Client GRPC客户端

func NewClient

func NewClient(address string) (*Client, error)

NewClient 创建GRPC客户端

func (*Client) Close

func (c *Client) Close()

Close 关闭连接

func (*Client) DeregisterInstance

func (c *Client) DeregisterInstance(instance *api.Instance) error

DeregisterInstance 反注册服务实例

func (*Client) Discover

func (c *Client) Discover(drt api.DiscoverRequest_DiscoverRequestType, service *api.Service, hook func(resp *api.DiscoverResponse)) error

Discover 统一发现函数

func (*Client) DiscoverRequest

func (c *Client) DiscoverRequest(request *api.DiscoverRequest) (*api.DiscoverResponse, error)

DiscoverRequest 统一发现函数

func (*Client) GetConfigFile

func (c *Client) GetConfigFile(ctx context.Context, in *api.ClientConfigFileInfo) (*api.ConfigClientResponse, error)

func (*Client) Heartbeat

func (c *Client) Heartbeat(instance *api.Instance) error

Heartbeat 上报心跳

func (*Client) RegisterInstance

func (c *Client) RegisterInstance(instance *api.Instance) error

RegisterInstance 注册服务实例

func (*Client) ReportClient

func (c *Client) ReportClient(client *api.Client) error

ReportClient 上报客户端信息

func (*Client) WatchConfigFiles

func (c *Client) WatchConfigFiles(ctx context.Context, in *api.ClientWatchConfigFileRequest) (*api.ConfigClientResponse, error)

订阅配置变更