Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.