rpc

Documentation

Index

• type SyncRPCClient
  • func NewSyncRPCClient(target string) (c *SyncRPCClient, err error)
  • func (c *SyncRPCClient) RunUpdatesStreamLoop(server *net2.Server)

Types

type SyncRPCClient

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

func NewSyncRPCClient

func NewSyncRPCClient(target string) (c *SyncRPCClient, err error)

func (*SyncRPCClient) RunUpdatesStreamLoop

func (c *SyncRPCClient) RunUpdatesStreamLoop(server *net2.Server)

TODO(@benqi): 可能有问题