extension

Documentation

Index

• type ExtensionServer
  • func GetExtensionServer() *ExtensionServer
  • func (es *ExtensionServer) GetBaseUserInfos(ctx context.Context, req *pb.BaseUserInfosReq) (resp *pb.DepartmentUsers, err error)
  • func (es *ExtensionServer) GetDepartmentUsers(ctx context.Context, req *pb.GetDepartmentUsersReq) (resp *pb.GetDepartmentUsersResp, err error)
  • func (es *ExtensionServer) GetUserInfo(ctx context.Context, req *pb.GetAreaInfoReq) (resp *pb.GetUserInfoResp, err error)
  • func (es *ExtensionServer) Notify(notifyType pb.SAEvent, content map[string]interface{})
  • func (es *ExtensionServer) Run(ctx context.Context)
  • func (es *ExtensionServer) SANotifyEvent(req *pb.EmptyReq, server pb.Extension_SANotifyEventServer) error
  • func (es *ExtensionServer) Subscribe(notify chan pb.SAEventInfo)
  • func (es *ExtensionServer) Unsubscribe(notify chan pb.SAEventInfo)

Types

type ExtensionServer

type ExtensionServer struct {
	NotifyChans map[chan pb.SAEventInfo]struct{}
}

ExtensionServer 扩展服务

func GetExtensionServer

func GetExtensionServer() *ExtensionServer

func (*ExtensionServer) GetBaseUserInfos

func (es *ExtensionServer) GetBaseUserInfos(ctx context.Context, req *pb.BaseUserInfosReq) (resp *pb.DepartmentUsers, err error)

GetBaseUserInfos 通过请求userID获取基础用户数据

func (*ExtensionServer) GetDepartmentUsers

func (es *ExtensionServer) GetDepartmentUsers(ctx context.Context, req *pb.GetDepartmentUsersReq) (resp *pb.GetDepartmentUsersResp, err error)

GetDepartmentUsers 获取部门下所有成员

func (*ExtensionServer) GetUserInfo

func (es *ExtensionServer) GetUserInfo(ctx context.Context, req *pb.GetAreaInfoReq) (resp *pb.GetUserInfoResp, err error)

GetUserInfo 获取用户数据

func (*ExtensionServer) Notify

func (es *ExtensionServer) Notify(notifyType pb.SAEvent, content map[string]interface{})

Notify 通知正在监听的服务

func (*ExtensionServer) Run

func (es *ExtensionServer) Run(ctx context.Context)

func (*ExtensionServer) SANotifyEvent

func (es *ExtensionServer) SANotifyEvent(req *pb.EmptyReq, server pb.Extension_SANotifyEventServer) error

SANotifyEvent Sa通知事件

func (*ExtensionServer) Subscribe

func (es *ExtensionServer) Subscribe(notify chan pb.SAEventInfo)

Subscribe 注册通知服务

func (*ExtensionServer) Unsubscribe

func (es *ExtensionServer) Unsubscribe(notify chan pb.SAEventInfo)

Unsubscribe 解除通知服务