Versions in this module Expand all Collapse all v0 v0.1.2 Oct 13, 2025 Changes in this version + type API struct + func NewAPI(ctx context.Context, client *Client, refreshInterval time.Duration) *API + func (e *API) Deregister(ctx context.Context, endpoints []Endpoint) error + func (e *API) GetService(ctx context.Context, serverName string) []Instance + func (e *API) Register(ctx context.Context, serviceName string, endpoints ...Endpoint) error + func (e *API) Subscribe(serverName string, fn func()) error + func (e *API) ToAppID(serverName string) string + func (e *API) Unsubscribe(serverName string) + type APIInterface interface + Deregister func(ctx context.Context, appID, instanceID string) error + Down func(ctx context.Context, appID, instanceID string) error + FetchAllUpInstances func(ctx context.Context) []Instance + FetchAppInstance func(ctx context.Context, appID string, instanceID string) (m Instance, err error) + FetchAppInstances func(ctx context.Context, appID string) (m Application, err error) + FetchAppUpInstances func(ctx context.Context, appID string) []Instance + FetchApps func(ctx context.Context) []Application + FetchInstance func(ctx context.Context, instanceID string) (m Instance, err error) + Heartbeat func(ep Endpoint) + Out func(ctx context.Context, appID, instanceID string) error + Register func(ctx context.Context, ep Endpoint) error + type Application struct + Instance []Instance + Name string + type ApplicationsResponse struct + Applications []Application + AppsHashcode string + Version string + type ApplicationsRootResponse struct + type Client struct + func NewClient(urls []string, opts ...ClientOption) *Client + func (e *Client) Deregister(ctx context.Context, appID, instanceID string) error + func (e *Client) Down(ctx context.Context, appID, instanceID string) error + func (e *Client) FetchAllUpInstances(ctx context.Context) []Instance + func (e *Client) FetchAppInstance(ctx context.Context, appID string, instanceID string) (m Instance, err error) + func (e *Client) FetchAppInstances(ctx context.Context, appID string) (m Application, err error) + func (e *Client) FetchAppUpInstances(ctx context.Context, appID string) []Instance + func (e *Client) FetchApps(ctx context.Context) []Application + func (e *Client) FetchInstance(ctx context.Context, instanceID string) (m Instance, err error) + func (e *Client) Heartbeat(ep Endpoint) + func (e *Client) Out(ctx context.Context, appID, instanceID string) error + func (e *Client) Register(ctx context.Context, ep Endpoint) error + type ClientOption func(e *Client) + func WithClientContext(ctx context.Context) ClientOption + func WithHeartbeatInterval(interval time.Duration) ClientOption + func WithMaxRetry(maxRetry int) ClientOption + func WithNamespace(path string) ClientOption + type DataCenterInfo struct + Class string + Name string + type Endpoint struct + AppID string + HealthCheckURL string + HomePageURL string + IP string + InstanceID string + MetaData map[string]string + Port int + SecurePort int + StatusPageURL string + type Instance struct + App string + DataCenterInfo DataCenterInfo + HealthCheckURL string + HomePageURL string + HostName string + IPAddr string + InstanceID string + Metadata map[string]string + Port Port + SecurePort Port + Status string + StatusPageURL string + VipAddress string + type Option func(o *Registry) + func WithContext(ctx context.Context) Option + func WithEurekaPath(path string) Option + func WithHeartbeat(interval time.Duration) Option + func WithRefresh(interval time.Duration) Option + type Port struct + Enabled string + Port int + type Registry struct + func New(eurekaUrls []string, opts ...Option) (*Registry, error) + func NewRegistry(c *conf.Registry) *Registry + func (r *Registry) Deregister(ctx context.Context, service *registry.ServiceInstance) error + func (r *Registry) Endpoints(service *registry.ServiceInstance) []Endpoint + func (r *Registry) GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error) + func (r *Registry) Register(ctx context.Context, service *registry.ServiceInstance) error + func (r *Registry) Watch(ctx context.Context, serviceName string) (registry.Watcher, error) + type RequestInstance struct + Instance Instance
Go to main page