discovery

Documentation

Index

• Constants
• type Config
• type Discovery
  • func New(cfg Config) (*Discovery, error)
  • func (d *Discovery) Register(ctx context.Context, node Service) error
  • func (d *Discovery) Resolve(ctx context.Context, handlers []ResolveHandler) error
• type EnventType
• type Register
• type ResolveHandler
• type Resolver
• type Service
  • func (s Service) Key() string
  • func (s Service) Value() string
  • func (s Service) WatchKey() string
• type Watcher
  • func NewWatcher(ctx context.Context, brokers []string) (Watcher, error)
  • func NewWatcherWithClient(ctx context.Context, cli *clientv3.Client) Watcher

Constants

const (
	GrpcDiscoveryPrefix = "service://"
)

Types

type Config

type Config struct {
	Endpoints   []string
	DialTimeout int64
	HeartTime   int64
}

type Discovery

type Discovery struct {
	HeartTime int64
	Config    Config
	// contains filtered or unexported fields
}

func New

func New(cfg Config) (*Discovery, error)

func (*Discovery) Register

func (d *Discovery) Register(ctx context.Context, node Service) error

func (*Discovery) Resolve

func (d *Discovery) Resolve(ctx context.Context, handlers []ResolveHandler) error

type EnventType

type EnventType mvccpb.Event_EventType

var (
	PUT    EnventType = EnventType(mvccpb.PUT)
	DELETE EnventType = EnventType(mvccpb.DELETE)
)

type Register

type Register interface {
	Register(ctx context.Context, node Service) error
}

type ResolveHandler

type ResolveHandler func(EnventType, Service)

type Resolver

type Resolver interface {
	Resolve(ctx context.Context, handlers []ResolveHandler) error
}

type Service

type Service struct {
	AppID    string            `json:"app_id"`
	Name     string            `json:"name"`
	Host     string            `json:"host"`
	Port     int               `json:"port"`
	Metadata map[string]string `json:"metadata"`
}

func (Service) Key

func (s Service) Key() string

func (Service) Value

func (s Service) Value() string

func (Service) WatchKey

func (s Service) WatchKey() string

type Watcher

type Watcher interface {
	Watch(string, bool, func(*clientv3.Event))
	Shutdown()
}

func NewWatcher

func NewWatcher(ctx context.Context, brokers []string) (Watcher, error)

func NewWatcherWithClient

func NewWatcherWithClient(ctx context.Context, cli *clientv3.Client) Watcher