proxy

package
v2.6.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 22, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

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

type PluginContext struct {
	*proxy.Context
	// contains filtered or unexported fields
}

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

type Publisher

type Publisher interface {
	RequestPublish(id string, mts []*types.Metric) types.ProcessingStatus
	LoadTask(id string, config []byte) error
	UnloadTask(id string) error
	CustomInfo(id string) ([]byte, error)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL