mock

Documentation

Index

• type EmptyContext
  • func NewEmptyContext(project, logstore, configName string) *EmptyContext
  • func (p *EmptyContext) AddPlugin(name string)
  • func (p *EmptyContext) ExportMetricRecords() (results []map[string]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) GetLogstoreConfigMetricRecord() *pipeline.MetricsRecord
  • func (p *EmptyContext) GetMetricRecord() *pipeline.MetricsRecord
  • func (p *EmptyContext) GetProject() string
  • func (p *EmptyContext) GetRuntimeContext() context.Context
  • func (p *EmptyContext) InitContext(project, logstore, configName string)
  • func (p *EmptyContext) RegisterCounterMetric(metricsRecord *pipeline.MetricsRecord, metric pipeline.CounterMetric)
  • func (p *EmptyContext) RegisterLatencyMetric(metricsRecord *pipeline.MetricsRecord, metric pipeline.LatencyMetric)
  • func (p *EmptyContext) RegisterLogstoreConfigMetricRecord(labels []pipeline.LabelPair) *pipeline.MetricsRecord
  • func (p *EmptyContext) RegisterMetricRecord(labels []pipeline.LabelPair) *pipeline.MetricsRecord
  • func (p *EmptyContext) RegisterStringMetric(metricsRecord *pipeline.MetricsRecord, 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 {
	MetricsRecords []*pipeline.MetricsRecord
	// 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) ExportMetricRecords

func (p *EmptyContext) ExportMetricRecords() (results []map[string]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) GetLogstoreConfigMetricRecord

func (p *EmptyContext) GetLogstoreConfigMetricRecord() *pipeline.MetricsRecord

func (*EmptyContext) GetMetricRecord

func (p *EmptyContext) GetMetricRecord() *pipeline.MetricsRecord

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) RegisterCounterMetric

func (p *EmptyContext) RegisterCounterMetric(metricsRecord *pipeline.MetricsRecord, metric pipeline.CounterMetric)

func (*EmptyContext) RegisterLatencyMetric

func (p *EmptyContext) RegisterLatencyMetric(metricsRecord *pipeline.MetricsRecord, metric pipeline.LatencyMetric)

func (*EmptyContext) RegisterLogstoreConfigMetricRecord

func (p *EmptyContext) RegisterLogstoreConfigMetricRecord(labels []pipeline.LabelPair) *pipeline.MetricsRecord

func (*EmptyContext) RegisterMetricRecord

func (p *EmptyContext) RegisterMetricRecord(labels []pipeline.LabelPair) *pipeline.MetricsRecord

func (*EmptyContext) RegisterStringMetric

func (p *EmptyContext) RegisterStringMetric(metricsRecord *pipeline.MetricsRecord, 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