stackdriver

May 17, 2019

Changes in this version

+ type CreateTimeSeriesRequestWriterCloser struct

+ func NewCreateTimeSeriesRequestWriterCloser(writeCloser io.WriteCloser, logger log.Logger) *CreateTimeSeriesRequestWriterCloser

+ func (c *CreateTimeSeriesRequestWriterCloser) Close() error

+ func (c *CreateTimeSeriesRequestWriterCloser) Store(req *monitoring.CreateTimeSeriesRequest) error

May 10, 2019

Changes in this version

type ClientConfig

+ Resolver *manual.Resolver

Oct 23, 2018

Changes in this version

+ const MaxTimeseriesesPerRequest

+ const MonitoringWriteScope

+ type Client struct

+ func NewClient(conf *ClientConfig) *Client

+ func (c *Client) Store(req *monitoring.CreateTimeSeriesRequest) error

+ func (c Client) Close() error

+ type ClientConfig struct

+ Logger log.Logger

+ ProjectId string

+ Timeout time.Duration

+ URL *url.URL

+ type QueueManager struct

+ func NewQueueManager(logger log.Logger, cfg config.QueueConfig, clientFactory StorageClientFactory, ...) (*QueueManager, error)

+ func (t *QueueManager) Append(hash uint64, sample *monitoring_pb.TimeSeries) error

+ func (t *QueueManager) Start() error

+ func (t *QueueManager) Stop() error

+ type StorageClient interface

+ Close func() error

+ Store func(*monitoring_pb.CreateTimeSeriesRequest) error

+ type StorageClientFactory interface

+ Name func() string

+ New func() StorageClient