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 proxy of WeightAdjuster

func (*Proxy) SetRealPlugin

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

SetRealPlugin 设置

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)
}