Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BusinessClient ¶
type BusinessClient interface {
// IsOnline gets the online status of the clientId
IsOnline(clientId string) (bool, error)
// SendToClientId sends a message to a clientId
SendToClientId(req *gateway.SendToClientIdRequest) (*gateway.SendToClientIdResponse, error)
// SendToClientId sends a message to multiple clientIds
SendToClientIds(req *gateway.SendToClientIdsRequest) (*gateway.SendToClientIdsResponse, error)
}
type BusinessClientConf ¶
type BusinessClientConf struct {
// contains filtered or unexported fields
}
NodeConf node config
func NewBusinessClientConf ¶
func NewBusinessClientConf(discoveryHandler discovery.ServiceDiscovery, sessionStorageHandler session_storage.SessionStorage) *BusinessClientConf
NewNodeConf creates a new NodeConf.
func (*BusinessClientConf) WithPassword ¶
func (conf *BusinessClientConf) WithPassword(password string) *BusinessClientConf
WithPassword sets the password for transport node
type GatewayClient ¶ added in v1.0.1
type GatewayClient struct {
// contains filtered or unexported fields
}
func NewGatewayClient ¶ added in v1.0.1
func NewGatewayClient(cfg *BusinessClientConf) *GatewayClient
func (*GatewayClient) IsOnline ¶ added in v1.0.1
func (g *GatewayClient) IsOnline(clientId string) (bool, error)
func (*GatewayClient) SendToClientId ¶ added in v1.0.1
func (g *GatewayClient) SendToClientId(req *gateway.SendToClientIdRequest) (*gateway.SendToClientIdResponse, error)
func (*GatewayClient) SendToClientIds ¶ added in v1.0.1
func (g *GatewayClient) SendToClientIds(req *gateway.SendToClientIdsRequest) (*gateway.SendToClientIdsResponse, error)
Click to show internal directories.
Click to hide internal directories.