xrpc

Documentation

Index

• func CustomCodec(codec codec.Codec)
• func NewServer(namespace, addr string, etcds []string) (*server.Server, error)
• type BaseService
  • func (svc *BaseService) ConvertContext(ctx context.Context) context.Context
  • func (svc *BaseService) RpcCall() error
  • func (svc *BaseService) ValidateArgs(arg any) error
• type JsonCodec
  • func (c *JsonCodec) Decode(data []byte, i interface{}) error
  • func (c *JsonCodec) Encode(i interface{}) ([]byte, error)
• type RpcConfig
• type Service

Functions

func CustomCodec

func CustomCodec(codec codec.Codec)

自定义编解码器

func NewServer

func NewServer(namespace, addr string, etcds []string) (*server.Server, error)

获取server实例

Types

type BaseService

type BaseService struct{}

func (*BaseService) ConvertContext

func (svc *BaseService) ConvertContext(ctx context.Context) context.Context

转换context 系统约定：正常rpcx传递的context中带有traceid(必须)和extra(可选)字段

func (*BaseService) RpcCall

func (svc *BaseService) RpcCall() error

跨服务调用

func (*BaseService) ValidateArgs

func (svc *BaseService) ValidateArgs(arg any) error

转换&验证参数

type JsonCodec

type JsonCodec struct{}

func (*JsonCodec) Decode

func (c *JsonCodec) Decode(data []byte, i interface{}) error

解码

func (*JsonCodec) Encode

func (c *JsonCodec) Encode(i interface{}) ([]byte, error)

编码

type RpcConfig

type RpcConfig struct {
	Namespace string   `mapstructure:"namespace"`
	Type      string   `mapstructure:"type"`
	Hosts     []string `mapstructure:"hosts"`
}

type Service

type Service struct {
	Group   string
	Name    string
	Service any
}