Documentation
¶
Index ¶
- func CheckService(details *ServiceCheck)
- type ConsoleData
- type DetailsMap
- type EgressBinding
- type EgressPortMap
- type HttpRequestStats
- type HttpRequestStatsMap
- type HttpRequestsHandled
- type HttpRequestsHandledList
- type HttpRequestsReceived
- type HttpRequestsReceivedList
- type HttpService
- type HttpServiceMap
- func (index HttpServiceMap) AddServices(listeners []qdr.HttpEndpoint)
- func (index HttpServiceMap) AddTargets(connectors []qdr.HttpEndpoint, mapping NameMapping)
- func (index HttpServiceMap) AsList() []HttpService
- func (index HttpServiceMap) Update(siteId string, requests []qdr.HttpRequestInfo, mapping NameMapping)
- type IngressBinding
- type LegacySiteInfo
- type NameMapping
- type NullNameMapping
- type Service
- type ServiceCheck
- type ServiceDetail
- func (sd *ServiceDetail) AddObservation(message string)
- func (detail *ServiceDetail) ExtractHttpConnectorPorts(connectors []qdr.HttpEndpoint)
- func (detail *ServiceDetail) ExtractHttpListenerPorts(listeners []qdr.HttpEndpoint)
- func (detail *ServiceDetail) ExtractTcpConnectorPorts(connectors []qdr.TcpEndpoint)
- func (detail *ServiceDetail) ExtractTcpListenerPorts(listeners []qdr.TcpEndpoint)
- type ServiceTarget
- type Site
- type SiteQueryData
- type TcpConnectionStats
- type TcpService
- type TcpServiceEndpoints
- type TcpServiceEndpointsList
- type TcpServiceMap
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckService ¶
func CheckService(details *ServiceCheck)
Types ¶
type ConsoleData ¶
type ConsoleData struct {
Sites []Site `json:"sites"`
Services []interface{} `json:"services"`
}
func (*ConsoleData) Merge ¶
func (c *ConsoleData) Merge(data []SiteQueryData)
type DetailsMap ¶
type EgressBinding ¶
type EgressPortMap ¶
type HttpRequestStats ¶
type HttpRequestStats struct {
Requests int `json:"requests"`
BytesIn int `json:"bytes_in"`
BytesOut int `json:"bytes_out"`
Details DetailsMap `json:"details"`
LatencyMax int `json:"latency_max"`
ByHandlingSite HttpRequestStatsMap `json:"by_handling_site,omitempty"`
}
type HttpRequestStatsMap ¶
type HttpRequestStatsMap map[string]HttpRequestStats
type HttpRequestsHandled ¶
type HttpRequestsHandled struct {
SiteId string `json:"site_id"`
ByServer HttpRequestStatsMap `json:"by_server,omitempty"`
ByOriginatingSite HttpRequestStatsMap `json:"by_originating_site,omitempty"`
}
type HttpRequestsHandledList ¶
type HttpRequestsHandledList []HttpRequestsHandled
type HttpRequestsReceived ¶
type HttpRequestsReceived struct {
SiteId string `json:"site_id"`
ByClient HttpRequestStatsMap `json:"by_client,omitempty"`
}
type HttpRequestsReceivedList ¶
type HttpRequestsReceivedList []HttpRequestsReceived
type HttpService ¶
type HttpService struct {
Service
RequestsReceived HttpRequestsReceivedList `json:"requests_received"`
RequestsHandled HttpRequestsHandledList `json:"requests_handled"`
}
func GetHttpServices ¶
func GetHttpServices(siteId string, info [][]qdr.HttpRequestInfo, targets []qdr.HttpEndpoint, listeners []qdr.HttpEndpoint, lookup NameMapping) []HttpService
type HttpServiceMap ¶
type HttpServiceMap map[string]HttpService
func (HttpServiceMap) AddServices ¶
func (index HttpServiceMap) AddServices(listeners []qdr.HttpEndpoint)
func (HttpServiceMap) AddTargets ¶
func (index HttpServiceMap) AddTargets(connectors []qdr.HttpEndpoint, mapping NameMapping)
func (HttpServiceMap) AsList ¶
func (index HttpServiceMap) AsList() []HttpService
func (HttpServiceMap) Update ¶
func (index HttpServiceMap) Update(siteId string, requests []qdr.HttpRequestInfo, mapping NameMapping)
type IngressBinding ¶
type LegacySiteInfo ¶
type LegacySiteInfo struct {
SiteId string
SiteName string
Version string
Namespace string
Url string
}
Used for interacting with 0.4.x sites
type NameMapping ¶
func NewNullNameMapping ¶
func NewNullNameMapping() NameMapping
type NullNameMapping ¶
type NullNameMapping struct {
}
func (*NullNameMapping) Lookup ¶
func (n *NullNameMapping) Lookup(name string) string
type Service ¶
type Service struct {
Address string `json:"address"`
Protocol string `json:"protocol"`
Targets []ServiceTarget `json:"targets"`
}
func (*Service) AddTarget ¶
func (s *Service) AddTarget(name string, host string, siteId string, mapping NameMapping)
func (*Service) AddressUnqualified ¶
type ServiceCheck ¶
type ServiceCheck struct {
Details []ServiceDetail `json:"site_details"`
Observations []string `json:"observations,omitempty"`
}
func (*ServiceCheck) AddObservation ¶
func (sc *ServiceCheck) AddObservation(message string)
func (*ServiceCheck) HasDetailObservations ¶
func (sc *ServiceCheck) HasDetailObservations() bool
type ServiceDetail ¶
type ServiceDetail struct {
SiteId string `json:"site_id"`
Definition types.ServiceInterface `json:"definition"`
IngressBinding IngressBinding `json:"ingress_binding"`
EgressBindings []EgressBinding `json:"egress_bindings"`
Observations []string `json:"observations,omitempty"`
}
func (*ServiceDetail) AddObservation ¶
func (sd *ServiceDetail) AddObservation(message string)
func (*ServiceDetail) ExtractHttpConnectorPorts ¶
func (detail *ServiceDetail) ExtractHttpConnectorPorts(connectors []qdr.HttpEndpoint)
func (*ServiceDetail) ExtractHttpListenerPorts ¶
func (detail *ServiceDetail) ExtractHttpListenerPorts(listeners []qdr.HttpEndpoint)
func (*ServiceDetail) ExtractTcpConnectorPorts ¶
func (detail *ServiceDetail) ExtractTcpConnectorPorts(connectors []qdr.TcpEndpoint)
func (*ServiceDetail) ExtractTcpListenerPorts ¶
func (detail *ServiceDetail) ExtractTcpListenerPorts(listeners []qdr.TcpEndpoint)
type ServiceTarget ¶
type Site ¶
type Site struct {
SiteName string `json:"site_name"`
SiteId string `json:"site_id"`
Version string `json:"version"`
Connected []string `json:"connected"`
Namespace string `json:"namespace"`
Url string `json:"url"`
Edge bool `json:"edge"`
Gateway bool `json:"gateway"`
}
func (*Site) AsLegacySiteInfo ¶
func (s *Site) AsLegacySiteInfo() *LegacySiteInfo
func (*Site) IsConnectedTo ¶
type SiteQueryData ¶
type SiteQueryData struct {
Site
TcpServices []TcpService `json:"tcp_services"`
HttpServices []HttpService `json:"http_services"`
}
type TcpConnectionStats ¶
type TcpService ¶
type TcpService struct {
Service
ConnectionsIngress TcpServiceEndpointsList `json:"connections_ingress,omitempty"`
ConnectionsEgress TcpServiceEndpointsList `json:"connections_egress,omitempty"`
}
func GetTcpServices ¶
func GetTcpServices(siteId string, info [][]qdr.TcpConnection, targets []qdr.TcpEndpoint, lookup NameMapping) []TcpService
type TcpServiceEndpoints ¶
type TcpServiceEndpoints struct {
SiteId string `json:"site_id"`
Connections map[string]TcpConnectionStats `json:"connections"`
}
type TcpServiceEndpointsList ¶
type TcpServiceEndpointsList []TcpServiceEndpoints
type TcpServiceMap ¶
type TcpServiceMap map[string]TcpService
func (TcpServiceMap) AddTargets ¶
func (s TcpServiceMap) AddTargets(connectors []qdr.TcpEndpoint, mapping NameMapping)
func (TcpServiceMap) AsList ¶
func (s TcpServiceMap) AsList() []TcpService
func (TcpServiceMap) Update ¶
func (index TcpServiceMap) Update(siteId string, connections []qdr.TcpConnection, mapping NameMapping)
Click to show internal directories.
Click to hide internal directories.