Documentation
¶
Index ¶
- type Dispatcher
- func (d *Dispatcher) Endpoints() map[string]*endpoint.Endpoint
- func (d *Dispatcher) FindEndpoint(insID string) (*endpoint.Endpoint, error)
- func (d *Dispatcher) FindEvent(event int) (*Event, error)
- func (d *Dispatcher) FindRoute(route int32) (*Route, error)
- func (d *Dispatcher) ReplaceServices(services ...*registry.ServiceInstance)
- func (d *Dispatcher) VisitEndpoints(fn func(insID string, ep *endpoint.Endpoint) bool)
- type Event
- type Route
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
func NewDispatcher ¶
func NewDispatcher(dispatch cluster.Dispatch) *Dispatcher
func (*Dispatcher) Endpoints ¶
func (d *Dispatcher) Endpoints() map[string]*endpoint.Endpoint
Endpoints 获取所有端口
func (*Dispatcher) FindEndpoint ¶
func (d *Dispatcher) FindEndpoint(insID string) (*endpoint.Endpoint, error)
FindEndpoint 查找服务端口
func (*Dispatcher) FindEvent ¶
func (d *Dispatcher) FindEvent(event int) (*Event, error)
FindEvent 查找节点事件
func (*Dispatcher) FindRoute ¶
func (d *Dispatcher) FindRoute(route int32) (*Route, error)
FindRoute 查找节点路由
func (*Dispatcher) ReplaceServices ¶
func (d *Dispatcher) ReplaceServices(services ...*registry.ServiceInstance)
ReplaceServices 替换服务
func (*Dispatcher) VisitEndpoints ¶
func (d *Dispatcher) VisitEndpoints(fn func(insID string, ep *endpoint.Endpoint) bool)
VisitEndpoints 迭代服务端口
type Route ¶
type Route struct {
// contains filtered or unexported fields
}
func (*Route) FindEndpoint ¶
FindEndpoint 查询路由服务端点
Source Files
Click to show internal directories.
Click to hide internal directories.