registry

type Factory interface {
	Name() string
	Create(config.Config) (Registrar, error)
}

type Registrar interface {
	Name() string

	ServerConfigs() string
	// Register the registration.
	Register(ctx context.Context, service *ServiceInstance) error
	// Deregister the registration.
	Deregister(ctx context.Context, service *ServiceInstance) error

	// GetService return the service instances in memory according to the service name.
	GetService(ctx context.Context, serviceName string) ([]*ServiceInstance, error)
	// Watch creates a watcher according to the service name.
	Watch(ctx context.Context, serviceName string) (Watcher, error)

	GetAllServicesInfo(ctx context.Context) (ServiceList, error)

	GetImpl() any
}

type ServerItem struct {
	ServiceName string
	EndpointURL string //scheme://host:port/path
}

type ServiceInstance struct {
	ID       string            `json:"id"`
	Name     string            `json:"name"`
	Version  string            `json:"version"`
	Metadata map[string]string `json:"metadata"`
	//http://localhost:8000
	Endpoints []ServerItem `json:"endpoints"`
}

type ServiceList struct {
	Count    int64    `json:"count"`
	NameList []string `json:"name_list"`
}

type Watcher interface {
	// Next returns services in the following two cases:
	// 1.the first time to watch and the service instance list is not empty.
	// 2.any service instance changes found.
	// if the above two conditions are not met, it will block until context deadline exceeded or canceled
	Next() ([]*ServiceInstance, error)
	// Stop close the watcher.
	Stop() error
}