handler

type AppEvent struct {
	DeleteApp []*model.App
	AddApp    []*model.App
	UpdateApp []*model.App
}

type AppManager struct {
	AppMap   map[string]*model.App
	AppSlice []*model.App

	UpdateAt  time.Time
	Observers map[AppObserver]bool
	// contains filtered or unexported fields
}

type AppObserver interface {
	Update(*AppEvent)
}

type AppSubject interface {
	Regist(ServiceObserver)
	Deregist(ServiceObserver)
	Notify(*AppEvent)
}

type DistributedCountService struct {
	Name        string
	Interval    time.Duration
	QPS         int64
	Unix        int64
	TickerCount int64
	TotalCount  int64
	// contains filtered or unexported fields
}

type DistributedLimiter struct {
	Name     string
	Dtype    int //0=qps 1=qpm 2=qph
	Rate     int64
	Capacity int64
}

type FlowAppCounter struct {
	FlowCounter
}

type FlowCounter struct {
	RedisFlowCountMap map[string]*DistributedCountService
	Locker            sync.RWMutex
}

type FlowLimiter struct {
	FlowLimiterMap map[string]*FlowLimiterItem
	Locker         sync.RWMutex
}

type FlowLimiterItem struct {
	LastTime      time.Time
	Name          string
	LType         int  //限流类型 0=qps 1=qpm 2=qph
	IsDistributed bool //是否分布式
	Limter        Limiter
}

type Limiter interface {
	Allow() bool
}

type LoadBalancer struct {
	LoadBanlanceMap   map[string]*LoadBalancerItem
	LoadBanlanceSlice []*LoadBalancerItem
	Locker            sync.RWMutex
}

type LoadBalancerItem struct {
	LoadBanlance *load_balance.LoadBalance
	ServiceName  string
	UpdatedAt    time.Time
}

type ServiceEvent struct {
	DeleteService []*model.ServiceDetail
	AddService    []*model.ServiceDetail
	UpdateService []*model.ServiceDetail
}

type ServiceManager struct {
	ServiceMap   map[string]*model.ServiceDetail
	ServiceSlice []*model.ServiceDetail

	UpdateAt  time.Time
	Observers map[ServiceObserver]bool
	sync.RWMutex
	// contains filtered or unexported fields
}

type ServiceObserver interface {
	Update(*ServiceEvent)
}

type ServiceSubject interface {
	Regist(ServiceObserver)
	Deregist(ServiceObserver)
	Notify(*ServiceEvent)
}

type TransportItem struct {
	Trans       *http.Transport
	ServiceName string
	UpdateAt    time.Time
}

type Transportor struct {
	TransportMap   map[string]*TransportItem
	TransportSlice []*TransportItem
	Locker         sync.RWMutex
}