nodebucket

Documentation

Index

• func Build()
• func HandleBucketNode(chanel chan map[string]interface{})
• func HandleBucketOperate(chanel chan map[string]interface{})
• func HandleBucketSeed(chanel chan map[string]interface{})
• func RunService(chanels map[string]chan map[string]interface{}) *error.Error

Functions

func Build

func Build()

Build 为了初始化全局变量bucket

func HandleBucketNode

func HandleBucketNode(chanel chan map[string]interface{})

HandleBucketNode 输出可用Node 主要对外输出可用Node，给节点连接服务为主

func HandleBucketOperate

func HandleBucketOperate(chanel chan map[string]interface{})

HandleBucketOperate 接收数据 主要管理bucket添加节点操作

func HandleBucketSeed

func HandleBucketSeed(chanel chan map[string]interface{})

HandleBucketSeed 推送数据 这里主要是对外输出可用Seed，给节点发现服务用为主

func RunService

func RunService(chanels map[string]chan map[string]interface{}) *error.Error

RunService 负责接收Bucket chanel的消息，并持续处理 可能添加new tried节点路由，也可能是添加邻居路由