repository

Documentation

Overview

Package repository @Title title @Description desc @Author yr 2024/11/11 @Update yr 2024/11/11

Package repository @Title 服务存储器 @Description 用于存放所有服务的注册信息,包括本地和远程的服务信息 @Author yr 2024/11/7 @Update yr 2024/11/7

Package repository @Title 服务选择器 @Description 根据条件选择服务 @Author yr 2024/11/7 @Update yr 2024/11/7

Index

• type Repository
  • func NewRepository() *Repository
  • func (r *Repository) Add(client inf.IRpcSender)
  • func (r *Repository) AddTmp(sender inf.IRpcSender) inf.IRpcSender
  • func (r *Repository) Remove(pid *actor.PID)
  • func (r *Repository) Select(sender *actor.PID, serverId int32, serviceId, serviceName string) inf.IBus
  • func (r *Repository) SelectByFilterAndChoice(sender *actor.PID, filter func(pid *actor.PID) bool, ...) inf.IBus
  • func (r *Repository) SelectByPid(sender, receiver *actor.PID) inf.IBus
  • func (r *Repository) SelectByRule(sender *actor.PID, rule func(pid *actor.PID) bool) inf.IBus
  • func (r *Repository) SelectByServiceType(sender *actor.PID, serverId int32, nodeType, serviceName string) inf.IBus
  • func (r *Repository) SelectByServiceUid(serviceUid string) inf.IRpcSender
  • func (r *Repository) SelectBySvcUid(sender *actor.PID, serviceUid string) inf.IBus
  • func (r *Repository) Start()
  • func (r *Repository) Stop()

Types

type Repository

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

func NewRepository

func NewRepository() *Repository

func (*Repository) Add

func (r *Repository) Add(client inf.IRpcSender)

func (*Repository) AddTmp

func (r *Repository) AddTmp(sender inf.IRpcSender) inf.IRpcSender

func (*Repository) Remove

func (r *Repository) Remove(pid *actor.PID)

func (*Repository) Select

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

func (*Repository) SelectByFilterAndChoice

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

func (*Repository) SelectByPid

func (r *Repository) SelectByPid(sender, receiver *actor.PID) inf.IBus

func (*Repository) SelectByRule

func (r *Repository) SelectByRule(sender *actor.PID, rule func(pid *actor.PID) bool) inf.IBus

func (*Repository) SelectByServiceType

func (r *Repository) SelectByServiceType(sender *actor.PID, serverId int32, nodeType, serviceName string) inf.IBus

func (*Repository) SelectByServiceUid

func (r *Repository) SelectByServiceUid(serviceUid string) inf.IRpcSender

func (*Repository) SelectBySvcUid

func (r *Repository) SelectBySvcUid(sender *actor.PID, serviceUid string) inf.IBus

func (*Repository) Start

func (r *Repository) Start()

func (*Repository) Stop

func (r *Repository) Stop()