source

Documentation

Index

• func DataHandler(ctx *context.Context)
• func EventChan() <-chan *Event
• func Init()
• type Event
  • func NewEvent(ed *discovery.EndpointInfo) *Event
  • func (nd *Event) Key() string
• type EventType

Functions

func DataHandler

func DataHandler(ctx *context.Context)

新建服务发现 source的主要逻辑，这里是一个协程处理，是将etcd中的变更传入到eventChan中， 等待dispatcher通过eventChan去操作dis到map，也就是对应修改/删除操作。 具体的：这里不需要接口操作，所有的数据通过etcd watch发现，得到的数据是etcd的k-v结构 利用set和del去操作这个k-v，一个k-v等于是一个gateway，操作的具体行为是插入eventChan，source只需要做好这个就好了。

func EventChan

func EventChan() <-chan *Event

func Init

func Init()

Types

type Event

type Event struct {
	Type         EventType
	IP           string
	Port         string
	ConnectNum   float64
	MessageBytes float64
}

func NewEvent

func NewEvent(ed *discovery.EndpointInfo) *Event

一个event，对应一个endpoint的操作，增加/删除/更新

func (*Event) Key

func (nd *Event) Key() string

type EventType

type EventType string

const (
	AddNodeEvent EventType = "addNode"
	DelNodeEvent EventType = "delNode"
)