influxdb

Documentation

Index

• Constants
• Variables
• func InitHandler(ctx context.Context, confraw *utils.ConfigRaw) (retconf utils.TypeOutputConfig, err error)
• type OutputConfig
  • func (oc *OutputConfig) Close()
  • func (oc *OutputConfig) Event(ctx context.Context, event utils.LogEvent) (err error)

Constants

const (
	ModuleName = "influxdb"
)

Variables

var (
	DefaultBulkSize      uint64 = 10000
	DefaultWriteInterval uint   = 300 //seconds
)

Functions

func InitHandler

func InitHandler(ctx context.Context, confraw *utils.ConfigRaw) (retconf utils.TypeOutputConfig, err error)

InitHandler Init Handler.

Types

type OutputConfig

type OutputConfig struct {
	utils.OutputConfig
	WriteInterval int64    `json:"writeInterval"` //seconds
	BulkSize      uint64   `json:"bulkSize"`
	DSN           string   `json:"dsn"` //influx data source
	Database      string   `json:"database"`
	Table         string   `json:"table"`
	Precision     string   `json:"precision"`
	Tags          []string `json:"tags"`
	// RetentionPolicy is the retention policy of the points.
	RetentionPolicy string `json:"retentionPolicy"`
	// Write consistency is the number of servers required to confirm write.
	WriteConsistency string `json:"writeConsistency"`
	// contains filtered or unexported fields
}

OutputConfig Define outputstdout' config.

func (*OutputConfig) Close

func (oc *OutputConfig) Close()

func (*OutputConfig) Event

func (oc *OutputConfig) Event(ctx context.Context, event utils.LogEvent) (err error)

Event Input's event,and this is the main function of output.