baserpc

Documentation

Index

• type BaseRpc
  • func (cli *BaseRpc) SendRpc(ctx *RpcContext, rpcFunc Rpc) *RpcResult
• type Rpc
• type RpcContext
  • func NewRpcContext(addrs []string, funcName string) *RpcContext
• type RpcResult

Types

type BaseRpc

type BaseRpc struct {
	Timeout    time.Duration
	RetryTimes uint32
}

func (*BaseRpc) SendRpc

func (cli *BaseRpc) SendRpc(ctx *RpcContext, rpcFunc Rpc) *RpcResult

type Rpc

type Rpc interface {
	NewRpcClient(cc grpc.ClientConnInterface)
	Stub_Func(ctx context.Context, opt ...grpc.CallOption) (interface{}, error)
}

type RpcContext

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

func NewRpcContext

func NewRpcContext(addrs []string, funcName string) *RpcContext

type RpcResult

type RpcResult struct {
	Key    interface{}
	Err    error
	Result interface{}
}