SpringRpc

Documentation

Index

• Variables
• type Handler
• type RpcBeanInitialization
• type RpcContainer
• type RpcContext
• type RpcError
  • func (e *RpcError) Data(data interface{}) *RpcResult
  • func (e *RpcError) Panic(err error) *RpcPanic
• type RpcPanic
  • func (p *RpcPanic) When(isPanic bool)
• type RpcResult

Variables

var (
	ERROR   = &RpcError{-1, "ERROR"}
	SUCCESS = &RpcError{200, "SUCCESS"}
)

Types

type Handler

type Handler func(RpcContext) interface{}

type RpcBeanInitialization

type RpcBeanInitialization interface {
	InitRpcBean(c RpcContainer)
}

RPC Bean 初始化

type RpcContainer

type RpcContainer interface {
	Stop()

	Start(address string) error
	StartTLS(address string, certFile, keyFile string) error

	// 注册 RPC 方法（服务名+方法名）
	Register(service string, method string, fn Handler)
}

RPC 服务器

type RpcContext

type RpcContext interface {
	SpringTrace.TraceContext

	Bind(i interface{}) error

	// Get retrieves data from the context.
	Get(key string) interface{}

	// Set saves data in the context.
	Set(key string, val interface{})
}

RPC 上下文，务必保持是 WebContext 的子集！

type RpcError

type RpcError struct {
	Code int32  // 错误码
	Msg  string // 错误信息
}

RPC 错误值

func (*RpcError) Data

func (e *RpcError) Data(data interface{}) *RpcResult

func (*RpcError) Panic

func (e *RpcError) Panic(err error) *RpcPanic

type RpcPanic

type RpcPanic struct {
	Result *RpcResult
}

封装触发 panic 条件

func (*RpcPanic) When

func (p *RpcPanic) When(isPanic bool)

type RpcResult

type RpcResult struct {
	*RpcError

	Err  string      // 错误源
	Data interface{} // 返回值数据
}

RPC 返回值