rpcli

package
v0.3.16 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2025 License: LGPL-2.1 Imports: 21 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	Main = "" // 主过程名称
)

Variables

View Source 
var (
	ErrProcedureExists              = errors.New("rpc: procedure exists")                // 过程已存在
	ErrProcedureNotFound            = errors.New("rpc: procedure not found")             // 找不到过程
	ErrMethodNotFound               = errors.New("rpc: method not found")                // 找不到方法
	ErrMethodParameterCountMismatch = errors.New("rpc: method parameter count mismatch") // 方法参数数量不匹配
	ErrMethodParameterTypeMismatch  = errors.New("rpc: method parameter type mismatch")  // 方法参数类型不匹配
)

Functions

This section is empty.

Types

type IProcedure 

type IProcedure interface {

	// GetCli 获取RPC客户端
	GetCli() *RPCli
	// GetName 获取名称
	GetName() string
	// GetReflected 获取反射值
	GetReflected() reflect.Value
	// contains filtered or unexported methods
}

IProcedure 过程接口

type Procedure 

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

Procedure 过程

func (*Procedure) GetCli 

func (p *Procedure) GetCli() *RPCli

GetCli 获取RPC客户端

func (*Procedure) GetName 

func (p *Procedure) GetName() string

GetName 获取名称

func (*Procedure) GetReflected 

func (p *Procedure) GetReflected() reflect.Value

GetReflected 获取反射值

type RPCli 

type RPCli struct {
	*cli.Client
	// contains filtered or unexported fields
}

RPCli RCP客户端

func (*RPCli) AddProcedure 

func (c *RPCli) AddProcedure(name string, proc any) error

AddProcedure 添加过程

func (*RPCli) GetProcedure 

func (c *RPCli) GetProcedure(name string) (IProcedure, bool)

GetProcedure 查询过程

func (*RPCli) GetRemoteTime 

func (c *RPCli) GetRemoteTime() cli.ResponseTime

GetRemoteTime 获取对端时间

func (*RPCli) OnewayRPC 

func (c *RPCli) OnewayRPC(service, comp, method string, args ...any) error

OnewayRPC 单向RPC调用

func (*RPCli) RPC 

func (c *RPCli) RPC(service, comp, method string, args ...any) async.AsyncRet

RPC RPC调用

func (*RPCli) RemoveProcedure 

func (c *RPCli) RemoveProcedure(name string) error

RemoveProcedure 删除过程

type RPCliCreator 

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

RPCliCreator RPC客户端构建器

func BuildRPCli added in v0.3.14 

func BuildRPCli() RPCliCreator

BuildRPCli 创建RPC客户端

func (RPCliCreator) Connect 

func (ctor RPCliCreator) Connect(ctx context.Context, endpoint string) (*RPCli, error)

func (RPCliCreator) SetAuthExtensions added in v0.3.14 

func (ctor RPCliCreator) SetAuthExtensions(extensions []byte) RPCliCreator

func (RPCliCreator) SetAuthToken added in v0.3.14 

func (ctor RPCliCreator) SetAuthToken(token string) RPCliCreator

func (RPCliCreator) SetAuthUserId added in v0.3.14 

func (ctor RPCliCreator) SetAuthUserId(userId string) RPCliCreator

func (RPCliCreator) SetFutureTimeout added in v0.3.14 

func (ctor RPCliCreator) SetFutureTimeout(d time.Duration) RPCliCreator

func (RPCliCreator) SetGAPDecoderMsgCreator added in v0.3.14 

func (ctor RPCliCreator) SetGAPDecoderMsgCreator(mc gap.IMsgCreator) RPCliCreator

func (RPCliCreator) SetGTPAutoReconnect added in v0.3.14 

func (ctor RPCliCreator) SetGTPAutoReconnect(b bool) RPCliCreator

func (RPCliCreator) SetGTPAutoReconnectInterval added in v0.3.14 

func (ctor RPCliCreator) SetGTPAutoReconnectInterval(dur time.Duration) RPCliCreator

func (RPCliCreator) SetGTPAutoReconnectRetryTimes added in v0.3.14 

func (ctor RPCliCreator) SetGTPAutoReconnectRetryTimes(times int) RPCliCreator

func (RPCliCreator) SetGTPCompressedSize added in v0.3.14 

func (ctor RPCliCreator) SetGTPCompressedSize(size int) RPCliCreator

func (RPCliCreator) SetGTPCompression added in v0.3.14 

func (ctor RPCliCreator) SetGTPCompression(c gtp.Compression) RPCliCreator

func (RPCliCreator) SetGTPDecoderMsgCreator added in v0.3.14 

func (ctor RPCliCreator) SetGTPDecoderMsgCreator(mc gtp.IMsgCreator) RPCliCreator

func (RPCliCreator) SetGTPEncCipherSuite added in v0.3.14 

func (ctor RPCliCreator) SetGTPEncCipherSuite(cs gtp.CipherSuite) RPCliCreator

func (RPCliCreator) SetGTPEncSignatureAlgorithm added in v0.3.14 

func (ctor RPCliCreator) SetGTPEncSignatureAlgorithm(sa gtp.SignatureAlgorithm) RPCliCreator

func (RPCliCreator) SetGTPEncSignaturePrivateKey added in v0.3.14 

func (ctor RPCliCreator) SetGTPEncSignaturePrivateKey(priv crypto.PrivateKey) RPCliCreator

func (RPCliCreator) SetGTPEncVerifyServerSignature added in v0.3.14 

func (ctor RPCliCreator) SetGTPEncVerifyServerSignature(b bool) RPCliCreator

func (RPCliCreator) SetGTPEncVerifySignaturePublicKey added in v0.3.14 

func (ctor RPCliCreator) SetGTPEncVerifySignaturePublicKey(pub crypto.PublicKey) RPCliCreator

func (RPCliCreator) SetGTPInactiveTimeout added in v0.3.14 

func (ctor RPCliCreator) SetGTPInactiveTimeout(d time.Duration) RPCliCreator

func (RPCliCreator) SetGTPRTTSampling added in v0.3.14 

func (ctor RPCliCreator) SetGTPRTTSampling(n int) RPCliCreator

func (RPCliCreator) SetGTPRecvDataChanSize added in v0.3.14 

func (ctor RPCliCreator) SetGTPRecvDataChanSize(size int, recyclable bool) RPCliCreator

func (RPCliCreator) SetGTPRecvDataHandler added in v0.3.14 

func (ctor RPCliCreator) SetGTPRecvDataHandler(handler cli.RecvDataHandler) RPCliCreator

func (RPCliCreator) SetGTPRecvEventChanSize added in v0.3.14 

func (ctor RPCliCreator) SetGTPRecvEventChanSize(size int) RPCliCreator

func (RPCliCreator) SetGTPRecvEventHandler added in v0.3.14 

func (ctor RPCliCreator) SetGTPRecvEventHandler(handler cli.RecvEventHandler) RPCliCreator

func (RPCliCreator) SetGTPSendDataChanSize added in v0.3.14 

func (ctor RPCliCreator) SetGTPSendDataChanSize(size int) RPCliCreator

func (RPCliCreator) SetGTPSendEventChanSize added in v0.3.14 

func (ctor RPCliCreator) SetGTPSendEventChanSize(size int) RPCliCreator

func (RPCliCreator) SetIOBufferCap added in v0.3.14 

func (ctor RPCliCreator) SetIOBufferCap(cap int) RPCliCreator

func (RPCliCreator) SetIORetryTimes added in v0.3.14 

func (ctor RPCliCreator) SetIORetryTimes(times int) RPCliCreator

func (RPCliCreator) SetIOTimeout added in v0.3.14 

func (ctor RPCliCreator) SetIOTimeout(d time.Duration) RPCliCreator

func (RPCliCreator) SetMainProcedure added in v0.3.14 

func (ctor RPCliCreator) SetMainProcedure(proc any) RPCliCreator

func (RPCliCreator) SetNetProtocol added in v0.3.14 

func (ctor RPCliCreator) SetNetProtocol(p cli.NetProtocol) RPCliCreator

func (RPCliCreator) SetReduceCallPath added in v0.3.14 

func (ctor RPCliCreator) SetReduceCallPath(b bool) RPCliCreator

func (RPCliCreator) SetTCPLinger added in v0.3.14 

func (ctor RPCliCreator) SetTCPLinger(sec int) RPCliCreator

func (RPCliCreator) SetTCPNoDelay added in v0.3.14 

func (ctor RPCliCreator) SetTCPNoDelay(b bool) RPCliCreator

func (RPCliCreator) SetTCPQuickAck added in v0.3.14 

func (ctor RPCliCreator) SetTCPQuickAck(b bool) RPCliCreator

func (RPCliCreator) SetTCPRecvBuf added in v0.3.14 

func (ctor RPCliCreator) SetTCPRecvBuf(size int) RPCliCreator

func (RPCliCreator) SetTCPSendBuf added in v0.3.14 

func (ctor RPCliCreator) SetTCPSendBuf(size int) RPCliCreator

func (RPCliCreator) SetTLSConfig added in v0.3.14 

func (ctor RPCliCreator) SetTLSConfig(tlsConfig tls.Config) RPCliCreator

func (RPCliCreator) SetWebSocketOrigin added in v0.3.14 

func (ctor RPCliCreator) SetWebSocketOrigin(origin string) RPCliCreator

func (RPCliCreator) SetZapLogger added in v0.3.14 

func (ctor RPCliCreator) SetZapLogger(logger *zap.Logger) RPCliCreator

Source Files

View all Source files

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.