Struct Components

desc.go:5–20

Components holds the descriptions of all components one can use to build a topology.

// Components holds the descriptions of all components one can use
// to build a topology.
type Components struct {
	Inputs  []InputDesc  // Inputs represents the list of available inputs
	Filters []FilterDesc // Filters represents the list of available filters
	Outputs []OutputDesc // Outputs represents the list of available outputs
	Uploads []UploadDesc // Uploads represents the list of available uploads

	Metrics []MetricsDesc // Metrics represents the list of available metrics clients
	User    []UserDesc    // User represents the list of user-defined configurations

	ShardingFuncs map[FieldIndex]ShardingFunc // ShardingFuncs are functions to calculate sharding based on field index
	Validate      ValidationFunc              // Validate is the function used to validate a Record
	CreateRecord  func() Record               // CreateRecord creates a new record

	FieldByName func(string) (FieldIndex, bool) // FieldByName gets a field index by its name
	FieldNames  []string                        // FieldNames holds field names, indexed by their FieldIndex
}

// ComponentParams holds the common configuration parameters passed to components of all kinds.
type ComponentParams struct {