Documentation ¶
Index ¶
- Constants
- func InitGlobalMetrics()
- func ParamsGetList(params url.Values, name string) (list []string, err error)
- func ParamsGetListRequired(params url.Values, name string) (list []string, err error)
- type LogAnalyticsPanicStop
- type LogAnalyticsProbeResult
- type LogAnalyticsProber
- func (p *LogAnalyticsProber) AddWorkspaces(workspaces ...string)
- func (p *LogAnalyticsProber) EnableCache(cache *cache.Cache)
- func (p *LogAnalyticsProber) GetPrometheusRegistry() *prometheus.Registry
- func (p *LogAnalyticsProber) Init()
- func (p *LogAnalyticsProber) Run()
- func (p *LogAnalyticsProber) SetPrometheusRegistry(registry *prometheus.Registry)
- type LogAnalyticsServiceDiscovery
- func (sd *LogAnalyticsServiceDiscovery) GetWorkspace(ctx context.Context, resourceId string) (*armoperationalinsights.Workspace, error)
- func (sd *LogAnalyticsServiceDiscovery) IsCacheEnabled() bool
- func (sd *LogAnalyticsServiceDiscovery) ResourcesClient(subscriptionId string) *armoperationalinsights.WorkspacesClient
- func (sd *LogAnalyticsServiceDiscovery) ServiceDiscovery()
- func (sd *LogAnalyticsServiceDiscovery) Use()
Constants ¶
View Source
const (
OperationInsightsWorkspaceUrlSuffix = "/v1"
)
Variables ¶
This section is empty.
Functions ¶
func InitGlobalMetrics ¶
func InitGlobalMetrics()
Types ¶
type LogAnalyticsPanicStop ¶
type LogAnalyticsPanicStop struct {
Message string
}
type LogAnalyticsProbeResult ¶
type LogAnalyticsProber ¶
type LogAnalyticsProber struct { QueryConfig kusto.Config Conf config.Opts UserAgent string Azure struct { Client *armclient.ArmClient } ServiceDiscovery LogAnalyticsServiceDiscovery // contains filtered or unexported fields }
func NewLogAnalyticsProber ¶
func NewLogAnalyticsProber(logger *zap.SugaredLogger, w http.ResponseWriter, r *http.Request, concurrencyWaitGroup *sizedwaitgroup.SizedWaitGroup) *LogAnalyticsProber
func (*LogAnalyticsProber) AddWorkspaces ¶
func (p *LogAnalyticsProber) AddWorkspaces(workspaces ...string)
func (*LogAnalyticsProber) EnableCache ¶
func (p *LogAnalyticsProber) EnableCache(cache *cache.Cache)
func (*LogAnalyticsProber) GetPrometheusRegistry ¶
func (p *LogAnalyticsProber) GetPrometheusRegistry() *prometheus.Registry
func (*LogAnalyticsProber) Init ¶
func (p *LogAnalyticsProber) Init()
func (*LogAnalyticsProber) Run ¶
func (p *LogAnalyticsProber) Run()
func (*LogAnalyticsProber) SetPrometheusRegistry ¶
func (p *LogAnalyticsProber) SetPrometheusRegistry(registry *prometheus.Registry)
type LogAnalyticsServiceDiscovery ¶
type LogAnalyticsServiceDiscovery struct {
// contains filtered or unexported fields
}
func (*LogAnalyticsServiceDiscovery) GetWorkspace ¶
func (sd *LogAnalyticsServiceDiscovery) GetWorkspace(ctx context.Context, resourceId string) (*armoperationalinsights.Workspace, error)
func (*LogAnalyticsServiceDiscovery) IsCacheEnabled ¶
func (sd *LogAnalyticsServiceDiscovery) IsCacheEnabled() bool
func (*LogAnalyticsServiceDiscovery) ResourcesClient ¶
func (sd *LogAnalyticsServiceDiscovery) ResourcesClient(subscriptionId string) *armoperationalinsights.WorkspacesClient
func (*LogAnalyticsServiceDiscovery) ServiceDiscovery ¶
func (sd *LogAnalyticsServiceDiscovery) ServiceDiscovery()
func (*LogAnalyticsServiceDiscovery) Use ¶
func (sd *LogAnalyticsServiceDiscovery) Use()
Click to show internal directories.
Click to hide internal directories.