properties

Documentation

Index

• type DimensionPropertyClient
  • func NewDimensionPropertyClient(ctx context.Context, conf *config.WriterConfig) (*DimensionPropertyClient, error)
  • func (dpc *DimensionPropertyClient) AcceptDimProp(dimProps *types.DimProperties) error
  • func (dpc *DimensionPropertyClient) InternalMetrics() []*datapoint.Datapoint
  • func (dpc *DimensionPropertyClient) Start()

Types

type DimensionPropertyClient

type DimensionPropertyClient struct {
	sync.RWMutex

	Token  string
	APIURL *url.URL

	PropertyFilterSet *propfilters.FilterSet

	DimensionsCurrentlyDelayed int64
	TotalDimensionsDropped     int64
	// The number of dimension updates that happened to the same dimension
	// within sendDelay.
	TotalFlappyUpdates int64
	// contains filtered or unexported fields
}

DimensionPropertyClient sends updates to dimensions to the SignalFx API

func NewDimensionPropertyClient

func NewDimensionPropertyClient(ctx context.Context, conf *config.WriterConfig) (*DimensionPropertyClient, error)

NewDimensionPropertyClient returns a new client

func (*DimensionPropertyClient) AcceptDimProp

func (dpc *DimensionPropertyClient) AcceptDimProp(dimProps *types.DimProperties) error

AcceptDimProp to be sent to the API. This will return fairly quickly and won't block. If the buffer is full, the dim update will be dropped.

func (*DimensionPropertyClient) InternalMetrics

func (dpc *DimensionPropertyClient) InternalMetrics() []*datapoint.Datapoint

InternalMetrics returns datapoints that describe the current state of the dimension update client

func (*DimensionPropertyClient) Start

func (dpc *DimensionPropertyClient) Start()

Start the client's processing queue