Documentation ¶
Index ¶
- type ApplicationInfo
- type ApplicationList
- type DiscoveryClient
- type EurekaClient
- func (hc *EurekaClient) Deregister(appName, instanceId string) (bool, error)
- func (hc *EurekaClient) GetApplication(appName string) (*ApplicationInfo, error)
- func (hc *EurekaClient) GetApplications(regions ...string) (*ApplicationList, error)
- func (hc *EurekaClient) GetInstance(appName, instanceId string) (*InstanceInfo, error)
- func (hc *EurekaClient) GetInstanceById(instanceId string) (*InstanceInfo, error)
- func (hc *EurekaClient) HttpRequest() *HttpRequest
- func (hc *EurekaClient) Register(info *InstanceInfo) (success bool, err error)
- func (hc *EurekaClient) SendHeartBeat(appName, instanceId, status, lastDirtyTimestamp, overriddenStatus string) (int, error)
- func (hc *EurekaClient) ServiceUrl() string
- func (hc *EurekaClient) StatusUpdate(appName, instanceId, status, lastDirtyTimestamp string) (bool, error)
- type EurekaClientConfig
- type EurekaClientStub
- type EurekaDiscoveryClient
- func (d *EurekaDiscoveryClient) Client() *EurekaClient
- func (c *EurekaDiscoveryClient) Deregister(instance *registry.InstanceInfo) error
- func (c *EurekaDiscoveryClient) GetInstance(serviceId string) *registry.InstanceInfo
- func (c *EurekaDiscoveryClient) GetInstanceById(serviceId string, instanceId string) *registry.InstanceInfo
- func (c *EurekaDiscoveryClient) GetInstances(serviceId string) ([]registry.InstanceInfo, error)
- func (c *EurekaDiscoveryClient) GetService(serviceId string) (*registry.ServiceInfo, error)
- func (c *EurekaDiscoveryClient) GetServices() ([]registry.ServiceInfo, error)
- func (c *EurekaDiscoveryClient) Register(instance *registry.InstanceInfo) (bool, error)
- func (c *EurekaDiscoveryClient) SendHeartBeat(instance *registry.InstanceInfo, status string) (bool, error)
- type HttpRequest
- func (r *HttpRequest) BODY(body string) *HttpRequest
- func (r *HttpRequest) DELETE(url string, params ...RequestParameters) *HttpRequest
- func (r *HttpRequest) Do() *HttpRequest
- func (r *HttpRequest) Fetch(data interface{}) (status int, err error)
- func (r *HttpRequest) GET(url string, params ...RequestParameters) *HttpRequest
- func (r *HttpRequest) HEADER(head string, value string) *HttpRequest
- func (r *HttpRequest) PASSWORD(password string) *HttpRequest
- func (r *HttpRequest) PATCH(url string, params ...RequestParameters) *HttpRequest
- func (r *HttpRequest) POST(url string, params ...RequestParameters) *HttpRequest
- func (r *HttpRequest) PUT(url string, params ...RequestParameters) *HttpRequest
- func (r *HttpRequest) Result() (status int, body []byte, err error)
- func (r *HttpRequest) ResultTo(result interface{}) (status int, err error)
- func (r *HttpRequest) String() (result string, err error)
- func (r *HttpRequest) USERNAME(username string) *HttpRequest
- type InstanceInfo
- type RequestParameters
- type WrapperApplicationInfo
- type WrapperApplicationList
- type WrapperDataCenterInfo
- type WrapperInstanceInfo
- type WrapperLeaseInfo
- type WrapperMetadata
- type WrapperPort
- type WrapperSecurePort
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) 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 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 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 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 ¶
Click to show internal directories.
Click to hide internal directories.