rpc

package

v0.1.32 Latest Latest Go to latest Published: Mar 10, 2024 License: LGPL-2.1 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pangdogs/framework

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Result1[T1 any](ret runtime.Ret) (T1, error)
func Result10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, error)
func Result11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, error)
func Result12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, error)
func Result13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, error)
func Result14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, error)
func Result15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, error)
func Result16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, error)
func Result2[T1, T2 any](ret runtime.Ret) (T1, T2, error)
func Result3[T1, T2, T3 any](ret runtime.Ret) (T1, T2, T3, error)
func Result4[T1, T2, T3, T4 any](ret runtime.Ret) (T1, T2, T3, T4, error)
func Result5[T1, T2, T3, T4, T5 any](ret runtime.Ret) (T1, T2, T3, T4, T5, error)
func Result6[T1, T2, T3, T4, T5, T6 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, error)
func Result7[T1, T2, T3, T4, T5, T6, T7 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, error)
func Result8[T1, T2, T3, T4, T5, T6, T7, T8 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, error)
func Result9[T1, T2, T3, T4, T5, T6, T7, T8, T9 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, error)
func ResultVoid(ret runtime.Ret) error
func Results(ret runtime.Ret) ([]any, error)
type IProcessorDeliverer
type IProcessorDispatcher
type IRPC
type LifecycleProcessorInit
type LifecycleProcessorShut
type RPCOptions

Constants ¶

This section is empty.

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 (
	ErrNoDeliverer = errors.New("rpc: no deliverer") // 没有匹配的投递器
)

View Source

var With _Option

Functions ¶

func Result1 ¶

func Result1[T1 any](ret runtime.Ret) (T1, error)

func Result10 ¶

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

func Result11 ¶

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

func Result12 ¶

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

func Result13 ¶

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

func Result14 ¶

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

func Result15 ¶

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

func Result16 ¶

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

func Result2 ¶

func Result2[T1, T2 any](ret runtime.Ret) (T1, T2, error)

func Result3 ¶

func Result3[T1, T2, T3 any](ret runtime.Ret) (T1, T2, T3, error)

func Result4 ¶

func Result4[T1, T2, T3, T4 any](ret runtime.Ret) (T1, T2, T3, T4, error)

func Result5 ¶

func Result5[T1, T2, T3, T4, T5 any](ret runtime.Ret) (T1, T2, T3, T4, T5, error)

func Result6 ¶

func Result6[T1, T2, T3, T4, T5, T6 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, error)

func Result7 ¶

func Result7[T1, T2, T3, T4, T5, T6, T7 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, error)

func Result8 ¶

func Result8[T1, T2, T3, T4, T5, T6, T7, T8 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, error)

func Result9 ¶

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

func ResultVoid ¶

func ResultVoid(ret runtime.Ret) error

func Results ¶

func Results(ret runtime.Ret) ([]any, error)

Types ¶

type IProcessorDeliverer ¶ added in v0.1.32

type IProcessorDeliverer interface {
	// Match 是否匹配
	Match(ctx service.Context, dst, path string, oneWay bool) bool
	// Request 请求
	Request(ctx service.Context, dst, path string, args []any) runtime.AsyncRet
	// Notify 通知
	Notify(ctx service.Context, dst, path string, args []any) error
}

IProcessorDeliverer RPC投递器接口，用于将RPC投递至目标

type IProcessorDispatcher ¶ added in v0.1.32

type IProcessorDispatcher any

IProcessorDispatcher RPC分发器接口，用于分发RPC请求与响应

type IRPC ¶

type IRPC interface {
	// RPC RPC调用
	RPC(dst, path string, args ...any) runtime.AsyncRet
	// OneWayRPC 单向RPC调用
	OneWayRPC(dst, path string, args ...any) error
}

IRPC RPC支持

type LifecycleProcessorInit ¶ added in v0.1.32

type LifecycleProcessorInit interface {
	Init(ctx service.Context)
}

LifecycleProcessorInit RPC投递器或分发器生命周期开始

type LifecycleProcessorShut ¶ added in v0.1.32

type LifecycleProcessorShut interface {
	Shut(ctx service.Context)
}

LifecycleProcessorShut RPC投递器或分发器生命周期结束

type RPCOptions ¶

type RPCOptions struct {
	Deliverers  []IProcessorDeliverer
	Dispatchers []IProcessorDispatcher
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
callpath
processors

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