eureka

package
v0.0.11 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApplicationInfo 

type ApplicationInfo struct {
	Application *WrapperApplicationInfo `json:"application"`
}

information of eureka application

type ApplicationList 

type ApplicationList struct {
	Applications *WrapperApplicationList `json:"applications"`
}

information of eureka application list

type DiscoveryClient 

type DiscoveryClient interface {
	DiscoveryStatusUpdate(status string) (bool, error)
	GetApplications(regions ...string) (*ApplicationList, error)
	GetApplication(appName string) (*ApplicationInfo, error)
	GetInstance(appName, instanceId string) (*InstanceInfo, error)
	GetInstanceById(instanceId string) (*InstanceInfo, error)
	Shutdown()
}

func NewDiscoveryClient 

func NewDiscoveryClient(conf *EurekaClientConfig) (registered bool, discovery DiscoveryClient, err error)

type EurekaClient 

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

func NewEurekaClient 

func NewEurekaClient(serviceUrlList []string, username, password string, contentIsJson bool) *EurekaClient

func (*EurekaClient) Deregister 

func (hc *EurekaClient) Deregister(appName, instanceId string) (bool, error)

deregister from eureka server

func (*EurekaClient) GetApplication 

func (hc *EurekaClient) GetApplication(appName string) (*ApplicationInfo, error)

get application's information by appName

func (*EurekaClient) GetApplications 

func (hc *EurekaClient) GetApplications(regions ...string) (*ApplicationList, error)

if regions is nil, get all application's information if regions is not nil,get application's information by regions

func (*EurekaClient) GetInstance 

func (hc *EurekaClient) GetInstance(appName, instanceId string) (*InstanceInfo, error)

get instance's information by appName and instanceId

func (*EurekaClient) GetInstanceById 

func (hc *EurekaClient) GetInstanceById(instanceId string) (*InstanceInfo, error)

get instance's information by instanceId

func (*EurekaClient) HttpRequest 

func (hc *EurekaClient) HttpRequest() *HttpRequest

func (*EurekaClient) Register 

func (hc *EurekaClient) Register(info *InstanceInfo) (success bool, err error)

register to eureka server

func (*EurekaClient) SendHeartBeat 

func (hc *EurekaClient) SendHeartBeat(appName, instanceId, status, lastDirtyTimestamp, overriddenStatus string) (int, error)

send heartbeat to eureka

func (*EurekaClient) ServiceUrl 

func (hc *EurekaClient) ServiceUrl() string

func (*EurekaClient) StatusUpdate 

func (hc *EurekaClient) StatusUpdate(appName, instanceId, status, lastDirtyTimestamp string) (bool, error)

update eureka client status

type EurekaClientConfig 

type EurekaClientConfig struct {
	AppName           string //application name
	InstanceId        string //instance id
	HostName          string //hostname
	IpAddr            string // IPAddr
	Port              int    //port
	Username          string
	Password          string
	HeaderContentType string

	ServiceUrls           []string //url list of service
	RegisterWithEureka    bool     //register to eureka server
	RenewalIntervalInSecs int      //lease-renewal-interval-in-seconds
	DurationInSecs        int      //lease-expiration-duration-in-seconds
}

type EurekaClientStub 

type EurekaClientStub struct {
	*WrapperInstanceInfo
	// contains filtered or unexported fields
}

func (*EurekaClientStub) Client 

func (d *EurekaClientStub) Client() *EurekaClient

func (*EurekaClientStub) Shutdown 

func (d *EurekaClientStub) Shutdown()

type EurekaDiscoveryClient 

type EurekaDiscoveryClient struct {
	registry.AbstractDiscoveryClient
	// contains filtered or unexported fields
}

func CreateEurekaDiscoveryClient 

func CreateEurekaDiscoveryClient() (*EurekaDiscoveryClient, error)

func (*EurekaDiscoveryClient) Client 

func (d *EurekaDiscoveryClient) Client() *EurekaClient

func (*EurekaDiscoveryClient) Deregister 

func (c *EurekaDiscoveryClient) Deregister(instance *registry.InstanceInfo) error

func (*EurekaDiscoveryClient) GetInstance 

func (c *EurekaDiscoveryClient) GetInstance(serviceId string) *registry.InstanceInfo

func (*EurekaDiscoveryClient) GetInstanceById 

func (c *EurekaDiscoveryClient) GetInstanceById(serviceId string, instanceId string) *registry.InstanceInfo

func (*EurekaDiscoveryClient) GetInstances 

func (c *EurekaDiscoveryClient) GetInstances(serviceId string) ([]registry.InstanceInfo, error)

func (*EurekaDiscoveryClient) GetService 

func (c *EurekaDiscoveryClient) GetService(serviceId string) (*registry.ServiceInfo, error)

func (*EurekaDiscoveryClient) GetServices 

func (c *EurekaDiscoveryClient) GetServices() ([]registry.ServiceInfo, error)

func (*EurekaDiscoveryClient) Register 

func (c *EurekaDiscoveryClient) Register(instance *registry.InstanceInfo) (bool, error)

func (*EurekaDiscoveryClient) SendHeartBeat 

func (c *EurekaDiscoveryClient) SendHeartBeat(instance *registry.InstanceInfo, status string) (bool, error)

type HttpRequest 

type HttpRequest struct {
	Base               string
	URL                string
	Method             string
	Headers            map[string]string
	Body               string
	Username, Password string
	ContentType        string
	Response           *http.Response
	StatusCode         int
	Error              error
	// contains filtered or unexported fields
}

func (*HttpRequest) BODY 

func (r *HttpRequest) BODY(body string) *HttpRequest

func (*HttpRequest) DELETE 

func (r *HttpRequest) DELETE(url string, params ...RequestParameters) *HttpRequest

func (*HttpRequest) Do 

func (r *HttpRequest) Do() *HttpRequest

func (*HttpRequest) Fetch 

func (r *HttpRequest) Fetch(data interface{}) (status int, err error)

func (*HttpRequest) GET 

func (r *HttpRequest) GET(url string, params ...RequestParameters) *HttpRequest

func (*HttpRequest) HEADER 

func (r *HttpRequest) HEADER(head string, value string) *HttpRequest

func (*HttpRequest) PASSWORD 

func (r *HttpRequest) PASSWORD(password string) *HttpRequest

func (*HttpRequest) PATCH 

func (r *HttpRequest) PATCH(url string, params ...RequestParameters) *HttpRequest

func (*HttpRequest) POST 

func (r *HttpRequest) POST(url string, params ...RequestParameters) *HttpRequest

func (*HttpRequest) PUT 

func (r *HttpRequest) PUT(url string, params ...RequestParameters) *HttpRequest

func (*HttpRequest) Result 

func (r *HttpRequest) Result() (status int, body []byte, err error)

func (*HttpRequest) ResultTo 

func (r *HttpRequest) ResultTo(result interface{}) (status int, err error)

func (*HttpRequest) String 

func (r *HttpRequest) String() (result string, err error)

func (*HttpRequest) USERNAME 

func (r *HttpRequest) USERNAME(username string) *HttpRequest

type InstanceInfo 

type InstanceInfo struct {
	Instance *WrapperInstanceInfo `json:"instance"`
}

information of eureka instance

type RequestParameters 

type RequestParameters map[string]string

type WrapperApplicationInfo 

type WrapperApplicationInfo struct {
	Name     string                `json:"name"`
	Instance []WrapperInstanceInfo `json:"instance"`
}

type WrapperApplicationList 

type WrapperApplicationList struct {
	Version      string                   `json:"versions__delta"`
	AppsHashCode string                   `json:"appsHashCode"`
	Applications []WrapperApplicationInfo `json:"application"`
}

type WrapperDataCenterInfo 

type WrapperDataCenterInfo struct {
	Class string `json:"@class,omitempty"`
	Name  string `json:"name,omitempty"`
}

type WrapperInstanceInfo 

type WrapperInstanceInfo struct {
	InstanceId                    string                 `json:"instanceId,omitempty"`
	HostName                      string                 `json:"hostName,omitempty"`
	App                           string                 `json:"app,omitempty"`
	IpAddr                        string                 `json:"ipAddr,omitempty"`
	Status                        string                 `json:"status,omitempty"`
	OverriddenStatus              string                 `json:"overriddenStatus,omitempty"`
	Port                          *WrapperPort           `json:"port,omitempty"`
	SecurePort                    *WrapperSecurePort     `json:"securePort,omitempty"`
	CountryId                     int                    `json:"countryId,omitempty"`
	DataCenterInfo                *WrapperDataCenterInfo `json:"dataCenterInfo,omitempty"`
	LeaseInfo                     *WrapperLeaseInfo      `json:"leaseInfo,omitempty"`
	Metadata                      *WrapperMetadata       `json:"metadata,omitempty"`
	HomePageUrl                   string                 `json:"homePageUrl,omitempty"`
	StatusPageUrl                 string                 `json:"statusPageUrl,omitempty"`
	HealthCheckUrl                string                 `json:"healthCheckUrl,omitempty"`
	VipAddress                    string                 `json:"vipAddress,omitempty"`
	SecureVipAddress              string                 `json:"secureVipAddress,omitempty"`
	IsCoordinatingDiscoveryServer string                 `json:"isCoordinatingDiscoveryServer,omitempty"`
	LastUpdatedTimestamp          string                 `json:"lastUpdatedTimestamp,omitempty"`
	LastDirtyTimestamp            string                 `json:"lastDirtyTimestamp,omitempty"`
	ActionType                    string                 `json:"actionType,omitempty"`
}

type WrapperLeaseInfo 

type WrapperLeaseInfo struct {
	RenewalIntervalInSecs int   `json:"renewalIntervalInSecs,omitempty"`
	DurationInSecs        int   `json:"durationInSecs,omitempty"`
	RegistrationTimestamp int64 `json:"registrationTimestamp,omitempty"`
	LastRenewalTimestamp  int64 `json:"lastRenewalTimestamp,omitempty"`
	EvictionTimestamp     int64 `json:"evictionTimestamp,omitempty"`
	ServiceUpTimestamp    int64 `json:"serviceUpTimestamp,omitempty"`
}

type WrapperMetadata 

type WrapperMetadata struct {
	ManagementPort string `json:"management.port,omitempty"`
	JmxPort        string `json:"jmx.port,omitempty"`
}

type WrapperPort 

type WrapperPort struct {
	Port    int         `json:"$,omitempty"`
	Enabled interface{} `json:"@enabled,omitempty"`
}

type WrapperSecurePort 

type WrapperSecurePort struct {
	Port   int         `json:"$,omitempty"`
	Enable interface{} `json:"@enabled"`
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.