logic

Documentation

Index

• Constants
• Variables
• func CreateBizServer(ip string, port int) (*udp.Server, error)
• func CreateBrokerClient(ip string, port int, enableHeartbeat bool) *client.AsyncClient
• func KeepUsingHandler(_ *udp.Server, _ *net.UDPAddr, pb proto.Message)
• func PeriodPulling()
• func PullResultHandler(_ *client.AsyncClient, pb proto.Message)
• func PullWhenStart()
• func PushConfigHandler(_ *client.AsyncClient, pb proto.Message)
• func SubscribeReqHandler(server *udp.Server, addr *net.UDPAddr, pb proto.Message)
• func SubscribeResultHandler(_ *client.AsyncClient, pb proto.Message)
• type AccessRecord
  • func GetAccessRecord(serviceKeys []string) *AccessRecord
  • func (r *AccessRecord) Cleaner(cc *core.ConfigController)
  • func (r *AccessRecord) Record(serviceKey string)
  • func (r *AccessRecord) RemoveOutdated() []string

Constants

const (
	CleanPeriod int64 = 3600
)

Variables

var BizServer *udp.Server

biz服务

var BrokerClient *client.AsyncClient

broker客户端

var ConfController *core.ConfigController

配置管理

Functions

func CreateBizServer

func CreateBizServer(ip string, port int) (*udp.Server, error)

创建一个面向biz服务的UDP服务

func CreateBrokerClient

func CreateBrokerClient(ip string, port int, enableHeartbeat bool) *client.AsyncClient

func KeepUsingHandler

func KeepUsingHandler(_ *udp.Server, _ *net.UDPAddr, pb proto.Message)

KeepUsingReqId消息的回调

func PeriodPulling

func PeriodPulling()

func PullResultHandler

func PullResultHandler(_ *client.AsyncClient, pb proto.Message)

PullServiceConfigRspId消息的回调函数

func PullWhenStart

func PullWhenStart()

agent与broker重建连接后立刻拉取一次，以便告知broker：agent已订阅了哪些service key

func PushConfigHandler

func PushConfigHandler(_ *client.AsyncClient, pb proto.Message)

PushServiceConfigReqId消息的回调函数

func SubscribeReqHandler

func SubscribeReqHandler(server *udp.Server, addr *net.UDPAddr, pb proto.Message)

SubscribeReqId消息的回调

func SubscribeResultHandler

func SubscribeResultHandler(_ *client.AsyncClient, pb proto.Message)

SubscribeBrokerRspId消息的回调函数

Types

type AccessRecord

type AccessRecord struct {
	// contains filtered or unexported fields
}

周期性检查是否有待清理的serviceKey

var AccessRecordTable *AccessRecord

记录每个service的最近心跳

func GetAccessRecord

func GetAccessRecord(serviceKeys []string) *AccessRecord

agent启动加载共享内存后，使用共享内存中所有serviceKey，创建accessRecord

func (*AccessRecord) Cleaner

func (r *AccessRecord) Cleaner(cc *core.ConfigController)

周期性检查是否有需要删除的service key

func (*AccessRecord) Record

func (r *AccessRecord) Record(serviceKey string)

client每次KeepUsing请求到来就更新一下使用记录

func (*AccessRecord) RemoveOutdated

func (r *AccessRecord) RemoveOutdated() []string

删除近期未使用的serviceKey