metrics

Documentation

Index

• type LMMetricIngest
  • func NewLMMetricIngest(ctx context.Context, opts ...Option) (*LMMetricIngest, error)
  • func (lmi LMMetricIngest) BatchInterval() time.Duration
  • func (lmi *LMMetricIngest) CreateRequestBody() internal.DataPayload
  • func (lmi *LMMetricIngest) ExportData(payloadList internal.DataPayload, uri, method string) error
  • func (lmi *LMMetricIngest) SendMetrics(ctx context.Context, rInput model.ResourceInput, dsInput model.DatasourceInput, ...) error
  • func (lmi LMMetricIngest) URI() string
  • func (lmi *LMMetricIngest) UpdateInstanceProperties(resIDs, insProps map[string]string, dsName, dsDisplayName, insName string, ...) error
  • func (lmi *LMMetricIngest) UpdateResourceProperties(resName string, resIDs, resProps map[string]string, patch bool) error
• type Option
  • func WithAuthentication(authProvider model.AuthProvider) Option
  • func WithGzipCompression(gzip bool) Option
  • func WithMetricBatchingEnabled(batchingInterval time.Duration) Option

Types

type LMMetricIngest

type LMMetricIngest struct {
	// contains filtered or unexported fields
}

func NewLMMetricIngest

func NewLMMetricIngest(ctx context.Context, opts ...Option) (*LMMetricIngest, error)

NewLMMetricIngest initializes LMMetricIngest

func (LMMetricIngest) BatchInterval

func (lmi LMMetricIngest) BatchInterval() time.Duration

BatchInterval returns the time interval for batching

func (*LMMetricIngest) CreateRequestBody

func (lmi *LMMetricIngest) CreateRequestBody() internal.DataPayload

CreateRequestBody merges the requests present in batching cache and creates metric payload at the end of every batching interval

func (*LMMetricIngest) ExportData

func (lmi *LMMetricIngest) ExportData(payloadList internal.DataPayload, uri, method string) error

ExportData exports metrics to the LM platform

func (*LMMetricIngest) SendMetrics

func (lmi *LMMetricIngest) SendMetrics(ctx context.Context, rInput model.ResourceInput, dsInput model.DatasourceInput, instInput model.InstanceInput, dpInput model.DataPointInput) error

SendMetrics is the entry point for receiving metric data. It also validates the attributes of metrics before creating metric payload.

func (LMMetricIngest) URI

func (lmi LMMetricIngest) URI() string

URI returns the endpoint/uri of metric ingest API

func (*LMMetricIngest) UpdateInstanceProperties

func (lmi *LMMetricIngest) UpdateInstanceProperties(resIDs, insProps map[string]string, dsName, dsDisplayName, insName string, patch bool) error

func (*LMMetricIngest) UpdateResourceProperties

func (lmi *LMMetricIngest) UpdateResourceProperties(resName string, resIDs, resProps map[string]string, patch bool) error

type Option

type Option func(*LMMetricIngest) error

func WithAuthentication

func WithAuthentication(authProvider model.AuthProvider) Option

WithAuthentication is used for passing authentication token if not set in environment variables.

func WithGzipCompression

func WithGzipCompression(gzip bool) Option

WithGzipCompression can be used to enable/disable gzip compression of metric payload Note: By default, gzip compression is enabled.

func WithMetricBatchingEnabled

func WithMetricBatchingEnabled(batchingInterval time.Duration) Option

WithMetricBatchingEnabled is used for enabling batching for metrics. Pass time interval for batch as an input parameter.