Documentation ¶
Index ¶
- type ServiceMock
- func (p *ServiceMock) Collect(pipeline.Collector) error
- func (p *ServiceMock) Description() string
- func (p *ServiceMock) Init(context pipeline.Context) (int, error)
- func (p *ServiceMock) MockOneLog(c pipeline.Collector)
- func (p *ServiceMock) Start(c pipeline.Collector) error
- func (p *ServiceMock) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ServiceMock ¶
type ServiceMock struct { Tags map[string]string Fields map[string]string File string Index int64 LogsPerSecond int MaxLogCount int // contains filtered or unexported fields }
func (*ServiceMock) Collect ¶
func (p *ServiceMock) Collect(pipeline.Collector) error
Gather takes in an accumulator and adds the metrics that the Input gathers. This is called every "interval"
func (*ServiceMock) Description ¶
func (p *ServiceMock) Description() string
func (*ServiceMock) MockOneLog ¶
func (p *ServiceMock) MockOneLog(c pipeline.Collector)
func (*ServiceMock) Start ¶
func (p *ServiceMock) Start(c pipeline.Collector) error
Start starts the ServiceInput's service, whatever that may be
func (*ServiceMock) Stop ¶
func (p *ServiceMock) Stop() error
Stop stops the services and closes any necessary channels and connections
Click to show internal directories.
Click to hide internal directories.