registry

Documentation

Index

• Variables
• func CopyService(service *micro.Service) *micro.Service
• func CopyServices(current []*micro.Service) []*micro.Service
• func Merge(olist []*micro.Service, nlist []*micro.Service) []*micro.Service
• func NewEtcdRegistry(opts ...Option) (micro.Registry, error)
• func Remove(old, del []*micro.Service) []*micro.Service
• func Topic(service string, version *micro.Version, node string) string
• func Topics(service string, version *micro.Version, node string) []string
• type Option
  • func WithAddress(address []string) Option
  • func WithTLSConfig(config *tls.Config) Option
  • func WithTTL(timeout int32) Option
  • func WithTimeout(timeout int32) Option
• type Options

Variables

var (
	DefaultRegisterCheck = func(ctx context.Context) error { return nil }
)

Functions

func CopyService

func CopyService(service *micro.Service) *micro.Service

CopyService make a copy of service

func CopyServices

func CopyServices(current []*micro.Service) []*micro.Service

CopyServices makes a copy of services

func Merge

func Merge(olist []*micro.Service, nlist []*micro.Service) []*micro.Service

Merge merges two lists of services and returns a new copy

func NewEtcdRegistry

func NewEtcdRegistry(opts ...Option) (micro.Registry, error)

func Remove

func Remove(old, del []*micro.Service) []*micro.Service

Remove removes services and returns a new copy

func Topic

func Topic(service string, version *micro.Version, node string) string

Topic 获取需要发送的主题

func Topics

func Topics(service string, version *micro.Version, node string) []string

Types

type Option

type Option func(*Options)

func WithAddress

func WithAddress(address []string) Option

func WithTLSConfig

func WithTLSConfig(config *tls.Config) Option

func WithTTL

func WithTTL(timeout int32) Option

WithTTL timeout with seconds

func WithTimeout

func WithTimeout(timeout int32) Option

WithTimeout timeout with seconds

type Options

type Options struct {
	TLSConfig *tls.Config
	Address   []string
	Timeout   time.Duration
	TTL       time.Duration
}