Golang route.Uri类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中vulcan/router/route.Uri类的典型用法代码示例。如果您正苦于以下问题：Golang Uri类的具体用法？Golang Uri怎么用？Golang Uri使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了Uri类的8个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: Insert

func (r *Trie) Insert(uri route.Uri, value *route.Pool) *Trie {
	key := strings.TrimPrefix(uri.String(), "/")
	node := r

	for {
		pathParts := parts(key)
		SegmentValue := pathParts[0]

		matchingChild, ok := node.ChildNodes[SegmentValue]

		if !ok {
			matchingChild = NewTrie()
			matchingChild.Segment = SegmentValue
			matchingChild.Parent = node
			node.ChildNodes[SegmentValue] = matchingChild
		}

		node = matchingChild

		if len(pathParts) != 2 {
			break
		}

		key = pathParts[1]
	}

	node.Pool = value
	return node
}

开发者ID:qinguoan，项目名称:vulcan，代码行数:29，代码来源:trie.go

示例2: Find

func (r *Trie) Find(uri route.Uri) (*route.Pool, bool) {
	key := strings.TrimPrefix(uri.String(), "/")
	node := r

	for {
		pathParts := parts(key)
		SegmentValue := pathParts[0]

		matchingChild, ok := node.ChildNodes[SegmentValue]
		if !ok {
			return nil, false
		}

		node = matchingChild

		if len(pathParts) <= 1 {
			break
		}

		key = pathParts[1]
	}

	if nil != node.Pool {
		return node.Pool, true
	}

	return nil, false
}

开发者ID:qinguoan，项目名称:vulcan，代码行数:28，代码来源:trie.go

示例3: Delete

func (r *Trie) Delete(uri route.Uri) bool {
	key := strings.TrimPrefix(uri.String(), "/")
	node := r
	initialKey := key

	for {
		pathParts := parts(key)
		SegmentValue := pathParts[0]

		// It is currently impossible to Delete a non-existent path. This invariant is
		// provided by the fact that a call to Find is done before Delete in the registry.
		matchingChild, _ := node.ChildNodes[SegmentValue]

		node = matchingChild

		if len(pathParts) <= 1 {
			break
		}

		key = pathParts[1]
	}
	node.Pool = nil
	r.deleteEmptyNodes(initialKey)

	return true
}

开发者ID:qinguoan，项目名称:vulcan，代码行数:26，代码来源:trie.go

示例4: parseContextPath

func parseContextPath(uri route.Uri) string {
	contextPath := "/"
	split := strings.SplitN(strings.TrimPrefix(uri.String(), "/"), "/", 2)

	if len(split) > 1 {
		contextPath += split[1]
	}
	return contextPath
}

开发者ID:qinguoan，项目名称:vulcan，代码行数:9，代码来源:registry.go

示例5: Lookup

func (r *RouteRegistry) Lookup(uri route.Uri) *route.Pool {
	r.RLock()

	uri = uri.RouteKey()
	var err error
	pool, found := r.byUri.MatchUri(uri)

	r.logger.Infof("endpoint pool: %#v", pool)
	for !found && err == nil {
		uri, err = uri.NextWildcard()
		pool, found = r.byUri.MatchUri(uri)
	}

	r.RUnlock()

	return pool
}

开发者ID:qinguoan，项目名称:vulcan，代码行数:17，代码来源:registry.go

示例6: Register

func (r *RouteRegistry) Register(uri route.Uri, ep *route.Endpoint) {
	t := time.Now()
	r.Lock()

	uri = uri.RouteKey()

	pool, found := r.byUri.Find(uri)
	if !found {
		contextPath := parseContextPath(uri)
		pool = route.NewPool(r.dropletStaleThreshold/4, contextPath)
		r.byUri.Insert(uri, pool)
	}

	pool.Put(ep)

	r.timeOfLastUpdate = t
	r.Unlock()
}

开发者ID:qinguoan，项目名称:vulcan，代码行数:18，代码来源:registry.go

示例7: Unregister

func (r *RouteRegistry) Unregister(uri route.Uri, ep *route.Endpoint) {
	r.Lock()

	uri = uri.RouteKey()

	pool, found := r.byUri.Find(uri)
	if found {

		r.logger.Infof("remove endpoint %#v of uri: %#v", ep, uri)
		pool.Remove(ep)

		if pool.IsEmpty() {
			r.byUri.Delete(uri)
		}
	}

	r.Unlock()
}

开发者ID:qinguoan，项目名称:vulcan，代码行数:18，代码来源:registry.go

示例8: RegisterAll

func (r *RouteRegistry) RegisterAll(uri route.Uri, eps []*route.Endpoint) {
	r.Lock()
	defer r.Unlock()

	uri = uri.RouteKey()

	contextPath := parseContextPath(uri)
	pool := route.NewPool(r.dropletStaleThreshold/4, contextPath)

	for _, ep := range eps {
		r.logger.Infof("route.endpoint: %v", ep)
		pool.Put(ep)
	}

	r.logger.Infof("byUri: %#v", *pool)
	ok := r.byUri.Insert(uri, pool)
	r.logger.Infof("=======ok: %#v", *ok.Pool)

	r.timeOfLastUpdate = time.Now()

}

开发者ID:qinguoan，项目名称:vulcan，代码行数:21，代码来源:registry.go

注：本文中的vulcan/router/route.Uri类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。