Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( RemoteUrl *url.URL Token string )
Functions ¶
func Meta ¶
func Meta() *plugin.PluginMeta
Types ¶
type HostedtsdbPublisher ¶
type HostedtsdbPublisher struct {
}
func NewHostedtsdbPublisher ¶
func NewHostedtsdbPublisher() *HostedtsdbPublisher
func (*HostedtsdbPublisher) GetConfigPolicy ¶
func (f *HostedtsdbPublisher) GetConfigPolicy() (*cpolicy.ConfigPolicy, error)
func (*HostedtsdbPublisher) Publish ¶
func (f *HostedtsdbPublisher) Publish(contentType string, content []byte, config map[string]ctypes.ConfigValue) error
type WriteQueue ¶
type WriteQueue struct {
sync.Mutex
Metrics []*schema.MetricData
QueueFull chan struct{}
}
func NewWriteQueue ¶
func NewWriteQueue() *WriteQueue
func (*WriteQueue) Add ¶
func (q *WriteQueue) Add(metrics []*schema.MetricData)
func (*WriteQueue) Flush ¶
func (q *WriteQueue) Flush()
func (*WriteQueue) Run ¶
func (q *WriteQueue) Run()
Source Files
Click to show internal directories.
Click to hide internal directories.