Documentation
¶
Index ¶
- type ContextManager
- func (cm *ContextManager) CustomInfo(id string) ([]byte, error)
- func (cm *ContextManager) LoadTask(id string, config []byte) error
- func (cm *ContextManager) RequestPluginDefinition()
- func (cm *ContextManager) RequestPublish(id string, mts []*types.Metric) types.ProcessingStatus
- func (cm *ContextManager) UnloadTask(id string) error
- type PluginContext
- type Publisher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContextManager ¶
type ContextManager struct {
*commonProxy.ContextManager
// contains filtered or unexported fields
}
func NewContextManager ¶
func NewContextManager(publisher plugin.Publisher, statsController stats.Controller) *ContextManager
func (*ContextManager) CustomInfo ¶
func (cm *ContextManager) CustomInfo(id string) ([]byte, error)
func (*ContextManager) LoadTask ¶
func (cm *ContextManager) LoadTask(id string, config []byte) error
func (*ContextManager) RequestPluginDefinition ¶
func (cm *ContextManager) RequestPluginDefinition()
func (*ContextManager) RequestPublish ¶
func (cm *ContextManager) RequestPublish(id string, mts []*types.Metric) types.ProcessingStatus
func (*ContextManager) UnloadTask ¶
func (cm *ContextManager) UnloadTask(id string) error
type PluginContext ¶
func NewPluginContext ¶
func NewPluginContext(ctxManager *ContextManager, taskID string, rawConfig []byte) (*PluginContext, error)
func (*PluginContext) Count ¶
func (pc *PluginContext) Count() int
func (*PluginContext) ListAllMetrics ¶
func (pc *PluginContext) ListAllMetrics() []plugin.Metric
func (*PluginContext) TaskID ¶
func (pc *PluginContext) TaskID() string
Click to show internal directories.
Click to hide internal directories.