grpc_discover

README

Grpc Discover

Plugin

• ETCD
• Consul
• Redis

example

• etcd_example
• consul_example
• redis_example

server use etcd plugin

	lis, err := net.Listen("tcp", "127.0.0.1:8372")
	if err != nil {
		log.Fatalf("failed to listen: %v", err)
	}

	plugin, err := grpc_discover.NewETCDPlugin(clientv3.Config{
		Endpoints:   []string{"127.0.0.1:2379"},
		DialTimeout: 5 * time.Second,
	})
	if err != nil {
		panic(err)
	}

	// 注册服务 registration service
	serverID, err := plugin.Register("GreeterServer", lis.Addr().String())
	if err != nil {
		panic(err)
	}
	plugin.AutoUnRegister(serverID) // 自动反注册 Automatic anti-registration

	s := grpc.NewServer()
	proto.RegisterGreeterServer(s, &server{})
	log.Printf("server listening at %v", lis.Addr())
	if err := s.Serve(lis); err != nil {
		log.Fatalf("failed to serve: %v", err)
	}

client use etcd plugin

    plugin, err := grpc_discover.NewETCDPlugin(clientv3.Config{
		Endpoints:   []string{"127.0.0.1:2379"},
		DialTimeout: 5 * time.Second,
	})
	if err != nil {
		panic(err)
	}
	resolver.Register(plugin)

	// Set up a connection to the server.
	conn, err := grpc.Dial("etcd:///GreeterServer", grpc.WithTransportCredentials(insecure.NewCredentials()))
	if err != nil {
		log.Fatalf("did not connect: %v", err)
	}
	defer conn.Close()
	c := proto.NewGreeterClient(conn)

	// Contact the server and print out its response.
	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
	defer cancel()
	r, err := c.SayHello(ctx, &proto.HelloReply{Message: "cpxsd"})
	if err != nil {
		log.Fatalf("could not greet: %v", err)
	}
	log.Printf("Greeting: %s", r.GetName())

Documentation

Index

• Variables
• func Signal(call func())
• type ConsulPlugin
  • func NewConsulPlugin(config *consulapi.Config) (*ConsulPlugin, error)
  • func (c *ConsulPlugin) AutoUnRegister(serverID string)
  • func (c *ConsulPlugin) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (c *ConsulPlugin) DiscoverByServerID(serverID string) (string, error)
  • func (c *ConsulPlugin) DiscoverByServerName(serverName string) ([]string, error)
  • func (c *ConsulPlugin) Register(serverName string, address string, checkAddress string) (serverID string, err error)
  • func (c *ConsulPlugin) Scheme() string
  • func (c *ConsulPlugin) UnRegister(serverID string) error
• type ETCDPlugin
  • func NewETCDPlugin(config clientv3.Config) (*ETCDPlugin, error)
  • func (e *ETCDPlugin) AutoUnRegister(serverID string)
  • func (e *ETCDPlugin) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (e *ETCDPlugin) DiscoverByServerID(serverID string) (string, error)
  • func (e *ETCDPlugin) DiscoverByServerName(serverName string) ([]string, error)
  • func (e *ETCDPlugin) Register(serverName string, address string) (serverID string, err error)
  • func (e *ETCDPlugin) Scheme() string
  • func (e *ETCDPlugin) UnRegister(serverID string) error
• type GrpcDiscoverPluginInterface
• type RedisPlugin
  • func NewRedisPlugin(config *redis.Options) (*RedisPlugin, error)
  • func (r *RedisPlugin) AutoUnRegister(serverID string)
  • func (r *RedisPlugin) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r *RedisPlugin) DiscoverByServerID(serverID string) (string, error)
  • func (r *RedisPlugin) DiscoverByServerName(serverName string) ([]string, error)
  • func (r *RedisPlugin) Register(serverName string, address string) (serverID string, err error)
  • func (r *RedisPlugin) Scheme() string
  • func (r *RedisPlugin) UnRegister(serverID string) error

Variables

var (
	ErrServiceNotFound = errors.New("service not found")
)

errors

Functions

func Signal

func Signal(call func())

Types

type ConsulPlugin

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

func NewConsulPlugin

func NewConsulPlugin(config *consulapi.Config) (*ConsulPlugin, error)

func (*ConsulPlugin) AutoUnRegister

func (c *ConsulPlugin) AutoUnRegister(serverID string)

func (*ConsulPlugin) Build

func (c *ConsulPlugin) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*ConsulPlugin) DiscoverByServerID

func (c *ConsulPlugin) DiscoverByServerID(serverID string) (string, error)

func (*ConsulPlugin) DiscoverByServerName

func (c *ConsulPlugin) DiscoverByServerName(serverName string) ([]string, error)

func (*ConsulPlugin) Register

func (c *ConsulPlugin) Register(serverName string, address string, checkAddress string) (serverID string, err error)

func (*ConsulPlugin) Scheme

func (c *ConsulPlugin) Scheme() string

func (*ConsulPlugin) UnRegister

func (c *ConsulPlugin) UnRegister(serverID string) error

type ETCDPlugin

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

func NewETCDPlugin

func NewETCDPlugin(config clientv3.Config) (*ETCDPlugin, error)

NewETCDPlugin 初始化 etcd 插件，Initialize etcd plugin

func (*ETCDPlugin) AutoUnRegister

func (e *ETCDPlugin) AutoUnRegister(serverID string)

AutoUnRegister 自动退出

func (*ETCDPlugin) Build

func (e *ETCDPlugin) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*ETCDPlugin) DiscoverByServerID

func (e *ETCDPlugin) DiscoverByServerID(serverID string) (string, error)

func (*ETCDPlugin) DiscoverByServerName

func (e *ETCDPlugin) DiscoverByServerName(serverName string) ([]string, error)

func (*ETCDPlugin) Register

func (e *ETCDPlugin) Register(serverName string, address string) (serverID string, err error)

Register 服务注册

func (*ETCDPlugin) Scheme

func (e *ETCDPlugin) Scheme() string

func (*ETCDPlugin) UnRegister

func (e *ETCDPlugin) UnRegister(serverID string) error

UnRegister 服务反注册

type GrpcDiscoverPluginInterface

type GrpcDiscoverPluginInterface interface {
	Register(serverName string, address string) (serverID string, err error)
	UnRegister(serverID string) error
	AutoUnRegister(serverID string)

	DiscoverByServerName(serverName string) ([]string, error)
	DiscoverByServerID(serverID string) (string, error)

	Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
	Scheme() string
}

type RedisPlugin

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

func NewRedisPlugin

func NewRedisPlugin(config *redis.Options) (*RedisPlugin, error)

func (*RedisPlugin) AutoUnRegister

func (r *RedisPlugin) AutoUnRegister(serverID string)

func (*RedisPlugin) Build

func (r *RedisPlugin) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*RedisPlugin) DiscoverByServerID

func (r *RedisPlugin) DiscoverByServerID(serverID string) (string, error)

func (*RedisPlugin) DiscoverByServerName

func (r *RedisPlugin) DiscoverByServerName(serverName string) ([]string, error)

func (*RedisPlugin) Register

func (r *RedisPlugin) Register(serverName string, address string) (serverID string, err error)

func (*RedisPlugin) Scheme

func (r *RedisPlugin) Scheme() string

func (*RedisPlugin) UnRegister

func (r *RedisPlugin) UnRegister(serverID string) error