hredisrouter

package
v1.1.44 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 10, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	RpcxServer = "HasServices"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type RedisRouter

type RedisRouter struct {
	core.EntityConfBase

	RedisServers  []string //如果cluster=false,使用第一个
	RedisUserName string
	RedisPassword string
	Database      int
	RpcxAddr      string
	Domain        string
	Cluster       bool
}

type Router

type Router struct {
	core.BaseRouter
	// contains filtered or unexported fields
}

func New

func New() *Router

func (*Router) Config

func (this *Router) Config() core.IEntityConf

func (*Router) EntityStub

func (this *Router) EntityStub() *core.EntityStub

func (*Router) HandleServiceRequested

func (this *Router) HandleServiceRequested(_ context.Context, args *core.RpcRequestArguments, resp *core.SlotResponse) error

func (*Router) Open

func (this *Router) Open(s core.IServer, ins core.IRouter) *herrors.Error

func (*Router) RegisterService

func (this *Router) RegisterService(s core.IService) *herrors.Error

func (*Router) RequestService

func (this *Router) RequestService(service string, slot string, params htypes.Map) (htypes.Any, *herrors.Error)

func (*Router) UnRegisterService

func (this *Router) UnRegisterService(s core.IService)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL