provider

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2024 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const PROVIDER_TYPE_NAME = "mezmo"

Variables

This section is empty.

Functions

func New 

func New(version string) func() provider.Provider

func NewAgentSourceResource 

func NewAgentSourceResource() resource.Resource

func NewAggregateV2ProcessorResource added in v1.11.0 

func NewAggregateV2ProcessorResource() resource.Resource

func NewAzureBlobStorageDestinationResource 

func NewAzureBlobStorageDestinationResource() resource.Resource

func NewAzureEventHubSourceResource 

func NewAzureEventHubSourceResource() resource.Resource

func NewBlackholeDestinationResource 

func NewBlackholeDestinationResource() resource.Resource

func NewCompactFieldsProcessorResource 

func NewCompactFieldsProcessorResource() resource.Resource

func NewDatadogLogsDestinationResource 

func NewDatadogLogsDestinationResource() resource.Resource

func NewDatadogMetricsDestinationResource 

func NewDatadogMetricsDestinationResource() resource.Resource

func NewDatadogSourceResource added in v1.0.2 

func NewDatadogSourceResource() resource.Resource

func NewDecryptFieldsProcessorResource 

func NewDecryptFieldsProcessorResource() resource.Resource

func NewDedupeProcessorResource 

func NewDedupeProcessorResource() resource.Resource

func NewDemoSourceResource 

func NewDemoSourceResource() resource.Resource

func NewDropFieldsProcessorResource 

func NewDropFieldsProcessorResource() resource.Resource

func NewElasticSearchDestinationResource 

func NewElasticSearchDestinationResource() resource.Resource

func NewEncryptFieldsProcessorResource 

func NewEncryptFieldsProcessorResource() resource.Resource

func NewEventToMetricProcessorResource added in v1.0.2 

func NewEventToMetricProcessorResource() resource.Resource

func NewFilterProcessorResource added in v1.0.3 

func NewFilterProcessorResource() resource.Resource

func NewFlattenFieldsProcessorResource 

func NewFlattenFieldsProcessorResource() resource.Resource

func NewFluentSourceResource 

func NewFluentSourceResource() resource.Resource

func NewGcpCloudStorageDestinationResource 

func NewGcpCloudStorageDestinationResource() resource.Resource

func NewHoneycombLogsDestinationResource 

func NewHoneycombLogsDestinationResource() resource.Resource

func NewHttpDestinationResource 

func NewHttpDestinationResource() resource.Resource

func NewHttpSourceResource 

func NewHttpSourceResource() resource.Resource

func NewKafkaDestinationResource 

func NewKafkaDestinationResource() resource.Resource

func NewKafkaSourceResource 

func NewKafkaSourceResource() resource.Resource

func NewKinesisFirehoseSourceResource 

func NewKinesisFirehoseSourceResource() resource.Resource

func NewLogAnalysisSourceResource 

func NewLogAnalysisSourceResource() resource.Resource

func NewLogStashSourceResource 

func NewLogStashSourceResource() resource.Resource

func NewLokiDestinationResource 

func NewLokiDestinationResource() resource.Resource

func NewMapFieldsProcessorResource added in v1.0.1 

func NewMapFieldsProcessorResource() resource.Resource

func NewMetricsTagCardinalityLimitProcessorResource added in v1.0.2 

func NewMetricsTagCardinalityLimitProcessorResource() resource.Resource

func NewMezmoDestinationResource 

func NewMezmoDestinationResource() resource.Resource

func NewNewRelicDestinationResource 

func NewNewRelicDestinationResource() resource.Resource

func NewOpenTelemetryTracesSourceResource added in v1.0.9 

func NewOpenTelemetryTracesSourceResource() resource.Resource

func NewParseProcessorResource 

func NewParseProcessorResource() resource.Resource

func NewParseSequentiallyProcessorResource 

func NewParseSequentiallyProcessorResource() resource.Resource

func NewPipelineResource 

func NewPipelineResource() resource.Resource

func NewPrometheusRemoteWriteDestinationResource 

func NewPrometheusRemoteWriteDestinationResource() resource.Resource

func NewPrometheusRemoteWriteSourceResource 

func NewPrometheusRemoteWriteSourceResource() resource.Resource

func NewReduceProcessorResource 

func NewReduceProcessorResource() resource.Resource

func NewRouteProcessorResource 

func NewRouteProcessorResource() resource.Resource

func NewS3DestinationResource 

func NewS3DestinationResource() resource.Resource

func NewS3SourceResource 

func NewS3SourceResource() resource.Resource

func NewSQSSourceResource 

func NewSQSSourceResource() resource.Resource

func NewSampleProcessorResource 

func NewSampleProcessorResource() resource.Resource

func NewScriptExecutionProcessorResource 

func NewScriptExecutionProcessorResource() resource.Resource

func NewSplunkHecLogsDestinationResource 

func NewSplunkHecLogsDestinationResource() resource.Resource

func NewSplunkHecSourceResource 

func NewSplunkHecSourceResource() resource.Resource

func NewStringifyProcessorResource 

func NewStringifyProcessorResource() resource.Resource

func NewUnrollProcessorResource 

func NewUnrollProcessorResource() resource.Resource

func NewWebhookSourceResource added in v1.0.2 

func NewWebhookSourceResource() resource.Resource

func NullifyPlanFields 

func NullifyPlanFields[M ComponentModel](plan *M, schema resourceSchema.Schema)

This function is used only in testing to protect us from forgetting to overwrite plan values with what comes back from the API responses. Our models can be complicated, and it's possible we will miss things in the provider code and in code review. What's worse is that test assertions will actually give false positives even if properties have not been updated. @see: https://mezmo.atlassian.net/browse/LOG-18104

Types

type ComponentModel 

type ComponentModel interface {
	SourceModel | ProcessorModel | DestinationModel
}

Generic type representing a source / processor / destination model.

type DestinationModel 

type DestinationModel interface {
	AzureBlobStorageDestinationModel |
		BlackholeDestinationModel |
		DatadogLogsDestinationModel |
		DatadogMetricsDestinationModel |
		ElasticSearchDestinationModel |
		GcpCloudStorageDestinationModel |
		HoneycombLogsDestinationModel |
		HttpDestinationModel |
		KafkaDestinationModel |
		LokiDestinationModel |
		MezmoDestinationModel |
		NewRelicDestinationModel |
		PrometheusRemoteWriteDestinationModel |
		S3DestinationModel |
		SplunkHecLogsDestinationModel
}

type DestinationResource 

type DestinationResource[T DestinationModel] struct {
	// contains filtered or unexported fields
}

func (*DestinationResource[T]) Configure 

func (r *DestinationResource[T]) Configure(_ context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

Configure implements resource.ResourceWithConfigure.

func (*DestinationResource[T]) ConvertToTerraformModel 

func (r *DestinationResource[T]) ConvertToTerraformModel(component *reflect.Value) (*reflect.Value, error)

func (*DestinationResource[T]) Create 

func (r *DestinationResource[T]) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

Create implements resource.Resource.

func (*DestinationResource[T]) Delete 

func (r *DestinationResource[T]) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

Delete implements resource.Resource.

func (*DestinationResource[T]) ImportState added in v1.0.4 

func (r *DestinationResource[T]) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse)

func (*DestinationResource[T]) Metadata 

func (r *DestinationResource[T]) Metadata(_ context.Context, _ resource.MetadataRequest, resp *resource.MetadataResponse)

Metadata implements resource.Resource.

func (*DestinationResource[T]) NodeType added in v1.0.2 

func (r *DestinationResource[T]) NodeType() string

func (*DestinationResource[T]) Read 

func (r *DestinationResource[T]) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

Read implements resource.Resource.

func (*DestinationResource[T]) Schema 

func (r *DestinationResource[T]) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse)

Schema implements resource.Resource.

func (*DestinationResource[T]) TerraformSchema 

func (r *DestinationResource[T]) TerraformSchema() schema.Schema

func (*DestinationResource[T]) TypeName 

func (r *DestinationResource[T]) TypeName() string

func (*DestinationResource[T]) Update 

func (r *DestinationResource[T]) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

Update implements resource.Resource.

type MezmoProvider 

type MezmoProvider struct {
	// contains filtered or unexported fields
}

MezmoProvider defines the provider implementation.

func (*MezmoProvider) Configure 

func (p *MezmoProvider) Configure(ctx context.Context, req provider.ConfigureRequest, resp *provider.ConfigureResponse)

func (*MezmoProvider) DataSources 

func (p *MezmoProvider) DataSources(ctx context.Context) []func() datasource.DataSource

func (*MezmoProvider) Metadata 

func (p *MezmoProvider) Metadata(ctx context.Context, req provider.MetadataRequest, resp *provider.MetadataResponse)

func (*MezmoProvider) Resources 

func (p *MezmoProvider) Resources(ctx context.Context) []func() resource.Resource

func (*MezmoProvider) Schema 

func (p *MezmoProvider) Schema(ctx context.Context, req provider.SchemaRequest, resp *provider.SchemaResponse)

type MezmoProviderModel 

type MezmoProviderModel struct {
	Endpoint String `tfsdk:"endpoint"`
	AuthKey  String `tfsdk:"auth_key"`
	Headers  Map    `tfsdk:"headers"`
}

MezmoProviderModel describes the provider data model.

type PipelineResource 

type PipelineResource struct {
	// contains filtered or unexported fields
}

func (*PipelineResource) Configure 

func (r *PipelineResource) Configure(_ context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

Configure implements resource.ResourceWithConfigure.

func (*PipelineResource) ConvertToTerraformModel 

func (r *PipelineResource) ConvertToTerraformModel(component *reflect.Value) (*reflect.Value, error)

func (*PipelineResource) Create 

func (r *PipelineResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

Create implements resource.Resource.

func (*PipelineResource) Delete 

func (r *PipelineResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

Delete implements resource.Resource.

func (*PipelineResource) ImportState added in v1.0.4 

func (r *PipelineResource) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse)

func (*PipelineResource) Metadata 

func (r *PipelineResource) Metadata(_ context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse)

Metadata implements resource.Resource.

func (*PipelineResource) NodeType added in v1.0.2 

func (r *PipelineResource) NodeType() string

func (*PipelineResource) Read 

func (r *PipelineResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

Read implements resource.Resource.

func (*PipelineResource) Schema 

func (*PipelineResource) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse)

Schema implements resource.Resource.

func (*PipelineResource) TerraformSchema 

func (r *PipelineResource) TerraformSchema() schema.Schema

func (*PipelineResource) TypeName 

func (r *PipelineResource) TypeName() string

func (*PipelineResource) Update 

func (r *PipelineResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

Update implements resource.Resource.

type ProcessorModel 

type ProcessorModel interface {
	AggregateV2ProcessorModel |
		CompactFieldsProcessorModel |
		DecryptFieldsProcessorModel |
		DedupeProcessorModel |
		DropFieldsProcessorModel |
		EncryptFieldsProcessorModel |
		EventToMetricProcessorModel |
		FilterProcessorModel |
		FlattenFieldsProcessorModel |
		MapFieldsProcessorModel |
		MetricsTagCardinalityLimitProcessorModel |
		ParseProcessorModel |
		ParseSequentiallyProcessorModel |
		ReduceProcessorModel |
		RouteProcessorModel |
		SampleProcessorModel |
		ScriptExecutionProcessorModel |
		StringifyProcessorModel |
		UnrollProcessorModel
}

type ProcessorResource 

type ProcessorResource[T ProcessorModel] struct {
	// contains filtered or unexported fields
}

func (*ProcessorResource[T]) Configure 

func (r *ProcessorResource[T]) Configure(_ context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

Configure implements resource.ResourceWithConfigure.

func (*ProcessorResource[T]) ConvertToTerraformModel 

func (r *ProcessorResource[T]) ConvertToTerraformModel(component *reflect.Value) (*reflect.Value, error)

func (*ProcessorResource[T]) Create 

func (r *ProcessorResource[T]) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

Create implements resource.Resource.

func (*ProcessorResource[T]) Delete 

func (r *ProcessorResource[T]) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

Delete implements resource.Resource.

func (*ProcessorResource[T]) ImportState added in v1.0.4 

func (r *ProcessorResource[T]) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse)

func (*ProcessorResource[T]) Metadata 

func (r *ProcessorResource[T]) Metadata(_ context.Context, _ resource.MetadataRequest, resp *resource.MetadataResponse)

Metadata implements resource.Resource.

func (*ProcessorResource[T]) NodeType added in v1.0.2 

func (r *ProcessorResource[T]) NodeType() string

func (*ProcessorResource[T]) Read 

func (r *ProcessorResource[T]) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

Read implements resource.Resource.

func (*ProcessorResource[T]) Schema 

func (r *ProcessorResource[T]) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse)

Schema implements resource.Resource.

func (*ProcessorResource[T]) TerraformSchema 

func (r *ProcessorResource[T]) TerraformSchema() schema.Schema

func (*ProcessorResource[T]) TypeName 

func (r *ProcessorResource[T]) TypeName() string

func (*ProcessorResource[T]) Update 

func (r *ProcessorResource[T]) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

Update implements resource.Resource.

type SourceModel 

type SourceModel interface {
	AgentSourceModel |
		AzureEventHubSourceModel |
		DatadogSourceModel |
		DemoSourceModel |
		FluentSourceModel |
		HttpSourceModel |
		KafkaSourceModel |
		KinesisFirehoseSourceModel |
		LogAnalysisSourceModel |
		LogStashSourceModel |
		OpenTelemetryTracesSourceModel |
		PrometheusRemoteWriteSourceModel |
		S3SourceModel |
		SplunkHecSourceModel |
		SQSSourceModel |
		WebhookSourceModel
}

type SourceResource 

type SourceResource[T SourceModel] struct {
	// contains filtered or unexported fields
}

func (*SourceResource[T]) Configure 

func (r *SourceResource[T]) Configure(_ context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

Configure implements resource.ResourceWithConfigure.

func (*SourceResource[T]) ConvertToTerraformModel 

func (r *SourceResource[T]) ConvertToTerraformModel(component *reflect.Value) (*reflect.Value, error)

func (*SourceResource[T]) Create 

func (r *SourceResource[T]) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

Create implements resource.Resource.

func (*SourceResource[T]) Delete 

func (r *SourceResource[T]) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

Delete implements resource.Resource.

func (*SourceResource[T]) ImportState added in v1.0.4 

func (r *SourceResource[T]) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse)

func (*SourceResource[T]) Metadata 

func (r *SourceResource[T]) Metadata(_ context.Context, _ resource.MetadataRequest, resp *resource.MetadataResponse)

Metadata implements resource.Resource.

func (*SourceResource[T]) NodeType added in v1.0.2 

func (r *SourceResource[T]) NodeType() string

func (*SourceResource[T]) Read 

func (r *SourceResource[T]) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

Read implements resource.Resource.

func (*SourceResource[T]) Schema 

func (r *SourceResource[T]) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse)

Schema implements resource.Resource.

func (*SourceResource[T]) TerraformSchema 

func (r *SourceResource[T]) TerraformSchema() schema.Schema

func (*SourceResource[T]) TypeName 

func (r *SourceResource[T]) TypeName() string

func (*SourceResource[T]) Update 

func (r *SourceResource[T]) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

Update implements resource.Resource.

Source Files

View all Source files

Directories

Path Synopsis
destinations
destinations/test
modelutils
processors
processors/test
sources
sources/test

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.