Versions in this module Expand all Collapse all v1 v1.5.0 Jan 30, 2022 Changes in this version + const KumaMadsV1ResourceType + const KumaMadsV1ResourceTypeURL + const ProtocolV3 + var DefaultKumaSDConfig = KumaSDConfig + var File_observability_v1_mads_proto protoreflect.FileDescriptor + func NewKumaHTTPDiscovery(conf *KumaSDConfig, logger *zap.Logger) (discovery.Discoverer, error) + type HTTPConfig struct + type HTTPResourceClient struct + func NewHTTPResourceClient(conf *HTTPResourceClientConfig, protocolVersion ProtocolVersion) (*HTTPResourceClient, error) + func (rc *HTTPResourceClient) Close() + func (rc *HTTPResourceClient) Fetch(ctx context.Context) (*v3.DiscoveryResponse, error) + func (rc *HTTPResourceClient) ID() string + func (rc *HTTPResourceClient) ResourceTypeURL() string + func (rc *HTTPResourceClient) Server() string + type HTTPResourceClientConfig struct + ClientID string + ExtraQueryParams url.Values + Name string + ResourceType string + ResourceTypeURL string + Server string + Timeout time.Duration + type KumaSDConfig = SDConfig + func (c *KumaSDConfig) Name() string + func (c *KumaSDConfig) NewDiscoverer(opts discovery.DiscovererOptions) (discovery.Discoverer, error) + func (c *KumaSDConfig) SetDirectory(dir string) + func (c *KumaSDConfig) UnmarshalYAML(unmarshal func(interface{}) error) error + type MonitoringAssignment struct + Labels map[string]string + Mesh string + Service string + Targets []*MonitoringAssignment_Target + func (*MonitoringAssignment) Descriptor() ([]byte, []int) + func (*MonitoringAssignment) ProtoMessage() + func (x *MonitoringAssignment) GetLabels() map[string]string + func (x *MonitoringAssignment) GetMesh() string + func (x *MonitoringAssignment) GetService() string + func (x *MonitoringAssignment) GetTargets() []*MonitoringAssignment_Target + func (x *MonitoringAssignment) ProtoReflect() protoreflect.Message + func (x *MonitoringAssignment) Reset() + func (x *MonitoringAssignment) String() string + type MonitoringAssignmentDiscoveryServiceServer interface + FetchMonitoringAssignments func(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error) + type MonitoringAssignment_Target struct + Address string + Labels map[string]string + MetricsPath string + Name string + Scheme string + func (*MonitoringAssignment_Target) Descriptor() ([]byte, []int) + func (*MonitoringAssignment_Target) ProtoMessage() + func (x *MonitoringAssignment_Target) GetAddress() string + func (x *MonitoringAssignment_Target) GetLabels() map[string]string + func (x *MonitoringAssignment_Target) GetMetricsPath() string + func (x *MonitoringAssignment_Target) GetName() string + func (x *MonitoringAssignment_Target) GetScheme() string + func (x *MonitoringAssignment_Target) ProtoReflect() protoreflect.Message + func (x *MonitoringAssignment_Target) Reset() + func (x *MonitoringAssignment_Target) String() string + type ProtocolVersion string + type ResourceClient interface + Close func() + Fetch func(ctx context.Context) (*v3.DiscoveryResponse, error) + ID func() string + ResourceTypeURL func() string + Server func() string + type SDConfig struct + FetchTimeout model.Duration + HTTPClientConfig config.HTTPClientConfig + RefreshInterval model.Duration + Server string
Go to main page