streamanalytics

package
v1.44.1-0...-4e0a530 Latest Latest
Warning

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

 Go to latest Published: May 21, 2024 License: MPL-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterModel 

type ClusterModel struct {
	Name              string                 `tfschema:"name"`
	ResourceGroup     string                 `tfschema:"resource_group_name"`
	Location          string                 `tfschema:"location"`
	StreamingCapacity int64                  `tfschema:"streaming_capacity"`
	Tags              map[string]interface{} `tfschema:"tags"`
}

type ClusterResource 

type ClusterResource struct{}

func (ClusterResource) Arguments 

func (r ClusterResource) Arguments() map[string]*pluginsdk.Schema

func (ClusterResource) Attributes 

func (r ClusterResource) Attributes() map[string]*pluginsdk.Schema

func (ClusterResource) Create 

func (r ClusterResource) Create() sdk.ResourceFunc

func (ClusterResource) Delete 

func (r ClusterResource) Delete() sdk.ResourceFunc

func (ClusterResource) IDValidationFunc 

func (r ClusterResource) IDValidationFunc() pluginsdk.SchemaValidateFunc

func (ClusterResource) ModelObject 

func (r ClusterResource) ModelObject() interface{}

func (ClusterResource) Read 

func (r ClusterResource) Read() sdk.ResourceFunc

func (ClusterResource) ResourceType 

func (r ClusterResource) ResourceType() string

func (ClusterResource) StateUpgraders 

func (r ClusterResource) StateUpgraders() sdk.StateUpgradeData

func (ClusterResource) Update 

func (r ClusterResource) Update() sdk.ResourceFunc

type JobScheduleResource 

type JobScheduleResource struct{}

func (JobScheduleResource) Arguments 

func (r JobScheduleResource) Arguments() map[string]*pluginsdk.Schema

func (JobScheduleResource) Attributes 

func (r JobScheduleResource) Attributes() map[string]*pluginsdk.Schema

func (JobScheduleResource) Create 

func (r JobScheduleResource) Create() sdk.ResourceFunc

func (JobScheduleResource) Delete 

func (r JobScheduleResource) Delete() sdk.ResourceFunc

func (JobScheduleResource) IDValidationFunc 

func (r JobScheduleResource) IDValidationFunc() pluginsdk.SchemaValidateFunc

func (JobScheduleResource) ModelObject 

func (r JobScheduleResource) ModelObject() interface{}

func (JobScheduleResource) Read 

func (r JobScheduleResource) Read() sdk.ResourceFunc

func (JobScheduleResource) ResourceType 

func (r JobScheduleResource) ResourceType() string

func (JobScheduleResource) StateUpgraders 

func (r JobScheduleResource) StateUpgraders() sdk.StateUpgradeData

func (JobScheduleResource) Update 

func (r JobScheduleResource) Update() sdk.ResourceFunc

type JobScheduleResourceModel 

type JobScheduleResourceModel struct {
	StreamAnalyticsJob string `tfschema:"stream_analytics_job_id"`
	StartMode          string `tfschema:"start_mode"`
	StartTime          string `tfschema:"start_time"`
	LastOutputTime     string `tfschema:"last_output_time"`
}

type ManagedPrivateEndpointModel 

type ManagedPrivateEndpointModel struct {
	Name                   string `tfschema:"name"`
	ResourceGroup          string `tfschema:"resource_group_name"`
	StreamAnalyticsCluster string `tfschema:"stream_analytics_cluster_name"`
	TargetResourceId       string `tfschema:"target_resource_id"`
	SubResourceName        string `tfschema:"subresource_name"`
}

type ManagedPrivateEndpointResource 

type ManagedPrivateEndpointResource struct{}

func (ManagedPrivateEndpointResource) Arguments 

func (r ManagedPrivateEndpointResource) Arguments() map[string]*pluginsdk.Schema

func (ManagedPrivateEndpointResource) Attributes 

func (r ManagedPrivateEndpointResource) Attributes() map[string]*pluginsdk.Schema

func (ManagedPrivateEndpointResource) Create 

func (r ManagedPrivateEndpointResource) Create() sdk.ResourceFunc

func (ManagedPrivateEndpointResource) Delete 

func (r ManagedPrivateEndpointResource) Delete() sdk.ResourceFunc

func (ManagedPrivateEndpointResource) IDValidationFunc 

func (r ManagedPrivateEndpointResource) IDValidationFunc() pluginsdk.SchemaValidateFunc

func (ManagedPrivateEndpointResource) ModelObject 

func (r ManagedPrivateEndpointResource) ModelObject() interface{}

func (ManagedPrivateEndpointResource) Read 

func (r ManagedPrivateEndpointResource) Read() sdk.ResourceFunc

func (ManagedPrivateEndpointResource) ResourceType 

func (r ManagedPrivateEndpointResource) ResourceType() string

func (ManagedPrivateEndpointResource) StateUpgraders 

func (r ManagedPrivateEndpointResource) StateUpgraders() sdk.StateUpgradeData

type OutputCosmosDBResource 

type OutputCosmosDBResource struct{}

func (OutputCosmosDBResource) Arguments 

func (r OutputCosmosDBResource) Arguments() map[string]*pluginsdk.Schema

func (OutputCosmosDBResource) Attributes 

func (r OutputCosmosDBResource) Attributes() map[string]*schema.Schema

func (OutputCosmosDBResource) Create 

func (r OutputCosmosDBResource) Create() sdk.ResourceFunc

func (OutputCosmosDBResource) CustomImporter 

func (r OutputCosmosDBResource) CustomImporter() sdk.ResourceRunFunc

func (OutputCosmosDBResource) Delete 

func (r OutputCosmosDBResource) Delete() sdk.ResourceFunc

func (OutputCosmosDBResource) IDValidationFunc 

func (r OutputCosmosDBResource) IDValidationFunc() pluginsdk.SchemaValidateFunc

func (OutputCosmosDBResource) ModelObject 

func (r OutputCosmosDBResource) ModelObject() interface{}

func (OutputCosmosDBResource) Read 

func (r OutputCosmosDBResource) Read() sdk.ResourceFunc

func (OutputCosmosDBResource) ResourceType 

func (r OutputCosmosDBResource) ResourceType() string

func (OutputCosmosDBResource) StateUpgraders 

func (r OutputCosmosDBResource) StateUpgraders() sdk.StateUpgradeData

func (OutputCosmosDBResource) Update 

func (r OutputCosmosDBResource) Update() sdk.ResourceFunc

type OutputCosmosDBResourceModel 

type OutputCosmosDBResourceModel struct {
	Name               string `tfschema:"name"`
	StreamAnalyticsJob string `tfschema:"stream_analytics_job_id"`
	AccountKey         string `tfschema:"cosmosdb_account_key"`
	Database           string `tfschema:"cosmosdb_sql_database_id"`
	ContainerName      string `tfschema:"container_name"`
	DocumentID         string `tfschema:"document_id"`
	PartitionKey       string `tfschema:"partition_key"`
}

type OutputFunctionResource 

type OutputFunctionResource struct {
}

func (OutputFunctionResource) Arguments 

func (r OutputFunctionResource) Arguments() map[string]*pluginsdk.Schema

func (OutputFunctionResource) Attributes 

func (r OutputFunctionResource) Attributes() map[string]*pluginsdk.Schema

func (OutputFunctionResource) Create 

func (r OutputFunctionResource) Create() sdk.ResourceFunc

func (OutputFunctionResource) CustomImporter 

func (r OutputFunctionResource) CustomImporter() sdk.ResourceRunFunc

func (OutputFunctionResource) Delete 

func (r OutputFunctionResource) Delete() sdk.ResourceFunc

func (OutputFunctionResource) IDValidationFunc 

func (r OutputFunctionResource) IDValidationFunc() pluginsdk.SchemaValidateFunc

func (OutputFunctionResource) ModelObject 

func (r OutputFunctionResource) ModelObject() interface{}

func (OutputFunctionResource) Read 

func (r OutputFunctionResource) Read() sdk.ResourceFunc

func (OutputFunctionResource) ResourceType 

func (r OutputFunctionResource) ResourceType() string

func (OutputFunctionResource) StateUpgraders 

func (r OutputFunctionResource) StateUpgraders() sdk.StateUpgradeData

func (OutputFunctionResource) Update 

func (r OutputFunctionResource) Update() sdk.ResourceFunc

type OutputFunctionResourceModel 

type OutputFunctionResourceModel struct {
	Name               string `tfschema:"name"`
	StreamAnalyticsJob string `tfschema:"stream_analytics_job_name"`
	ResourceGroup      string `tfschema:"resource_group_name"`
	FunctionApp        string `tfschema:"function_app"`
	FunctionName       string `tfschema:"function_name"`
	ApiKey             string `tfschema:"api_key"`
	BatchMaxInBytes    int    `tfschema:"batch_max_in_bytes"`
	BatchMaxCount      int    `tfschema:"batch_max_count"`
}

type OutputPowerBIResource 

type OutputPowerBIResource struct{}

func (OutputPowerBIResource) Arguments 

func (r OutputPowerBIResource) Arguments() map[string]*pluginsdk.Schema

func (OutputPowerBIResource) Attributes 

func (r OutputPowerBIResource) Attributes() map[string]*schema.Schema

func (OutputPowerBIResource) Create 

func (r OutputPowerBIResource) Create() sdk.ResourceFunc

func (OutputPowerBIResource) CustomImporter 

func (r OutputPowerBIResource) CustomImporter() sdk.ResourceRunFunc

func (OutputPowerBIResource) Delete 

func (r OutputPowerBIResource) Delete() sdk.ResourceFunc

func (OutputPowerBIResource) IDValidationFunc 

func (r OutputPowerBIResource) IDValidationFunc() pluginsdk.SchemaValidateFunc

func (OutputPowerBIResource) ModelObject 

func (r OutputPowerBIResource) ModelObject() interface{}

func (OutputPowerBIResource) Read 

func (r OutputPowerBIResource) Read() sdk.ResourceFunc

func (OutputPowerBIResource) ResourceType 

func (r OutputPowerBIResource) ResourceType() string

func (OutputPowerBIResource) StateUpgraders 

func (r OutputPowerBIResource) StateUpgraders() sdk.StateUpgradeData

func (OutputPowerBIResource) Update 

func (r OutputPowerBIResource) Update() sdk.ResourceFunc

type OutputPowerBIResourceModel 

type OutputPowerBIResourceModel struct {
	Name                   string `tfschema:"name"`
	StreamAnalyticsJob     string `tfschema:"stream_analytics_job_id"`
	DataSet                string `tfschema:"dataset"`
	Table                  string `tfschema:"table"`
	GroupID                string `tfschema:"group_id"`
	GroupName              string `tfschema:"group_name"`
	TokenUserPrincipalName string `tfschema:"token_user_principal_name"`
	TokenUserDisplayName   string `tfschema:"token_user_display_name"`
}

type OutputTableResource 

type OutputTableResource struct{}

func (OutputTableResource) Arguments 

func (r OutputTableResource) Arguments() map[string]*pluginsdk.Schema

func (OutputTableResource) Attributes 

func (r OutputTableResource) Attributes() map[string]*pluginsdk.Schema

func (OutputTableResource) Create 

func (r OutputTableResource) Create() sdk.ResourceFunc

func (OutputTableResource) CustomImporter 

func (r OutputTableResource) CustomImporter() sdk.ResourceRunFunc

func (OutputTableResource) Delete 

func (r OutputTableResource) Delete() sdk.ResourceFunc

func (OutputTableResource) IDValidationFunc 

func (r OutputTableResource) IDValidationFunc() pluginsdk.SchemaValidateFunc

func (OutputTableResource) ModelObject 

func (r OutputTableResource) ModelObject() interface{}

func (OutputTableResource) Read 

func (r OutputTableResource) Read() sdk.ResourceFunc

func (OutputTableResource) ResourceType 

func (r OutputTableResource) ResourceType() string

func (OutputTableResource) StateUpgraders 

func (r OutputTableResource) StateUpgraders() sdk.StateUpgradeData

func (OutputTableResource) Update 

func (r OutputTableResource) Update() sdk.ResourceFunc

type OutputTableResourceModel 

type OutputTableResourceModel struct {
	Name               string   `tfschema:"name"`
	StreamAnalyticsJob string   `tfschema:"stream_analytics_job_name"`
	ResourceGroup      string   `tfschema:"resource_group_name"`
	StorageAccount     string   `tfschema:"storage_account_name"`
	StorageAccountKey  string   `tfschema:"storage_account_key"`
	Table              string   `tfschema:"table"`
	PartitionKey       string   `tfschema:"partition_key"`
	RowKey             string   `tfschema:"row_key"`
	BatchSize          int64    `tfschema:"batch_size"`
	ColumnsToRemove    []string `tfschema:"columns_to_remove"`
}

type Registration 

type Registration struct{}

func (Registration) AssociatedGitHubLabel 

func (r Registration) AssociatedGitHubLabel() string

func (Registration) DataSources 

func (r Registration) DataSources() []sdk.DataSource

func (Registration) Name 

func (r Registration) Name() string

Name is the name of this Service

func (Registration) Resources 

func (r Registration) Resources() []sdk.Resource

func (Registration) SupportedDataSources 

func (r Registration) SupportedDataSources() map[string]*pluginsdk.Resource

SupportedDataSources returns the supported Data Sources supported by this Service

func (Registration) SupportedResources 

func (r Registration) SupportedResources() map[string]*pluginsdk.Resource

SupportedResources returns the supported Resources supported by this Service

func (Registration) WebsiteCategories 

func (r Registration) WebsiteCategories() []string

WebsiteCategories returns a list of categories which can be used for the sidebar

type Serialization 

type Serialization struct {
	Type           string `tfschema:"type"`
	FieldDelimiter string `tfschema:"field_delimiter"`
	Encoding       string `tfschema:"encoding"`
}

type StreamInputEventHubV2Resource 

type StreamInputEventHubV2Resource struct{}

func (StreamInputEventHubV2Resource) Arguments 

func (r StreamInputEventHubV2Resource) Arguments() map[string]*pluginsdk.Schema

func (StreamInputEventHubV2Resource) Attributes 

func (r StreamInputEventHubV2Resource) Attributes() map[string]*schema.Schema

func (StreamInputEventHubV2Resource) Create 

func (r StreamInputEventHubV2Resource) Create() sdk.ResourceFunc

func (StreamInputEventHubV2Resource) CustomImporter 

func (r StreamInputEventHubV2Resource) CustomImporter() sdk.ResourceRunFunc

func (StreamInputEventHubV2Resource) Delete 

func (r StreamInputEventHubV2Resource) Delete() sdk.ResourceFunc

func (StreamInputEventHubV2Resource) IDValidationFunc 

func (r StreamInputEventHubV2Resource) IDValidationFunc() pluginsdk.SchemaValidateFunc

func (StreamInputEventHubV2Resource) ModelObject 

func (r StreamInputEventHubV2Resource) ModelObject() interface{}

func (StreamInputEventHubV2Resource) Read 

func (r StreamInputEventHubV2Resource) Read() sdk.ResourceFunc

func (StreamInputEventHubV2Resource) ResourceType 

func (r StreamInputEventHubV2Resource) ResourceType() string

func (StreamInputEventHubV2Resource) StateUpgraders 

func (r StreamInputEventHubV2Resource) StateUpgraders() sdk.StateUpgradeData

func (StreamInputEventHubV2Resource) Update 

func (r StreamInputEventHubV2Resource) Update() sdk.ResourceFunc

type StreamInputEventHubV2ResourceModel 

type StreamInputEventHubV2ResourceModel struct {
	Name                      string `tfschema:"name"`
	StreamAnalyticsJobId      string `tfschema:"stream_analytics_job_id"`
	ServiceBusNamespace       string `tfschema:"servicebus_namespace"`
	EventHubName              string `tfschema:"eventhub_name"`
	EventHubConsumerGroupName string `tfschema:"eventhub_consumer_group_name"`

	SharedAccessPolicyKey  string          `tfschema:"shared_access_policy_key"`
	SharedAccessPolicyName string          `tfschema:"shared_access_policy_name"`
	PartitionKey           string          `tfschema:"partition_key"`
	AuthenticationMode     string          `tfschema:"authentication_mode"`
	Serialization          []Serialization `tfschema:"serialization"`
}

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.