discovery

README

Discovery Registry

This module implements a registry.Registrar and registry.Discovery interface in kratos based bilibili/discovery.

Quick Start

Register a service

import (
	"github.com/fengleng/mars/contrib/registry/discovery"
)

func main() {
	// initialize a registry
	r := discovery.New(&discovery.Config{
		Nodes:  []string{"0.0.0.0:7171"},
		Env:    "dev",
		Region: "sh1",
		Zone:   "zone1",
		Host:   "hostname",
	})

	// construct srv instance
	// ...
	
	app := kratos.New(
		kratos.Name("helloworld"),
		kratos.Server(
			httpSrv,
			grpcSrv,
		),
		kratos.Metadata(map[string]string{"color": "gray"}),
		// use Registrar
		kratos.Registrar(r),
	)
	
	if err := app.Run(); err != nil {
		log.NewHelper(logger).Fatal(err)
	}	
}

Discover a service

import (
	"github.com/fengleng/mars/contrib/registry/discovery"
	"github.com/fengleng/mars/transport/grpc"
)

func main() {
	// initialize a discovery
	r := discovery.New(&discovery.Config{
		Nodes:  []string{"0.0.0.0:7171"},
		Env:    "dev",
		Region: "sh1",
		Zone:   "zone1",
		Host:   "localhost",
	}, nil)

	conn, err := grpc.DialInsecure(
		context.Background(),
		grpc.WithEndpoint("discovery:///appid"),
		// use discovery
		grpc.WithDiscovery(r),
	)
	if err != nil {
		log.Fatal(err)
	}
	defer conn.Close()
	
	// request and log
}

Config explain

type Config struct {
	Nodes  []string // discovery nodes address
	Region string   // region of the service, sh
	Zone   string   // zone of region, sh001
	Env    string   // env of service, dev, prod and etc
	Host   string   // hostname of service
}

References

• bilibili/discovery

Documentation

Index

• Variables
• type Config
• type Discovery
  • func New(c *Config) *Discovery
  • func (d *Discovery) Close() error
  • func (d *Discovery) Deregister(ctx context.Context, service *registry.ServiceInstance) error
  • func (d *Discovery) GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)
  • func (d *Discovery) Register(ctx context.Context, service *registry.ServiceInstance) (err error)
  • func (d *Discovery) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)
• type Resolve
  • func (r *Resolve) Close() error
  • func (r *Resolve) Watch() <-chan struct{}

Variables

var (
	ErrDuplication = errors.New("register failed: instance duplicated: ")
	ErrServerError = errors.New("server error")
)

Types

type Config

type Config struct {
	Nodes  []string
	Region string
	Zone   string
	Env    string
	Host   string
}

Config Discovery configures.

type Discovery

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

func New

func New(c *Config) *Discovery

New construct a Discovery instance which implements registry.Registrar, registry.Discovery and registry.Watcher.

func (*Discovery) Close

func (d *Discovery) Close() error

Close stop all running process including Discovery and register

func (*Discovery) Deregister

func (d *Discovery) Deregister(ctx context.Context, service *registry.ServiceInstance) error

func (*Discovery) GetService

func (d *Discovery) GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)

func (*Discovery) Register

func (d *Discovery) Register(ctx context.Context, service *registry.ServiceInstance) (err error)

func (*Discovery) Watch

func (d *Discovery) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)

type Resolve

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

Resolve Discovery resolver.

func (*Resolve) Close

func (r *Resolve) Close() error

Close resolver

func (*Resolve) Watch

func (r *Resolve) Watch() <-chan struct{}

Watch instance.