resolver

Documentation

Index

• type NamespaceNodes
• type Resolver
  • func NewResolver(sharedIndexInformers []cache.SharedIndexInformer, idFilterPrefix string) *Resolver
  • func (b *Resolver) RegisterCalcShardIDFunc(f rpc.CalcShardIDFunc)
  • func (c *Resolver) Resolve(namespace string, obj interface{}) (*rpc.NodeInfo, error)
  • func (c *Resolver) ResolveAll(namespace string) ([]*rpc.NodeInfo, error)
• type StaticResolver
  • func (b *StaticResolver) RegisterCalcShardIDFunc(f rpc.CalcShardIDFunc)
  • func (s *StaticResolver) Resolve(namespace string, obj interface{}) (*rpc.NodeInfo, error)
  • func (s *StaticResolver) ResolveAll(namespace string) ([]*rpc.NodeInfo, error)
  • func (s *StaticResolver) SetIndex(nodeInfosIndex map[string]NamespaceNodes)

Types

type NamespaceNodes

type NamespaceNodes map[string]*rpc.NodeInfo

NamespaceNodes namespace node list

type Resolver

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

Resolver Configmap resolver

func NewResolver

func NewResolver(sharedIndexInformers []cache.SharedIndexInformer, idFilterPrefix string) *Resolver

NewResolver create Resolver and start

func (*Resolver) RegisterCalcShardIDFunc

func (b *Resolver) RegisterCalcShardIDFunc(f rpc.CalcShardIDFunc)

RegisterCalcShardIDFunc register calc shardID func

func (*Resolver) Resolve

func (c *Resolver) Resolve(namespace string, obj interface{}) (*rpc.NodeInfo, error)

Resolve resolve config

func (*Resolver) ResolveAll

func (c *Resolver) ResolveAll(namespace string) ([]*rpc.NodeInfo, error)

ResolveAll namespace all node

type StaticResolver

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

StaticResolver static router

func (*StaticResolver) RegisterCalcShardIDFunc

func (b *StaticResolver) RegisterCalcShardIDFunc(f rpc.CalcShardIDFunc)

RegisterCalcShardIDFunc register calc shardID func

func (*StaticResolver) Resolve

func (s *StaticResolver) Resolve(namespace string, obj interface{}) (*rpc.NodeInfo, error)

Resolve resolve config

func (*StaticResolver) ResolveAll

func (s *StaticResolver) ResolveAll(namespace string) ([]*rpc.NodeInfo, error)

ResolveAll namespace all node

func (*StaticResolver) SetIndex

func (s *StaticResolver) SetIndex(nodeInfosIndex map[string]NamespaceNodes)

SetIndex sets resolve static config