registry

Documentation

Index

• Constants
• Variables
• type NewRegistry
• type Option
  • func ApplicationConf(conf common.ApplicationConfig) Option
  • func Context(ctx context.Context) Option
  • func RegistryConf(conf RegistryConfig) Option
• type Options
• type ProviderServiceConfig
  • func (c ProviderServiceConfig) ServiceEqual(url *ServiceURL) bool
  • func (c ProviderServiceConfig) String() string
• type Registry
• type RegistryConfig
• type Result
• type ServerConfig
  • func (c *ServerConfig) Address() string
• type ServiceConfig
  • func (c ServiceConfig) Key() string
  • func (c ServiceConfig) ServiceEqual(url *ServiceURL) bool
  • func (c ServiceConfig) String() string
• type ServiceConfigIf
• type ServiceURL
  • func NewServiceURL(urlString string) (*ServiceURL, error)
  • func (s *ServiceURL) CheckMethod(method string) bool
  • func (s *ServiceURL) ServiceConfig() ServiceConfig
  • func (s ServiceURL) String() string
• type ServiceURLEvent
  • func (e ServiceURLEvent) String() string
• type ServiceURLEventType
  • func (t ServiceURLEventType) String() string
• type Watcher

Constants

const (
	ServiceURLAdd = iota
	ServiceURLDel
	ServiceURLUpdate
)

const (
	REGISTRY_CONN_DELAY = 3 // watchDir中使用，防止不断地对zk重连
)

Variables

var (
	ErrorRegistryNotFound = errors.New("registry not found")
)

Types

type NewRegistry

type NewRegistry func(...Option) Registry

type Option

type Option func(*Options)

Option used to initialise the client

func ApplicationConf

func ApplicationConf(conf common.ApplicationConfig) Option

func Context

func Context(ctx context.Context) Option

func RegistryConf

func RegistryConf(conf RegistryConfig) Option

type Options

type Options struct {
	common.ApplicationConfig
	RegistryConfig

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type ProviderServiceConfig

type ProviderServiceConfig struct {
	ServiceConfig
	Path    string
	Methods string
}

func (ProviderServiceConfig) ServiceEqual

func (c ProviderServiceConfig) ServiceEqual(url *ServiceURL) bool

func (ProviderServiceConfig) String

func (c ProviderServiceConfig) String() string

type Registry

type Registry interface {
	// Register(conf ServiceConfig) error
	Register(conf interface{}) error
	GetServices(ServiceConfigIf) ([]*ServiceURL, error)
	Watch() (Watcher, error)
	Close()
	String() string
}

The registry provides an interface for service discovery and an abstraction over varying implementations {etcd, zookeeper, ...}

type RegistryConfig

type RegistryConfig struct {
	Address  []string `required:"true"`
	UserName string
	Password string
	Timeout  int `default:"5"` // unit: second
}

type Result

type Result = ServiceURLEvent

Result is returned by a call to Next on the watcher. Actions can be create, update, delete

type ServerConfig

type ServerConfig struct {
	Protocol string `required:"true",default:"dubbo"` // codec string, jsonrpc etc
	IP       string
	Port     int `required:"true"`
}

func (*ServerConfig) Address

func (c *ServerConfig) Address() string

type ServiceConfig

type ServiceConfig struct {
	Protocol string `required:"true",default:"dubbo"` // codec string, jsonrpc etc
	Service  string `required:"true"`                 // 其本质是dubbo.xml中的interface
	Group    string
	Version  string
}

func (c *consumerZookeeperRegistry) Register(conf ServiceConfig) 函数用到了Service

func (ServiceConfig) Key

func (c ServiceConfig) Key() string

func (ServiceConfig) ServiceEqual

func (c ServiceConfig) ServiceEqual(url *ServiceURL) bool

目前不支持一个service的多个协议的使用，将来如果要支持，关键点就是修改这个函数

func (ServiceConfig) String

func (c ServiceConfig) String() string

type ServiceConfigIf

type ServiceConfigIf interface {
	String() string
	ServiceEqual(url *ServiceURL) bool
}

type ServiceURL

type ServiceURL struct {
	Protocol     string
	Location     string // ip+port
	Path         string // like  /com.ikurento.dubbo.UserProvider3
	Ip           string
	Port         string
	Version      string
	Group        string
	Query        url.Values
	Weight       int32
	PrimitiveURL string
}

func NewServiceURL

func NewServiceURL(urlString string) (*ServiceURL, error)

func (*ServiceURL) CheckMethod

func (s *ServiceURL) CheckMethod(method string) bool

func (*ServiceURL) ServiceConfig

func (s *ServiceURL) ServiceConfig() ServiceConfig

func (ServiceURL) String

func (s ServiceURL) String() string

type ServiceURLEvent

type ServiceURLEvent struct {
	Action  ServiceURLEventType
	Service *ServiceURL
}

func (ServiceURLEvent) String

func (e ServiceURLEvent) String() string

type ServiceURLEventType

type ServiceURLEventType int

func (ServiceURLEventType) String

func (t ServiceURLEventType) String() string

type Watcher

type Watcher interface {
	// Next is a blocking call
	Next() (*Result, error)
	Valid() bool // 检查watcher与registry连接是否正常
	Stop()
}

Watcher is an interface that returns updates about services within the registry.