subscribe

Documentation

Index

• Variables
• type Proxy
  • func (p *Proxy) SetRealPlugin(plug plugin.Plugin, engine model.Engine)
  • func (p *Proxy) WatchService(key model.ServiceKey) (interface{}, error)
• type Subscribe

Variables

var (
	SubScribedServices []model.ServiceKey
)

Types

type Proxy

type Proxy struct {
	Subscribe
	// contains filtered or unexported fields
}

proxy of WeightAdjuster

func (*Proxy) SetRealPlugin

func (p *Proxy) SetRealPlugin(plug plugin.Plugin, engine model.Engine)

设置

func (*Proxy) WatchService

func (p *Proxy) WatchService(key model.ServiceKey) (interface{}, error)

type Subscribe

type Subscribe interface {
	plugin.Plugin

	//执行消息处理逻辑
	DoSubScribe(event *common.PluginEvent) error

	//订阅service消息
	WatchService(key model.ServiceKey) (interface{}, error)
}