endpoints

Documentation

Overview

Package endpoints @Title 请填写文件名称（需要改） @Description 请填写文件描述（需要改） @Author yr 2024/8/29 下午6:24 @Update yr 2024/8/29 下午6:24

Package endpoints @Title title @Description desc @Author yr 2024/12/3 @Update yr 2024/12/3

Index

• type EndpointManager
  • func GetEndpointManager() *EndpointManager
  • func (em *EndpointManager) AddService(serverId int32, serviceId, serviceType, serviceName string, version int64, ...) *actor.PID
  • func (em *EndpointManager) GetSender(pid *actor.PID) inf.IRpcSender
  • func (em *EndpointManager) Init(eventProcessor inf.IEventProcessor) *EndpointManager
  • func (em *EndpointManager) RemoveService(pid *actor.PID)
  • func (em *EndpointManager) Select(sender *actor.PID, serverId int32, serviceId, serviceName string) inf.IBus
  • func (em *EndpointManager) SelectByFilterAndChoice(sender *actor.PID, filter func(pid *actor.PID) bool, ...) inf.IBus
  • func (em *EndpointManager) SelectByPid(sender, receiver *actor.PID) inf.IBus
  • func (em *EndpointManager) SelectByRule(sender *actor.PID, rule func(pid *actor.PID) bool) inf.IBus
  • func (em *EndpointManager) SelectByServiceType(sender *actor.PID, serverId int32, serviceType, serviceName string) inf.IBus
  • func (em *EndpointManager) Start()
  • func (em *EndpointManager) Stop()

Types

type EndpointManager

type EndpointManager struct {
	inf.IEventProcessor
	inf.IEventHandler
	// contains filtered or unexported fields
}

func GetEndpointManager

func GetEndpointManager() *EndpointManager

func (*EndpointManager) AddService

func (em *EndpointManager) AddService(serverId int32, serviceId, serviceType, serviceName string, version int64, rpcType string, rpcHandler inf.IRpcHandler) *actor.PID

AddService 添加本地服务到服务发现中

func (*EndpointManager) GetSender

func (em *EndpointManager) GetSender(pid *actor.PID) inf.IRpcSender

func (*EndpointManager) Init

func (em *EndpointManager) Init(eventProcessor inf.IEventProcessor) *EndpointManager

func (*EndpointManager) RemoveService

func (em *EndpointManager) RemoveService(pid *actor.PID)

func (*EndpointManager) Select

func (em *EndpointManager) Select(sender *actor.PID, serverId int32, serviceId, serviceName string) inf.IBus

func (*EndpointManager) SelectByFilterAndChoice

func (em *EndpointManager) SelectByFilterAndChoice(sender *actor.PID, filter func(pid *actor.PID) bool, choice func(pids []*actor.PID) []*actor.PID) inf.IBus

func (*EndpointManager) SelectByPid

func (em *EndpointManager) SelectByPid(sender, receiver *actor.PID) inf.IBus

func (*EndpointManager) SelectByRule

func (em *EndpointManager) SelectByRule(sender *actor.PID, rule func(pid *actor.PID) bool) inf.IBus

SelectByRule 根据自定义规则选择服务

func (*EndpointManager) SelectByServiceType

func (em *EndpointManager) SelectByServiceType(sender *actor.PID, serverId int32, serviceType, serviceName string) inf.IBus

func (*EndpointManager) Start

func (em *EndpointManager) Start()

func (*EndpointManager) Stop

func (em *EndpointManager) Stop()