rpc

package
v0.1.3 Latest Latest
Warning

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

Go to latest
Published: Mar 19, 2022 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewRPCServer

func NewRPCServer(plugin *serverplugin.ZooKeeperRegisterPlugin) (*server.Server, error)

Types

type XClientPool

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

func NewXClientPool

func NewXClientPool(pPrefix string, servers []string) (*XClientPool, error)

func (*XClientPool) Call

func (s *XClientPool) Call(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

Call serviceMethod: {包名后缀}_{服务名}_{成员函数名} 比如: activity_TaskService_Draw

func (*XClientPool) G

func (s *XClientPool) G(pSuffix string, service string) (client.XClient, error)

func (*XClientPool) Must

func (s *XClientPool) Must(c client.XClient, err error) client.XClient

Jump to

Keyboard shortcuts

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