Registry

    2.     // fetch the service list of serviceName
    3.     Fetch(ctx context.Context, serviceName string) ([]*ServiceInstance, error)
    4.     // subscribe to a list of serviceName
    5.     Watch(ctx context.Context, serviceName string) (Watcher, error)
    6. }

    Implementations:

    Usage

    Register a Service

    If use etcd or any other implementations, you can create a Registrar with other client.

    1. import (
    2.     "github.com/go-kratos/kratos/contrib/registry/etcd/v2"
    3.     clientv3 "go.etcd.io/etcd/client/v3"
    4. )
    5. // new etcd client
    6. client, err := clientv3.New(clientv3.Config{
    7.     Endpoints: []string{"127.0.0.1:2379"},
    8. })
    9. if err != nil {
    10.     panic(err)
    11. }
    12. // new reg with etcd client
    15. app := kratos.New(
    16.     // service-name
    17.     kratos.Name(Name),
    18.     kratos.Version(Version),
    19.     kratos.Metadata(map[string]string{}),
    20.     kratos.Logger(logger),
    21.     kratos.Server(
    22.         hs,
    23.         gs,
    24.     ),
    25.     // with registrar
    26. )

    Service Discovery (gRPC)

    It is the same as Register, if use etcd or any other implementations, you can create a Discovery with other client.

    1. import (
    3.     clientv3 "go.etcd.io/etcd/client/v3"
    4. )
    6. // new etcd client
    7. client, err := clientv3.New(clientv3.Config{
    8.     Endpoints: []string{"127.0.0.1:2379"},
    9. })
    10. if err != nil {
    11.     panic(err)
    12. }
    13. // new dis with etcd client
    14. dis := etcd.New(client)
    16. endpoint := "discovery://default/provider"
    17. conn, err := grpc.Dial(context.Background(), grpc.WithEndpoint(endpoint), grpc.WithDiscovery(dis))
    18. if err != nil {
    19.     panic(err)
    20. }