discovery

type Client struct {
	Namespace *string

	DiscoveryAndRegister
	// contains filtered or unexported fields
}

type DiscoveryAndRegister interface {
	// ReleaseDiscovery cancel the discovery of a Naming.
	ReleaseDiscovery(naming string)

	// Discovery a Naming, will open a goroutine to achieve continuous discovery of Naming.
	Discovery(namespace *string, naming string) error

	// Unregister one or more services using an Endpoint ID.
	Unregister(namespace *string, naming string, ids ...string) error

	// Register one or more services with Naming.
	Register(namespace *string, naming string, endpoints ...*Endpoint) error

	// UseListener
	//
	// Monitors whether a Naming is available.
	// When ready is true, it means that there are available services for this Naming.
	// When it is false, it means that there are no services available under the Naming.
	UseListener(naming string, callback ListenCallbackFunc) (string, error)

	// DestroyListener cancel listening to Naming based on the ListenerID returned by UseListener.
	DestroyListener(naming, listenerID string)
}

type Endpoint struct {
	ID          string              `json:"id"`
	PeerAddress string              `json:"peer-addr"`
	Metadata    jsoniter.RawMessage `json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type EndpointMetadata interface {
	Entry() (jsoniter.RawMessage, error)
}

type KVMetadata[K comparable, V any] struct {
	// contains filtered or unexported fields
}

type ListenCallbackFunc func(ready bool, conn *grpc.ClientConn, wg *sync.WaitGroup)

type Service interface {
	// Naming returns service naming.
	Naming() string

	// SetNaming set service naming.
	SetNaming(naming string)

	WithEndpointNaming(endpointID string) string

	// Alive returns whether the current service is available.
	Alive() bool

	// AddEndpoints by endpoints slice.
	AddEndpoints(endpoints ...*Endpoint)

	// DelEndpoints by id slice.
	DelEndpoints(ids ...string)

	RangeEndpoints(f func(endpoint *Endpoint) bool)

	// AliveConn returns the grpc connection of all service endpoints on internal.
	//
	// DON'T CLOSE GRPC CONN
	AliveConn() map[string]*grpc.ClientConn

	// NextAliveConn returns the internal grpc connection through the load balancing algorithm.
	//
	// DON"T CLOSE GRPC CONN
	NextAliveConn() (*grpc.ClientConn, error)

	// CloseAliveConn Close internal all grpc conn.
	CloseAliveConn()

	// DialContext realizes the grpc connect function of internal load balancing through round-robin algorithm.
	DialContext(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

	// DialAll connect to all endpoints.
	DialAll(ctx context.Context, opts ...grpc.DialOption) (map[string]*grpc.ClientConn, error)
}