Affected by 
Documentation
¶
Index ¶
- Constants
- func NewPhlareDatasource(httpClientProvider httpclient.Provider, ...) (instancemgmt.Instance, error)
- type CustomMeta
- type EnumField
- type Function
- type PhlareDatasource
- func (d *PhlareDatasource) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
- func (d *PhlareDatasource) CheckHealth(ctx context.Context, _ *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
- func (d *PhlareDatasource) PublishStream(_ context.Context, _ *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
- func (d *PhlareDatasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
- func (d *PhlareDatasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
- func (d *PhlareDatasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
- type ProfileTree
- type SeriesRequestJson
- type Service
- func (s *Service) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
- func (s *Service) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
- func (s *Service) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
- func (s *Service) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
- func (s *Service) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
- func (s *Service) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
Constants ¶
const ITEM_OFFSET = 4
ITEM_OFFSET Next bar. Each bar of the profile is represented by 4 number in a flat array.
const NAME_OFFSET = 3
NAME_OFFSET is index into the names array
const SELF_OFFSET = 2
SELF_OFFSET is self value of the bar
const START_OFFSET = 0
START_OFFSET is offset of the bar relative to previous sibling
const VALUE_OFFSET = 1
VALUE_OFFSET is value or width of the bar
Variables ¶
This section is empty.
Functions ¶
func NewPhlareDatasource ¶
func NewPhlareDatasource(httpClientProvider httpclient.Provider, settings backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
NewPhlareDatasource creates a new datasource instance.
Types ¶
type CustomMeta ¶
type CustomMeta struct {
ProfileTypeID string
}
type PhlareDatasource ¶
type PhlareDatasource struct {
// contains filtered or unexported fields
}
PhlareDatasource is a datasource for querying application performance profiles.
func (*PhlareDatasource) CallResource ¶
func (d *PhlareDatasource) CallResource(ctx context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error
func (*PhlareDatasource) CheckHealth ¶
func (d *PhlareDatasource) CheckHealth(ctx context.Context, _ *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
CheckHealth handles health checks sent from Grafana to the plugin. The main use case for these health checks is the test button on the datasource configuration page which allows users to verify that a datasource is working as expected.
func (*PhlareDatasource) PublishStream ¶
func (d *PhlareDatasource) PublishStream(_ context.Context, _ *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
PublishStream is called when a client sends a message to the stream.
func (*PhlareDatasource) QueryData ¶
func (d *PhlareDatasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
QueryData handles multiple queries and returns multiple responses. req contains the queries []DataQuery (where each query contains RefID as a unique identifier). The QueryDataResponse contains a map of RefID to the response for each query, and each response contains Frames ([]*Frame).
func (*PhlareDatasource) RunStream ¶
func (d *PhlareDatasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error
RunStream is called once for any open channel. Results are shared with everyone subscribed to the same channel.
func (*PhlareDatasource) SubscribeStream ¶
func (d *PhlareDatasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
SubscribeStream is called when a client wants to connect to a stream. This callback allows sending the first message.
type ProfileTree ¶
type ProfileTree struct {
Start int64
Value int64
Self int64
Level int
Name string
Nodes []*ProfileTree
}
func (*ProfileTree) String ¶
func (pt *ProfileTree) String() string
type SeriesRequestJson ¶
type SeriesRequestJson struct {
Matchers []string `json:"matchers"`
}
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func ProvideService ¶
func ProvideService(httpClientProvider httpclient.Provider) *Service
func (*Service) CallResource ¶
func (s *Service) CallResource(ctx context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error
func (*Service) CheckHealth ¶
func (s *Service) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
func (*Service) PublishStream ¶
func (s *Service) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
PublishStream is called when a client sends a message to the stream.
func (*Service) QueryData ¶
func (s *Service) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
func (*Service) RunStream ¶
func (s *Service) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error
func (*Service) SubscribeStream ¶
func (s *Service) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
Source Files
Directories