mock

Documentation

Index

• type EmptyContext
  • func NewEmptyContext(project, logstore, configName string) *EmptyContext
  • func (p *EmptyContext) AddPlugin(name string)
  • func (p *EmptyContext) GetCheckPoint(key string) (value []byte, exist bool)
  • func (p *EmptyContext) GetCheckPointObject(key string, obj interface{}) (exist bool)
  • func (p *EmptyContext) GetConfigName() string
  • func (p *EmptyContext) GetExtension(name string, cfg any) (pipeline.Extension, error)
  • func (p *EmptyContext) GetLogstore() string
  • func (p *EmptyContext) GetProject() string
  • func (p *EmptyContext) GetRuntimeContext() context.Context
  • func (p *EmptyContext) InitContext(project, logstore, configName string)
  • func (p *EmptyContext) MetricSerializeToPB(log *protocol.Log)
  • func (p *EmptyContext) RegisterCounterMetric(metric pipeline.CounterMetric)
  • func (p *EmptyContext) RegisterLatencyMetric(metric pipeline.LatencyMetric)
  • func (p *EmptyContext) RegisterStringMetric(metric pipeline.StringMetric)
  • func (p *EmptyContext) SaveCheckPoint(key string, value []byte) error
  • func (p *EmptyContext) SaveCheckPointObject(key string, obj interface{}) error

Types

type EmptyContext

type EmptyContext struct {
	StringMetrics  map[string]pipeline.StringMetric
	CounterMetrics map[string]pipeline.CounterMetric
	LatencyMetrics map[string]pipeline.LatencyMetric
	// contains filtered or unexported fields
}

func NewEmptyContext

func NewEmptyContext(project, logstore, configName string) *EmptyContext

func (*EmptyContext) AddPlugin

func (p *EmptyContext) AddPlugin(name string)

func (*EmptyContext) GetCheckPoint

func (p *EmptyContext) GetCheckPoint(key string) (value []byte, exist bool)

func (*EmptyContext) GetCheckPointObject

func (p *EmptyContext) GetCheckPointObject(key string, obj interface{}) (exist bool)

func (*EmptyContext) GetConfigName

func (p *EmptyContext) GetConfigName() string

func (*EmptyContext) GetExtension

func (p *EmptyContext) GetExtension(name string, cfg any) (pipeline.Extension, error)

func (*EmptyContext) GetLogstore

func (p *EmptyContext) GetLogstore() string

func (*EmptyContext) GetProject

func (p *EmptyContext) GetProject() string

func (*EmptyContext) GetRuntimeContext

func (p *EmptyContext) GetRuntimeContext() context.Context

func (*EmptyContext) InitContext

func (p *EmptyContext) InitContext(project, logstore, configName string)

func (*EmptyContext) MetricSerializeToPB

func (p *EmptyContext) MetricSerializeToPB(log *protocol.Log)

func (*EmptyContext) RegisterCounterMetric

func (p *EmptyContext) RegisterCounterMetric(metric pipeline.CounterMetric)

func (*EmptyContext) RegisterLatencyMetric

func (p *EmptyContext) RegisterLatencyMetric(metric pipeline.LatencyMetric)

func (*EmptyContext) RegisterStringMetric

func (p *EmptyContext) RegisterStringMetric(metric pipeline.StringMetric)

func (*EmptyContext) SaveCheckPoint

func (p *EmptyContext) SaveCheckPoint(key string, value []byte) error

func (*EmptyContext) SaveCheckPointObject

func (p *EmptyContext) SaveCheckPointObject(key string, obj interface{}) error