sources

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: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AgentSourceFromModel 

func AgentSourceFromModel(plan *AgentSourceModel, previousState *AgentSourceModel) (*Source, diag.Diagnostics)

func AgentSourceResourceSchema 

func AgentSourceResourceSchema() schema.Schema

func AgentSourceToModel 

func AgentSourceToModel(plan *AgentSourceModel, component *Source)

func AzureEventHubSourceFromModel 

func AzureEventHubSourceFromModel(plan *AzureEventHubSourceModel, previousState *AzureEventHubSourceModel) (*Source, diag.Diagnostics)

func AzureEventHubSourceResourceSchema 

func AzureEventHubSourceResourceSchema() schema.Schema

func AzureEventHubSourceToModel 

func AzureEventHubSourceToModel(plan *AzureEventHubSourceModel, component *Source)

func DemoSourceFromModel 

func DemoSourceFromModel(plan *DemoSourceModel, previousState *DemoSourceModel) (*Source, diag.Diagnostics)

func DemoSourceResourceSchema 

func DemoSourceResourceSchema() schema.Schema

func DemoSourceToModel 

func DemoSourceToModel(plan *DemoSourceModel, component *Source)

func FluentSourceFromModel 

func FluentSourceFromModel(plan *FluentSourceModel, previousState *FluentSourceModel) (*Source, diag.Diagnostics)

func FluentSourceResourceSchema 

func FluentSourceResourceSchema() schema.Schema

func FluentSourceToModel 

func FluentSourceToModel(plan *FluentSourceModel, component *Source)

func HttpSourceFromModel 

func HttpSourceFromModel(plan *HttpSourceModel, previousState *HttpSourceModel) (*Source, diag.Diagnostics)

func HttpSourceResourceSchema 

func HttpSourceResourceSchema() schema.Schema

func HttpSourceToModel 

func HttpSourceToModel(plan *HttpSourceModel, component *Source)

func KafkaSourceFromModel 

func KafkaSourceFromModel(plan *KafkaSourceModel, previousState *KafkaSourceModel) (*Source, diag.Diagnostics)

func KafkaSourceResourceSchema 

func KafkaSourceResourceSchema() schema.Schema

func KafkaSourceToModel 

func KafkaSourceToModel(plan *KafkaSourceModel, component *Source)

func KinesisFirehoseSourceFromModel 

func KinesisFirehoseSourceFromModel(plan *KinesisFirehoseSourceModel, previousState *KinesisFirehoseSourceModel) (*Source, diag.Diagnostics)

func KinesisFirehoseSourceResourceSchema 

func KinesisFirehoseSourceResourceSchema() schema.Schema

func KinesisFirehoseSourceToModel 

func KinesisFirehoseSourceToModel(plan *KinesisFirehoseSourceModel, component *Source)

func LogAnalysisSourceFromModel 

func LogAnalysisSourceFromModel(plan *LogAnalysisSourceModel, previousState *LogAnalysisSourceModel) (*Source, diag.Diagnostics)

func LogAnalysisSourceResourceSchema 

func LogAnalysisSourceResourceSchema() schema.Schema

func LogAnalysisSourceToModel 

func LogAnalysisSourceToModel(plan *LogAnalysisSourceModel, component *Source)

func LogStashSourceFromModel 

func LogStashSourceFromModel(plan *LogStashSourceModel, previousState *LogStashSourceModel) (*Source, diag.Diagnostics)

func LogStashSourceResourceSchema 

func LogStashSourceResourceSchema() schema.Schema

func LogStashSourceToModel 

func LogStashSourceToModel(plan *LogStashSourceModel, component *Source)

func PrometheusRemoteWriteSourceFromModel 

func PrometheusRemoteWriteSourceFromModel(plan *PrometheusRemoteWriteSourceModel, previousState *PrometheusRemoteWriteSourceModel) (*Source, diag.Diagnostics)

func PrometheusRemoteWriteSourceResourceSchema 

func PrometheusRemoteWriteSourceResourceSchema() schema.Schema

func PrometheusRemoteWriteSourceToModel 

func PrometheusRemoteWriteSourceToModel(plan *PrometheusRemoteWriteSourceModel, component *Source)

func S3SourceFromModel 

func S3SourceFromModel(plan *S3SourceModel, previousState *S3SourceModel) (*Source, diag.Diagnostics)

func S3SourceResourceSchema 

func S3SourceResourceSchema() schema.Schema

func S3SourceToModel 

func S3SourceToModel(plan *S3SourceModel, component *Source)

func SQSSourceFromModel 

func SQSSourceFromModel(plan *SQSSourceModel, previousState *SQSSourceModel) (*Source, diag.Diagnostics)

func SQSSourceResourceSchema 

func SQSSourceResourceSchema() schema.Schema

func SQSSourceToModel 

func SQSSourceToModel(plan *SQSSourceModel, component *Source)

func SplunkHecSourceFromModel 

func SplunkHecSourceFromModel(plan *SplunkHecSourceModel, previousState *SplunkHecSourceModel) (*Source, diag.Diagnostics)

func SplunkHecSourceResourceSchema 

func SplunkHecSourceResourceSchema() schema.Schema

func SplunkHecSourceToModel 

func SplunkHecSourceToModel(plan *SplunkHecSourceModel, component *Source)

Types

type AgentSourceModel 

type AgentSourceModel struct {
	Id              String `tfsdk:"id"`
	PipelineId      String `tfsdk:"pipeline_id"`
	Title           String `tfsdk:"title"`
	Description     String `tfsdk:"description"`
	GenerationId    Int64  `tfsdk:"generation_id"`
	GatewayRouteId  String `tfsdk:"gateway_route_id"`
	CaptureMetadata Bool   `tfsdk:"capture_metadata" user_config:"true"`
}

type AzureEventHubSourceModel 

type AzureEventHubSourceModel struct {
	Id               String `tfsdk:"id"`
	PipelineId       String `tfsdk:"pipeline_id"`
	Title            String `tfsdk:"title"`
	Description      String `tfsdk:"description"`
	GenerationId     Int64  `tfsdk:"generation_id"`
	Decoding         String `tfsdk:"decoding" user_config:"true"`
	ConnectionString String `tfsdk:"connection_string" user_config:"true"`
	Namespace        String `tfsdk:"namespace" user_config:"true"`
	GroupId          String `tfsdk:"group_id" user_config:"true"`
	Topics           List   `tfsdk:"topics" user_config:"true"`
}

type DemoSourceModel 

type DemoSourceModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	Format       String `tfsdk:"format"`
	GenerationId Int64  `tfsdk:"generation_id"`
}

type FluentSourceModel 

type FluentSourceModel struct {
	Id              String `tfsdk:"id"`
	PipelineId      String `tfsdk:"pipeline_id"`
	Title           String `tfsdk:"title"`
	Description     String `tfsdk:"description"`
	GenerationId    Int64  `tfsdk:"generation_id"`
	GatewayRouteId  String `tfsdk:"gateway_route_id"`
	Decoding        String `tfsdk:"decoding" user_config:"true"`
	CaptureMetadata Bool   `tfsdk:"capture_metadata" user_config:"true"`
}

type HttpSourceModel 

type HttpSourceModel struct {
	Id              String `tfsdk:"id"`
	PipelineId      String `tfsdk:"pipeline_id"`
	Title           String `tfsdk:"title"`
	Description     String `tfsdk:"description"`
	GenerationId    Int64  `tfsdk:"generation_id"`
	GatewayRouteId  String `tfsdk:"gateway_route_id"`
	Decoding        String `tfsdk:"decoding" user_config:"true"`
	CaptureMetadata Bool   `tfsdk:"capture_metadata" user_config:"true"`
}

type KafkaSourceModel 

type KafkaSourceModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	GenerationId Int64  `tfsdk:"generation_id"`
	Brokers      List   `tfsdk:"brokers" user_config:"true"`
	Topics       List   `tfsdk:"topics" user_config:"true"`
	GroupId      String `tfsdk:"group_id" user_config:"true"`
	TLSEnabled   Bool   `tfsdk:"tls_enabled" user_config:"true"`
	SASL         Object `tfsdk:"sasl" user_config:"true"`
	Decoding     String `tfsdk:"decoding" user_config:"true"`
}

type KinesisFirehoseSourceModel 

type KinesisFirehoseSourceModel struct {
	Id              String `tfsdk:"id"`
	PipelineId      String `tfsdk:"pipeline_id"`
	Title           String `tfsdk:"title"`
	Description     String `tfsdk:"description"`
	GenerationId    Int64  `tfsdk:"generation_id"`
	GatewayRouteId  String `tfsdk:"gateway_route_id"`
	Decoding        String `tfsdk:"decoding" user_config:"true"`
	CaptureMetadata Bool   `tfsdk:"capture_metadata" user_config:"true"`
}

type LogAnalysisSourceModel 

type LogAnalysisSourceModel struct {
	Id           StringValue `tfsdk:"id"`
	PipelineId   StringValue `tfsdk:"pipeline_id"`
	Title        StringValue `tfsdk:"title"`
	Description  StringValue `tfsdk:"description"`
	GenerationId Int64Value  `tfsdk:"generation_id"`
}

type LogStashSourceModel 

type LogStashSourceModel struct {
	Id              String `tfsdk:"id"`
	PipelineId      String `tfsdk:"pipeline_id"`
	Title           String `tfsdk:"title"`
	Description     String `tfsdk:"description"`
	GenerationId    Int64  `tfsdk:"generation_id"`
	GatewayRouteId  String `tfsdk:"gateway_route_id"`
	Format          String `tfsdk:"format" user_config:"true"`
	CaptureMetadata Bool   `tfsdk:"capture_metadata" user_config:"true"`
}

type PrometheusRemoteWriteSourceModel 

type PrometheusRemoteWriteSourceModel struct {
	Id              String `tfsdk:"id"`
	PipelineId      String `tfsdk:"pipeline_id"`
	Title           String `tfsdk:"title"`
	Description     String `tfsdk:"description"`
	GenerationId    Int64  `tfsdk:"generation_id"`
	GatewayRouteId  String `tfsdk:"gateway_route_id"`
	CaptureMetadata Bool   `tfsdk:"capture_metadata" user_config:"true"`
}

type S3SourceModel 

type S3SourceModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	GenerationId Int64  `tfsdk:"generation_id"`
	Auth         Object `tfsdk:"auth" user_config:"true"`
	Region       String `tfsdk:"region" user_config:"true"`
	SqsQueueUrl  String `tfsdk:"sqs_queue_url" user_config:"true"`
	Compression  String `tfsdk:"compression" user_config:"true"`
}

type SQSSourceModel 

type SQSSourceModel struct {
	Id           String `tfsdk:"id"`
	PipelineId   String `tfsdk:"pipeline_id"`
	Title        String `tfsdk:"title"`
	Description  String `tfsdk:"description"`
	GenerationId Int64  `tfsdk:"generation_id"`
	QueueUrl     String `tfsdk:"queue_url" user_config:"true"`
	Auth         Object `tfsdk:"auth" user_config:"true"`
	Region       String `tfsdk:"region" user_config:"true"`
}

type SchemaAttributes 

type SchemaAttributes map[string]schema.Attribute

func ExtendBaseAttributes 

func ExtendBaseAttributes(target SchemaAttributes, addons []string) SchemaAttributes

type SplunkHecSourceModel 

type SplunkHecSourceModel struct {
	Id              String `tfsdk:"id"`
	PipelineId      String `tfsdk:"pipeline_id"`
	Title           String `tfsdk:"title"`
	Description     String `tfsdk:"description"`
	GenerationId    Int64  `tfsdk:"generation_id"`
	GatewayRouteId  String `tfsdk:"gateway_route_id"`
	CaptureMetadata Bool   `tfsdk:"capture_metadata" 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.