Documentation
¶
Index ¶
- func CallClient(c context.Context, clientID string, event pb.Event, msg proto.Message) (*pb.ClientMessage, error)
- func GetClientCert(clientID, clientSecret string, clientType pb.ClientType) []byte
- func InitRPCClients()
- func MasterCli(c context.Context) (pb.MasterClient, error)
- func MustInitClientsManager()
- func Recv(clientID string) chan bool
- type ClientsManager
- type ClientsManagerImpl
- type Connector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CallClient ¶
func GetClientCert ¶
func GetClientCert(clientID, clientSecret string, clientType pb.ClientType) []byte
func InitRPCClients ¶
func InitRPCClients()
func MustInitClientsManager ¶
func MustInitClientsManager()
Types ¶
type ClientsManager ¶
type ClientsManager interface {
Get(cliID string) *Connector
Set(cliID, clientType string, sender pb.Master_ServerSendServer)
Remove(cliID string)
}
func GetClientsManager ¶
func GetClientsManager() ClientsManager
type ClientsManagerImpl ¶
type ClientsManagerImpl struct {
// contains filtered or unexported fields
}
func NewClientsManager ¶
func NewClientsManager() *ClientsManagerImpl
func (*ClientsManagerImpl) Get ¶
func (c *ClientsManagerImpl) Get(cliID string) *Connector
Get implements ClientsManager.
func (*ClientsManagerImpl) Remove ¶
func (c *ClientsManagerImpl) Remove(cliID string)
func (*ClientsManagerImpl) Set ¶
func (c *ClientsManagerImpl) Set(cliID, clientType string, sender pb.Master_ServerSendServer)
Set implements ClientsManager.
Source Files
Click to show internal directories.
Click to hide internal directories.