eureka

Documentation

Index

• type DataCenterInfo
• type Endpoint
• type EurekaRegistry
  • func NewEurekaRegistry(reg *regOps.RegistryOptions, opts ...Option) *EurekaRegistry
  • func (r *EurekaRegistry) Deregister(ctx context.Context, service *registry.ServiceInstance) error
  • func (r *EurekaRegistry) Endpoints(service *registry.ServiceInstance) []Endpoint
  • func (e *EurekaRegistry) Heartbeat(ep Endpoint)
  • func (r *EurekaRegistry) Register(ctx context.Context, service *registry.ServiceInstance) error
• type Instance
• type Option
  • func WithClientContext(ctx context.Context) Option
  • func WithContext(ctx context.Context) Option
  • func WithEurekaPath(path string) Option
  • func WithHeartbeat(interval time.Duration) Option
  • func WithHeartbeatInterval(interval time.Duration) Option
  • func WithMaxRetry(maxRetry int) Option
  • func WithNamespace(path string) Option
  • func WithRefresh(interval time.Duration) Option
• type Port
• type RequestInstance

Types

type DataCenterInfo

type DataCenterInfo struct {
	Name  string `json:"name"`
	Class string `json:"@class"`
}

type Endpoint

type Endpoint struct {
	InstanceID     string
	IP             string
	AppID          string
	Port           int
	SecurePort     int
	HomePageURL    string
	StatusPageURL  string
	HealthCheckURL string
	MetaData       map[string]string
}

type EurekaRegistry

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

func NewEurekaRegistry

func NewEurekaRegistry(reg *regOps.RegistryOptions, opts ...Option) *EurekaRegistry

func (*EurekaRegistry) Deregister

func (r *EurekaRegistry) Deregister(ctx context.Context, service *registry.ServiceInstance) error

func (*EurekaRegistry) Endpoints

func (r *EurekaRegistry) Endpoints(service *registry.ServiceInstance) []Endpoint

func (*EurekaRegistry) Heartbeat

func (e *EurekaRegistry) Heartbeat(ep Endpoint)

func (*EurekaRegistry) Register

func (r *EurekaRegistry) Register(ctx context.Context, service *registry.ServiceInstance) error

type Instance

type Instance struct {
	InstanceID     string            `json:"instanceId"`
	HostName       string            `json:"hostName"`
	Port           Port              `json:"port"`
	App            string            `json:"app"`
	IPAddr         string            `json:"ipAddr"`
	VipAddress     string            `json:"vipAddress"`
	Status         string            `json:"status"`
	SecurePort     Port              `json:"securePort"`
	HomePageURL    string            `json:"homePageUrl"`
	StatusPageURL  string            `json:"statusPageUrl"`
	HealthCheckURL string            `json:"healthCheckUrl"`
	DataCenterInfo DataCenterInfo    `json:"dataCenterInfo"`
	Metadata       map[string]string `json:"metadata"`
}

type Option

type Option func(o *EurekaRegistry)

func WithClientContext

func WithClientContext(ctx context.Context) Option

func WithContext

func WithContext(ctx context.Context) Option

WithContext with registry context.

func WithEurekaPath

func WithEurekaPath(path string) Option

func WithHeartbeat

func WithHeartbeat(interval time.Duration) Option

func WithHeartbeatInterval

func WithHeartbeatInterval(interval time.Duration) Option

func WithMaxRetry

func WithMaxRetry(maxRetry int) Option

func WithNamespace

func WithNamespace(path string) Option

func WithRefresh

func WithRefresh(interval time.Duration) Option

type Port

type Port struct {
	Port    int    `json:"$"`
	Enabled string `json:"@enabled"`
}

type RequestInstance

type RequestInstance struct {
	Instance Instance `json:"instance"`
}