Documentation ¶
Index ¶
- Variables
- func GetServices(criteria *skynet.Criteria) ([]*skynet.ServiceInfo, int64, error)
- func RegisterServices(si *skynet.ServiceInfo) error
- func UnRegisterServices(si *skynet.ServiceInfo) error
- type ClientManager
- type RPCMonitorGetIn
- type RPCMonitorGetOut
- type RPCMonitorRegisterIn
- type RPCMonitorRegisterOut
- type RPCMonitorUnRegisterIn
- type RPCMonitorUnRegisterOut
- type ServiceClient
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ServiceClientClosed = errors.New("Service client shutdown") MaxRetryCount = errors.New("Max Retry Count") )
Functions ¶
func GetServices ¶
func RegisterServices ¶
func RegisterServices(si *skynet.ServiceInfo) error
func UnRegisterServices ¶
func UnRegisterServices(si *skynet.ServiceInfo) error
Types ¶
type ClientManager ¶
type ClientManager struct {
// contains filtered or unexported fields
}
func NewClientManager ¶
func NewClientManager() *ClientManager
func (*ClientManager) DelClient ¶
func (manager *ClientManager) DelClient(serviceName, version string)
func (*ClientManager) DelClientByServiceKey ¶
func (manager *ClientManager) DelClientByServiceKey(serviceKey string)
func (*ClientManager) GetClient ¶
func (manager *ClientManager) GetClient(serviceName, version string) *ServiceClient
type RPCMonitorGetIn ¶
type RPCMonitorGetOut ¶
type RPCMonitorGetOut struct { Code string Services []*skynet.ServiceInfo RunTime int64 // 运行时间(Seconds) }
type RPCMonitorRegisterIn ¶
type RPCMonitorRegisterIn struct {
Si *skynet.ServiceInfo
}
type RPCMonitorRegisterOut ¶
type RPCMonitorRegisterOut struct {
Code string
}
type RPCMonitorUnRegisterIn ¶
type RPCMonitorUnRegisterIn struct {
Si *skynet.ServiceInfo
}
type RPCMonitorUnRegisterOut ¶
type RPCMonitorUnRegisterOut struct {
Code string
}
type ServiceClient ¶
type ServiceClient struct {
// contains filtered or unexported fields
}
func NewMonitorClient ¶
func NewMonitorClient() *ServiceClient
func NewServiceClient ¶
func NewServiceClient(criteria *skynet.Criteria) *ServiceClient
func (*ServiceClient) Close ¶
func (sc *ServiceClient) Close()
func (*ServiceClient) IsClosed ¶
func (sc *ServiceClient) IsClosed() bool
func (*ServiceClient) Send ¶
func (sc *ServiceClient) Send(fn string, in interface{}, out interface{}) error
func (*ServiceClient) UpdateServices ¶
func (sc *ServiceClient) UpdateServices(services []*skynet.ServiceInfo)
Click to show internal directories.
Click to hide internal directories.