rpc

package
v0.3.67 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2025 License: LGPL-2.1 Imports: 24 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	Main        = "" // 调用客户端主过程
	EntitySelf  = "" // 调用实体自身方法
	RuntimeSelf = "" // 调用运行时自身方法
	ServiceSelf = "" // 调用服务自身方法
)

Variables

View Source 
var (
	Name      = self.Name
	Using     = self.Using
	Install   = self.Install
	Uninstall = self.Uninstall
)
View Source 
var (
	ErrMethodResultCountMismatch = errors.New("rpc: method result count mismatch")
	ErrMethodResultTypeMismatch  = errors.New("rpc: method result type mismatch")
)
View Source 
var With _Option

Functions

func Assert1 

func Assert1[T1 any](ret async.Ret) T1

func Assert10 

func Assert10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10 any](ret async.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10)

func Assert11 

func Assert11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11 any](ret async.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11)

func Assert12 

func Assert12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12 any](ret async.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12)

func Assert13 

func Assert13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13 any](ret async.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13)

func Assert14 

func Assert14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14 any](ret async.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14)

func Assert15 

func Assert15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15 any](ret async.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15)

func Assert16 

func Assert16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16 any](ret async.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16)

func Assert2 

func Assert2[T1, T2 any](ret async.Ret) (T1, T2)

func Assert3 

func Assert3[T1, T2, T3 any](ret async.Ret) (T1, T2, T3)

func Assert4 

func Assert4[T1, T2, T3, T4 any](ret async.Ret) (T1, T2, T3, T4)

func Assert5 

func Assert5[T1, T2, T3, T4, T5 any](ret async.Ret) (T1, T2, T3, T4, T5)

func Assert6 

func Assert6[T1, T2, T3, T4, T5, T6 any](ret async.Ret) (T1, T2, T3, T4, T5, T6)

func Assert7 

func Assert7[T1, T2, T3, T4, T5, T6, T7 any](ret async.Ret) (T1, T2, T3, T4, T5, T6, T7)

func Assert8 

func Assert8[T1, T2, T3, T4, T5, T6, T7, T8 any](ret async.Ret) (T1, T2, T3, T4, T5, T6, T7, T8)

func Assert9 

func Assert9[T1, T2, T3, T4, T5, T6, T7, T8, T9 any](ret async.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9)

func AssertVoid 

func AssertVoid(ret async.Ret)

func Asserts 

func Asserts(ret async.Ret) []any

Types

type EntityProxied added in v0.3.39 

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

EntityProxied 实体代理，用于向实体发送RPC

func ProxyEntity added in v0.3.39 

func ProxyEntity(provider runtime.CurrentContextProvider, id uid.Id) EntityProxied

ProxyEntity 创建实体代理，用于向实体发送RPC

func UntrackedProxyEntity added in v0.3.39 

func UntrackedProxyEntity(svcCtx service.Context, id uid.Id) EntityProxied

UntrackedProxyEntity 创建实体代理，不继承RPC调用链，用于向实体发送RPC

func (EntityProxied) BalanceOnewayRPC added in v0.3.39 

func (p EntityProxied) BalanceOnewayRPC(service, comp, method string, args ...any) error

BalanceOnewayRPC 使用负载均衡模式，向分布式实体目标服务发送单向RPC

func (EntityProxied) BalanceRPC added in v0.3.39 

func (p EntityProxied) BalanceRPC(service, comp, method string, args ...any) async.AsyncRet

BalanceRPC 使用负载均衡模式，向分布式实体目标服务发送RPC

func (EntityProxied) BroadcastCliOnewayRPC added in v0.3.39 

func (p EntityProxied) BroadcastCliOnewayRPC(proc, method string, args ...any) error

BroadcastCliOnewayRPC 向包含实体的所有分组发送单向RPC

func (EntityProxied) BroadcastOnewayRPC added in v0.3.39 

func (p EntityProxied) BroadcastOnewayRPC(excludeSelf bool, service, comp, method string, args ...any) error

BroadcastOnewayRPC 使用广播模式，向分布式实体目标服务发送单向RPC

func (EntityProxied) CliOnewayRPC added in v0.3.39 

func (p EntityProxied) CliOnewayRPC(proc, method string, args ...any) error

CliOnewayRPC 向客户端发送单向RPC

func (EntityProxied) CliRPC added in v0.3.39 

func (p EntityProxied) CliRPC(proc, method string, args ...any) async.AsyncRet

CliRPC 向客户端发送RPC

func (EntityProxied) GetId added in v0.3.39 

func (p EntityProxied) GetId() uid.Id

GetId 获取实体id

func (EntityProxied) GlobalBalanceOnewayRPC added in v0.3.39 

func (p EntityProxied) GlobalBalanceOnewayRPC(excludeSelf bool, comp, method string, args ...any) error

GlobalBalanceOnewayRPC 使用全局负载均衡模式，向分布式实体任意服务发送单向RPC

func (EntityProxied) GlobalBalanceRPC added in v0.3.39 

func (p EntityProxied) GlobalBalanceRPC(excludeSelf bool, comp, method string, args ...any) async.AsyncRet

GlobalBalanceRPC 使用全局负载均衡模式，向分布式实体任意服务发送RPC

func (EntityProxied) GlobalBroadcastOnewayRPC added in v0.3.39 

func (p EntityProxied) GlobalBroadcastOnewayRPC(excludeSelf bool, comp, method string, args ...any) error

GlobalBroadcastOnewayRPC 使用全局广播模式，向分布式实体所有服务发送单向RPC

func (EntityProxied) OnewayRPC added in v0.3.39 

func (p EntityProxied) OnewayRPC(service, comp, method string, args ...any) error

OnewayRPC 向分布式实体目标服务发送单向RPC

func (EntityProxied) RPC added in v0.3.39 

func (p EntityProxied) RPC(service, comp, method string, args ...any) async.AsyncRet

RPC 向分布式实体目标服务发送RPC

type GroupProxied added in v0.3.39 

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

GroupProxied 分组代理，用于向分组发送RPC

func ProxyGroup added in v0.3.39 

func ProxyGroup(provider runtime.CurrentContextProvider, name string) GroupProxied

ProxyGroup 创建分组代理，用于向分组发送RPC

func UntrackedProxyGroup added in v0.3.39 

func UntrackedProxyGroup(svcCtx service.Context, name string) GroupProxied

UntrackedProxyGroup 创建分组代理，不继承RPC调用链，用于向分组发送RPC

func (GroupProxied) CliOnewayRPC added in v0.3.39 

func (p GroupProxied) CliOnewayRPC(proc, method string, args ...any) error

CliOnewayRPC 向分组发送单向RPC

func (GroupProxied) GetAddr added in v0.3.39 

func (p GroupProxied) GetAddr() string

GetAddr 获取分组地址

func (GroupProxied) GetName added in v0.3.39 

func (p GroupProxied) GetName() string

GetName 获取分组名称

type IRPC 

type IRPC interface {
	// RPC RPC调用
	RPC(dst string, cc rpcstack.CallChain, cp callpath.CallPath, args ...any) async.AsyncRet
	// OnewayRPC 单向RPC调用
	OnewayRPC(dst string, cc rpcstack.CallChain, cp callpath.CallPath, args ...any) error
}

IRPC RPC支持

type RPCOptions 

type RPCOptions struct {
	Processors []any
}

type ResultTuple0 

type ResultTuple0 struct {
	Error error
}

func ResultVoid 

func ResultVoid(ret async.Ret) (rtp ResultTuple0)

func (ResultTuple0) Ensure 

func (rtp ResultTuple0) Ensure()

func (ResultTuple0) Extract 

func (rtp ResultTuple0) Extract() error

type ResultTuple1 

type ResultTuple1[T1 any] struct {
	R1    T1
	Error error
}

func Result1 

func Result1[T1 any](ret async.Ret) (rtp ResultTuple1[T1])

func (ResultTuple1[T1]) Ensure 

func (rtp ResultTuple1[T1]) Ensure() T1

func (ResultTuple1[T1]) Extract 

func (rtp ResultTuple1[T1]) Extract() (T1, error)

type ResultTuple10 

type ResultTuple10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	R7    T7
	R8    T8
	R9    T9
	R10   T10
	Error error
}

func Result10 

func Result10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10 any](ret async.Ret) (rtp ResultTuple10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10])

func (ResultTuple10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10]) Ensure 

func (rtp ResultTuple10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10]) Ensure() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10)

func (ResultTuple10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10]) Extract 

func (rtp ResultTuple10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10]) Extract() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, error)

type ResultTuple11 

type ResultTuple11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	R7    T7
	R8    T8
	R9    T9
	R10   T10
	R11   T11
	Error error
}

func Result11 

func Result11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11 any](ret async.Ret) (rtp ResultTuple11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11])

func (ResultTuple11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11]) Ensure 

func (rtp ResultTuple11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11]) Ensure() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11)

func (ResultTuple11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11]) Extract 

func (rtp ResultTuple11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11]) Extract() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, error)

type ResultTuple12 

type ResultTuple12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	R7    T7
	R8    T8
	R9    T9
	R10   T10
	R11   T11
	R12   T12
	Error error
}

func Result12 

func Result12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12 any](ret async.Ret) (rtp ResultTuple12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12])

func (ResultTuple12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12]) Ensure 

func (rtp ResultTuple12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12]) Ensure() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12)

func (ResultTuple12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12]) Extract 

func (rtp ResultTuple12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12]) Extract() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, error)

type ResultTuple13 

type ResultTuple13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	R7    T7
	R8    T8
	R9    T9
	R10   T10
	R11   T11
	R12   T12
	R13   T13
	Error error
}

func Result13 

func Result13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13 any](ret async.Ret) (rtp ResultTuple13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13])

func (ResultTuple13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13]) Ensure 

func (rtp ResultTuple13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13]) Ensure() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13)

func (ResultTuple13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13]) Extract 

func (rtp ResultTuple13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13]) Extract() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, error)

type ResultTuple14 

type ResultTuple14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	R7    T7
	R8    T8
	R9    T9
	R10   T10
	R11   T11
	R12   T12
	R13   T13
	R14   T14
	Error error
}

func Result14 

func Result14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14 any](ret async.Ret) (rtp ResultTuple14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14])

func (ResultTuple14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14]) Ensure 

func (rtp ResultTuple14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14]) Ensure() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14)

func (ResultTuple14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14]) Extract 

func (rtp ResultTuple14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14]) Extract() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, error)

type ResultTuple15 

type ResultTuple15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	R7    T7
	R8    T8
	R9    T9
	R10   T10
	R11   T11
	R12   T12
	R13   T13
	R14   T14
	R15   T15
	Error error
}

func Result15 

func Result15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15 any](ret async.Ret) (rtp ResultTuple15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15])

func (ResultTuple15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15]) Ensure 

func (rtp ResultTuple15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15]) Ensure() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15)

func (ResultTuple15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15]) Extract 

func (rtp ResultTuple15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15]) Extract() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, error)

type ResultTuple16 

type ResultTuple16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	R7    T7
	R8    T8
	R9    T9
	R10   T10
	R11   T11
	R12   T12
	R13   T13
	R14   T14
	R15   T15
	R16   T16
	Error error
}

func Result16 

func Result16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16 any](ret async.Ret) (rtp ResultTuple16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16])

func (ResultTuple16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16]) Ensure 

func (rtp ResultTuple16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16]) Ensure() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16)

func (ResultTuple16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16]) Extract 

func (rtp ResultTuple16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16]) Extract() (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, error)

type ResultTuple2 

type ResultTuple2[T1, T2 any] struct {
	R1    T1
	R2    T2
	Error error
}

func Result2 

func Result2[T1, T2 any](ret async.Ret) (rtp ResultTuple2[T1, T2])

func (ResultTuple2[T1, T2]) Ensure 

func (rtp ResultTuple2[T1, T2]) Ensure() (T1, T2)

func (ResultTuple2[T1, T2]) Extract 

func (rtp ResultTuple2[T1, T2]) Extract() (T1, T2, error)

type ResultTuple3 

type ResultTuple3[T1, T2, T3 any] struct {
	R1    T1
	R2    T2
	R3    T3
	Error error
}

func Result3 

func Result3[T1, T2, T3 any](ret async.Ret) (rtp ResultTuple3[T1, T2, T3])

func (ResultTuple3[T1, T2, T3]) Ensure 

func (rtp ResultTuple3[T1, T2, T3]) Ensure() (T1, T2, T3)

func (ResultTuple3[T1, T2, T3]) Extract 

func (rtp ResultTuple3[T1, T2, T3]) Extract() (T1, T2, T3, error)

type ResultTuple4 

type ResultTuple4[T1, T2, T3, T4 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	Error error
}

func Result4 

func Result4[T1, T2, T3, T4 any](ret async.Ret) (rtp ResultTuple4[T1, T2, T3, T4])

func (ResultTuple4[T1, T2, T3, T4]) Ensure 

func (rtp ResultTuple4[T1, T2, T3, T4]) Ensure() (T1, T2, T3, T4)

func (ResultTuple4[T1, T2, T3, T4]) Extract 

func (rtp ResultTuple4[T1, T2, T3, T4]) Extract() (T1, T2, T3, T4, error)

type ResultTuple5 

type ResultTuple5[T1, T2, T3, T4, T5 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	Error error
}

func Result5 

func Result5[T1, T2, T3, T4, T5 any](ret async.Ret) (rtp ResultTuple5[T1, T2, T3, T4, T5])

func (ResultTuple5[T1, T2, T3, T4, T5]) Ensure 

func (rtp ResultTuple5[T1, T2, T3, T4, T5]) Ensure() (T1, T2, T3, T4, T5)

func (ResultTuple5[T1, T2, T3, T4, T5]) Extract 

func (rtp ResultTuple5[T1, T2, T3, T4, T5]) Extract() (T1, T2, T3, T4, T5, error)

type ResultTuple6 

type ResultTuple6[T1, T2, T3, T4, T5, T6 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	Error error
}

func Result6 

func Result6[T1, T2, T3, T4, T5, T6 any](ret async.Ret) (rtp ResultTuple6[T1, T2, T3, T4, T5, T6])

func (ResultTuple6[T1, T2, T3, T4, T5, T6]) Ensure 

func (rtp ResultTuple6[T1, T2, T3, T4, T5, T6]) Ensure() (T1, T2, T3, T4, T5, T6)

func (ResultTuple6[T1, T2, T3, T4, T5, T6]) Extract 

func (rtp ResultTuple6[T1, T2, T3, T4, T5, T6]) Extract() (T1, T2, T3, T4, T5, T6, error)

type ResultTuple7 

type ResultTuple7[T1, T2, T3, T4, T5, T6, T7 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	R7    T7
	Error error
}

func Result7 

func Result7[T1, T2, T3, T4, T5, T6, T7 any](ret async.Ret) (rtp ResultTuple7[T1, T2, T3, T4, T5, T6, T7])

func (ResultTuple7[T1, T2, T3, T4, T5, T6, T7]) Ensure 

func (rtp ResultTuple7[T1, T2, T3, T4, T5, T6, T7]) Ensure() (T1, T2, T3, T4, T5, T6, T7)

func (ResultTuple7[T1, T2, T3, T4, T5, T6, T7]) Extract 

func (rtp ResultTuple7[T1, T2, T3, T4, T5, T6, T7]) Extract() (T1, T2, T3, T4, T5, T6, T7, error)

type ResultTuple8 

type ResultTuple8[T1, T2, T3, T4, T5, T6, T7, T8 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	R7    T7
	R8    T8
	Error error
}

func Result8 

func Result8[T1, T2, T3, T4, T5, T6, T7, T8 any](ret async.Ret) (rtp ResultTuple8[T1, T2, T3, T4, T5, T6, T7, T8])

func (ResultTuple8[T1, T2, T3, T4, T5, T6, T7, T8]) Ensure 

func (rtp ResultTuple8[T1, T2, T3, T4, T5, T6, T7, T8]) Ensure() (T1, T2, T3, T4, T5, T6, T7, T8)

func (ResultTuple8[T1, T2, T3, T4, T5, T6, T7, T8]) Extract 

func (rtp ResultTuple8[T1, T2, T3, T4, T5, T6, T7, T8]) Extract() (T1, T2, T3, T4, T5, T6, T7, T8, error)

type ResultTuple9 

type ResultTuple9[T1, T2, T3, T4, T5, T6, T7, T8, T9 any] struct {
	R1    T1
	R2    T2
	R3    T3
	R4    T4
	R5    T5
	R6    T6
	R7    T7
	R8    T8
	R9    T9
	Error error
}

func Result9 

func Result9[T1, T2, T3, T4, T5, T6, T7, T8, T9 any](ret async.Ret) (rtp ResultTuple9[T1, T2, T3, T4, T5, T6, T7, T8, T9])

func (ResultTuple9[T1, T2, T3, T4, T5, T6, T7, T8, T9]) Ensure 

func (rtp ResultTuple9[T1, T2, T3, T4, T5, T6, T7, T8, T9]) Ensure() (T1, T2, T3, T4, T5, T6, T7, T8, T9)

func (ResultTuple9[T1, T2, T3, T4, T5, T6, T7, T8, T9]) Extract 

func (rtp ResultTuple9[T1, T2, T3, T4, T5, T6, T7, T8, T9]) Extract() (T1, T2, T3, T4, T5, T6, T7, T8, T9, error)

type ResultValues 

type ResultValues struct {
	Values []any
	Error  error
}

func Results 

func Results(ret async.Ret) (rvs ResultValues)

func (ResultValues) Ensure 

func (rvs ResultValues) Ensure() []any

func (ResultValues) Extract 

func (rvs ResultValues) Extract() ([]any, error)

type RuntimeProxied added in v0.3.39 

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

RuntimeProxied 运行时代理，用于向实体的运行时发送RPC

func ProxyRuntime added in v0.3.39 

func ProxyRuntime(provider runtime.CurrentContextProvider, entityId uid.Id) RuntimeProxied

ProxyRuntime 创建运行时代理，用于向实体的运行时发送RPC

func UntrackedProxyRuntime added in v0.3.39 

func UntrackedProxyRuntime(svcCtx service.Context, entityId uid.Id) RuntimeProxied

UntrackedProxyRuntime 创建运行时代理，不继承RPC调用链，用于向实体的运行时发送RPC

func (RuntimeProxied) BalanceOnewayRPC added in v0.3.39 

func (p RuntimeProxied) BalanceOnewayRPC(service, addIn, method string, args ...any) error

BalanceOnewayRPC 使用负载均衡模式，向分布式实体目标服务的运行时发送单向RPC

func (RuntimeProxied) BalanceRPC added in v0.3.39 

func (p RuntimeProxied) BalanceRPC(service, addIn, method string, args ...any) async.AsyncRet

BalanceRPC 使用负载均衡模式，向分布式实体目标服务的运行时发送RPC

func (RuntimeProxied) BroadcastOnewayRPC added in v0.3.39 

func (p RuntimeProxied) BroadcastOnewayRPC(excludeSelf bool, service, addIn, method string, args ...any) error

BroadcastOnewayRPC 使用广播模式，向分布式实体目标服务的运行时发送单向RPC

func (RuntimeProxied) GetEntityId added in v0.3.39 

func (p RuntimeProxied) GetEntityId() uid.Id

GetEntityId 获取实体id

func (RuntimeProxied) GlobalBalanceOnewayRPC added in v0.3.39 

func (p RuntimeProxied) GlobalBalanceOnewayRPC(excludeSelf bool, addIn, method string, args ...any) error

GlobalBalanceOnewayRPC 使用全局负载均衡模式，向分布式实体任意服务的运行时发送单向RPC

func (RuntimeProxied) GlobalBalanceRPC added in v0.3.39 

func (p RuntimeProxied) GlobalBalanceRPC(excludeSelf bool, addIn, method string, args ...any) async.AsyncRet

GlobalBalanceRPC 使用全局负载均衡模式，向分布式实体任意服务的运行时发送RPC

func (RuntimeProxied) GlobalBroadcastOnewayRPC added in v0.3.39 

func (p RuntimeProxied) GlobalBroadcastOnewayRPC(excludeSelf bool, addIn, method string, args ...any) error

GlobalBroadcastOnewayRPC 使用全局广播模式，向分布式实体所有服务的运行时发送单向RPC

func (RuntimeProxied) OnewayRPC added in v0.3.39 

func (p RuntimeProxied) OnewayRPC(service, addIn, method string, args ...any) error

OnewayRPC 向分布式实体目标服务的运行时发送单向RPC

func (RuntimeProxied) RPC added in v0.3.39 

func (p RuntimeProxied) RPC(service, addIn, method string, args ...any) async.AsyncRet

RPC 向分布式实体目标服务的运行时发送RPC

type ServiceProxied added in v0.3.39 

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

ServiceProxied 服务代理，用于向服务发送RPC

func ProxyService added in v0.3.39 

func ProxyService(provider runtime.CurrentContextProvider, serviceName ...string) ServiceProxied

ProxyService 创建服务代理，用于向服务发送RPC

func UntrackedProxyService added in v0.3.39 

func UntrackedProxyService(svcCtx service.Context, serviceName ...string) ServiceProxied

UntrackedProxyService 创建服务代理，不继承RPC调用链，用于向服务发送RPC

func (ServiceProxied) BalanceOnewayRPC added in v0.3.39 

func (p ServiceProxied) BalanceOnewayRPC(addIn, method string, args ...any) error

BalanceOnewayRPC 使用负载均衡模式，向分布式服务发送单向RPC

func (ServiceProxied) BalanceRPC added in v0.3.39 

func (p ServiceProxied) BalanceRPC(addIn, method string, args ...any) async.AsyncRet

BalanceRPC 使用负载均衡模式，向分布式服务发送RPC

func (ServiceProxied) BroadcastOnewayRPC added in v0.3.39 

func (p ServiceProxied) BroadcastOnewayRPC(excludeSelf bool, addIn, method string, args ...any) error

BroadcastOnewayRPC 使用广播模式，向分布式服务发送单向RPC

func (ServiceProxied) GetService added in v0.3.39 

func (p ServiceProxied) GetService() string

GetService 获取服务名

func (ServiceProxied) OnewayRPC added in v0.3.39 

func (p ServiceProxied) OnewayRPC(nodeId uid.Id, addIn, method string, args ...any) error

OnewayRPC 向分布式服务指定节点发送单向RPC

func (ServiceProxied) RPC added in v0.3.39 

func (p ServiceProxied) RPC(nodeId uid.Id, addIn, method string, args ...any) async.AsyncRet

RPC 向分布式服务指定节点发送RPC

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.