gse

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

Functions

func MakeGSE

func MakeGSE(im outputs.IndexManager, beat beat.Info, stats outputs.Observer, cfg *common.Config) (outputs.Group, error)

MakeGSE create a gse client

func String

func String(n int32) string

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

func (c *Output) Close() error

Close : close gse out put

func (*Output) Publish

func (c *Output) Publish(batch publisher.Batch) error

Publish implement output interface

func (*Output) PublishEvent

func (c *Output) PublishEvent(event *publisher.Event) error

PublishEvent implement output interface data is event, must contain 'dataid' filed data will attach agent info, see publishEventAttachInfo

func (*Output) Report

func (c *Output) Report(dataid int32, data common.MapStr) error

Report implement interface for bkmonitor

func (*Output) ReportRaw

func (c *Output) ReportRaw(dataid int32, data interface{}) error

ReportRaw implement interface for monitor send op raw data, without attach anything

func (*Output) String

func (c *Output) String() string

String returns the name of the output client