dubboregistry

Documentation

Index

• type Adapter
  • func (a *Adapter) Apply() error
  • func (a *Adapter) Config() interface{}
  • func (a *Adapter) OnAddAPI(r router.API) error
  • func (a *Adapter) OnDeleteRouter(r config.Resource) error
  • func (a *Adapter) OnRemoveAPI(r router.API) error
  • func (a *Adapter) Start()
  • func (a *Adapter) Stop()
• type AdaptorConfig
• type Plugin
  • func (p *Plugin) CreateAdapter(a *model.Adapter) (adapter.Adapter, error)
  • func (p Plugin) Kind() string

Types

type Adapter

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

Adapter to monitor dubbo services on registry center

func (*Adapter) Apply

func (a *Adapter) Apply() error

Apply inits the registries according to the configuration

func (*Adapter) Config

func (a *Adapter) Config() interface{}

Config returns the config of the adaptor

func (*Adapter) OnAddAPI

func (a *Adapter) OnAddAPI(r router.API) error

func (*Adapter) OnDeleteRouter

func (a *Adapter) OnDeleteRouter(r config.Resource) error

func (*Adapter) OnRemoveAPI

func (a *Adapter) OnRemoveAPI(r router.API) error

func (*Adapter) Start

func (a *Adapter) Start()

Start starts the adaptor

func (*Adapter) Stop

func (a *Adapter) Stop()

Stop stops the adaptor

type AdaptorConfig

type AdaptorConfig struct {
	Registries map[string]model.Registry `yaml:"registries" json:"registries" mapstructure:"registries"`
}

type Plugin

type Plugin struct {
}

Plugin to monitor dubbo services on registry center

func (*Plugin) CreateAdapter

func (p *Plugin) CreateAdapter(a *model.Adapter) (adapter.Adapter, error)

CreateAdapter returns the dubbo registry center adapter

func (Plugin) Kind

func (p Plugin) Kind() string

Kind returns the identifier of the plugin