processors

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 27, 2023 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ParseSequentiallyProcessorName = "parse_sequentially"
View Source 
var RouteProcessorName = "route"

Functions

func CompactFieldsProcessorFromModel 

func CompactFieldsProcessorFromModel(plan *CompactFieldsProcessorModel, previousState *CompactFieldsProcessorModel) (*Processor, diag.Diagnostics)

func CompactFieldsProcessorResourceSchema 

func CompactFieldsProcessorResourceSchema() schema.Schema

func CompactFieldsProcessorToModel 

func CompactFieldsProcessorToModel(plan *CompactFieldsProcessorModel, component *Processor)

func DecryptFieldsProcessorFromModel 

func DecryptFieldsProcessorFromModel(plan *DecryptFieldsProcessorModel, previousState *DecryptFieldsProcessorModel) (*Processor, diag.Diagnostics)

func DecryptFieldsProcessorResourceSchema 

func DecryptFieldsProcessorResourceSchema() schema.Schema

func DecryptFieldsProcessorToModel 

func DecryptFieldsProcessorToModel(plan *DecryptFieldsProcessorModel, component *Processor)

func DedupeProcessorFromModel 

func DedupeProcessorFromModel(plan *DedupeProcessorModel, previousState *DedupeProcessorModel) (*Processor, diag.Diagnostics)

func DedupeProcessorResourceSchema 

func DedupeProcessorResourceSchema() schema.Schema

func DedupeProcessorToModel 

func DedupeProcessorToModel(plan *DedupeProcessorModel, component *Processor)

func DropFieldsProcessorFromModel 

func DropFieldsProcessorFromModel(plan *DropFieldsProcessorModel, previousState *DropFieldsProcessorModel) (*Processor, diag.Diagnostics)

func DropFieldsProcessorResourceSchema 

func DropFieldsProcessorResourceSchema() schema.Schema

func DropFieldsProcessorToModel 

func DropFieldsProcessorToModel(plan *DropFieldsProcessorModel, component *Processor)

func EncryptFieldsProcessorFromModel 

func EncryptFieldsProcessorFromModel(plan *EncryptFieldsProcessorModel, previousState *EncryptFieldsProcessorModel) (*Processor, diag.Diagnostics)

func EncryptFieldsProcessorResourceSchema 

func EncryptFieldsProcessorResourceSchema() schema.Schema

func EncryptFieldsProcessorToModel 

func EncryptFieldsProcessorToModel(plan *EncryptFieldsProcessorModel, component *Processor)

func FlattenFieldsProcessorFromModel 

func FlattenFieldsProcessorFromModel(plan *FlattenFieldsProcessorModel, previousState *FlattenFieldsProcessorModel) (*Processor, diag.Diagnostics)

func FlattenFieldsProcessorResourceSchema 

func FlattenFieldsProcessorResourceSchema() schema.Schema

func FlattenFieldsProcessorToModel 

func FlattenFieldsProcessorToModel(plan *FlattenFieldsProcessorModel, component *Processor)

func ParseProcessorFromModel 

func ParseProcessorFromModel(plan *ParseProcessorModel, previousState *ParseProcessorModel) (*Processor, diag.Diagnostics)

func ParseProcessorResourceSchema 

func ParseProcessorResourceSchema() schema.Schema

func ParseProcessorToModel 

func ParseProcessorToModel(plan *ParseProcessorModel, component *Processor)

func ParseSequentiallyProcessorFromModel 

func ParseSequentiallyProcessorFromModel(plan *ParseSequentiallyProcessorModel, previousState *ParseSequentiallyProcessorModel) (*Processor, diag.Diagnostics)

func ParseSequentiallyProcessorResourceSchema 

func ParseSequentiallyProcessorResourceSchema() schema.Schema

func ParseSequentiallyProcessorToModel 

func ParseSequentiallyProcessorToModel(plan *ParseSequentiallyProcessorModel, component *Processor)

func ReduceProcessorFromModel 

func ReduceProcessorFromModel(plan *ReduceProcessorModel, previousState *ReduceProcessorModel) (*Processor, diag.Diagnostics)

func ReduceProcessorResourceSchema 

func ReduceProcessorResourceSchema() schema.Schema

func ReduceProcessorToModel 

func ReduceProcessorToModel(plan *ReduceProcessorModel, component *Processor)

func RouteProcessorFromModel 

func RouteProcessorFromModel(plan *RouteProcessorModel, previousState *RouteProcessorModel) (*Processor, diag.Diagnostics)

func RouteProcessorResourceSchema 

func RouteProcessorResourceSchema() schema.Schema

func RouteProcessorToModel 

func RouteProcessorToModel(plan *RouteProcessorModel, component *Processor)

func SampleProcessorFromModel 

func SampleProcessorFromModel(plan *SampleProcessorModel, previousState *SampleProcessorModel) (*Processor, diag.Diagnostics)

func SampleProcessorResourceSchema 

func SampleProcessorResourceSchema() schema.Schema

func SampleProcessorToModel 

func SampleProcessorToModel(plan *SampleProcessorModel, component *Processor)

func ScriptExecutionProcessorFromModel 

func ScriptExecutionProcessorFromModel(plan *ScriptExecutionProcessorModel, previousState *ScriptExecutionProcessorModel) (*Processor, diag.Diagnostics)

func ScriptExecutionProcessorResourceSchema 

func ScriptExecutionProcessorResourceSchema() schema.Schema

func ScriptExecutionProcessorToModel 

func ScriptExecutionProcessorToModel(plan *ScriptExecutionProcessorModel, component *Processor)

func StringifyProcessorFromModel 

func StringifyProcessorFromModel(plan *StringifyProcessorModel, previousState *StringifyProcessorModel) (*Processor, diag.Diagnostics)

func StringifyProcessorResourceSchema 

func StringifyProcessorResourceSchema() schema.Schema

func StringifyProcessorToModel 

func StringifyProcessorToModel(plan *StringifyProcessorModel, component *Processor)

func UnrollProcessorFromModel 

func UnrollProcessorFromModel(plan *UnrollProcessorModel, previousState *UnrollProcessorModel) (*Processor, diag.Diagnostics)

func UnrollProcessorResourceSchema 

func UnrollProcessorResourceSchema() schema.Schema

func UnrollProcessorToModel 

func UnrollProcessorToModel(plan *UnrollProcessorModel, component *Processor)

Types

type CompactFieldsProcessorModel 

type CompactFieldsProcessorModel struct {
	Id            String `tfsdk:"id"`
	PipelineId    String `tfsdk:"pipeline_id"`
	Title         String `tfsdk:"title"`
	Description   String `tfsdk:"description"`
	Inputs        List   `tfsdk:"inputs"`
	GenerationId  Int64  `tfsdk:"generation_id"`
	Fields        List   `tfsdk:"fields" user_config:"true"`
	CompactArray  Bool   `tfsdk:"compact_array" user_config:"true"`
	CompactObject Bool   `tfsdk:"compact_object" user_config:"true"`
}

type DecryptFieldsProcessorModel 

type DecryptFieldsProcessorModel struct {
	Id             String `tfsdk:"id"`
	PipelineId     String `tfsdk:"pipeline_id"`
	Title          String `tfsdk:"title"`
	Description    String `tfsdk:"description"`
	Inputs         List   `tfsdk:"inputs"`
	GenerationId   Int64  `tfsdk:"generation_id"`
	Field          String `tfsdk:"field" user_config:"true"`
	Algorithm      String `tfsdk:"algorithm" user_config:"true"`
	Key            String `tfsdk:"key" user_config:"true"`
	IvField        String `tfsdk:"iv_field" user_config:"true"`
	DecodeRawBytes Bool   `tfsdk:"decode_raw_bytes" user_config:"true"`
}

type DedupeProcessorModel 

type DedupeProcessorModel struct {
	Id             String `tfsdk:"id"`
	PipelineId     String `tfsdk:"pipeline_id"`
	Title          String `tfsdk:"title"`
	Description    String `tfsdk:"description"`
	Inputs         List   `tfsdk:"inputs"`
	GenerationId   Int64  `tfsdk:"generation_id"`
	Fields         List   `tfsdk:"fields" user_config:"true"`
	NumberOfEvents Int64  `tfsdk:"number_of_events" user_config:"true"`
	ComparisonType String `tfsdk:"comparison_type" user_config:"true"`
}

type DropFieldsProcessorModel 

type DropFieldsProcessorModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	Inputs       List   `tfsdk:"inputs"`
	GenerationId Int64  `tfsdk:"generation_id"`
	Fields       List   `tfsdk:"fields" user_config:"true"`
}

type EncryptFieldsProcessorModel 

type EncryptFieldsProcessorModel struct {
	Id             String `tfsdk:"id"`
	PipelineId     String `tfsdk:"pipeline_id"`
	Title          String `tfsdk:"title"`
	Description    String `tfsdk:"description"`
	Inputs         List   `tfsdk:"inputs"`
	GenerationId   Int64  `tfsdk:"generation_id"`
	Field          String `tfsdk:"field" user_config:"true"`
	Algorithm      String `tfsdk:"algorithm" user_config:"true"`
	Key            String `tfsdk:"key" user_config:"true"`
	IvField        String `tfsdk:"iv_field" user_config:"true"`
	EncodeRawBytes Bool   `tfsdk:"encode_raw_bytes" user_config:"true"`
}

type FlattenFieldsProcessorModel 

type FlattenFieldsProcessorModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	Inputs       List   `tfsdk:"inputs"`
	GenerationId Int64  `tfsdk:"generation_id"`
	Fields       List   `tfsdk:"fields" user_config:"true"`
	Delimiter    String `tfsdk:"delimiter" user_config:"true"`
}

type ParseProcessorModel 

type ParseProcessorModel struct {
	Id               String `tfsdk:"id"`
	PipelineId       String `tfsdk:"pipeline_id"`
	Title            String `tfsdk:"title"`
	Description      String `tfsdk:"description"`
	Inputs           List   `tfsdk:"inputs"`
	GenerationId     Int64  `tfsdk:"generation_id"`
	Field            String `tfsdk:"field" user_config:"true"`
	TargetField      String `tfsdk:"target_field" user_config:"true"`
	Parser           String `tfsdk:"parser" user_config:"true"`
	ApacheOptions    Object `tfsdk:"apache_log_options" user_config:"true"`
	CefOptions       Object `tfsdk:"cef_log_options" user_config:"true"`
	CsvOptions       Object `tfsdk:"csv_row_options" user_config:"true"`
	GrokOptions      Object `tfsdk:"grok_parser_options" user_config:"true"`
	KeyValueOptions  Object `tfsdk:"key_value_log_options" user_config:"true"`
	NginxOptions     Object `tfsdk:"nginx_log_options" user_config:"true"`
	RegexOptions     Object `tfsdk:"regex_parser_options" user_config:"true"`
	TimestampOptions Object `tfsdk:"timestamp_parser_options" user_config:"true"`
}

type ParseSequentiallyProcessorModel 

type ParseSequentiallyProcessorModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	Inputs       List   `tfsdk:"inputs"`
	GenerationId Int64  `tfsdk:"generation_id"`
	Field        String `tfsdk:"field" user_config:"true"`
	TargetField  String `tfsdk:"target_field" user_config:"true"`
	Parsers      List   `tfsdk:"parsers" user_config:"true"`
}

type ReduceProcessorModel 

type ReduceProcessorModel struct {
	Id              StringValue `tfsdk:"id"`
	PipelineId      StringValue `tfsdk:"pipeline_id"`
	Title           StringValue `tfsdk:"title"`
	Description     StringValue `tfsdk:"description"`
	Inputs          ListValue   `tfsdk:"inputs"`
	GenerationId    Int64Value  `tfsdk:"generation_id"`
	DurationMs      Int64Value  `tfsdk:"duration_ms" user_config:"true"`
	GroupBy         ListValue   `tfsdk:"group_by" user_config:"true"`
	DateFormats     ListValue   `tfsdk:"date_formats" user_config:"true"`
	MergeStrategies ListValue   `tfsdk:"merge_strategies" user_config:"true"`
	FlushCondition  ObjectValue `tfsdk:"flush_condition" user_config:"true"`
}

type RouteProcessorModel 

type RouteProcessorModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	Inputs       List   `tfsdk:"inputs"`
	GenerationId Int64  `tfsdk:"generation_id"`
	Conditionals List   `tfsdk:"conditionals" user_config:"true"`
}

type SampleProcessorModel 

type SampleProcessorModel struct {
	Id            String `tfsdk:"id"`
	PipelineId    String `tfsdk:"pipeline_id"`
	Title         String `tfsdk:"title"`
	Description   String `tfsdk:"description"`
	Inputs        List   `tfsdk:"inputs"`
	GenerationId  Int64  `tfsdk:"generation_id"`
	Rate          Int64  `tfsdk:"rate" user_config:"true"`
	AlwaysInclude Object `tfsdk:"always_include" user_config:"true"`
}

type SchemaAttributes 

type SchemaAttributes map[string]schema.Attribute

func ExtendBaseAttributes 

func ExtendBaseAttributes(target SchemaAttributes) SchemaAttributes

func ExtendSchemaAttributes 

func ExtendSchemaAttributes(fromAttributes SchemaAttributes, toAttributes SchemaAttributes) SchemaAttributes

type ScriptExecutionProcessorModel 

type ScriptExecutionProcessorModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	Inputs       List   `tfsdk:"inputs"`
	GenerationId Int64  `tfsdk:"generation_id"`
	Script       String `tfsdk:"script" user_config:"true"`
}

type StringifyProcessorModel 

type StringifyProcessorModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	Inputs       List   `tfsdk:"inputs"`
	GenerationId Int64  `tfsdk:"generation_id"`
}

type UnrollProcessorModel 

type UnrollProcessorModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	Inputs       List   `tfsdk:"inputs"`
	GenerationId Int64  `tfsdk:"generation_id"`
	Field        String `tfsdk:"field" user_config:"true"`
	ValuesOnly   Bool   `tfsdk:"values_only" user_config:"true"`
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.