Documentation ¶
Index ¶
- Variables
- type Config
- type Registry
- func (r *Registry) FindAllEventMeshInfo() ([]*registry.EventMeshDataInfo, error)
- func (r *Registry) FindEventMeshClientDistributionData(clusterName, group, purpose string) (map[string]map[string]int, error)
- func (r *Registry) FindEventMeshInfoByCluster(clusterName string) ([]*registry.EventMeshDataInfo, error)
- func (r *Registry) Init() error
- func (r *Registry) Register(info *registry.EventMeshRegisterInfo) error
- func (r *Registry) RegisterMetadata(map[string]string)
- func (r *Registry) Setup(name string, dec plugin.Decoder) error
- func (r *Registry) Shutdown() error
- func (r *Registry) Start() error
- func (r *Registry) Type() string
- func (r *Registry) UnRegister(info *registry.EventMeshUnRegisterInfo) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultClusterName = "DEFAULT" DefaultGroupName = "DEFAULT_GROUP" DefaultWeight float64 = 10 )
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { ServiceName string `yaml:"service-name"` CacheDir string `yaml:"cache-dir"` Port string `yaml:"port"` // nacos server port AddressList string `yaml:"address-list"` // nacos server address list }
Config define registry nacos plugin config
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
func (*Registry) FindAllEventMeshInfo ¶
func (r *Registry) FindAllEventMeshInfo() ([]*registry.EventMeshDataInfo, error)
func (*Registry) FindEventMeshClientDistributionData ¶
func (r *Registry) FindEventMeshClientDistributionData(clusterName, group, purpose string) (map[string]map[string]int, error)
FindEventMeshClientDistributionData not used deprecate
func (*Registry) FindEventMeshInfoByCluster ¶
func (r *Registry) FindEventMeshInfoByCluster(clusterName string) ([]*registry.EventMeshDataInfo, error)
func (*Registry) RegisterMetadata ¶
func (*Registry) UnRegister ¶
func (r *Registry) UnRegister(info *registry.EventMeshUnRegisterInfo) error
Click to show internal directories.
Click to hide internal directories.