The highest tagged major version is
Documentation
¶
Index ¶
- func MakeGSE(im outputs.IndexManager, beat beat.Info, stats outputs.Observer, ...) (outputs.Group, error)
- func String(n int32) string
- type Config
- type Output
- func (c *Output) Close() error
- func (c *Output) Publish(batch publisher.Batch) error
- func (c *Output) PublishEvent(event *publisher.Event) error
- func (c *Output) Report(dataid int32, data common.MapStr) error
- func (c *Output) ReportRaw(dataid int32, data interface{}) error
- func (c *Output) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
type Config struct {
// gse client config
RetryTimes uint `config:"retrytimes"`
RetryInterval time.Duration `config:"retryinterval"`
Nonblock bool `config:"nonblock"`
EventBufferMax int32 `config:"eventbuffermax"`
MsgQueueSize uint32 `config:"mqsize"`
Endpoint string `config:"endpoint"`
WriteTimeout time.Duration `config:"writetimeout"` // unit: second
// monitor config
MonitorID int32 `config:"monitorid"` // <= 0 : disable bk monitor tag
ResourceID int32 `config:"resourceid"` // <= 0 : disable resource report
}
type Output ¶
type Output struct {
// contains filtered or unexported fields
}
Output : gse output, for libbeat output
func (*Output) PublishEvent ¶
PublishEvent implement output interface data is event, must contain 'dataid' filed data will attach agent info, see publishEventAttachInfo
Source Files
Click to show internal directories.
Click to hide internal directories.