graphmetrics

Feb 22, 2021

Changes in this version

type AdvancedConfiguration

+ Debug bool

+ OperationBufferSize int

+ StopTimeout time.Duration

type Aggregator

+ func (a *Aggregator) PushOperation(msg *OperationMessage)

type Configuration

+ func (c *Configuration) GetClientExtractor() client.Extractor

+ func (c *Configuration) GetDebug() bool

+ func (c *Configuration) GetEndpoint() string

+ func (c *Configuration) GetFieldBufferSize() int

+ func (c *Configuration) GetLogger() logger.Logger

+ func (c *Configuration) GetOperationBufferSize() int

+ func (c *Configuration) GetProtocol() string

+ func (c *Configuration) GetStopTimeout() time.Duration

+ type OperationMessage struct

+ Client client.Details

+ Duration time.Duration

+ HasErrors bool

+ Hash string

+ Name string

+ Signature string

+ Type string

type Sender

+ func (s *Sender) SendDefinitions(definitions *models.UsageDefinitions)

+ func (s *Sender) SendMetrics(metrics *models.UsageMetrics)

Jan 26, 2021

Changes in this version

type AdvancedConfiguration

+ Http bool

Jan 24, 2021

Changes in this version

+ type AdvancedConfiguration struct

+ Endpoint string

+ FieldBufferSize int

+ type Aggregator struct

+ func NewAggregator(cfg *Configuration) *Aggregator

+ func (a *Aggregator) PushField(msg *FieldMessage)

+ func (a *Aggregator) Start()

+ func (a *Aggregator) Stop()

+ type Configuration struct

+ Advanced *AdvancedConfiguration

+ ApiKey string

+ ClientExtractor client.Extractor

+ Logger Logger

+ ServerVersion string

+ type FieldMessage struct

+ Client client.Details

+ Duration time.Duration

+ Error error

+ FieldName string

+ ReturnType string

+ TypeName string

+ type Logger interface

+ Debug func(msg string, metadata map[string]interface{})

+ Error func(msg string, metadata map[string]interface{})

+ Info func(msg string, metadata map[string]interface{})

+ Warn func(msg string, metadata map[string]interface{})

+ type Sender struct

+ func NewSender(cfg *Configuration) *Sender

+ func (s *Sender) Send(metrics *internal.UsageMetrics)

+ func (s *Sender) Start()

+ func (s *Sender) Stop()